add cryptographic primitives

Author: snqre

.gitignore

@@ -8,6 +8,4 @@ result/
 result
 doc/README.md
 doc/proof-of-transport.md
-lib/algo
-lib/chain
-lib/crypto
+lib/chain

Cargo.lock

@@ -8,7 +8,15 @@ members = [
     "app/simulation-item/switch",
     "image",
     "image_util",
+    
+    "lib/cryptography",
+    "lib/cryptography_algorithm/dilithium3", # cryptography_algorithm_dilithium3
+    "lib/cryptography_algorithm/ed25519",    # cryptography_algorithm_ed25519
+    "lib/cryptography_algorithm/kyber1024",  # cryptography_algorithm_hyber1024
     "lib/e2e",
+    "lib/kore",
+    "lib/packet",
+    
     # ... coming soon ...
     "task",
 

Cargo.toml

@@ -7,6 +7,7 @@ build = "build.rs"
 publish = false
 
 [dependencies]
+kore = { version = "*", path = "../../lib/kore" }
 bytes = "*"
 rand = "*"
 rand_core = "*"

app/node/Cargo.toml

@@ -0,0 +1,5 @@
+use super::*;
+
+modwire::expose! {
+	pub packet
+}

app/node/src/cmn.rs

@@ -0,0 +1,13 @@
+#[derive(Debug)]
+#[derive(Clone)]
+#[derive(PartialEq)]
+#[derive(Eq)]
+#[derive(derive_more::Deref)]
+#[derive(derive_more::DerefMut)]
+pub struct Packet<T> {
+	phantom_data: std::marker::PhantomData<T>,
+	pub peer: libp2p::PeerId,
+	#[deref]
+	#[deref_mut]
+	pub content: bytes::Bytes
+}

app/node/src/cmn/packet.rs

@@ -3,7 +3,21 @@ use ed25519_dalek::Signer as _;
 use ed25519::signature::Keypair as _;
 
 pub mod commitment {
+	use super::*;
+	
+	// a packet which may or may not contain encrypted data
+	pub struct Puzzle {
+		
+	}
+	
 
+	pub struct Accumulator {
+		pkts: Vec<sub_system::stream::Packet<sub_system::broker::An>>
+	}
+	
+	impl Accumulator {
+		pub fn store(&mut self, pkt: sub_system::stream::Packet<>)
+	}
 }
 
 pub mod multi_party {
@@ -38,18 +52,18 @@ pub mod multi_party {
 	}
 
 	impl Partial {
-		pub fn sign(self, pk: PublicKey, sg: Signature) -> Result<Or<Self, CompleteVerified>> {
+		pub fn sign(self, pk: PublicKey, sg: Signature) -> Result<kore::Or<Self, CompleteVerified>> {
 			sg.verify(mg, &pk)?;
 
 			self.pk_to_sg.insert(pk, sg);
-			Ok(Or::Lhs(self))
+			Ok(kore::Or::Lhs(self))
 		}
 	}
 
-	impl TryFrom<Vec<u8>> for Partial {
+	impl TryFrom<bytes::Bytes> for Partial {
 		type Error = Box<dyn std::error::Error>;
 
-		fn try_from(value: Vec<u8>) -> std::result::Result<Self, Self::Error> {
+		fn try_from(value: bytes::Bytes) -> std::result::Result<Self, Self::Error> {
 
 		}
 	}
@@ -83,7 +97,7 @@ pub mod single_party {
 		}
 	}
 
-	impl Unpack<(PublicKey, Unsigned)> for SignedVerified {
+	impl kore::Unpack<(PublicKey, Unsigned)> for SignedVerified {
 		fn unpack(self) -> (PublicKey, Unsigned) {
 			let mg: Unsigned = self.content.into();
 			(self.pk, mg)

app/node/src/identity.rs

@@ -104,6 +104,7 @@ use clap::Parser as _;
 use ubyte::ToByteUnit as _;
 use num::ToPrimitive as _;
 
+mod cmn;
 mod config;
 mod identity;
 mod env_key;
@@ -112,14 +113,6 @@ mod saga;
 mod stream;
 mod sub_system;
 
-#[derive(Debug)]
-#[derive(Clone)]
-#[derive(derive_more::From)]
-enum Or<A, B> {
-	Lhs(A),
-	Rhs(B)
-}
-
 #[derive(Debug)]
 #[derive(Clone)]
 #[derive(PartialEq)]
@@ -192,25 +185,15 @@ struct Proof {
 	relays: Vec<(identity::PublicKey, identity::Signature)>
 }
 
-trait Unpack<T> {
-	fn unpack(self) -> T;
-}
-
-trait TryUnpack<T> {
-	type Error;
-	
-	fn unpack(self) -> std::result::Result<T, Self::Error>;
-}
-
 /// External dns source of truth provider, may be swapped and implemented by
 /// other chains or networks, the nodes rely on this sytem for value transfer
 /// and cryptographic proofs
 #[async_trait::async_trait]
 trait Dns {
 	async fn receive_attestation(
 		&self,
-		public_key: identity::PublicKey,
-		signature: identity::Signature
+		pk: identity::PublicKey,
+		sg: identity::Signature
 	) -> Result;
 
 	/// Receives a proof of trasit from src to dst through possible relays.
@@ -219,7 +202,7 @@ trait Dns {
 	// for a given foreign key will return the onchain identity
 	//
 	// i own this pk offchain, this is who i am onchain
-	async fn attestation(&self, key: identity::PublicKey) -> Result<Address>;
+	async fn attestation(&self, pk: identity::PublicKey) -> Result<Address>;
 
 	async fn foreign_attestation(&self) -> Result<identity::PublicKey>;
 
@@ -263,6 +246,61 @@ trait Dns {
 	async fn age(&self, pk: identity::PublicKey) -> Result<Option<Age>>;
 }
 
+#[derive(Debug)]
+struct StellarTestnet;
+
+#[async_trait::async_trait]
+impl Dns for StellarTestnet {
+	async fn receive_attestation(
+		&self,
+		pk: identity::PublicKey,
+		sg: identity::Signature
+	) -> Result {
+		
+	}
+	
+	async fn receive_proof(&self, proof: Proof) -> Result {
+		
+	}
+	
+	async fn attestation(&self, pk: identity::PublicKey) -> Result<Address> {
+		
+	}
+	
+	async fn renew(&self, domain: Domain) -> Result {
+		todo!()
+	}
+	
+	async fn mint(&self, domain: Domain) -> Result {
+		todo!()
+	}
+	
+	async fn congestion_charge(&self) -> Result<Fee> {
+		todo!()
+	}
+	
+	async fn fee(&self) -> Result<Fee> {
+		todo!()
+	}
+	
+	async fn traffic(&self, domain: Domain) -> Result<Traffic> {
+		todo!()
+	}
+	
+	async fn total_spend(&self) -> Result<Balance> {
+		todo!()
+	}
+	
+	async fn total_claim(&self) -> Result<Balance> {
+		todo!()
+	}
+	
+	async fn age(&self, pk: identity::PublicKey) -> Result<Option<Age>> {
+		todo!()
+	}
+}
+
+
 type Result<T = ()> = std::result::Result<T, Box<dyn std::error::Error>>;
 
 type Swarm = swarm::Swarm<Behaviour>;

app/node/src/main.rs

@@ -139,10 +139,16 @@ where
 				};
 
 				tokio::runtime::Handle::current().block_on(async move {
-					dns.receive_proof(proof).await.unwrap();
+					match dns.receive_proof(proof).await {
+						Ok(_) => {
+							
+						},
+						Err(_) => {
+							
+						}
+					}
 				});
 
-				
 			},
 			_ => self
 		}