Support for excluding body in validation-POST

README.md

@@ -81,6 +81,11 @@ $ curl -X POST http://kong:8001/apis/{api}/plugins \
 <td></td>
 <td>Keepalive time (miliseconds) for the request to the URL specified above. Default value is 60000.</td>
 </tr>
+<tr>
+<td><code>config.include_body</code></td>
+<td></td>
+<td>Include body in request. Default value is true.</td>
+</tr>
 </tbody></table>
 
 Middleman will execute a JSON <code>POST</code> request to the specified <code>url</code> with the following body:
@@ -91,7 +96,7 @@ Middleman will execute a JSON <code>POST</code> request to the specified <code>u
         <th>Description</th>
     </tr>
     <tr>
-    <td><code>body_data</code></td>
+    <td><code>body_data (optional)</code></td>
     <td><small>The body of the original request</small></td>
     </tr>
     <tr>

middleman-0.1.1-1.rockspec → middleman-0.2.1-1.rockspec

@@ -1,8 +1,8 @@
 package = "middleman"
 
-version = "0.1.1-1"
+version = "0.2.1-1"
 
--- The version '0.1.1' is the source code version, the trailing '1' is the version of this rockspec.
+-- The version '0.2.1' is the source code version, the trailing '1' is the version of this rockspec.
 -- whenever the source version changes, the rockspec should be reset to 1. The rockspec version is only
 -- updated (incremented) when this file changes, but the source remains the same.
 

src/access.lua

@@ -44,7 +44,7 @@ function _M.execute(conf)
   local parsed_url = parse_url(conf.url)
   local host = parsed_url.host
   local port = tonumber(parsed_url.port)
-  local payload = _M.compose_payload(parsed_url)
+  local payload = _M.compose_payload(parsed_url, conf)
 
   local sock = ngx.socket.tcp()
   sock:settimeout(conf.timeout)
@@ -120,7 +120,7 @@ function _M.execute(conf)
 
 end
 
-function _M.compose_payload(parsed_url)
+function _M.compose_payload(parsed_url, conf)
     local headers = get_headers()
     local uri_args = get_uri_args()
     local next = next
@@ -150,7 +150,14 @@ function _M.compose_payload(parsed_url)
       raw_json_uri_args = "{}"
     end
 
-    local payload_body = [[{"headers":]] .. raw_json_headers .. [[,"uri_args":]] .. raw_json_uri_args.. [[,"body_data":]] .. raw_json_body_data .. [[}]]
+    local payload_body = [[{"headers":]] .. raw_json_headers .. [[,"uri_args":]] .. raw_json_uri_args
+
+    -- add the payload
+    if conf.include_body then
+      payload_body = payload_body .. [[,"body_data":]] .. raw_json_body_data
+    end
+
+    payload_body = payload_body .. [[}]]
 
     local payload_headers = string_format(
       "POST %s HTTP/1.1\r\nHost: %s\r\nConnection: Keep-Alive\r\nContent-Type: application/json\r\nContent-Length: %s\r\n",

src/schema.lua

@@ -4,6 +4,7 @@ return {
     url = {required = true, type = "string"},
     response = { required = true, default = "table", type = "string", enum = {"table", "string"}},
     timeout = { default = 10000, type = "number" },
-    keepalive = { default = 60000, type = "number" }
+    keepalive = { default = 60000, type = "number" },
+    include_body = { default = true, type = "boolean" }
   }
-}
+}