diff --git a/rpc-toolkit-macro-internals/src/command/build.rs b/rpc-toolkit-macro-internals/src/command/build.rs index 1b40b47..75bbed0 100644 --- a/rpc-toolkit-macro-internals/src/command/build.rs +++ b/rpc-toolkit-macro-internals/src/command/build.rs @@ -1,14 +1,14 @@ -use super::parse::*; -use super::*; +use std::collections::HashSet; + use proc_macro2::*; use quote::*; -use std::collections::HashSet; -use syn::{ - fold::Fold, - punctuated::Punctuated, - spanned::Spanned, - token::{Comma, Where}, -}; +use syn::fold::Fold; +use syn::punctuated::Punctuated; +use syn::spanned::Spanned; +use syn::token::{Comma, Where}; + +use super::parse::*; +use super::*; fn build_app(name: LitStr, opt: &mut Options, params: &mut [ParamType]) -> TokenStream { let about = opt.common().about.clone().into_iter(); diff --git a/rpc-toolkit-macro-internals/src/command/parse.rs b/rpc-toolkit-macro-internals/src/command/parse.rs index ff0300a..a376931 100644 --- a/rpc-toolkit-macro-internals/src/command/parse.rs +++ b/rpc-toolkit-macro-internals/src/command/parse.rs @@ -1,6 +1,7 @@ -use super::*; use syn::spanned::Spanned; +use super::*; + pub fn parse_command_attr(args: AttributeArgs) -> Result { let mut opt = Options::Leaf(Default::default()); for arg in args { diff --git a/rpc-toolkit-macro-internals/src/lib.rs b/rpc-toolkit-macro-internals/src/lib.rs index 71facb6..79597f0 100644 --- a/rpc-toolkit-macro-internals/src/lib.rs +++ b/rpc-toolkit-macro-internals/src/lib.rs @@ -15,4 +15,4 @@ pub use command::build::build as build_command; pub use rpc_server::build::build as build_rpc_server; pub use rpc_server::RpcServerArgs; pub use run_cli::build::build as build_run_cli; -pub use run_cli::RunCliArgs; \ No newline at end of file +pub use run_cli::RunCliArgs; diff --git a/rpc-toolkit-macro-internals/src/rpc_server/build.rs b/rpc-toolkit-macro-internals/src/rpc_server/build.rs index aa66403..525e477 100644 --- a/rpc-toolkit-macro-internals/src/rpc_server/build.rs +++ b/rpc-toolkit-macro-internals/src/rpc_server/build.rs @@ -1,8 +1,9 @@ -use super::*; use proc_macro2::TokenStream; use quote::quote; use syn::spanned::Spanned; +use super::*; + pub fn build(args: RpcServerArgs) -> TokenStream { let mut command = args.command; let arguments = std::mem::replace( diff --git a/rpc-toolkit-macro-internals/src/rpc_server/parse.rs b/rpc-toolkit-macro-internals/src/rpc_server/parse.rs index 7947997..ef9e0a8 100644 --- a/rpc-toolkit-macro-internals/src/rpc_server/parse.rs +++ b/rpc-toolkit-macro-internals/src/rpc_server/parse.rs @@ -1,6 +1,7 @@ -use super::*; use syn::parse::{Parse, ParseStream}; +use super::*; + impl Parse for RpcServerArgs { fn parse(input: ParseStream) -> Result { let command = input.parse()?; diff --git a/rpc-toolkit-macro-internals/src/run_cli/build.rs b/rpc-toolkit-macro-internals/src/run_cli/build.rs index c50eabd..b33922c 100644 --- a/rpc-toolkit-macro-internals/src/run_cli/build.rs +++ b/rpc-toolkit-macro-internals/src/run_cli/build.rs @@ -1,8 +1,9 @@ -use super::*; use proc_macro2::TokenStream; use quote::quote; use syn::spanned::Spanned; +use super::*; + pub fn build(args: RunCliArgs) -> TokenStream { let mut command_handler = args.command.clone(); let mut arguments = std::mem::replace( diff --git a/rpc-toolkit-macro-internals/src/run_cli/parse.rs b/rpc-toolkit-macro-internals/src/run_cli/parse.rs index 23de053..b693d21 100644 --- a/rpc-toolkit-macro-internals/src/run_cli/parse.rs +++ b/rpc-toolkit-macro-internals/src/run_cli/parse.rs @@ -1,6 +1,7 @@ -use super::*; use syn::parse::{Parse, ParseStream}; +use super::*; + impl Parse for MakeSeed { fn parse(input: ParseStream) -> Result { let matches_ident = input.parse()?; diff --git a/rpc-toolkit/src/command_helpers.rs b/rpc-toolkit/src/command_helpers.rs index 002579c..a4c43bc 100644 --- a/rpc-toolkit/src/command_helpers.rs +++ b/rpc-toolkit/src/command_helpers.rs @@ -1,5 +1,7 @@ +use std::fmt::Display; +use std::io::Stdin; +use std::marker::PhantomData; use std::str::FromStr; -use std::{fmt::Display, io::Stdin, marker::PhantomData}; use clap::ArgMatches; use hyper::Method; @@ -10,18 +12,21 @@ use yajrc::{GenericRpcMethod, Id, RpcError, RpcRequest, RpcResponse}; use crate::Context; pub mod prelude { + pub use std::borrow::Cow; + pub use std::marker::PhantomData; + + pub use clap::{App, AppSettings, Arg, ArgMatches}; + pub use serde::{Deserialize, Serialize}; + pub use serde_json::{from_value, to_value, Value}; + pub use tokio::runtime::Runtime; + pub use tokio::task::spawn_blocking; + pub use yajrc::{self, RpcError}; + pub use super::{ call_remote, default_arg_parser, default_display, default_stdin_parser, make_phantom, match_types, }; pub use crate::Context; - pub use clap::{App, AppSettings, Arg, ArgMatches}; - pub use serde::{Deserialize, Serialize}; - pub use serde_json::{from_value, to_value, Value}; - pub use std::borrow::Cow; - pub use std::marker::PhantomData; - pub use tokio::{runtime::Runtime, task::spawn_blocking}; - pub use yajrc::{self, RpcError}; } #[derive(Debug, Error)] diff --git a/rpc-toolkit/src/rpc_server_helpers.rs b/rpc-toolkit/src/rpc_server_helpers.rs index 7453136..df20a2b 100644 --- a/rpc-toolkit/src/rpc_server_helpers.rs +++ b/rpc-toolkit/src/rpc_server_helpers.rs @@ -1,17 +1,17 @@ use std::marker::PhantomData; -use crate::SeedableContext; -use hyper::{ - body::Buf, - server::{conn::AddrIncoming, Builder, Server}, - Body, Request, Response, StatusCode, -}; +use hyper::body::Buf; +use hyper::server::conn::AddrIncoming; +use hyper::server::{Builder, Server}; +use hyper::{Body, Request, Response, StatusCode}; use lazy_static::lazy_static; use serde::Deserialize; use serde_json::Value; use url::Host; use yajrc::{AnyRpcMethod, GenericRpcMethod, Id, RpcError, RpcRequest, RpcResponse}; +use crate::SeedableContext; + lazy_static! { #[cfg(feature = "cbor")] static ref CBOR_INTERNAL_ERROR: Vec = diff --git a/rpc-toolkit/src/test.rs b/rpc-toolkit/src/test.rs index e92da66..62abcb1 100644 --- a/rpc-toolkit/src/test.rs +++ b/rpc-toolkit/src/test.rs @@ -1,13 +1,16 @@ -pub use crate as rpc_toolkit; -use crate::{command, rpc_server, Context, SeedableContext}; +use std::fmt::Display; +use std::str::FromStr; +use std::sync::Arc; + use clap::Arg; use rpc_toolkit_macro::run_cli; use serde::{Deserialize, Serialize}; -use std::str::FromStr; -use std::{fmt::Display, sync::Arc}; use url::Host; use yajrc::RpcError; +pub use crate as rpc_toolkit; +use crate::{command, rpc_server, Context, SeedableContext}; + pub struct AppState { seed: T, data: U, @@ -93,9 +96,10 @@ fn dothething2 Deserialize<'a> + FromStr, E: Dis #[tokio::test] async fn test() { - use crate as rpc_toolkit; use tokio::io::AsyncWriteExt; + use crate as rpc_toolkit; + let seed = Arc::new(ConfigSeed { host: Host::parse("localhost").unwrap(), port: 8000,