aboutsummaryrefslogtreecommitdiffstats
path: root/mumctl/src
diff options
context:
space:
mode:
Diffstat (limited to 'mumctl/src')
-rw-r--r--mumctl/src/main.rs32
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);
}