feat: replace cloud_storage with custom implementation (#18) (#42)

* feat: replace cloud_storage with custom implementation (#18)

* feat: use ring directly

Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>

Cargo.toml

@@ -24,8 +24,12 @@ azure_storage_blobs = { version = "0.2", optional = true, default-features = fal
 bytes = "1.0"
 chrono = { version = "0.4", default-features = false, features = ["clock"] }
 # Google Cloud Storage integration
-cloud-storage = { version = "0.11.1", optional = true, default-features = false, features = ["rustls-tls"] }
 futures = "0.3"
+serde = { version = "1.0", default-features = false, features = ["derive"], optional = true }
+serde_json = { version = "1.0", default-features = false, optional = true }
+rustls-pemfile = { version = "1.0", default-features = false, optional = true }
+ring = { version = "0.16", default-features = false, features = ["std"] }
+base64 = { version = "0.13", default-features = false, optional = true }
 # for rusoto
 hyper = { version = "0.14", optional = true, default-features = false }
 # for rusoto
@@ -48,7 +52,7 @@ walkdir = "2"
 [features]
 azure = ["azure_core", "azure_storage_blobs", "azure_storage", "reqwest"]
 azure_test = ["azure", "azure_core/azurite_workaround", "azure_storage/azurite_workaround", "azure_storage_blobs/azurite_workaround"]
-gcp = ["cloud-storage"]
+gcp = ["serde", "serde_json", "reqwest", "reqwest/json", "reqwest/stream", "chrono/serde", "rustls-pemfile", "base64"]
 aws = ["rusoto_core", "rusoto_credential", "rusoto_s3", "hyper", "hyper-rustls"]
 
 [dev-dependencies] # In alphabetical order

src/aws.rs

@@ -909,9 +909,7 @@ mod tests {
         let err = get_nonexistent_object(&integration, Some(location))
             .await
             .unwrap_err();
-        if let Some(ObjectStoreError::NotFound { path, source }) =
-            err.downcast_ref::<ObjectStoreError>()
-        {
+        if let ObjectStoreError::NotFound { path, source } = err {
             let source_variant = source.downcast_ref::<rusoto_core::RusotoError<_>>();
             assert!(
                 matches!(