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

Cargo.toml

@@ -15,6 +15,7 @@ members = [
   "./crates/primitives",
   "./crates/runtime",
   "./crates/sdk",
+  "./crates/sdk/libs/near",
   "./crates/sdk/macros",
   "./crates/server",
   "./crates/server-primitives",
@@ -47,6 +48,7 @@ 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"
@@ -68,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" }

apps/only-peers/src/lib.rs

@@ -43,6 +43,17 @@ pub enum Event<'a> {
 
 #[app::logic]
 impl OnlyPeers {
+    pub fn foo(&mut self) -> String {
+        let client = calimero_sdk_near::Client::testnet();
+        match client.view_account(
+            "nearkat.testnet",
+            calimero_sdk_near::types::BlockId::Height(166710735),
+        ) {
+            Ok(r) => format!("{}", r.amount),
+            Err(e) => e,
+        }
+    }
+
     pub fn post(&self, id: usize) -> Option<&Post> {
         env::log(&format!("Getting post with id: {:?}", id));
 

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/examples/fetch.rs

@@ -24,7 +24,7 @@ fn main() -> eyre::Result<()> {
     let cx = logic::VMContext {
         input: serde_json::to_vec(&json!({}))?,
     };
-    let get_outcome = run(file, "fetch", cx, &mut storage, &limits)?;
+    let get_outcome = run(file, "foo", cx, &mut storage, &limits)?;
     let returns = String::from_utf8(get_outcome.returns.unwrap().unwrap()).unwrap();
     println!("{returns}");
 

crates/runtime/src/errors.rs

@@ -86,6 +86,8 @@ pub enum HostError {
     EventKindSizeOverflow,
     #[error("event data size overflow")]
     EventDataSizeOverflow,
+    #[error("failed to fetch data from {url} with error: {error}")]
+    FetchError { url: String, error: String },
 }
 
 #[derive(Debug, Serialize)]

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,16 @@
+[package]
+name = "calimero-sdk-near"
+version = "0.1.0"
+authors.workspace = true
+edition.workspace = true
+repository.workspace = true
+license.workspace = true
+
+[dependencies]
+serde = { workspace = true, features = ["derive"] }
+serde_json.workspace = true
+serde_with = {workspace = true, features = ["base64"]}
+
+calimero-sdk = { path = "../../" }
+calimero-primitives = { path = "../../../primitives" }
+

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

@@ -0,0 +1,63 @@
+use calimero_sdk::env;
+use serde::de::DeserializeOwned;
+use serde::{Deserialize, Serialize};
+
+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>, String> {
+        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: method.to_string(),
+            params,
+        })
+        .map_err(|err| format!("Cannot serialize request: {:?}", err))?;
+
+        let response = unsafe { env::ext::fetch(&self.url, "POST", &headers, &body) }?;
+        serde_json::from_slice::<Response<T, E>>(&response)
+            .map_err(|e| format!("Failed to parse response: {}", e.to_string(),))
+    }
+}
+
+#[derive(Debug, Clone, Serialize)]
+pub struct Request<P: Serialize> {
+    pub jsonrpc: &'static str,
+    pub id: String,
+    pub method: String,
+
+    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>,
+}