Read blobs

Signed-off-by: itowlson <[email protected]>

Author: itowlson

Cargo.lock

@@ -118,6 +118,12 @@ members = [
 [workspace.dependencies]
 anyhow = "1"
 async-trait = "0.1"
+azure_core = "0.21.0"
+azure_data_cosmos = "0.21.0"
+azure_identity = "0.21.0"
+azure_security_keyvault = "0.21.0"
+azure_storage = "0.21.0"
+azure_storage_blobs = "0.21.0"
 bytes = "1"
 conformance-tests = { git = "https://github.com/fermyon/conformance-tests", rev = "ecd22a45bcc5c775a56c67689a89aa4005866ac0" }
 dirs = "5.0"

Cargo.toml

@@ -0,0 +1,26 @@
+[package]
+name = "spin-blobstore-azure"
+version.workspace = true
+authors.workspace = true
+edition.workspace = true
+license.workspace = true
+homepage.workspace = true
+repository.workspace = true
+rust-version.workspace = true
+
+[dependencies]
+anyhow = { workspace = true }
+azure_core = { workspace = true }
+azure_storage = { workspace = true }
+azure_storage_blobs = { workspace = true }
+futures = { workspace = true }
+serde = { workspace = true }
+spin-core = { path = "../core" }
+spin-factor-blobstore = { path = "../factor-blobstore" }
+tokio = { workspace = true }
+tokio-stream = "0.1.16"
+tokio-util = "0.7.12"
+wasmtime-wasi = { workspace = true }
+
+[lints]
+workspace = true

crates/blobstore-azure/Cargo.toml

@@ -0,0 +1,58 @@
+mod store;
+
+use serde::Deserialize;
+use spin_factor_blobstore::runtime_config::spin::MakeBlobStore;
+use store::{
+    BlobStoreAzureBlob,
+    // KeyValueAzureCosmos, KeyValueAzureCosmosAuthOptions, KeyValueAzureCosmosRuntimeConfigOptions,
+};
+
+/// A key-value store that uses Azure Cosmos as the backend.
+#[derive(Default)]
+pub struct AzureBlobStore {
+    _priv: (),
+}
+
+impl AzureBlobStore {
+    /// Creates a new `AzureBlobStore`.
+    pub fn new() -> Self {
+        Self::default()
+    }
+}
+
+/// Runtime configuration for the Azure Cosmos key-value store.
+#[derive(Deserialize)]
+pub struct AzureBlobStoreRuntimeConfig {
+    /// The authorization token for the Azure blob storage  account.
+    key: Option<String>,
+    /// The Azure blob storage account name.
+    account: String,
+}
+
+impl MakeBlobStore for AzureBlobStore {
+    const RUNTIME_CONFIG_TYPE: &'static str = "azure_blob";
+
+    type RuntimeConfig = AzureBlobStoreRuntimeConfig;
+
+    type ContainerManager = BlobStoreAzureBlob;
+
+    fn make_store(
+        &self,
+        runtime_config: Self::RuntimeConfig,
+    ) -> anyhow::Result<Self::ContainerManager> {
+        let auth = match &runtime_config.key {
+            Some(key) => store::BlobStoreAzureAuthOptions::RuntimeConfigValues(store::BlobStoreAzureRuntimeConfigOptions::new(runtime_config.account.clone(), key.clone())),
+            None => store::BlobStoreAzureAuthOptions::Environmental,
+        };
+    
+
+        // let account = &runtime_config.account;
+        // let key = &runtime_config.key;
+
+        // let credentials = azure_storage::prelude::StorageCredentials::access_key(account, key);
+        // let client = azure_storage_blobs::prelude::ClientBuilder::new(account, credentials);
+
+        let blob_store = BlobStoreAzureBlob::new(auth)?;
+        Ok(blob_store)
+    }
+}