use axum::{
    routing::{get, post, put, delete, patch},
    Router,
};
use axum_extra::extract::cookie::Key;
use sqlx::AnyPool;
use std::sync::Arc;
use std::collections::HashMap;
use tokio::sync::Mutex;
use yrs_axum::broadcast::BroadcastGroup;
use tower_http::services::{ServeDir, ServeFile};
use tower_http::trace::TraceLayer;
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

mod admin;
mod api_keys;
mod auth;
mod compiler;
mod db;
mod desktop;
mod docs;
mod folders;
mod files;
mod handlers;
mod models;
mod packages;
mod public_api;
mod setup;
mod spaces;
mod world;
mod collab;

use compiler::TypstCompiler;
use handlers::{compile_handler, export_handler, yjs_handler};

pub type RateLimiterMap = Arc<Mutex<HashMap<String, (u32, std::time::Instant)>>>;

#[derive(Clone)]
pub struct AppState {
    pub compiler: Arc<Mutex<TypstCompiler>>,
    pub bcast_map: Arc<Mutex<HashMap<String, Arc<BroadcastGroup>>>>,
    pub db: AnyPool,
    pub key: Key,
    pub registration_enabled: bool,
    pub rate_limiter: RateLimiterMap,
}

impl axum::extract::FromRef<AppState> for Key {
    fn from_ref(state: &AppState) -> Self {
        state.key.clone()
    }
}

#[tokio::main]
async fn main() {
    tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| "server=debug,tower_http=debug".into()),
        )
        .with(tracing_subscriber::fmt::layer())
        .init();

    tracing::info!("Starting TypstDrive Server");

    let db = db::init_db().await;

    
    let key = match std::env::var("COOKIE_SECRET") {
        Ok(secret) => {
            let bytes = secret.as_bytes();
            if bytes.len() < 64 {
                tracing::warn!("COOKIE_SECRET is shorter than 64 bytes; sessions will not persist across restarts");
                Key::generate()
            } else {
                Key::from(bytes)
            }
        }
        Err(_) => {
            tracing::warn!("COOKIE_SECRET not set; generating a random key. Sessions will be invalidated on restart.");
            Key::generate()
        }
    };

    let registration_enabled = std::env::var("ALLOW_REGISTRATION")
        .map(|v| v.to_lowercase() != "false")
        .unwrap_or(true);

    let state = AppState {
        compiler: Arc::new(Mutex::new(TypstCompiler::new())),
        bcast_map: Arc::new(Mutex::new(HashMap::new())),
        db,
        key,
        registration_enabled,
        rate_limiter: Arc::new(Mutex::new(HashMap::new())),
    };

    let api_routes = Router::new()
        .route("/setup", get(setup::setup_status).post(setup::run_setup))
        .route("/admin/users", get(admin::list_users).post(admin::create_user))
        .route("/admin/users/{id}", patch(admin::update_user).delete(admin::delete_user))
        .route("/compile", post(compile_handler))
        .route("/export/{format}", post(export_handler))
        .route("/export/pandoc/{format}", post(handlers::pandoc_export_handler))
        .route("/import/pandoc", post(handlers::pandoc_import_handler))
        .route("/lsp/{id}", get(handlers::lsp_handler))
        .route("/auth/register", post(auth::register))
        .route("/auth/login", post(auth::login))
        .route("/auth/logout", post(auth::logout))
        .route("/auth/me", get(auth::me).put(auth::update_profile))
        .route("/auth/storage", get(auth::storage_stats))
        .route("/auth/change-password", put(auth::change_password))
        .route("/folders", get(folders::list_folders).post(folders::create_folder))
        .route("/folders/{id}", delete(folders::delete_folder).patch(folders::update_folder))
        .route("/fonts", get(files::list_fonts))
        .route("/files", get(files::list_files).post(files::upload_file_global))
        .route("/files/{id}", delete(files::delete_file).patch(files::update_file))
        .route("/files/{id}/data", get(files::get_file_data))
        .route("/docs/shared", get(docs::list_shared_documents))
        .route("/docs", get(docs::list_documents).post(docs::create_document))
        .route("/docs/accept-invite", get(collab::accept_invite))
        .route("/docs/{id}", get(docs::get_document).delete(docs::delete_document).patch(docs::update_document))
        .route("/docs/{id}/files", post(docs::upload_file))
        .route("/docs/{id}/collaborators", get(collab::list_collaborators))
        .route("/docs/{id}/collaborators/{collab_id}", delete(collab::remove_collaborator))
        .route("/docs/{id}/invite", post(collab::invite_collaborator))
        .route("/docs/{id}/comments", get(collab::get_comments).post(collab::add_comment))
        .route("/docs/{id}/versions", get(collab::get_versions).post(collab::create_version))
        .route("/comments/{id}", patch(collab::update_comment).delete(collab::delete_comment))
        .route("/keys", get(api_keys::list_keys).post(api_keys::create_key))
        .route("/keys/usage", get(api_keys::get_aggregate_usage))
        .route("/keys/{id}", delete(api_keys::delete_key))
        .route("/keys/{id}/regenerate", post(api_keys::regenerate_key))
        .route("/spaces/shared", get(spaces::list_shared_spaces))
        .route("/spaces", get(spaces::list_spaces).post(spaces::create_space))
        .route("/spaces/{id}", get(spaces::get_space).delete(spaces::delete_space).patch(spaces::update_space))
        .route("/spaces/{id}/files", get(spaces::list_space_files).post(spaces::create_space_file))
        .route("/spaces/{id}/files/upload", post(spaces::upload_space_file))
        .route("/spaces/{id}/files/{fid}", get(spaces::get_space_file).patch(spaces::update_space_file).delete(spaces::delete_space_file))
        .route("/packages", get(packages::list_packages))
        .route("/packages/publish", post(packages::publish_package))
        .route("/packages/{name}", get(packages::list_versions).delete(packages::delete_package));

    let desktop_routes = Router::new()
        .route("/auth/login", post(desktop::login))
        .route("/auth/logout", post(desktop::logout))
        .route("/auth/me", get(desktop::me))
        .route("/spaces", get(desktop::list_spaces).post(desktop::create_space))
        .route("/spaces/{id}", get(desktop::pull_space).delete(desktop::delete_space))
        .route("/spaces/{id}/manifest", get(desktop::get_manifest))
        .route("/folders", get(desktop::list_folders))
        .route("/documents", get(desktop::list_documents))
        .route("/documents/{id}", get(desktop::pull_document).put(desktop::push_document))
        .route("/shared", get(desktop::list_shared))
        .route("/files", get(desktop::list_account_files))
        .route("/files/{id}", get(desktop::pull_account_file))
        .route("/spaces/{id}/file", get(desktop::pull_file).put(desktop::push_file).delete(desktop::delete_file));

    let v1_routes = Router::new()
        .route("/render", post(public_api::render_handler));

    let yjs_routes = Router::new()
        .route("/{id}", get(yjs_handler));

    let static_dir = std::env::var("STATIC_DIR").unwrap_or_else(|_| "../build".to_string());

    let app = Router::new()
        .nest("/api", api_routes.nest("/desktop", desktop_routes).layer(TraceLayer::new_for_http()))
        .nest("/v1", v1_routes.layer(TraceLayer::new_for_http()))
        .nest("/yjs", yjs_routes.layer(TraceLayer::new_for_http()))
        .fallback_service(ServeDir::new(&static_dir).fallback(ServeFile::new(format!("{}/index.html", static_dir))))
        .with_state(state);

    let port = std::env::var("PORT").unwrap_or_else(|_| "3000".to_string());
    let addr = format!("0.0.0.0:{}", port);
    let listener = tokio::net::TcpListener::bind(&addr)
        .await
        .unwrap();
    tracing::info!("Server listening on http://{}", addr);
    axum::serve(listener, app).await.unwrap();
}