karyons jsonrpc implementation

1 files changed, 61 insertions, 0 deletions

diff --git a/jsonrpc/src/lib.rs b/jsonrpc/src/lib.rs
new file mode 100644
index 0000000..8a547d9
--- /dev/null
+++ b/jsonrpc/src/lib.rs
@@ -0,0 +1,61 @@
+//! A fast and lightweight async [JSONRPC 2.0](https://www.jsonrpc.org/specification) implementation.
+//!
+//! # Example
+//!
+//! ```
+//! use std::sync::Arc;
+//!
+//! use serde_json::Value;
+//!
+//! use karyons_jsonrpc::{JsonRPCError, Server, Client, register_service};
+//!
+//! struct HelloWorld {}
+//!
+//! impl HelloWorld {
+//!     async fn say_hello(&self, params: Value) -> Result<Value, JsonRPCError> {
+//!         let msg: String = serde_json::from_value(params)?;
+//!         Ok(serde_json::json!(format!("Hello {msg}!")))
+//!     }
+//! }
+//!
+//! // Server
+//! async {
+//!     let ex = Arc::new(smol::Executor::new());
+//!
+//!     // Creates a new server
+//!     let endpoint = "tcp://127.0.0.1:60000".parse().unwrap();
+//!     let server = Server::new_with_endpoint(&endpoint, ex.clone()).await.unwrap();
+//!
+//!     // Register the HelloWorld service
+//!     register_service!(HelloWorld, say_hello);
+//!     server.attach_service(HelloWorld{});
+//!
+//!     // Starts the server
+//!     ex.run(server.start());
+//! };
+//!
+//! // Client
+//! async {
+//!
+//!     // Creates a new client
+//!     let endpoint = "tcp://127.0.0.1:60000".parse().unwrap();
+//!     let client = Client::new_with_endpoint(&endpoint, None).await.unwrap();
+//!
+//!     let result: String = client.call("HelloWorld.say_hello", "world".to_string()).await.unwrap();
+//! };
+//!
+//! ```
+
+mod client;
+mod error;
+pub mod message;
+mod server;
+mod utils;
+
+pub const JSONRPC_VERSION: &str = "2.0";
+
+use error::{Error, Result};
+
+pub use client::Client;
+pub use error::Error as JsonRPCError;
+pub use server::{RPCMethod, RPCService, Server};