kawari/src/bin/kawari-web.rs

use std::net::SocketAddr;

use axum::{
    Json,
    Router, routing::get,
    extract::Form
};
use serde::{Deserialize, Serialize};
use axum::response::{Html, Redirect};
use axum::routing::post;
use kawari::config::{Config, get_config};
use minijinja::{Environment, context};
use kawari::setup_default_environment;

#[derive(Debug, Clone, Serialize, Deserialize)]
struct GateStatus {
    status: i32,
}

async fn root() -> Html<String> {
    let config = get_config();

    let environment = setup_default_environment();
    let template = environment.get_template("web.html").unwrap();
    Html(template.render(context! { }).unwrap())
}

async fn login() -> Html<String> {
    let config = get_config();

    let environment = setup_default_environment();
    let template = environment.get_template("login.html").unwrap();
    Html(template.render(context! { }).unwrap())
}

async fn register() -> Html<String> {
    let config = get_config();

    let environment = setup_default_environment();
    let template = environment.get_template("register.html").unwrap();
    Html(template.render(context! {  }).unwrap())
}

async fn world_status() -> Html<String> {
    let config = get_config();

    let environment = setup_default_environment();
    let template = environment.get_template("worldstatus.html").unwrap();
    Html(template.render(context! { login_open => config.login_open, worlds_open => config.worlds_open }).unwrap())
}

#[derive(Deserialize, Debug)]
#[allow(dead_code)]
struct Input {
    gate_open: Option<String>,
}

async fn apply(Form(input): Form<Input>) -> Redirect {
    tracing::info!("Apply config changes...");

    let mut config = get_config();

    serde_json::to_writer(
        &std::fs::File::create("config.json").unwrap(),
        &config,
    )
        .expect("TODO: panic message");

    Redirect::to("/")
}

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt::init();

    let app = Router::new()
        .route("/", get(root))
        .route("/login", get(login))
        .route("/register", get(register))
        .route("/worldstatus", get(world_status))
        .route("/apply", post(apply));

    let addr = SocketAddr::from(([127, 0, 0, 1], 5801));
    tracing::info!("Web server started on {}", addr);
    axum::Server::bind(&addr)
        .serve(app.into_make_service())
        .await
        .unwrap();
}