ref(rust-client): Use typed queries for resumable API

clients/rust/Cargo.toml

@@ -20,7 +20,7 @@ jsonwebtoken = { workspace = true }
 multer = { workspace = true }
 objectstore-types = { workspace = true }
 # Pinned below workspace version for MSRV compatibility
-reqwest = { version = "0.13.1", default-features = false, features = ["charset", "http2", "system-proxy", "json", "stream", "multipart"] }
+reqwest = { version = "0.13.1", default-features = false, features = ["charset", "http2", "system-proxy", "json", "stream", "multipart", "query"] }
 sentry-core = { version = ">=0.41", default-features = false, features = ["client"] }
 serde = { workspace = true }
 thiserror = { workspace = true }

clients/rust/src/client.rs

@@ -583,20 +583,6 @@ impl Session {
         self.prepare_builder(builder)
     }
 
-    #[cfg(feature = "resumable-upload-api")]
-    pub(crate) fn resumable_request(
-        &self,
-        method: reqwest::Method,
-        object_key: &str,
-        query_pair: (&str, &str),
-    ) -> crate::Result<RequestBuilder> {
-        let mut url = self.object_url(object_key);
-        url.query_pairs_mut()
-            .append_pair(query_pair.0, query_pair.1);
-        let builder = self.client.reqwest.request(method, url);
-        self.prepare_builder(builder)
-    }
-
     pub(crate) fn batch_request(&self) -> crate::Result<RequestBuilder> {
         let url = self.batch_url();
         let builder = self.client.reqwest.post(url);

clients/rust/src/resumable.rs

@@ -18,11 +18,28 @@ use objectstore_types::resumable::{
     UploadOffset,
 };
 use reqwest::{Method, Response, StatusCode};
+use serde::Serialize;
 
 pub use objectstore_types::resumable::{SessionToken, UploadProgress};
 
 use crate::{Compression, Error, ExpirationPolicy, ObjectKey, Session};
 
+#[derive(Serialize)]
+#[serde(rename_all = "snake_case")]
+enum UploadType {
+    Resumable,
+}
+
+#[derive(Serialize)]
+struct UploadTypeQuery {
+    upload_type: UploadType,
+}
+
+#[derive(Serialize)]
+struct SessionQuery<'a> {
+    session: &'a SessionToken,
+}
+
 /// A handle bound to one resumable upload session.
 ///
 /// See the [crate-level documentation](crate#resumable-upload-api) for more information and
@@ -113,9 +130,12 @@ impl ResumableUpload {
     }
 
     fn request(&self, method: Method) -> crate::Result<reqwest::RequestBuilder> {
-        let token = self.token.to_base64url();
-        self.session
-            .resumable_request(method, &self.key, ("session", &token))
+        Ok(self
+            .session
+            .request(method, &self.key)?
+            .query(&SessionQuery {
+                session: &self.token,
+            }))
     }
 }
 
@@ -195,11 +215,10 @@ impl CreateResumableUploadBuilder {
         };
         let request = self
             .session
-            .resumable_request(
-                method,
-                self.key.as_deref().unwrap_or_default(),
-                ("upload_type", "resumable"),
-            )?
+            .request(method, self.key.as_deref().unwrap_or_default())?
+            .query(&UploadTypeQuery {
+                upload_type: UploadType::Resumable,
+            })
             .headers(self.metadata.to_headers("")?)
             .header(HEADER_UPLOAD_LENGTH, self.total_length.to_string());
         let response = request.send().await?;