From a6016c7eeb11fc8aeaa1a3b160b970b15362695d Mon Sep 17 00:00:00 2001
From: hozan23 <hozan23@karyontech.net>
Date: Sun, 19 May 2024 22:20:03 +0200
Subject: add tokio examples to p2p, jsonrpc, and net crates

---
 jsonrpc/examples/tokio_server/src/main.rs | 58 +++++++++++++++++++++++++++++++
 1 file changed, 58 insertions(+)
 create mode 100644 jsonrpc/examples/tokio_server/src/main.rs

(limited to 'jsonrpc/examples/tokio_server/src/main.rs')

diff --git a/jsonrpc/examples/tokio_server/src/main.rs b/jsonrpc/examples/tokio_server/src/main.rs
new file mode 100644
index 0000000..978c90a
--- /dev/null
+++ b/jsonrpc/examples/tokio_server/src/main.rs
@@ -0,0 +1,58 @@
+use serde::{Deserialize, Serialize};
+use serde_json::Value;
+
+use karyon_jsonrpc::{rpc_impl, Error, Server};
+
+struct Calc {
+    version: String,
+}
+
+#[derive(Deserialize, Serialize)]
+struct Req {
+    x: u32,
+    y: u32,
+}
+
+#[derive(Deserialize, Serialize)]
+struct Pong {}
+
+#[rpc_impl]
+impl Calc {
+    async fn ping(&self, _params: Value) -> Result<Value, Error> {
+        Ok(serde_json::json!(Pong {}))
+    }
+
+    async fn add(&self, params: Value) -> Result<Value, Error> {
+        let params: Req = serde_json::from_value(params)?;
+        Ok(serde_json::json!(params.x + params.y))
+    }
+
+    async fn sub(&self, params: Value) -> Result<Value, Error> {
+        let params: Req = serde_json::from_value(params)?;
+        Ok(serde_json::json!(params.x - params.y))
+    }
+
+    async fn version(&self, _params: Value) -> Result<Value, Error> {
+        Ok(serde_json::json!(self.version))
+    }
+}
+
+#[tokio::main]
+async fn main() {
+    env_logger::init();
+    // Register the Calc service
+    let calc = Calc {
+        version: String::from("0.1"),
+    };
+
+    // Creates a new server
+    let server = Server::builder("tcp://127.0.0.1:6000")
+        .expect("Create a new server builder")
+        .service(calc)
+        .build()
+        .await
+        .expect("start a new server");
+
+    // Start the server
+    server.start().await.unwrap();
+}
-- 
cgit v1.2.3