fix(aggregator): incorrect object path when updating file acl

Author: Alenar

Cargo.lock

@@ -36,6 +36,7 @@ mithril-resource-pool = { path = "../internal/mithril-resource-pool" }
 mithril-signed-entity-lock = { path = "../internal/signed-entity/mithril-signed-entity-lock" }
 mithril-signed-entity-preloader = { path = "../internal/signed-entity/mithril-signed-entity-preloader" }
 paste = "1.0.15"
+percent-encoding = "2.3.1"
 rayon = { workspace = true }
 regex = "1.11.1"
 reqwest = { workspace = true, features = [

mithril-aggregator/Cargo.toml

@@ -16,7 +16,7 @@ use tokio_util::codec::{BytesCodec, FramedRead};
 use mithril_common::entities::FileUri;
 use mithril_common::StdResult;
 
-use crate::file_uploaders::cloud_uploader::CloudBackendUploader;
+use crate::file_uploaders::cloud_uploader::{gcp_percent_encode, CloudBackendUploader};
 use crate::file_uploaders::CloudRemotePath;
 
 /// Google Cloud Platform file uploader using `gcloud-storage` crate
@@ -133,13 +133,13 @@ impl CloudBackendUploader for GCloudBackendUploader {
             role: ObjectACLRole::READER,
         };
         info!(
-            self.logger,
-            "Updating acl for {remote_file_path}: {new_bucket_access_control:?}"
+            self.logger, "Updating acl for {remote_file_path}";
+            "inserted_acl" => ?new_bucket_access_control
         );
         self.storage_client
             .insert_object_access_control(&InsertObjectAccessControlRequest {
                 bucket: self.bucket.clone(),
-                object: remote_file_path.to_string(),
+                object: gcp_percent_encode(&remote_file_path.to_string()),
                 acl: new_bucket_access_control,
                 ..Default::default()
             })

mithril-aggregator/src/file_uploaders/cloud_uploader/gcloud_backend.rs

@@ -5,3 +5,16 @@ mod interface;
 pub use api::*;
 pub use gcloud_backend::*;
 pub use interface::*;
+
+use percent_encoding::{utf8_percent_encode, AsciiSet, NON_ALPHANUMERIC};
+
+const ENCODE_SET: &AsciiSet = &NON_ALPHANUMERIC
+    .remove(b'*')
+    .remove(b'-')
+    .remove(b'.')
+    .remove(b'_');
+
+/// Encode a string for use in a GCP URL, satisfying: https://cloud.google.com/storage/docs/request-endpoints#encoding
+pub fn gcp_percent_encode(input: &str) -> String {
+    utf8_percent_encode(input, ENCODE_SET).to_string()
+}