Add a common crate

backend/src/main.rs

@@ -0,0 +1,100 @@
+extern crate actix_web;
+extern crate listenfd;
+extern crate askama;
+
+use listenfd::ListenFd;
+use actix_files as fs;
+use actix_web::{web, middleware, App, HttpServer, HttpResponse, Result, web::Query};
+use askama::Template;
+
+use std::io::prelude::*;
+use ron::de::from_reader;
+use serde::Deserialize;
+use std::{fs::File, env::args};
+
+use itertools::Itertools;
+
+mod consts;
+
+#[derive(Template)]
+#[template(path = "main.html")]
+struct MainTemplate<'a> {
+    test: &'a str,
+}
+
+#[derive(Deserialize)]
+pub struct Request {
+   m: Option<String>
+}
+
+fn main_page(query: Query<Request>) -> Result<HttpResponse> {
+
+    let main_template = MainTemplate { test: &"test" };
+
+    let s = main_template.render().unwrap();
+    Ok(HttpResponse::Ok().content_type("text/html").body(s))
+}
+
+#[derive(Debug, Deserialize)]
+struct Config {
+    port: u16
+}
+
+fn get_exe_name() -> String {
+    let first_arg = std::env::args().nth(0).unwrap();
+    let sep: &[_] = &['\\', '/'];
+    first_arg[first_arg.rfind(sep).unwrap()+1..].to_string()
+}
+
+fn main() -> std::io::Result<()> {
+    if process_args() { return Ok(()) }
+
+    println!("Starting RUP as web server...");
+
+    let config: Config = {
+        let f = File::open(consts::FILE_CONF).unwrap_or_else(|_| panic!("Failed to open configuration file {}", consts::FILE_CONF));
+        match from_reader(f) {
+            Ok(c) => c,
+            Err(e) => panic!("Failed to load config: {}", e)
+        }
+    };
+
+    println!("Configuration: {:?}", config);
+
+    let mut listenfd = ListenFd::from_env();
+    let mut server =
+        HttpServer::new(
+            || {
+                App::new()
+                    .wrap(middleware::Compress::default())
+                    .wrap(middleware::Logger::default())
+                    .service(web::resource("/").to(main_page))
+                    .service(fs::Files::new("/static", "static").show_files_listing())
+            }
+        );
+
+    server =
+        if let Some(l) = listenfd.take_tcp_listener(0).unwrap() {
+            server.listen(l).unwrap()
+        } else {
+            server.bind(&format!("0.0.0.0:{}", config.port)).unwrap()
+        };
+
+    server.run()
+}
+
+fn process_args() -> bool {
+    fn print_usage() {
+        println!("Usage:");
+        println!(" {} [--help]", get_exe_name());
+    }
+
+    let args: Vec<String> = args().collect();
+
+    if args.iter().any(|arg| arg == "--help") {
+        print_usage();
+        return true
+    }
+
+    false
+}