src/bin/proxmox-backup-api.rs

   1 extern crate proxmox_backup;
   2
   3 use std::sync::Arc;
   4
   5 use proxmox_backup::tools;
   6 use proxmox_backup::api::schema::*;
   7 use proxmox_backup::api::router::*;
   8 use proxmox_backup::api::config::*;
   9 use proxmox_backup::server::rest::*;
  10 use proxmox_backup::getopts;
  11 use proxmox_backup::auth_helpers::*;
  12
  13 use lazy_static::lazy_static;
  14
  15 use futures::future::Future;
  16
  17 use hyper;
  18
  19 fn main() {
  20
  21     if let Err(err) = syslog::init(
  22         syslog::Facility::LOG_DAEMON,
  23         log::LevelFilter::Info,
  24         Some("proxmox-backup-api")) {
  25         eprintln!("unable to inititialize syslog: {}", err);
  26         std::process::exit(-1);
  27     }
  28
  29     if let Err(err) = generate_auth_key() {
  30         eprintln!("unable to generate auth key: {}", err);
  31         std::process::exit(-1);
  32     }
  33
  34     if let Err(err) = generate_csrf_key() {
  35         eprintln!("unable to generate csrf key: {}", err);
  36         std::process::exit(-1);
  37     }
  38
  39     let command : Arc<Schema> = StringSchema::new("Command.")
  40         .format(Arc::new(ApiStringFormat::Enum(vec![
  41             "start".into(),
  42             "status".into(),
  43             "stop".into()
  44         ])))
  45         .into();
  46
  47     let schema = ObjectSchema::new("Parameters.")
  48         .required("command", command);
  49
  50     let args: Vec<String> = std::env::args().skip(1).collect();
  51
  52     let options = match getopts::parse_arguments(&args, &vec!["command"], &schema) {
  53         Ok((options, rest)) => {
  54             if !rest.is_empty() {
  55                 eprintln!("Error: got additional arguments: {:?}", rest);
  56                 std::process::exit(-1);
  57             }
  58             options
  59         }
  60         Err(err) => {
  61             eprintln!("Error: unable to parse arguments:\n{}", err);
  62             std::process::exit(-1);
  63         }
  64     };
  65
  66     let command = options["command"].as_str().unwrap();
  67
  68     match command {
  69         "start" => {
  70             println!("Starting server.");
  71         },
  72         "stop" => {
  73             println!("Stopping server.");
  74             std::process::exit(0);
  75         },
  76         "status" => {
  77             println!("Server status.");
  78              std::process::exit(0);
  79        },
  80         _ => {
  81             eprintln!("got unexpected command {}", command);
  82             std::process::exit(-1);
  83         },
  84     }
  85
  86     let addr = ([127,0,0,1], 82).into();
  87
  88     lazy_static!{
  89        static ref ROUTER: Router = proxmox_backup::api2::router();
  90     }
  91
  92     let config = ApiConfig::new(
  93         "/usr/share/javascript/proxmox-backup", &ROUTER, RpcEnvironmentType::PRIVILEDGED);
  94
  95     let rest_server = RestServer::new(config);
  96
  97     let server = hyper::Server::bind(&addr)
  98         .serve(rest_server)
  99         .map_err(|e| eprintln!("server error: {}", e));
 100
 101
 102     // Run this server for... forever!
 103     hyper::rt::run(server);
 104 }