workflow-rpc 0.18.0

Workflow RPC (wRPC) framework based on the workflow-websocket crate offering native & in-browser (WASM32) clients and a native server (based on tokio & tungstenite). wRPC supports custom Borsh and JSON protocols with use of generics for RPC method declarations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

//! Module containing RPC [`Method`] closure wrappers
use crate::imports::*;

/// Base trait representing an RPC method, used to retain
/// method structures in an [`Interface`](super::Interface)
/// map without generics.
#[async_trait]
pub(crate) trait MethodTrait<ServerContext, ConnectionContext>:
    Send + Sync + 'static
{
    async fn call_with_borsh(
        &self,
        server_ctx: ServerContext,
        connection_ctx: ConnectionContext,
        data: &[u8],
    ) -> ServerResult<Vec<u8>>;
    async fn call_with_serde_json(
        &self,
        server_ctx: ServerContext,
        connection_ctx: ConnectionContext,
        value: Value,
    ) -> ServerResult<Value>;
}

/// RPC method function type
pub type MethodFn<ServerContext, ConnectionContext, Req, Resp> = Arc<
    Box<
        dyn Send
            + Sync
            + Fn(ServerContext, ConnectionContext, Req) -> MethodFnReturn<Resp>
            + 'static,
    >,
>;

/// RPC method function return type
pub type MethodFnReturn<T> = Pin<Box<(dyn Send + 'static + Future<Output = ServerResult<T>>)>>;

/// RPC method wrapper. Contains the method closure function.
pub struct Method<ServerContext, ConnectionContext, Req, Resp>
where
    ServerContext: Send + Sync + 'static,
    Req: MsgT,
    Resp: MsgT,
{
    method: MethodFn<ServerContext, ConnectionContext, Req, Resp>,
}

impl<ServerContext, ConnectionContext, Req, Resp>
    Method<ServerContext, ConnectionContext, Req, Resp>
where
    ServerContext: Send + Sync + 'static,
    Req: MsgT,
    Resp: MsgT,
{
    pub fn new<FN>(method_fn: FN) -> Method<ServerContext, ConnectionContext, Req, Resp>
    where
        FN: Send
            + Sync
            + Fn(ServerContext, ConnectionContext, Req) -> MethodFnReturn<Resp>
            + 'static,
    {
        Method {
            method: Arc::new(Box::new(method_fn)),
        }
    }
}

#[async_trait]
impl<ServerContext, ConnectionContext, Req, Resp> MethodTrait<ServerContext, ConnectionContext>
    for Method<ServerContext, ConnectionContext, Req, Resp>
where
    ServerContext: Clone + Send + Sync + 'static,
    ConnectionContext: Clone + Send + Sync + 'static,
    Req: MsgT,
    Resp: MsgT,
{
    async fn call_with_borsh(
        &self,
        server_ctx: ServerContext,
        connection_ctx: ConnectionContext,
        data: &[u8],
    ) -> ServerResult<Vec<u8>> {
        let req = Req::try_from_slice(data)?;
        let resp = (self.method)(server_ctx, connection_ctx, req).await;
        let vec = borsh::to_vec(&resp)?;
        Ok(vec)
    }

    async fn call_with_serde_json(
        &self,
        server_ctx: ServerContext,
        connection_ctx: ConnectionContext,
        value: Value,
    ) -> ServerResult<Value> {
        let req: Req = serde_json::from_value(value).map_err(|_| ServerError::ReqDeserialize)?;
        let resp = (self.method)(server_ctx, connection_ctx, req).await?;
        Ok(serde_json::to_value(resp).map_err(|_| ServerError::RespSerialize)?)
    }
}