From 96c6f2154007649c32fa5c29e04bb686df00dfff Mon Sep 17 00:00:00 2001 From: "Matthias P. Braendli" Date: Mon, 1 Jan 2024 23:05:29 +0100 Subject: Create scaffolding --- src/main.rs | 128 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 128 insertions(+) create mode 100644 src/main.rs (limited to 'src') diff --git a/src/main.rs b/src/main.rs new file mode 100644 index 0000000..1850e66 --- /dev/null +++ b/src/main.rs @@ -0,0 +1,128 @@ +use std::sync::{Arc, Mutex}; +use serde::Deserialize; +use askama::Template; +use axum::{ + extract::State, + routing::get, + Router, + response::Html, + Form, +}; +use sqlx::{Connection, SqliteConnection}; +use tower_http::services::ServeDir; + +struct AppState { + callsign : String, + db : Mutex +} + +type SharedState = Arc; + +#[tokio::main] +async fn main() -> std::io::Result<()> { + let mut conn = SqliteConnection::connect("sqlite:cats-radio-node.db").await.unwrap(); + sqlx::migrate!() + .run(&mut conn) + .await + .expect("could not run SQLx migrations"); + + let callsign = "HB9EGM-0".to_owned(); + + let shared_state = Arc::new(AppState { + callsign, + db: Mutex::new(conn) + }); + + let app = Router::new() + .route("/", get(dashboard)) + .route("/form", get(show_form).post(accept_form)) + .nest_service("/static", ServeDir::new("static")) + /* requires tracing and tower, e.g. + * tower = { version = "0.4", features = ["util", "timeout"] } + * tower-http = { version = "0.5.0", features = ["add-extension", "trace"] } + * tracing = "0.1" + * tracing-subscriber = { version = "0.3", features = ["env-filter"] } + .layer( + ServiceBuilder::new() + .layer(HandleErrorLayer::new(|error: BoxError| async move { + if error.is::() { + Ok(StatusCode::REQUEST_TIMEOUT) + } else { + Err(( + StatusCode::INTERNAL_SERVER_ERROR, + format!("Unhandled internal error: {error}"), + )) + } + })) + .timeout(Duration::from_secs(10)) + .layer(TraceLayer::new_for_http()) + .into_inner(), + )*/ + .with_state(shared_state); + + let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap(); + axum::serve(listener, app).await.unwrap(); + Ok(()) +} + +#[derive(PartialEq)] +enum ActivePage { + Dashboard, + Incoming, + Send, +} + +#[derive(Template)] +#[template(path = "dashboard.html")] +struct DashboardTemplate<'a> { + title: &'a str, + page: ActivePage, + callsign: String, +} + +async fn dashboard( + State(state): State, + ) -> DashboardTemplate<'static> { + DashboardTemplate { + title: "Dashboard", + callsign: state.callsign.clone(), + page: ActivePage::Dashboard, + } +} + +async fn show_form() -> Html<&'static str> { + Html( + r#" + + + + + + + + "#, + ) +} + +#[derive(Deserialize, Debug)] +#[allow(dead_code)] +struct Input { + name: String, + email: String, +} + +async fn accept_form(Form(input): Form) { + dbg!(&input); +} -- cgit v1.2.3