// Copyright 2019-2021 Parity Technologies (UK) Ltd. // // Permission is hereby granted, free of charge, to any // person obtaining a copy of this software and associated // documentation files (the "Software"), to deal in the // Software without restriction, including without // limitation the rights to use, copy, modify, merge, // publish, distribute, sublicense, and/or sell copies of // the Software, and to permit persons to whom the Software // is furnished to do so, subject to the following // conditions: // // The above copyright notice and this permission notice // shall be included in all copies or substantial portions // of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF // ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED // TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A // PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT // SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY // CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR // IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER // DEALINGS IN THE SOFTWARE. use std::net::SocketAddr; use jsonrpsee::core::{async_trait, client::Subscription, Error}; use jsonrpsee::proc_macros::rpc; use jsonrpsee::types::SubscriptionResult; use jsonrpsee::ws_client::WsClientBuilder; use jsonrpsee::ws_server::{SubscriptionSink, WsServerBuilder, WsServerHandle}; type ExampleHash = [u8; 32]; type ExampleStorageKey = Vec; #[rpc(server, client, namespace = "state")] pub trait Rpc where Hash: std::fmt::Debug, { /// Async method call example. #[method(name = "getKeys")] async fn storage_keys(&self, storage_key: StorageKey, hash: Option) -> Result, Error>; /// Subscription that takes a `StorageKey` as input and produces a `Vec`. #[subscription(name = "subscribeStorage" => "override", item = Vec)] fn subscribe_storage(&self, keys: Option>); } pub struct RpcServerImpl; #[async_trait] impl RpcServer for RpcServerImpl { async fn storage_keys( &self, storage_key: ExampleStorageKey, _hash: Option, ) -> Result, Error> { Ok(vec![storage_key]) } // Note that the server's subscription method must return `SubscriptionResult`. fn subscribe_storage( &self, mut sink: SubscriptionSink, _keys: Option>, ) -> SubscriptionResult { let _ = sink.send(&vec![[0; 32]]); Ok(()) } } #[tokio::main] async fn main() -> anyhow::Result<()> { tracing_subscriber::FmtSubscriber::builder() .with_env_filter(tracing_subscriber::EnvFilter::from_default_env()) .try_init() .expect("setting default subscriber failed"); let (server_addr, _handle) = run_server().await?; let url = format!("ws://{}", server_addr); let client = WsClientBuilder::default().build(&url).await?; assert_eq!(client.storage_keys(vec![1, 2, 3, 4], None::).await.unwrap(), vec![vec![1, 2, 3, 4]]); let mut sub: Subscription> = RpcClient::::subscribe_storage(&client, None).await.unwrap(); assert_eq!(Some(vec![[0; 32]]), sub.next().await.transpose().unwrap()); Ok(()) } async fn run_server() -> anyhow::Result<(SocketAddr, WsServerHandle)> { let server = WsServerBuilder::default().build("127.0.0.1:0").await?; let addr = server.local_addr()?; let handle = server.start(RpcServerImpl.into_rpc())?; Ok((addr, handle)) }