first test version

1 files changed, 79 insertions, 0 deletions

diff --git a/rust/src/main.rs b/rust/src/main.rs
new file mode 100644
index 0000000..9537bd7
--- /dev/null
+++ b/rust/src/main.rs
@@ -0,0 +1,79 @@
+use std::env;
+use std::collections::HashSet;
+use std::iter::repeat;
+use std::sync::mpsc::channel;
+
+extern crate base64;
+extern crate crypto;
+extern crate civet;
+extern crate conduit;
+extern crate getopts;
+extern crate time;
+extern crate rand;
+
+use civet::{Config, Server};
+use crypto::digest::Digest;
+use crypto::sha1::Sha1;
+use getopts::Options;
+use rand::{thread_rng, Rng};
+
+mod apachelog;
+mod handler;
+mod sendxmpp;
+mod token;
+
+fn print_usage(program: &str, opts: Options) {
+    let brief = format!("Usage: {} [options]", program);
+    print!("{}", opts.usage(&brief));
+}
+
+fn main() {
+    let args: Vec<String> = env::args().collect();
+    let program = args[0].clone();
+    let mut opts = Options::new();
+    opts.optopt("j", "jid", "bot jid", "JID");
+    opts.optopt("p", "password", "bot password", "PASSWORD");
+    opts.optmulti("u", "user", "add valid user", "USER");
+    opts.optopt("s", "secret", "server secret for token generation", "SECRET");
+    opts.optopt("t", "time", "Validity of the token in hours (default 48)", "HOURS");
+    opts.optopt("o", "port", "TCP Port to listen on", "PORT");
+    opts.optflag("h", "help", "print this help menu");
+    let matches = opts.parse(&args[1..]).unwrap_or_else(|f| panic!(f.to_string()));
+
+    if matches.opt_present("h") {
+        print_usage(&program, opts);
+        return;
+    }
+
+    if !(matches.opt_present("j") && matches.opt_present("p")) {
+        print_usage(&program, opts);
+        panic!("Missing jid or password");
+    }
+
+    let mut server_config = Config::new();
+    let usernames = matches.opt_strs("u").into_iter().collect::<HashSet<String>>();
+    let mut hasher = Sha1::new();
+    let mut secret: Vec<u8> = repeat(0).take((hasher.output_bits() + 7) / 8).collect();
+    matches.opt_str("s").and_then(|s| {
+        hasher.input_str(s.as_str());
+        hasher.result(&mut secret);
+        Some(())
+    }).unwrap_or_else(|| {
+        println!("No secret (-s/--secret) given, using random value");
+        thread_rng().fill_bytes(&mut secret);
+    });
+    let validity: i64 = matches.opt_str("t").unwrap_or(String::from("48")).parse()
+        .unwrap_or_else(|_| { panic!("Failed to parse time") });
+    server_config.port(matches.opt_str("o").unwrap_or(String::from("8080")).parse()
+        .unwrap_or_else(|_| { panic!("Failed to parse port number") }));
+
+
+    let handler = handler::AuthHandler::make(matches.opt_str("j").unwrap(),
+                                             matches.opt_str("p").unwrap(),
+                                             usernames,
+                                             time::Duration::hours(validity),
+                                             secret);
+    let _a = Server::start(server_config, handler);
+    let (_tx, rx) = channel::<()>();
+    rx.recv().unwrap();
+}
\ No newline at end of file