feat: UX improvement

Cargo.toml

@@ -1,17 +1,20 @@
 [workspace]
 members = [
+    "crates/aggregator/",
     "crates/common/",
     "crates/chainio/clients/avsregistry/",
     "crates/chainio/clients/elcontracts/",
     "crates/chainio/clients/eth/",
     "crates/chainio/clients/fireblocks/",
+    "crates/config/",
     "crates/crypto/bls/",
     "crates/crypto/bn254/",
     "crates/eigen-cli/",
     "crates/logging/",
     "crates/metrics/",
     "crates/metrics/collectors/economic/",
     "crates/metrics/collectors/rpc_calls/",
+    "crates/operator/",
     "crates/services/avsregistry/",
     "crates/services/bls_aggregation/",
     "crates/services/operatorsinfo/",
@@ -66,16 +69,19 @@ aws-config = "1.5.9"
 aws-sdk-kms = "1.49.0"
 backoff = { version = "0.4.0", features = ["futures", "tokio"] }
 clap = { version = "4.5.20", features = ["derive"] }
+eigen-aggregator = { path = "crates/aggregator/" }
 eigen-common = { path = "crates/common/" }
 eigen-client-elcontracts = { path = "crates/chainio/clients/elcontracts" }
 eigen-client-eth = { path = "crates/chainio/clients/eth" }
 eigen-client-fireblocks = { path = "crates/chainio/clients/fireblocks" }
+eigen-config = { path = "crates/config/" }
 eigen-crypto-bls = { path = "crates/crypto/bls/" }
 eigen-crypto-bn254 = { path = "crates/crypto/bn254/" }
 eigen-logging = { path = "crates/logging/" }
 eigen-metrics = { path = "crates/metrics/" }
 eigen-metrics-collectors-economic = { path = "crates/metrics/collectors/economic" }
 eigen-metrics-collectors-rpc-calls = { path = "crates/metrics/collectors/rpc_calls" }
+eigen-operator = { path = "crates/operator/" }
 eigen-services-avsregistry = { path = "crates/services/avsregistry" }
 eigen-services-blsaggregation = { path = "crates/services/bls_aggregation" }
 eigen-services-operatorsinfo = { path = "crates/services/operatorsinfo" }

crates/aggregator/Cargo.toml

@@ -0,0 +1,32 @@
+[package]
+name = "eigen-aggregator"
+version.workspace = true
+edition.workspace = true
+rust-version.workspace = true
+repository.workspace = true
+license-file.workspace = true
+description = "eigen layer aggregator"
+
+[lints]
+workspace = true
+
+[dependencies]
+alloy.workspace = true
+eigen-types.workspace = true
+serde.workspace = true
+eigen-crypto-bls.workspace = true
+eigen-common.workspace = true
+eigen-services-operatorsinfo.workspace = true
+eigen-logging.workspace = true
+eigen-client-avsregistry.workspace = true
+eigen-services-avsregistry.workspace = true
+eigen-services-blsaggregation.workspace = true
+eigen-utils.workspace = true
+tracing.workspace = true
+tokio.workspace = true
+thiserror.workspace = true
+futures-util.workspace = true
+
+jsonrpc-core = "18.0.0"
+jsonrpc-http-server = "18.0.0"
+tokio-util = "0.7.11"

crates/aggregator/src/error.rs

@@ -0,0 +1,41 @@
+use alloy::transports::{RpcError, TransportErrorKind};
+use eigen_client_avsregistry::error::AvsRegistryError;
+use eigen_services_blsaggregation::bls_aggregation_service_error::BlsAggregationServiceError;
+use eigen_services_operatorsinfo::operatorsinfo_inmemory::OperatorInfoServiceError;
+use thiserror::Error;
+
+/// Error returned by chainio
+#[derive(Debug, Error)]
+pub enum AggregatorError {
+    /// Bls Aggregation Service Error
+    #[error("Bls Aggregation Service Error : {0}")]
+    BlsAggregationServiceError(#[from] BlsAggregationServiceError),
+
+    /// Task Response not found
+    #[error("Task panicked or got cancelled")]
+    JoinError,
+
+    /// Decoding of the new task event failed
+    #[error("Log decode failed")]
+    LogDecodeFailed(#[from] alloy::sol_types::Error),
+
+    /// Build avs registry chain reader
+    #[error("Failed to build avs registry chain reader ")]
+    BuildAvsRegistryChainReader(#[from] AvsRegistryError),
+
+    /// alloy rpc error
+    #[error("Alloy rpc error")]
+    AlloyRpc(#[from] RpcError<TransportErrorKind>),
+
+    /// IO error
+    #[error("IO error")]
+    IOError(#[from] std::io::Error),
+
+    /// Operator Info service error
+    #[error("Operator Info Service error")]
+    OperatorInfoServiceError(#[from] OperatorInfoServiceError),
+
+    /// Error returned by the [`TaskProcessor`](crate::traits::TaskProcessor)
+    #[error("Task Processing failed")]
+    TaskProcessorError(#[from] Box<dyn std::error::Error + Send>),
+}