From 15a415edeb552506bb95b3918acd273ed21b330a Mon Sep 17 00:00:00 2001
From: Luke Swithenbank <swithenbank.luke@gmail.com>
Date: Thu, 31 Mar 2016 22:06:47 +1100
Subject: [PATCH] take a request body as a param

---
 plugins/inputs/http_response/README.md        |  6 +++++-
 plugins/inputs/http_response/http_response.go | 20 ++++++++++++-------
 2 files changed, 18 insertions(+), 8 deletions(-)

diff --git a/plugins/inputs/http_response/README.md b/plugins/inputs/http_response/README.md
index 99770e526..f2f45b2af 100644
--- a/plugins/inputs/http_response/README.md
+++ b/plugins/inputs/http_response/README.md
@@ -11,7 +11,7 @@ This input plugin will test HTTP/HTTPS connections.
   address = "http://github.com"
   ## Set response_timeout (default 10 seconds)
   response_timeout = 10
-  ## HTTP Method
+  ## HTTP Request Method
   method = "GET"
   ## HTTP Request Headers
   headers = '''
@@ -19,6 +19,10 @@ This input plugin will test HTTP/HTTPS connections.
   '''
   ## Whether to follow redirects from the server (defaults to false)
   follow_redirects = true
+  ## Optional HTTP Request Body
+  body = '''
+  {'fake':'data'}
+  '''
 ```
 
 ### Measurements & Fields:
diff --git a/plugins/inputs/http_response/http_response.go b/plugins/inputs/http_response/http_response.go
index 09569fe73..dc4b2df60 100644
--- a/plugins/inputs/http_response/http_response.go
+++ b/plugins/inputs/http_response/http_response.go
@@ -3,11 +3,10 @@ package http_response
 import (
 	"bufio"
 	"errors"
-	"fmt"
+	"io"
 	"net/http"
 	"net/textproto"
 	"net/url"
-	"os"
 	"strings"
 	"time"
 
@@ -18,6 +17,7 @@ import (
 // HTTPResponse struct
 type HTTPResponse struct {
 	Address         string
+	Body            string
 	Method          string
 	ResponseTimeout int
 	Headers         string
@@ -34,7 +34,7 @@ var sampleConfig = `
   address = "http://github.com"
   ## Set response_timeout (default 10 seconds)
   response_timeout = 10
-  ## HTTP Method
+  ## HTTP Request Method
   method = "GET"
   ## HTTP Request Headers
   headers = '''
@@ -42,6 +42,10 @@ var sampleConfig = `
   '''
 	## Whether to follow redirects from the server (defaults to false)
 	follow_redirects = true
+	## Optional HTTP Request Body
+	body = '''
+	{'fake':'data'}
+	'''
 `
 
 // SampleConfig returns the plugin SampleConfig
@@ -49,6 +53,7 @@ func (h *HTTPResponse) SampleConfig() string {
 	return sampleConfig
 }
 
+// ErrRedirectAttempted indicates that a redirect occurred
 var ErrRedirectAttempted = errors.New("redirect")
 
 // HTTPGather gathers all fields and returns any errors it encounters
@@ -61,13 +66,16 @@ func (h *HTTPResponse) HTTPGather() (map[string]interface{}, error) {
 	}
 
 	if h.FollowRedirects == false {
-		fmt.Println(h.FollowRedirects)
 		client.CheckRedirect = func(req *http.Request, via []*http.Request) error {
 			return ErrRedirectAttempted
 		}
 	}
 
-	request, err := http.NewRequest(h.Method, h.Address, nil)
+	var body io.Reader
+	if h.Body != "" {
+		body = strings.NewReader(h.Body)
+	}
+	request, err := http.NewRequest(h.Method, h.Address, body)
 	if err != nil {
 		return nil, err
 	}
@@ -81,7 +89,6 @@ func (h *HTTPResponse) HTTPGather() (map[string]interface{}, error) {
 	request.Header = http.Header(mimeHeader)
 	// Start Timer
 	start := time.Now()
-	request.Write(os.Stdout)
 	resp, err := client.Do(request)
 	if err != nil {
 		if h.FollowRedirects {
@@ -89,7 +96,6 @@ func (h *HTTPResponse) HTTPGather() (map[string]interface{}, error) {
 		}
 		if urlError, ok := err.(*url.Error); ok &&
 			urlError.Err == ErrRedirectAttempted {
-			fmt.Println(err)
 			err = nil
 		} else {
 			return nil, err