Support for chunked responses

kong/cli/utils/ssl.lua

@@ -40,7 +40,7 @@ function _M.prepare_ssl()
     local file_name = os.tmpname()
     local passphrase = utils.random_string()
 
-    local res, code = IO.os_execute([[
+    IO.os_execute([[
       cd /tmp && \
       openssl genrsa -des3 -out ]]..file_name..[[.key -passout pass:]]..passphrase..[[ 1024 && \
       openssl req -new -key ]]..file_name..[[.key -out ]]..file_name..[[.csr -subj "/C=US/ST=California/L=San Francisco/O=Kong/OU=IT Department/CN=localhost" -passin pass:]]..passphrase..[[ && \

kong/tools/http_client.lua

@@ -6,6 +6,14 @@ local ltn12 = require "ltn12"
 
 local _M = {}
 
+local function get_response(resp)
+  if #resp == 0 then
+    return nil
+  else
+    return table.concat(resp, "")
+  end
+end
+
 local function http_call(options)
   -- Set Host header accordingly
   local parsed_url = url.parse(options.url)
@@ -28,10 +36,10 @@ local function http_call(options)
     options.options = "all"
 
     local _, code, headers = https.request(options)
-    return resp[1], code, headers
+    return get_response(resp), code, headers
   else
     local _, code, headers = http.request(options)
-    return resp[1], code, headers
+    return get_response(resp), code, headers
   end
 end
 

spec/integration/cli/restart_spec.lua

@@ -1,4 +1,3 @@
-local IO = require "kong.tools.io"
 local spec_helper = require "spec.spec_helpers"
 
 describe("CLI", function()
@@ -26,7 +25,6 @@ describe("CLI", function()
   end)
 
   it("should restart kong when it's crashed", function()
-    local kong_pid = IO.read_file(spec_helper.get_env().configuration.pid_file)
     os.execute("pkill -9 nginx")
 
     local res, code = spec_helper.restart_kong()

spec/integration/proxy/dns_resolver_spec.lua

@@ -24,7 +24,7 @@ describe("DNS", function()
   describe("DNS", function()
 
     it("should work when calling local IP", function()
-      local thread = spec_helper.start_tcp_server(TCP_PORT) -- Starting the mock TCP server
+      local thread = spec_helper.start_http_server(TCP_PORT) -- Starting the mock TCP server
 
       local _, status = http_client.get(spec_helper.STUB_GET_URL, nil, { host = "dns1.com" })
       assert.are.equal(200, status)
@@ -33,7 +33,7 @@ describe("DNS", function()
     end)
 
     it("should work when calling local hostname", function()
-      local thread = spec_helper.start_tcp_server(TCP_PORT) -- Starting the mock TCP server
+      local thread = spec_helper.start_http_server(TCP_PORT) -- Starting the mock TCP server
 
       local _, status = http_client.get(spec_helper.STUB_GET_URL, nil, { host = "dns2.com" })
       assert.are.equal(200, status)