Feature/node 4963 lit node api

rust/lit-node/Cargo.toml

@@ -49,9 +49,12 @@ scc = "3"
 sdd = "4"
 sha2 = "0.10.9"
 sha3 = "0.10.8"
+siwe = "0.5.0"
+siwe-recap = { git = "https://github.com/spruceid/siwe-recap" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 soteria-rs = { version = "0.3.1", features = ["serde", "elements"] }
+tracing = "0.1.40"
 url = { version = "2", features = ["serde"] }
 utoipa = { version = "5", features = ["chrono"] }
 zeroize = { version = "1.8", features = ["derive"] }

rust/lit-node/lit-node-core/src/models.rs

@@ -18,6 +18,7 @@ mod endpoint_version;
 mod invocation;
 mod multiple_auth_sigs;
 mod node_set;
+mod payed_endpoint;
 mod payment_delegation_resource;
 mod peer_id;
 mod pkp_nft_resource;
@@ -26,6 +27,7 @@ mod resource_ability_request;
 mod resource_ability_request_resource;
 mod resource_prefix;
 mod resource_type;
+mod session_key;
 mod signable;
 mod signed_data;
 mod signing_scheme;
@@ -47,6 +49,7 @@ pub use endpoint_version::*;
 pub use invocation::*;
 pub use multiple_auth_sigs::*;
 pub use node_set::*;
+pub use payed_endpoint::*;
 pub use payment_delegation_resource::*;
 pub use peer_id::*;
 pub use pkp_nft_resource::*;
@@ -55,6 +58,7 @@ pub use resource_ability_request::*;
 pub use resource_ability_request_resource::*;
 pub use resource_prefix::*;
 pub use resource_type::*;
+pub use session_key::*;
 pub use signable::*;
 pub use signed_data::*;
 pub use signing_scheme::*;

rust/lit-node/lit-node/src/payment/payed_endpoint.rs → rust/lit-node/lit-node-core/src/models/payed_endpoint.rs

@@ -1,7 +1,7 @@
 use ethers::types::U256;
 use std::str::FromStr;
 
-use crate::error::{EC, Error, Result, parser_err_code};
+use crate::error::{Error, Result};
 
 #[derive(Clone, Copy, PartialEq, Debug)]
 pub enum PayedEndpoint {
@@ -19,11 +19,7 @@ impl FromStr for PayedEndpoint {
             "lit_action" => Ok(PayedEndpoint::LitAction),
             "pkp_sign" => Ok(PayedEndpoint::PkpSign),
             "sign_session_key" => Ok(PayedEndpoint::SignSessionKey),
-            _ => Err(parser_err_code(
-                "",
-                EC::NodeSerializationError,
-                Some(format!("`{s}` is not a valid PayedEndpoint")),
-            )),
+            _ => Err(Error::Parse(format!("`{s}` is not a valid PayedEndpoint"))),
         }
     }
 }

rust/lit-node/lit-node/src/models/auth.rs → rust/lit-node/lit-node-core/src/models/session_key.rs

@@ -1,6 +1,6 @@
 use super::JsonAuthSig;
+use crate::LitResourceAbilityRequest;
 use ethers::types::U256;
-use lit_node_core::LitResourceAbilityRequest;
 use serde::{Deserialize, Deserializer, Serialize, de::Error};
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -21,16 +21,8 @@ where
     D: Deserializer<'de>,
 {
     let s: &str = Deserialize::deserialize(deserializer)?;
-    let result = match s.starts_with("0x") {
-        true => U256::from_str_radix(&s[2..], 16).map_err(D::Error::custom),
-        false => U256::from_str_radix(s, 10).map_err(D::Error::custom),
-    };
-
-    if result.is_err() {
-        debug!(
-            "Deserializing max_price '{}' to U256 failed: {:?}",
-            s, result
-        );
+    match s.starts_with("0x") {
+        true => Ok(U256::from_str_radix(&s[2..], 16).map_err(D::Error::custom)?),
+        false => Ok(U256::from_str_radix(s, 10).map_err(D::Error::custom)?),
     }
-    result
 }

rust/lit-node/lit-node-testnet/Cargo.toml

@@ -11,7 +11,7 @@ lit-actions = []
 proxy_chatter = []
 lit-actions-server = ["lit-actions"] # start internal lit_actions server for testing
 testing = [] # enables testing features
-
+lit-peer-api-server = [] # disables certain functions not required for the api server
 
 
 [build-dependencies]
@@ -26,12 +26,15 @@ async-trait.workspace = true
 bs58 = "0.5.0"
 command-group = "1.0.8"
 chrono = "0.4.24"
+data-encoding.workspace = true
 ethers = { version = "2.0.8", features = [ "abigen", "legacy" ]}
 fs_extra = "1.3.0"
 futures = "0.3.17"
 hex.workspace = true
 hex-literal = "0.4.1"
 
+ecdsa = { version = "0.16", features = ["arithmetic"] }
+ed25519-dalek.workspace = true
 k256 = { version = "0.13.0", features = ["sha256", "ecdsa", "serde", "ecdsa-core", "expose-field", "hash2curve", "schnorr"], optional = false }
 once_cell = { version = "1" }
 rand = { workspace = true, features = ["std_rng"]}
@@ -42,19 +45,34 @@ regex = "1.7.1"
 # used to verify JWTs.  must match the version in the crate overrides at the bottom of this file
 sodalite = "0.4"
 serde_json.workspace = true
+siwe.workspace = true
+siwe-recap.workspace = true
 tokio = { version = "1.23.0", features = ["rt-multi-thread"] }
 tracing = "0.1.40"
 tracing-subscriber = { version = "0.3" }
 url = { version = "2", features = ["serde"] }
 #ECDSA
+lit-ecdsa-wasm-combine = { git = "https://github.com/LIT-Protocol/lit-ecdsa-wasm-combine", branch = "0.2.0" }
 lit-core = { path = "../../lit-core/lit-core", features = ["ipfs", "chrono"] }
+lit-api-core = { path = "../../lit-core/lit-api-core" }
 lit-logging = { path = "../../lit-core/lit-logging", features = ["service"] }
 lit-blockchain = { path = "../../lit-core/lit-blockchain" }
 lit-blockchain-lite = { git="https://github.com/LIT-Protocol/datil-lit-blockchain-lite.git" }
 lit-attestation = { path = "../../lit-core/lit-attestation", features = ["generate-via-service", "kdf"] }
 lit-node-common ={ path = "../lit-node-common" }
 lit-node-core = { path = "../lit-node-core" }
 lit-sdk = { path = "../lit-sdk" }
+lit-rust-crypto = { workspace = true, features = [
+    "arithmetic",
+    "default",
+    "ecdsa",
+    "ecdsa-core",
+    "expose-field",
+    "hash2curve",
+    "schnorr",
+    "sha",
+    "serde"
+] }
 toml_edit = "0.22"
 toxiproxy_rust = "*"
 uuid = { version = "1.4", features = ["v4"] }

rust/lit-node/lit-node/tests/common/auth_sig.rs → rust/lit-node/lit-node-testnet/src/common/auth_sig.rs

@@ -1,7 +1,6 @@
 use ethers::abi::AbiEncode;
 use std::collections::{BTreeMap, HashMap};
 use std::ops::Add;
-use std::str::FromStr;
 
 use anyhow::Result;
 use chrono::{Duration, SecondsFormat};
@@ -12,9 +11,10 @@ use ethers::types::{Address, H256, U256};
 use lit_api_core::error::Unexpected;
 use lit_blockchain::config::LitBlockchainConfig;
 use lit_core::config::LitConfig;
-use lit_node::models::auth::SessionKeySignedMessageV2;
-use lit_node::payment::payed_endpoint::PayedEndpoint;
-use lit_node::utils::encoding::{self, hex_to_bytes};
+use lit_core::utils::binary::{bytes_to_hex, hex_to_bytes};
+use lit_node_core::PayedEndpoint;
+use lit_node_core::SessionKeySignedMessageV2;
+
 use lit_node_core::{
     AuthMethod, AuthSigItem, CurveType, JsonAuthSig, LitResourceAbilityRequest, LitResourcePrefix,
     NodeSet,
@@ -37,7 +37,7 @@ use lit_node_core::response::GenericResponse;
 use rand_core::RngCore;
 
 use super::session_sigs::SessionSigAndNodeSet;
-use lit_node_testnet::node_collection::NodeIdentityKey;
+use crate::node_collection::NodeIdentityKey;
 use lit_rust_crypto::k256;
 use lit_sdk::UrlPrefix;
 
@@ -99,7 +99,8 @@ Expiration Time: {expiration_datetime}"
 
 #[tokio::test]
 async fn test_generate_authsig() {
-    super::setup_logging();
+    use std::str::FromStr;
+    use tracing::error;
 
     unsafe {
         std::env::set_var("LIT_CONFIG_FILE", "./config/test/lit_sig_cfg.toml");
@@ -193,7 +194,7 @@ pub fn get_auth_sig_with_payment_resources(
         sig.to_string(),
         "web3.eth.personal.sign".to_string(),
         siwe_message.to_string(),
-        encoding::bytes_to_hex(delegator_wallet.address()),
+        bytes_to_hex(delegator_wallet.address()),
         None,
     )
 }
@@ -253,7 +254,7 @@ pub fn get_auth_sig_for_session_sig(
         sig.expect("Could not parse sig").to_string(),
         "web3.eth.personal.sign".to_string(),
         siwe_message.to_string(),
-        encoding::bytes_to_hex(wallet.address()),
+        bytes_to_hex(wallet.address()),
         None,
     )
 }
@@ -269,7 +270,7 @@ pub fn get_session_sigs_for_auth(
     // Generate ed25519 keypair for signing.
     let signing_key = ed25519_dalek::SigningKey::generate(&mut rand::rngs::OsRng);
     let verifying_key = signing_key.verifying_key();
-    let session_pub_key = encoding::bytes_to_hex(verifying_key.to_bytes());
+    let session_pub_key = bytes_to_hex(verifying_key.to_bytes());
 
     // Sign SIWE first using the local wallet.
     let auth_sig = get_auth_sig_for_session_sig(
@@ -409,7 +410,7 @@ pub async fn get_session_delegation_sig_for_pkp(
         serialized_signature,
         "lit.bls".to_string(),
         one_response_with_share.siwe_message.clone(),
-        encoding::bytes_to_hex(eth_address),
+        bytes_to_hex(eth_address),
         Some("LIT_BLS".to_string()),
     ))
 }
@@ -430,7 +431,7 @@ pub async fn get_session_sigs_and_node_set_for_pkp(
     // Generate ed25519 keypair for signing.
     let signing_key = ed25519_dalek::SigningKey::generate(&mut rand::rngs::OsRng);
     let verifying_key = signing_key.verifying_key();
-    let session_pub_key = encoding::bytes_to_hex(verifying_key.to_bytes());
+    let session_pub_key = bytes_to_hex(verifying_key.to_bytes());
 
     let pkp_owner_auth_sig = generate_authsig(&auth_sig_wallet).await?;