Add support for custom authority

src/v1/objects.rs

@@ -1,14 +1,16 @@
 //! Types and APIs for interacting with GCS [Objects](https://cloud.google.com/storage/docs/json_api/v1/objects)
 
 use crate::common::StorageClass;
+use http::uri::Authority;
 use std::collections::BTreeMap;
 
 #[doc(hidden)]
 #[macro_export]
 macro_rules! __make_obj_url {
-    ($url:expr, $id:expr) => {{
+    ($url:expr, $authority:expr, $id:expr) => {{
         format!(
             $url,
+            $authority.as_str(),
             percent_encoding::percent_encode($id.bucket().as_ref(), crate::util::PATH_ENCODE_SET),
             percent_encoding::percent_encode($id.object().as_ref(), crate::util::PATH_ENCODE_SET)
         )
@@ -35,7 +37,25 @@ pub type Timestamp = time::OffsetDateTime;
 
 /// Helper struct used to collate all of the operations available for
 /// [Objects](https://cloud.google.com/storage/docs/json_api/v1/objects)
-pub struct Object;
+/// Additionally, it can also be used to specify a custom authority.
+#[derive(Clone, Debug)]
+pub struct Object {
+    authority: Authority,
+}
+
+impl Object {
+    pub fn with_authority(authority: Authority) -> Self {
+        Self { authority }
+    }
+}
+
+impl Default for Object {
+    fn default() -> Self {
+        Self {
+            authority: Authority::from_static("storage.googleapis.com"),
+        }
+    }
+}
 
 /// [Metadata](https://cloud.google.com/storage/docs/json_api/v1/objects#resource)
 /// associated with an Object.

src/v1/objects/delete.rs

@@ -49,13 +49,14 @@ impl super::Object {
     ///
     /// [Complete API documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/delete)
     pub fn delete<'a, OID>(
+        &self,
         id: &OID,
         optional: Option<DeleteObjectOptional<'_>>,
     ) -> Result<http::Request<std::io::Empty>, Error>
     where
         OID: ObjectIdentifier<'a> + ?Sized,
     {
-        let mut uri = crate::__make_obj_url!("https://www.googleapis.com/storage/v1/b/{}/o/{}", id);
+        let mut uri = crate::__make_obj_url!("https://{}/storage/v1/b/{}/o/{}", self.authority, id);
 
         let query = optional.unwrap_or_default();
         let query_params = serde_urlencoded::to_string(query)?;

src/v1/objects/download.rs

@@ -75,14 +75,16 @@ impl super::Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/get)
     pub fn download<'a, OID>(
+        &self,
         id: &OID,
         optional: Option<DownloadObjectOptional<'_>>,
     ) -> Result<http::Request<std::io::Empty>, Error>
     where
         OID: ObjectIdentifier<'a> + ?Sized,
     {
         let mut uri = crate::__make_obj_url!(
-            "https://www.googleapis.com/storage/v1/b/{}/o/{}?alt=media",
+            "https://{}/storage/v1/b/{}/o/{}?alt=media",
+            self.authority,
             id
         );
 

src/v1/objects/get.rs

@@ -52,14 +52,16 @@ impl super::Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/get)
     pub fn get<'a, OID>(
+        &self,
         id: &OID,
         optional: Option<GetObjectOptional<'_>>,
     ) -> Result<http::Request<std::io::Empty>, Error>
     where
         OID: ObjectIdentifier<'a> + ?Sized,
     {
         let mut uri = crate::__make_obj_url!(
-            "https://www.googleapis.com/storage/v1/b/{}/o/{}?alt=json",
+            "https://{}/storage/v1/b/{}/o/{}?alt=json",
+            self.authority,
             id
         );
 

src/v1/objects/insert.rs

@@ -81,6 +81,7 @@ impl super::Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/insert)
     pub fn insert_simple<'a, OID, B>(
+        &self,
         id: &OID,
         content: B,
         length: u64,
@@ -90,7 +91,8 @@ impl super::Object {
         OID: ObjectIdentifier<'a> + ?Sized,
     {
         let mut uri = format!(
-            "https://www.googleapis.com/upload/storage/v1/b/{}/o?name={}&uploadType=media",
+            "https://{}/upload/storage/v1/b/{}/o?name={}&uploadType=media",
+            self.authority.as_str(),
             percent_encoding::percent_encode(id.bucket().as_ref(), crate::util::PATH_ENCODE_SET,),
             percent_encoding::percent_encode(id.object().as_ref(), crate::util::QUERY_ENCODE_SET,),
         );

src/v1/objects/insert/multipart.rs

@@ -203,6 +203,7 @@ impl Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/insert)
     pub fn insert_multipart<B>(
+        &self,
         bucket: &BucketName<'_>,
         content: B,
         length: u64,
@@ -223,7 +224,8 @@ impl Object {
         };
 
         let mut uri = format!(
-            "https://www.googleapis.com/upload/storage/v1/b/{}/o?uploadType=multipart",
+            "https://{}/upload/storage/v1/b/{}/o?uploadType=multipart",
+            self.authority.as_str(),
             percent_encoding::percent_encode(bucket.as_ref(), crate::util::PATH_ENCODE_SET,),
         );
 

src/v1/objects/insert/resumable.rs

@@ -195,14 +195,16 @@ impl Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/performing-resumable-uploads#initiate-session)
     pub fn resumable_insert_init<'a, OID>(
+        &self,
         id: &OID,
         content_type: Option<&str>,
     ) -> Result<http::Request<()>, Error>
     where
         OID: ObjectIdentifier<'a> + ?Sized,
     {
         let uri = format!(
-            "https://www.googleapis.com/upload/storage/v1/b/{}/o?uploadType=resumable&name={}",
+            "https://{}/upload/storage/v1/b/{}/o?uploadType=resumable&name={}",
+            self.authority.as_str(),
             percent_encoding::percent_encode(id.bucket().as_ref(), crate::util::PATH_ENCODE_SET,),
             percent_encoding::percent_encode(id.object().as_ref(), crate::util::QUERY_ENCODE_SET,),
         );

src/v1/objects/list.rs

@@ -109,10 +109,15 @@ impl super::Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/list)
     pub fn list(
+        &self,
         bucket: &BucketName<'_>,
         optional: Option<ListOptional<'_>>,
     ) -> Result<http::Request<std::io::Empty>, Error> {
-        let mut uri = format!("https://www.googleapis.com/storage/v1/b/{}/o", bucket);
+        let mut uri = format!(
+            "https://{}/storage/v1/b/{}/o",
+            self.authority.as_str(),
+            bucket
+        );
 
         let query = optional.unwrap_or_default();
         let query_params = serde_urlencoded::to_string(query)?;

src/v1/objects/patch.rs

@@ -44,15 +44,15 @@ impl super::Object {
     ///
     /// [Complete API documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/patch)
     pub fn patch<'a, OID>(
+        &self,
         id: &OID,
         metadata: &super::Metadata,
         optional: Option<PatchObjectOptional<'_>>,
     ) -> Result<http::Request<std::io::Cursor<Vec<u8>>>, Error>
     where
         OID: ObjectIdentifier<'a> + ?Sized,
     {
-        let mut uri =
-            crate::__make_obj_url!("https://storage.googleapis.com/storage/v1/b/{}/o/{}", id);
+        let mut uri = crate::__make_obj_url!("https://{}/storage/v1/b/{}/o/{}", self.authority, id);
 
         let query = optional.unwrap_or_default();
         let query_params = serde_urlencoded::to_string(query)?;

src/v1/objects/rewrite.rs

@@ -116,6 +116,7 @@ impl super::Object {
     ///
     /// [Complete API Documentation](https://cloud.google.com/storage/docs/json_api/v1/objects/rewrite)
     pub fn rewrite<'a, OID>(
+        &self,
         source: &OID,
         destination: &OID,
         rewrite_token: Option<String>,
@@ -126,7 +127,8 @@ impl super::Object {
         OID: ObjectIdentifier<'a> + ?Sized,
     {
         let mut uri = format!(
-            "https://storage.googleapis.com/storage/v1/b/{}/o/{}/rewriteTo/b/{}/o/{}",
+            "https://{}/storage/v1/b/{}/o/{}/rewriteTo/b/{}/o/{}",
+            self.authority.as_str(),
             percent_encoding::percent_encode(
                 source.bucket().as_ref(),
                 crate::util::PATH_ENCODE_SET