feat(ext): add app-side library for NEAR

Cargo.toml

@@ -16,6 +16,7 @@ members = [
   "./crates/primitives",
   "./crates/runtime",
   "./crates/sdk",
+  "./crates/sdk/libs/near",
   "./crates/sdk/macros",
   "./crates/server",
   "./crates/server-primitives",
@@ -46,11 +47,13 @@ futures-util = "0.3.30"
 hex = "0.4.3"
 libp2p = "0.53.2"
 libp2p-stream = "0.1.0-alpha.1"
+libp2p-identity = "0.2.9"
 multiaddr = "0.18.1"
 # multibase = "0.9.1"
 near-jsonrpc-client = "0.8.0"
 near-jsonrpc-primitives = "0.20.0"
 near-primitives = "0.20.0"
+near-account-id = "1.0.0"
 near-sdk = "5.0.0"
 near-workspaces = "0.10.0"
 ouroboros = "0.18.3"
@@ -67,6 +70,7 @@ sha3 = "0.10.8"
 semver = "1.0.22"
 serde = "1.0.196"
 serde_json = "1.0.113"
+serde_with = "3.8.1"
 syn = "2.0"
 thiserror = "1.0.56"
 tokio = "1.35.1"

apps/only-peers/Cargo.toml

@@ -11,3 +11,4 @@ crate-type = ["cdylib"]
 
 [dependencies]
 calimero-sdk = { path = "../../crates/sdk" }
+calimero-sdk-near = { path = "../../crates/sdk/libs/near" }

crates/primitives/Cargo.toml

@@ -9,7 +9,7 @@ license.workspace = true
 [dependencies]
 bs58.workspace = true
 ed25519-dalek.workspace = true
-libp2p = { workspace = true, features = ["serde"] }
+libp2p-identity = { workspace = true, features = ["peerid", "serde"] }
 semver = { workspace = true, features = ["serde"] }
 serde = { workspace = true, features = ["derive"] }
 serde_json.workspace = true

crates/primitives/src/common.rs

@@ -1,3 +1,23 @@
+use serde::{Deserialize, Serialize};
+
 pub const fn bool_true() -> bool {
     true
 }
+
+#[derive(Serialize, Deserialize)]
+#[serde(remote = "Result")]
+pub enum ResultAlt<T, E> {
+    #[serde(rename = "result")]
+    Ok(T),
+    #[serde(rename = "error")]
+    Err(E),
+}
+
+impl<T, E> From<ResultAlt<T, E>> for Result<T, E> {
+    fn from(result: ResultAlt<T, E>) -> Self {
+        match result {
+            ResultAlt::Ok(value) => Ok(value),
+            ResultAlt::Err(err) => Err(err),
+        }
+    }
+}

crates/primitives/src/events.rs

@@ -34,7 +34,7 @@ pub struct ExecutedTransactionPayload {
 #[derive(Clone, Serialize, Deserialize, Debug)]
 #[serde(rename_all = "camelCase")]
 pub struct PeerJoinedPayload {
-    pub peer_id: libp2p::PeerId,
+    pub peer_id: libp2p_identity::PeerId,
 }
 
 #[derive(Clone, Serialize, Deserialize, Debug)]

crates/primitives/src/identity.rs

@@ -124,7 +124,7 @@ pub mod serde_signing_key {
 pub mod serde_identity {
     use std::fmt;
 
-    use libp2p::identity::Keypair;
+    use libp2p_identity::Keypair;
     use serde::de::{self, MapAccess};
     use serde::ser::{self, SerializeMap};
     use serde::{Deserializer, Serializer};

crates/runtime/src/logic.rs

@@ -321,7 +321,9 @@ impl<'a> VMHostFunctions<'a> {
         let url = self.get_string(url_ptr, url_len)?;
         let method = self.get_string(method_ptr, method_len)?;
         let headers = self.read_guest_memory(headers_ptr, headers_len)?;
-        let headers: Vec<(String, String)> = borsh::from_slice(&headers).unwrap(); // safety: headers are coming from an inner source. Safe to deserialize.
+
+        // safety: It's not possible to call `fetch` directly by apps. So headers is generated by our code. Safe to deserialize.
+        let headers: Vec<(String, String)> = borsh::from_slice(&headers).unwrap();
         let body = self.read_guest_memory(body_ptr, body_len)?;
         let mut request = ureq::request(&method, &url);
 

crates/sdk/libs/near/Cargo.toml

@@ -0,0 +1,17 @@
+[package]
+name = "calimero-sdk-near"
+version = "0.1.0"
+authors.workspace = true
+edition.workspace = true
+repository.workspace = true
+license.workspace = true
+
+[dependencies]
+near-account-id = { workspace = true, features = ["serde"]}
+serde = { workspace = true, features = ["derive"] }
+serde_json.workspace = true
+serde_with = {workspace = true, features = ["base64"]}
+thiserror.workspace = true
+
+calimero-sdk = { path = "../../" }
+calimero-primitives = { path = "../../../primitives" }

crates/sdk/libs/near/src/error.rs

@@ -0,0 +1,13 @@
+use thiserror::Error;
+
+#[derive(Debug, Error)]
+pub enum NearLibError {
+    #[error(transparent)]
+    JsonError(#[from] serde_json::Error),
+
+    #[error(transparent)]
+    IoError(#[from] std::io::Error),
+
+    #[error("Failed to fetch: {0}")]
+    FetchError(String),
+}

crates/sdk/libs/near/src/jsonrpc.rs

@@ -0,0 +1,64 @@
+use calimero_sdk::env;
+use serde::de::DeserializeOwned;
+use serde::{Deserialize, Serialize};
+
+use crate::error::NearLibError;
+
+pub(crate) struct Client {
+    url: String,
+    id: std::cell::RefCell<u64>,
+}
+
+impl Client {
+    pub fn new(url: String) -> Self {
+        Self {
+            url,
+            id: std::cell::RefCell::new(0),
+        }
+    }
+
+    pub fn call<T: DeserializeOwned, E: DeserializeOwned, P: Serialize>(
+        &self,
+        method: &str,
+        params: P,
+    ) -> Result<Response<T, E>, NearLibError> {
+        let headers = [("Content-Type", "application/json")];
+
+        *self.id.borrow_mut() += 1;
+        let body = serde_json::to_vec(&Request {
+            jsonrpc: "2.0",
+            id: &*self.id.borrow().to_string(),
+            method,
+            params,
+        })?;
+
+        let response = unsafe { env::ext::fetch(&self.url, "POST", &headers, &body) }
+            .map_err(NearLibError::FetchError)?;
+        Ok(serde_json::from_slice::<Response<T, E>>(&response)?)
+    }
+}
+
+#[derive(Debug, Clone, Serialize)]
+struct Request<'a, P: Serialize> {
+    pub jsonrpc: &'a str,
+    pub id: &'a str,
+    pub method: &'a str,
+
+    pub params: P,
+}
+
+#[derive(Debug, Clone, Deserialize)]
+pub struct Response<T: DeserializeOwned, E: DeserializeOwned> {
+    pub jsonrpc: Option<String>,
+    pub id: String,
+
+    #[serde(with = "calimero_primitives::common::ResultAlt", flatten)]
+    pub data: Result<T, RpcError<E>>,
+}
+
+#[derive(Debug, Clone, Deserialize)]
+pub struct RpcError<E> {
+    pub code: i32,
+    pub message: String,
+    pub data: Option<E>,
+}

crates/sdk/libs/near/src/lib.rs

@@ -0,0 +1,40 @@
+use error::NearLibError;
+use jsonrpc::Response;
+
+pub mod error;
+mod jsonrpc;
+pub mod query;
+pub mod types;
+pub mod views;
+
+pub struct Client {
+    client: jsonrpc::Client,
+}
+
+pub trait RpcMethod {
+    type Response: serde::de::DeserializeOwned;
+
+    fn method_name(&self) -> &str;
+    fn params(&self) -> Result<serde_json::Value, std::io::Error>;
+}
+
+impl Client {
+    pub fn testnet() -> Self {
+        Self {
+            client: jsonrpc::Client::new("https://rpc.testnet.near.org/".to_string()),
+        }
+    }
+
+    pub fn mainnet() -> Self {
+        Self {
+            client: jsonrpc::Client::new("https://rpc.mainnet.near.org/".to_string()),
+        }
+    }
+
+    pub fn call<M>(&self, method: M) -> Result<Response<M::Response, String>, NearLibError>
+    where
+        M: RpcMethod,
+    {
+        self.client.call(method.method_name(), &method.params()?)
+    }
+}