Deuxfleurs/garage
32
61
Fork 80
Code Issues 91 Pull requests 14 Releases 31 Wiki Activity

implement STREAMING-*-PAYLOAD-TRAILER #960

Merged
lx merged 15 commits from fix-824 into main 2025-02-19 09:59:32 +00:00
Conversation 0 Commits 15 Files changed 36 +6 -1
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit ccab0e4ae5 - Show all commits

7
src/api/common/signature/streaming.rs
View file

@ -189,7 +189,7 @@ mod payload {
use nom::bytes::streaming::{tag, take_while}; use nom::bytes::streaming::{tag, take_while};
use nom::character::streaming::hex_digit1; use nom::character::streaming::hex_digit1;
use nom::combinator::map_res; use nom::combinator::{map_res, opt};
use nom::number::streaming::hex_u32; use nom::number::streaming::hex_u32;
macro_rules! try_parse { macro_rules! try_parse {
@ -266,6 +266,11 @@ mod payload {
let (input, header_value) = try_parse!(take_while( let (input, header_value) = try_parse!(take_while(
|c: u8| c.is_ascii_alphanumeric() || b"+/=".contains(&c) |c: u8| c.is_ascii_alphanumeric() || b"+/=".contains(&c)
)(input)); )(input));
// Possible '\n' after the header value, depends on clients
// https://docs.aws.amazon.com/AmazonS3/latest/userguide/checking-object-integrity.html
let (input, _) = try_parse!(opt(tag(b"\n"))(input));
let (input, _) = try_parse!(tag(b"\r\n")(input)); let (input, _) = try_parse!(tag(b"\r\n")(input));
Ok(( Ok((