local http_parser = require "net.http.parser";

local function test_stream(stream, expect)

	local success_cb = spy.new(function (packet)

		assert.is_table(packet);

		assert.is_equal(expect.body, packet.body);

	end);

	stream = stream:gsub("\n", "\r\n");

	local parser = http_parser.new(success_cb, error, stream:sub(1,4) == "HTTP" and "client" or "server")

	for chunk in stream:gmatch("..?.?") do

		parser:feed(chunk);

	end

	assert.spy(success_cb).was_called(expect.count or 1);

end

describe("net.http.parser", function()

	describe("parser", function()

		it("should handle requests with no content-length or body", function ()

			test_stream(

[[

]],

				{

					body = "";

				}

			);

		end);

		it("should handle responses with empty body", function ()

			test_stream(

[[

]],

				{

					body = "";

				}

			);

		end);

		it("should handle simple responses", function ()

			test_stream(

[[

]],

				{

					body = "Hello\r\n", count = 1;

				}

			);

		end);

		it("should handle chunked encoding in responses", function ()

			test_stream(

[[

HTTP/1.1 200 OK

Transfer-Encoding: chunked

1

H

1

e

2

ll

1

o

0

]],

				{

					body = "Hello", count = 1;

				}

			);

		end);

		it("should handle a stream of responses", function ()

			test_stream(

[[

HTTP/1.1 200 OK

Content-Length: 5

Hello

]],

				{

					body = "Hello", count = 2;

				}

			);