4nk/sdk_common
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Replace Init with Handshake

Browse Source
This commit is contained in:
NicolasCantu 2025-01-09 17:27:03 +01:00 committed by Nicolas Cantu
parent 618b976339
commit 03c24e4eed
1 changed files with 13 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/network.rs
View File

@ -1,20 +1,17 @@
use std::collections::HashMap; use std::collections::HashMap;
use aes_gcm::aead::{Aead, Payload}; use anyhow::Result;
use aes_gcm::{Aes256Gcm, KeyInit};
use anyhow::{Error, Result};
use js_sys::Date;
use rand::{thread_rng, RngCore}; use rand::{thread_rng, RngCore};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use serde_json::{Map, Value}; use serde_json::Value;
use sp_client::bitcoin::consensus::serialize; use sp_client::bitcoin::consensus::serialize;
use sp_client::bitcoin::hex::{DisplayHex, FromHex}; use sp_client::bitcoin::hex::DisplayHex;
use sp_client::bitcoin::{OutPoint, Transaction}; use sp_client::bitcoin::{OutPoint, Transaction};
use tsify::Tsify; use tsify::Tsify;
use crate::crypto::AAD;
use crate::error::AnkError; use crate::error::AnkError;
use crate::pcd::{Member, RoleDefinition}; use crate::pcd::{Member, RoleDefinition};
use crate::process::Process;
use crate::signature::Proof; use crate::signature::Proof;
#[derive(Debug, Serialize, Deserialize, Tsify)] #[derive(Debug, Serialize, Deserialize, Tsify)]
@ -24,7 +21,7 @@ pub enum AnkFlag {
Faucet, Faucet,
Cipher, Cipher,
Commit, Commit,
Init, Handshake,
Unknown, Unknown,
} }
@ -35,7 +32,7 @@ impl From<&str> for AnkFlag {
"Faucet" => Self::Faucet, "Faucet" => Self::Faucet,
"Cipher" => Self::Cipher, "Cipher" => Self::Cipher,
"Commit" => Self::Commit, "Commit" => Self::Commit,
"Init" => Self::Init, "Handshake" => Self::Handshake,
_ => Self::Unknown, _ => Self::Unknown,
} }
} }
@ -54,7 +51,7 @@ impl AnkFlag {
1 => Self::Faucet, 1 => Self::Faucet,
2 => Self::Cipher, 2 => Self::Cipher,
3 => Self::Commit, 3 => Self::Commit,
4 => Self::Init, 4 => Self::Handshake,
_ => Self::Unknown, _ => Self::Unknown,
} }
} }
@ -65,7 +62,7 @@ impl AnkFlag {
Self::Faucet => "Faucet", Self::Faucet => "Faucet",
Self::Cipher => "Cipher", Self::Cipher => "Cipher",
Self::Commit => "Commit", Self::Commit => "Commit",
Self::Init => "Init", Self::Handshake => "Handshake",
Self::Unknown => "Unknown", Self::Unknown => "Unknown",
} }
} }
@ -173,14 +170,14 @@ impl NewTxMessage {
#[derive(Debug, PartialEq, Serialize, Deserialize, Tsify)] #[derive(Debug, PartialEq, Serialize, Deserialize, Tsify)]
#[tsify(into_wasm_abi, from_wasm_abi)] #[tsify(into_wasm_abi, from_wasm_abi)]
pub struct InitMessage { pub struct HandshakeMessage {
pub sp_address: String, pub sp_address: String,
pub peers_list: Option<String>, pub peers_list: HashMap<Member, OutPoint>,
pub processes_list: Option<String>, pub processes_list: HashMap<OutPoint, Process>,
} }
impl InitMessage { impl HandshakeMessage {
pub fn new(sp_address: String, peers_list: Option<String>, processes_list: Option<String>) -> Self { pub fn new(sp_address: String, peers_list: HashMap<Member, OutPoint>, processes_list: HashMap<OutPoint, Process>) -> Self {
Self { Self {
sp_address, sp_address,
peers_list, peers_list,