1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
use std::env;
use std::sync::Arc;
use axum::{Router, routing::post};
use axum::routing::{get, put};
use sqlx::PgPool;
use time::util::local_offset;
use tokio::sync::mpsc::{self, Sender};
use tracing::{info, level_filters::LevelFilter};
use tracing_subscriber::{EnvFilter, fmt::{self, time::LocalTime}, prelude::*};
use crate::config::SETTINGS;
use crate::db::init_db_pool;
use crate::routes::device::{get_device, post_device, put_device};
use crate::routes::start::start;
use crate::services::ping::ws_ping;
mod auth;
mod config;
mod routes;
mod wol;
mod db;
mod error;
mod services;
#[tokio::main]
async fn main() {
unsafe { local_offset::set_soundness(local_offset::Soundness::Unsound); }
let time_format =
time::macros::format_description!("[year]-[month]-[day] [hour]:[minute]:[second]");
let loc = LocalTime::new(time_format);
tracing_subscriber::registry()
.with(fmt::layer()
.with_timer(loc)
)
.with(
EnvFilter::builder()
.with_default_directive(LevelFilter::INFO.into())
.from_env_lossy(),
)
.init();
let version = env!("CARGO_PKG_VERSION");
info!("start webol v{}", version);
let db = init_db_pool().await;
sqlx::migrate!().run(&db).await.unwrap();
let (tx, mut rx) = mpsc::channel(32);
// FIXME: once_cell? or just static mutable
tokio::spawn( async move {
while let Some(message) = rx.recv().await {
println!("GOT = {}", message);
}
});
let shared_state = Arc::new(AppState { db, ping_send: tx });
let app = Router::new()
.route("/start", post(start))
.route("/device", get(get_device))
.route("/device", put(put_device))
.route("/device", post(post_device))
.route("/status", get(ws_ping))
.with_state(shared_state);
let addr = SETTINGS.get_string("serveraddr").unwrap_or("0.0.0.0:7229".to_string());
info!("start server on {}", addr);
axum::Server::bind(&addr.parse().unwrap())
.serve(app.into_make_service())
.await
.unwrap();
}
pub struct AppState {
db: PgPool,
ping_send: Sender<String>,
// ping_receive: Receiver<String>
}
|
