diff --git a/packages/ciphernode/enclave_node/src/bin/aggregator.rs b/packages/ciphernode/enclave_node/src/bin/aggregator.rs new file mode 100644 index 00000000..70d32a10 --- /dev/null +++ b/packages/ciphernode/enclave_node/src/bin/aggregator.rs @@ -0,0 +1,19 @@ +use enclave_core::Actor; +use enclave_core::CommitteeManager; +use enclave_core::EventBus; +use enclave_core::Fhe; +use enclave_core::P2p; +use enclave_core::SimpleLogger; +use std::error::Error; + +#[actix_rt::main] +async fn main() -> Result<(), Box> { + let fhe = Fhe::try_default()?.start(); + let bus = EventBus::new(true).start(); + SimpleLogger::attach(bus.clone()); + CommitteeManager::attach(bus.clone(), fhe.clone()); + let (_, h) = P2p::spawn_libp2p(bus.clone())?; + println!("Aggregator"); + let _ = tokio::join!(h); + Ok(()) +} diff --git a/packages/ciphernode/enclave_node/src/bin/ciphernode-noag.rs b/packages/ciphernode/enclave_node/src/bin/ciphernode-noag.rs new file mode 100644 index 00000000..627af0b3 --- /dev/null +++ b/packages/ciphernode/enclave_node/src/bin/ciphernode-noag.rs @@ -0,0 +1,21 @@ +use enclave_core::Actor; +use enclave_core::Ciphernode; +use enclave_core::Data; +use enclave_core::EventBus; +use enclave_core::Fhe; +use enclave_core::P2p; +use enclave_core::SimpleLogger; +use std::error::Error; + +#[actix_rt::main] +async fn main() -> Result<(), Box> { + let fhe = Fhe::try_default()?.start(); + let bus = EventBus::new(true).start(); + let data = Data::new(true).start(); // TODO: Use a sled backed Data Actor + SimpleLogger::attach(bus.clone()); + Ciphernode::attach(bus.clone(), fhe.clone(), data.clone()); + let (_, h) = P2p::spawn_libp2p(bus.clone())?; + println!("Ciphernode"); + let _ = tokio::join!(h); + Ok(()) +}