diff options
Diffstat (limited to 'mumctl/src/main.rs')
| -rw-r--r-- | mumctl/src/main.rs | 32 |
1 files changed, 31 insertions, 1 deletions
diff --git a/mumctl/src/main.rs b/mumctl/src/main.rs index e7a11a9..403447f 100644 --- a/mumctl/src/main.rs +++ b/mumctl/src/main.rs @@ -1,3 +1,33 @@ +use ipc_channel::ipc::{self, IpcReceiver, IpcSender}; +use log::*; +use mumlib::command::{Command, CommandResponse}; +use mumlib::setup_logger; +use std::fs; + fn main() { - println!("Hello, world!"); + setup_logger(); + + // MUMCTL + //temp send command and channel to listener + debug!("Creating channel"); + let (tx_client, rx_client): (IpcSender<Result<Option<CommandResponse>, ()>>, + IpcReceiver<Result<Option<CommandResponse>, ()>>) = ipc::channel().unwrap(); + + let server_name = fs::read_to_string("/var/tmp/mumd-oneshot").unwrap(); //TODO don't panic + debug!("Connecting to mumd at {}", server_name); + let tx0 = IpcSender::connect(server_name).unwrap(); + let connect_command = Command::ServerConnect { + host: "10.0.0.10".to_string(), + port: 64738u16, + username: "gustav-mumd".to_string(), + accept_invalid_cert: true, + }; + debug!("Sending {:?} to mumd", connect_command); + tx0.send(( + connect_command, + tx_client)) .unwrap(); + + debug!("Reading response"); + let response = rx_client.recv().unwrap(); + debug!("{:?}", response); } |
