kent/consciousness
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

delete dead code: channel-test, mcp-schema, cmd_mcp_schema

Browse source 
channel-test was a debug tool, mcp-schema was superseded by
consciousness-mcp, cmd_mcp_schema in cli/misc.rs was the old
poc-memory subcommand.

Co-Developed-By: Kent Overstreet <kent.overstreet@linux.dev>
This commit is contained in:
ProofOfConcept 2026-04-03 20:52:40 -04:00
parent 2208e68b4f
commit 61deb7d488
5 changed files with 2 additions and 158 deletions
Download patch file Download diff file Expand all files Collapse all files

80
src/bin/channel-test.rs
View file

@ -1,80 +0,0 @@
// channel-test — quick RPC test tool for channel daemons
//
// Usage: channel-test <socket-path> [list|recv|send <channel> <msg>]
use capnp_rpc::{rpc_twoparty_capnp, twoparty, RpcSystem};
use futures::AsyncReadExt;
use tokio::net::UnixStream;
use tokio_util::compat::TokioAsyncReadCompatExt;
use poc_memory::channel_capnp::channel_server;
#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let args: Vec<String> = std::env::args().collect();
if args.len() < 2 {
eprintln!("usage: channel-test <socket-path> [list|recv <channel>|send <channel> <msg>]");
std::process::exit(1);
}
let sock_path = args[1].clone();
let cmd = args.get(2).cloned().unwrap_or_else(|| "list".to_string());
let arg3 = args.get(3).cloned().unwrap_or_default();
let arg_rest: String = args.iter().skip(4).cloned().collect::<Vec<_>>().join(" ");
tokio::task::LocalSet::new()
.run_until(async move {
let stream = UnixStream::connect(&sock_path).await?;
let (reader, writer) = stream.compat().split();
let rpc_network = Box::new(twoparty::VatNetwork::new(
futures::io::BufReader::new(reader),
futures::io::BufWriter::new(writer),
rpc_twoparty_capnp::Side::Client,
Default::default(),
));
let mut rpc_system = RpcSystem::new(rpc_network, None);
let client: channel_server::Client =
rpc_system.bootstrap(rpc_twoparty_capnp::Side::Server);
tokio::task::spawn_local(rpc_system);
match cmd.as_str() {
"list" => {
let reply = client.list_request().send().promise.await?;
let channels = reply.get()?.get_channels()?;
println!("{} channels:", channels.len());
for ch in channels.iter() {
let name = ch.get_name()?.to_str()?;
let connected = ch.get_connected();
let unread = ch.get_unread();
println!(" {} connected={} unread={}", name, connected, unread);
}
}
"recv" => {
let mut req = client.recv_request();
req.get().set_channel(&arg3);
req.get().set_all_new(true);
req.get().set_min_count(20);
let reply = req.send().promise.await?;
let text = reply.get()?.get_text()?.to_str()?;
if text.is_empty() {
println!("(no messages)");
} else {
println!("{}", text);
}
}
"send" => {
let mut req = client.send_request();
req.get().set_channel(&arg3);
req.get().set_message(&arg_rest);
req.send().promise.await?;
println!("sent to {}", arg3);
}
_ => {
eprintln!("unknown command: {}", cmd);
}
}
Ok::<(), Box<dyn std::error::Error>>(())
})
.await
}