aboutsummaryrefslogtreecommitdiff
path: root/jsonrpc/src/service.rs
diff options
context:
space:
mode:
Diffstat (limited to 'jsonrpc/src/service.rs')
-rw-r--r--jsonrpc/src/service.rs64
1 files changed, 0 insertions, 64 deletions
diff --git a/jsonrpc/src/service.rs b/jsonrpc/src/service.rs
deleted file mode 100644
index 23a50d9..0000000
--- a/jsonrpc/src/service.rs
+++ /dev/null
@@ -1,64 +0,0 @@
-use std::{future::Future, pin::Pin};
-
-use crate::Result;
-
-/// Represents the RPC method
-pub type RPCMethod<'a> = Box<dyn Fn(serde_json::Value) -> RPCMethodOutput<'a> + Send + 'a>;
-type RPCMethodOutput<'a> =
- Pin<Box<dyn Future<Output = Result<serde_json::Value>> + Send + Sync + 'a>>;
-
-/// Defines the interface for an RPC service.
-pub trait RPCService: Sync + Send {
- fn get_method<'a>(&'a self, name: &'a str) -> Option<RPCMethod>;
- fn name(&self) -> String;
-}
-
-/// Implements the [`RPCService`] trait for a provided type.
-///
-/// # Example
-///
-/// ```
-/// use serde_json::Value;
-///
-/// use karyon_jsonrpc::{JsonRPCError, register_service};
-///
-/// struct Hello {}
-///
-/// impl Hello {
-/// async fn foo(&self, params: Value) -> Result<Value, JsonRPCError> {
-/// Ok(serde_json::json!("foo!"))
-/// }
-///
-/// async fn bar(&self, params: Value) -> Result<Value, JsonRPCError> {
-/// Ok(serde_json::json!("bar!"))
-/// }
-/// }
-///
-/// register_service!(Hello, foo, bar);
-///
-/// ```
-#[macro_export]
-macro_rules! register_service {
- ($t:ty, $($m:ident),*) => {
- impl karyon_jsonrpc::RPCService for $t {
- fn get_method<'a>(
- &'a self,
- name: &'a str
- ) -> Option<karyon_jsonrpc::RPCMethod> {
- match name {
- $(
- stringify!($m) => {
- Some(Box::new(move |params: serde_json::Value| Box::pin(self.$m(params))))
- }
- )*
- _ => None,
- }
-
-
- }
- fn name(&self) -> String{
- stringify!($t).to_string()
- }
- }
- };
-}