networkException/garage
1
0
Fork 0
forked from Deuxfleurs/garage
Code Pull requests Activity

Fix k2v_client with unicode in partition keys

Browse source
This commit is contained in:
Alex 2023-05-19 12:52:28 +02:00 committed by networkException
parent de5f3e2aa8
commit ccc2d0f375
Signed by: networkException
GPG key ID: E3877443AE684391
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/k2v-client/lib.rs
View file

@ -33,6 +33,12 @@ const STRICT_ENCODE_SET: AsciiSet = NON_ALPHANUMERIC
.remove(b'-') .remove(b'-')
.remove(b'.') .remove(b'.')
.remove(b'~'); .remove(b'~');
const PATH_ENCODE_SET: AsciiSet = NON_ALPHANUMERIC
.remove(b'/')
.remove(b'_')
.remove(b'-')
.remove(b'.')
.remove(b'~');
pub struct K2vClientConfig { pub struct K2vClientConfig {
pub endpoint: String, pub endpoint: String,
@ -445,7 +451,7 @@ impl K2vClient {
let mut url = format!("{}/{}", self.config.endpoint, self.config.bucket); let mut url = format!("{}/{}", self.config.endpoint, self.config.bucket);
if let Some(pk) = partition_key { if let Some(pk) = partition_key {
url.push('/'); url.push('/');
url += pk; url.extend(utf8_percent_encode(pk, &PATH_ENCODE_SET));
} }
if !query.is_empty() { if !query.is_empty() {
url.push('?'); url.push('?');