merge: Merge pull request #194 from arunaengine/feat/multipart-finish

Aruna API version update and staging object finish functionality extension

Author: das-Abroxas

Cargo.lock

@@ -14,11 +14,11 @@ license = "MIT OR Apache-2.0"
 [workspace.dependencies]
 ahash = "0.8.11"
 anyhow = "1.0.86"
-aruna-rust-api = "2.0.0"
+aruna-rust-api = "2.0.2"
 async-channel = "2.3.1"
 async-trait = "0.1.81"
-aws-config = "1.5.4"
-aws-sdk-s3 = "1.40.0"
+aws-config = "1.5.8"
+aws-sdk-s3 = "1.57.0"
 base64 = "0.22.1"
 cel-interpreter = "0.8.0"
 cel-parser = "0.7.0"

Cargo.toml

@@ -561,6 +561,7 @@ impl GrpcQueryHandler {
             content_len,
             hashes,
             completed_parts: vec![],
+            upload_id: "".to_string(), // Upload id only needed in requests from users
         });
 
         Self::add_token_to_md(req.metadata_mut(), token)?;
@@ -624,6 +625,7 @@ impl GrpcQueryHandler {
             content_len,
             hashes: proxy_object.get_hashes(), // Hashes stay the same
             completed_parts: vec![],
+            upload_id: "".to_string(), // Upload id only needed in requests from users
         });
 
         Self::add_token_to_md(req.metadata_mut(), token)?;
@@ -1314,6 +1316,7 @@ impl GrpcQueryHandler {
             content_len,
             hashes: vec![],
             completed_parts: vec![],
+            upload_id: "".to_string(), // Upload id only needed in requests from users
         });
 
         Self::add_token_to_md(req.metadata_mut(), token)?;

components/data_proxy/src/caching/grpc_query_handler.rs

@@ -420,7 +420,7 @@ impl User {
             }
         }
 
-        for (k, _) in &other.tokens {
+        for k in other.tokens.keys() {
             if !self.tokens.contains_key(k) {
                 to_delete.push(k.to_string());
             }