mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 13:47:41 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge 0.12->trunk

Browse source
This commit is contained in:
Matthew Wild 2023-02-09 22:58:01 +00:00
commit fbfe255e12
3 changed files with 15 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

2
net/http.lua
View file

@ -94,7 +94,7 @@ local function request_reader(request, data, err)
r.body_length and ("%d bytes"):format(r.body_length) or "unknown length" r.body_length and ("%d bytes"):format(r.body_length) or "unknown length"
); );
if request.streaming_handler then if request.streaming_handler then
log("debug", "Request '%s': Streaming via handler"); log("debug", "Request '%s': Streaming via handler", request.id);
r.body_sink, finalize_sink = request.streaming_handler(r); r.body_sink, finalize_sink = request.streaming_handler(r);
end end
return; return;

17
net/http/parser.lua
View file

@ -130,10 +130,13 @@ function httpstream.new(success_cb, error_cb, parser_type, options_cb)
partial = true; partial = true;
}; };
end end
if len and len > bodylimit then if not len or len > bodylimit then
-- Early notification, for redirection -- Early notification, for redirection
success_cb(packet); success_cb(packet);
if not packet.body_sink then error = true; return error_cb("content-length-limit-exceeded"); end if not packet.body_sink and (len and len > bodylimit) then
error = true;
return error_cb("content-length-limit-exceeded");
end
end end
if chunked and not packet.body_sink then if chunked and not packet.body_sink then
success_cb(packet); success_cb(packet);
@ -174,9 +177,11 @@ function httpstream.new(success_cb, error_cb, parser_type, options_cb)
end end
elseif packet.body_sink then elseif packet.body_sink then
local chunk = buffer:read_chunk(len); local chunk = buffer:read_chunk(len);
while chunk and len > 0 do while chunk and (not len or len > 0) do
if packet.body_sink:write(chunk) then if packet.body_sink:write(chunk) then
len = len - #chunk; if len then
len = len - #chunk;
end
chunk = buffer:read_chunk(len); chunk = buffer:read_chunk(len);
else else
error = true; error = true;
@ -188,9 +193,9 @@ function httpstream.new(success_cb, error_cb, parser_type, options_cb)
packet.partial = nil; packet.partial = nil;
success_cb(packet); success_cb(packet);
end end
elseif buffer:length() >= len then elseif not len or buffer:length() >= len then -- or not len
assert(not chunked) assert(not chunked)
packet.body = buffer:read(len) or ""; packet.body = len and buffer:read(len) or buffer:read_chunk() or "";
state = nil; state = nil;
packet.partial = nil; packet.partial = nil;
success_cb(packet); success_cb(packet);

6
spec/net_http_parser_spec.lua
View file

@ -87,7 +87,7 @@ o
]], ]],
{ {
body = "Hello", count = 2; body = "Hello", count = 3;
} }
); );
end); end);
@ -116,7 +116,7 @@ o
]], ]],
{ {
body = "Hello", count = 3; body = "Hello", count = 4;
} }
); );
end); end);
@ -129,7 +129,7 @@ o
assert.equal("25930f021785ae14053a322c2dbc1897c3769720", sha1(data, true), "test data malformed"); assert.equal("25930f021785ae14053a322c2dbc1897c3769720", sha1(data, true), "test data malformed");
test_stream(data, { test_stream(data, {
body = string.rep("~", 11085), count = 2; body = string.rep("~", 11085), count = 3;
}); });
end); end);
end); end);