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
100
101
102
103
104
105
106
107
108
109
// use std::path::PathBuf;
// use clap::Parser;
// use futures::Future;
// use rpc_toolkit::{
// AsyncCommand, CliContextSocket, Command, Contains, Context, DynCommand, LeafCommand, NoParent,
// ParentCommand, ParentInfo, Server, ShutdownHandle,
// };
// use serde::{Deserialize, Serialize};
// use tokio::net::UnixStream;
// use yajrc::RpcError;
// struct ServerContext;
// impl Context for ServerContext {
// type Metadata = ();
// }
// struct CliContext(PathBuf);
// impl Context for CliContext {
// type Metadata = ();
// }
// impl CliContextSocket for CliContext {
// type Stream = UnixStream;
// async fn connect(&self) -> std::io::Result<Self::Stream> {
// UnixStream::connect(&self.0).await
// }
// }
// impl rpc_toolkit::CliContext for CliContext {
// async fn call_remote(
// &self,
// method: &str,
// params: imbl_value::Value,
// ) -> Result<imbl_value::Value, RpcError> {
// <Self as CliContextSocket>::call_remote(self, method, params).await
// }
// }
// async fn run_server() {
// Server::new(
// vec![
// DynCommand::from_parent::<Group>(Contains::none()),
// DynCommand::from_async::<Thing1>(Contains::none()),
// // DynCommand::from_async::<Thing2>(Contains::none()),
// // DynCommand::from_sync::<Thing3>(Contains::none()),
// // DynCommand::from_sync::<Thing4>(Contains::none()),
// ],
// || async { Ok(ServerContext) },
// )
// .run_unix("./test.sock", |e| eprintln!("{e}"))
// .unwrap()
// .1
// .await
// }
// #[derive(Debug, Deserialize, Serialize, Parser)]
// struct Group {
// #[arg(short, long)]
// verbose: bool,
// }
// impl Command for Group {
// const NAME: &'static str = "group";
// type Parent = NoParent;
// }
// impl<Ctx> ParentCommand<Ctx> for Group
// where
// Ctx: Context,
// // SubThing: AsyncCommand<Ctx>,
// Thing1: AsyncCommand<Ctx>,
// {
// fn subcommands(chain: rpc_toolkit::ParentChain<Self>) -> Vec<DynCommand<Ctx>> {
// vec![
// // DynCommand::from_async::<SubThing>(chain.child()),
// DynCommand::from_async::<Thing1>(Contains::none()),
// ]
// }
// }
// #[derive(Debug, Deserialize, Serialize, Parser)]
// struct Thing1 {
// thing: String,
// }
// impl Command for Thing1 {
// const NAME: &'static str = "thing1";
// type Parent = NoParent;
// }
// impl LeafCommand<ServerContext> for Thing1 {
// type Ok = String;
// type Err = RpcError;
// fn display(self, _: ServerContext, _: rpc_toolkit::ParentInfo<Self::Parent>, res: Self::Ok) {
// println!("{}", res);
// }
// }
// impl AsyncCommand<ServerContext> for Thing1 {
// async fn implementation(
// self,
// _: ServerContext,
// _: ParentInfo<Self::Parent>,
// ) -> Result<Self::Ok, Self::Err> {
// Ok(format!("Thing1 is {}", self.thing))
// }
// }
// #[tokio::test]
// async fn test() {
// let server = tokio::spawn(run_server());
// }