Nulo/kawipiko
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

[common] Add support for arbitrary HTTP header value.

Browse source
This commit is contained in:
Ciprian Dorin Craciun 2021-12-22 23:27:12 +02:00
parent 46ddab0fc2
commit d16afd63e8
1 changed files with 55 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

50
sources/lib/common/metadata.go
View file

@ -144,14 +144,28 @@ func MetadataEncodeBinary (_metadata map[string]string) ([]byte, error) {
if !_keyFound { if !_keyFound {
return nil, fmt.Errorf ("[a2a62863] invalid metadata key: `%s` (not canonical)", _key) return nil, fmt.Errorf ("[a2a62863] invalid metadata key: `%s` (not canonical)", _key)
} }
if !_valueFound { if _valueFound {
return nil, fmt.Errorf ("[5ed34411] invalid metadata value: `%s` (not canonical)", _value)
}
var _pairBuffer [16]byte var _pairBuffer [16]byte
if _error := EncodeKeysPairToBytes_0 (NamespaceHeaderName, _keyId, NamespaceHeaderValue, _valueId, _pairBuffer[:]); _error != nil { if _error := EncodeKeysPairToBytes_0 (NamespaceHeaderName, _keyId, NamespaceHeaderValue, _valueId, _pairBuffer[:]); _error != nil {
return nil, _error return nil, _error
} }
_buffer.Write (_pairBuffer[:]) _buffer.Write (_pairBuffer[:])
} else {
_valueSize := len (_value)
if _valueSize > 4096 {
return nil, fmt.Errorf ("[85c25588] invalid metadata value: `%s`", _value)
}
var _pairBuffer [12]byte
if _error := EncodeKeyToBytes_0 (NamespaceHeaderName, _keyId, _pairBuffer[:8]); _error != nil {
return nil, _error
}
_pairBuffer[8] = 'Z'
_pairBuffer[9] = byte (_valueSize / 25 / 25) + 'a'
_pairBuffer[10] = byte (_valueSize / 25 % 25) + 'a'
_pairBuffer[11] = byte (_valueSize % 25) + 'a'
_buffer.Write (_pairBuffer[:])
_buffer.Write ([]byte (_value))
}
} }
_data := _buffer.Bytes () _data := _buffer.Bytes ()
@ -210,13 +224,12 @@ func MetadataDecodeBinaryIterate (_data []byte, _callback func ([]byte, []byte)
} }
_slice = _data[_dataOffset:] _slice = _data[_dataOffset:]
if _slice[0] != NamespaceHeaderValuePrefix { var _value []byte
return fmt.Errorf ("[2b43651c] invalid metadata encoding") if _slice[0] == NamespaceHeaderValuePrefix {
}
if _sliceSize < 8 { if _sliceSize < 8 {
return fmt.Errorf ("[7cd40b03] invalid metadata encoding") return fmt.Errorf ("[7cd40b03] invalid metadata encoding")
} }
var _value []byte
if _value_0, _found := CanonicalHeaderValuesFromKey[DecodeKey_9 (_slice[0:8])]; _found { if _value_0, _found := CanonicalHeaderValuesFromKey[DecodeKey_9 (_slice[0:8])]; _found {
_value = StringToBytes (_value_0) _value = StringToBytes (_value_0)
} else { } else {
@ -225,6 +238,29 @@ func MetadataDecodeBinaryIterate (_data []byte, _callback func ([]byte, []byte)
_dataOffset += 8 _dataOffset += 8
} else if _slice[0] == 'Z' {
if _sliceSize < 4 {
return fmt.Errorf ("[3c4a6b51] invalid metadata encoding")
}
_valueSize := 0
_valueSize += int (_slice[1] - 'a') * 25 * 25
_valueSize += int (_slice[2] - 'a') * 25
_valueSize += int (_slice[3] - 'a')
if _sliceSize < (4 + _valueSize) {
return fmt.Errorf ("[3c4a6b51] invalid metadata encoding")
}
_value = _slice[4 : 4 + _valueSize]
_dataOffset += 4 + _valueSize
} else {
return fmt.Errorf ("[2b43651c] invalid metadata encoding")
}
_callback (_key, _value) _callback (_key, _value)
} }
} }