uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2024-12-18 22:21:50 +03:00
Code Issues Packages Projects Releases Wiki Activity

Format Rust code using rustfmt

Browse Source
This commit is contained in:
github-actions[bot] 2023-12-26 01:26:58 +00:00 committed by GitHub
parent 0dce0f81ed
commit 19a2a996d2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
src/eth/provider.rs
View File

@ -1,19 +1,19 @@
use crate::http::types::HttpServerAction;
use crate::eth::types::EthRpcAction; use crate::eth::types::EthRpcAction;
use crate::http::types::HttpServerAction;
use crate::types::*; use crate::types::*;
use anyhow::Result; use anyhow::Result;
use ethers::core::types::Filter; use ethers::core::types::Filter;
use ethers::prelude::Provider; use ethers::prelude::Provider;
use ethers::types::{ValueOrArray, U256, U64}; use ethers::types::{ValueOrArray, U256, U64};
use ethers_providers::{Middleware, StreamExt, Ws}; use ethers_providers::{Middleware, StreamExt, Ws};
use futures::SinkExt;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use serde_json::json; use serde_json::json;
use std::collections::HashMap; use std::collections::HashMap;
use tokio_tungstenite::WebSocketStream;
use tokio_tungstenite::connect_async;
use futures::SinkExt;
use std::future::Future; use std::future::Future;
use std::pin::Pin; use std::pin::Pin;
use tokio_tungstenite::connect_async;
use tokio_tungstenite::WebSocketStream;
use url::Url; use url::Url;
pub async fn provider( pub async fn provider(
@ -75,20 +75,27 @@ pub async fn provider(
Ok(()) Ok(())
} }
async fn get_dispatch(rpc_url: String, send_to_loop: MessageSender) -> Box<dyn Fn(EthRpcAction) -> Pin<Box<dyn Future<Output = ()> + Send >>> { async fn get_dispatch(
rpc_url: String,
send_to_loop: MessageSender,
) -> Box<dyn Fn(EthRpcAction) -> Pin<Box<dyn Future<Output = ()> + Send>>> {
let parsed = Url::parse(&rpc_url).unwrap(); let parsed = Url::parse(&rpc_url).unwrap();
match parsed.scheme() { match parsed.scheme() {
"http" | "https" => { unreachable!() } "http" | "https" => {
"ws" | "wss" => { return ws_dispatch(rpc_url.clone(), send_to_loop).await } unreachable!()
_ => { unreachable!() } }
"ws" | "wss" => return ws_dispatch(rpc_url.clone(), send_to_loop).await,
_ => {
unreachable!()
}
} }
} }
async fn ws_dispatch(rpc_url: String, send_to_loop: MessageSender) -> Box<dyn Fn(EthRpcAction) -> Pin<Box<dyn Future<Output = ()> + Send >>> { async fn ws_dispatch(
rpc_url: String,
send_to_loop: MessageSender,
) -> Box<dyn Fn(EthRpcAction) -> Pin<Box<dyn Future<Output = ()> + Send>>> {
let provider = Provider::<Ws>::connect(&rpc_url).await; let provider = Provider::<Ws>::connect(&rpc_url).await;
Box::new(move |action| { Box::new(move |action| {
@ -97,12 +104,14 @@ async fn ws_dispatch(rpc_url: String, send_to_loop: MessageSender) -> Box<dyn Fn
Box::pin(async move { Box::pin(async move {
match action { match action {
EthRpcAction::JsonRpcRequest(json) => { EthRpcAction::JsonRpcRequest(json) => {
let (mut ws_stream, _) = connect_async(&rpc_url).await.expect("failed to connect"); let (mut ws_stream, _) =
ws_stream.send(tokio_tungstenite::tungstenite::Message::Text(json)).await.unwrap(); connect_async(&rpc_url).await.expect("failed to connect");
ws_stream
.send(tokio_tungstenite::tungstenite::Message::Text(json))
.await
.unwrap();
while let Some(msg) = ws_stream.next().await { while let Some(msg) = ws_stream.next().await {}
};
} }
EthRpcAction::Eth(method) => {} EthRpcAction::Eth(method) => {}
EthRpcAction::Debug(method) => {} EthRpcAction::Debug(method) => {}