From d3dc249b83709f08f44135d7b0de50bf3020be60 Mon Sep 17 00:00:00 2001
From: MujkicA <ahmedmujkic2@gmail.com>
Date: Thu, 23 Jan 2025 20:35:49 +0100
Subject: [PATCH] eigen connector files

---
 packages/adapters/eigenda/Cargo.toml    | 29 ++++++++++++
 packages/adapters/eigenda/src/error.rs  | 13 +++++
 packages/adapters/eigenda/src/lib.rs    |  6 +++
 packages/adapters/eigenda/src/signer.rs | 63 +++++++++++++++++++++++++
 4 files changed, 111 insertions(+)
 create mode 100644 packages/adapters/eigenda/Cargo.toml
 create mode 100644 packages/adapters/eigenda/src/error.rs
 create mode 100644 packages/adapters/eigenda/src/lib.rs
 create mode 100644 packages/adapters/eigenda/src/signer.rs

diff --git a/packages/adapters/eigenda/Cargo.toml b/packages/adapters/eigenda/Cargo.toml
new file mode 100644
index 00000000..c639a084
--- /dev/null
+++ b/packages/adapters/eigenda/Cargo.toml
@@ -0,0 +1,29 @@
+[package]
+name = "eigenda"
+authors = { workspace = true }
+edition = { workspace = true }
+homepage = { workspace = true }
+license = { workspace = true }
+repository = { workspace = true }
+version = { workspace = true }
+publish = { workspace = true }
+rust-version = { workspace = true }
+
+[dependencies]
+signers = { workspace = true }
+services = { workspace = true }
+hex = { workspace = true }
+k256 = { workspace = true, features = ["ecdsa"] }
+futures = { workspace = true }
+prost = { workspace = true }
+thiserror = { workspace = true }
+tokio = { workspace = true }
+tonic = { workspace = true, features = ["tls", "transport", "tls-roots", "codegen", "prost"] }
+tonic-build = { workspace = true }
+url = { workspace = true }
+
+[dev-dependencies]
+
+
+[features]
+test-helpers = []
diff --git a/packages/adapters/eigenda/src/error.rs b/packages/adapters/eigenda/src/error.rs
new file mode 100644
index 00000000..27ca9ee2
--- /dev/null
+++ b/packages/adapters/eigenda/src/error.rs
@@ -0,0 +1,13 @@
+#[derive(Debug, thiserror::Error)]
+pub enum ConnectorError {
+    #[error("Transport error: {0}")]
+    Transport(#[from] tonic::transport::Error),
+    #[error("RPC error: {0}")]
+    Rpc(#[from] tonic::Status),
+    #[error("Authentication failed")]
+    AuthenticationFailed,
+    #[error("Blob processing failed: {0}")]
+    BlobProcessingFailed(String),
+    #[error("Timeout waiting for blob status")]
+    Timeout,
+}
diff --git a/packages/adapters/eigenda/src/lib.rs b/packages/adapters/eigenda/src/lib.rs
new file mode 100644
index 00000000..10ca2a8e
--- /dev/null
+++ b/packages/adapters/eigenda/src/lib.rs
@@ -0,0 +1,6 @@
+mod bindings;
+mod connector;
+mod error;
+mod signer;
+
+pub use connector::*;
diff --git a/packages/adapters/eigenda/src/signer.rs b/packages/adapters/eigenda/src/signer.rs
new file mode 100644
index 00000000..28b5a167
--- /dev/null
+++ b/packages/adapters/eigenda/src/signer.rs
@@ -0,0 +1,63 @@
+use signers::{AwsKmsClient, KeySource};
+
+use crate::error::ConnectorError;
+
+pub struct SignedMessage {
+    pub data: Vec<u8>,
+}
+
+#[derive(Debug, Clone)]
+pub enum EigenDASigner {
+    AwsKms(AwsSigner),
+}
+
+#[derive(Debug, Clone)]
+pub struct AwsSigner {
+    key_id: String,
+    client: AwsKmsClient,
+}
+
+impl AwsSigner {
+    async fn new(key_id: String) -> Self {
+        let client = AwsKmsClient::new().await;
+
+        Self { key_id, client }
+    }
+
+    async fn sign(&self, message: &[u8]) -> Result<SignedMessage, ConnectorError> {
+        // TODO unwrap
+        let signed = self.client.sign(&self.key_id, message).await.unwrap();
+
+        Ok(SignedMessage { data: signed })
+    }
+
+    async fn account_id(&self) -> String {
+        let pk = self.client.get_public_key(&self.key_id).await.unwrap();
+        format!("0x{}", hex::encode(pk))
+    }
+}
+
+// get the public key from the signing key
+// let public_key = signing_key.verifying_key().to_encoded_point(false);
+// let account_id = format!("0x{}", hex::encode(public_key.as_bytes()));
+
+impl EigenDASigner {
+    pub async fn new(key: KeySource) -> Self {
+        match key {
+            KeySource::Kms(key_id) => Self::AwsKms(AwsSigner::new(key_id).await),
+            _ => unimplemented!(),
+        }
+    }
+
+    pub async fn sign(&self, message: &[u8]) -> Result<SignedMessage, ConnectorError> {
+        match self {
+            Self::AwsKms(signer) => signer.sign(message).await,
+        }
+    }
+
+    pub async fn account_id(&self) -> String {
+        match self {
+            Self::AwsKms(signer) => signer.account_id().await,
+        }
+    }
+}