]> git.proxmox.com Git - proxmox-backup.git/blob - src/bin/proxmox-backup-api.rs
update to nix 0.14, use code from proxmox:tools
[proxmox-backup.git] / src / bin / proxmox-backup-api.rs
1 //use proxmox_backup::tools;
2 use proxmox_backup::api_schema::router::*;
3 use proxmox_backup::api_schema::config::*;
4 use proxmox_backup::server::rest::*;
5 use proxmox_backup::server;
6 use proxmox_backup::tools::daemon;
7 use proxmox_backup::auth_helpers::*;
8 use proxmox_backup::config;
9
10 use failure::*;
11 use lazy_static::lazy_static;
12 use proxmox::tools::try_block;
13
14 use futures::*;
15 use futures::future::Future;
16
17 use hyper;
18
19 fn main() {
20
21 if let Err(err) = run() {
22 eprintln!("Error: {}", err);
23 std::process::exit(-1);
24 }
25 }
26
27 fn run() -> Result<(), Error> {
28 if let Err(err) = syslog::init(
29 syslog::Facility::LOG_DAEMON,
30 log::LevelFilter::Info,
31 Some("proxmox-backup-api")) {
32 bail!("unable to inititialize syslog - {}", err);
33 }
34
35 server::create_task_log_dirs()?;
36
37 config::create_configdir()?;
38
39 if let Err(err) = generate_auth_key() {
40 bail!("unable to generate auth key - {}", err);
41 }
42 let _ = private_auth_key(); // load with lazy_static
43
44 if let Err(err) = generate_csrf_key() {
45 bail!("unable to generate csrf key - {}", err);
46 }
47 let _ = csrf_secret(); // load with lazy_static
48
49 lazy_static!{
50 static ref ROUTER: Router = proxmox_backup::api2::router();
51 }
52
53 let config = ApiConfig::new(
54 env!("PROXMOX_JSDIR"), &ROUTER, RpcEnvironmentType::PRIVILEGED);
55
56 let rest_server = RestServer::new(config);
57
58 // http server future:
59 let server = daemon::create_daemon(
60 ([127,0,0,1], 82).into(),
61 |listener| {
62 Ok(hyper::Server::builder(listener.incoming())
63 .serve(rest_server)
64 .with_graceful_shutdown(server::shutdown_future())
65 .map_err(|e| eprintln!("server error: {}", e))
66 )
67 },
68 )?;
69
70 daemon::systemd_notify(daemon::SystemdNotify::Ready)?;
71
72 tokio::run(lazy(|| {
73
74 let init_result: Result<(), Error> = try_block!({
75 server::create_task_control_socket()?;
76 server::server_state_init()?;
77 Ok(())
78 });
79
80 if let Err(err) = init_result {
81 eprintln!("unable to start daemon - {}", err);
82 } else {
83 tokio::spawn(server.then(|_| {
84 log::info!("done - exit server");
85 Ok(())
86 }));
87 }
88
89 Ok(())
90 }));
91
92 Ok(())
93 }