use axum::{
    extract::{Form, State},
    response::{IntoResponse, Redirect},
    routing::post,
    Router,
};
use sqlx::sqlite::SqlitePool;

use super::repo::Provider as _;
use crate::{error::InternalError, login::repo::logins::Login};

pub fn router() -> Router<SqlitePool> {
    Router::new().route("/create", post(on_create))
}

#[derive(serde::Deserialize)]
struct CreateRequest {
    name: String,
}

async fn on_create(
    State(db): State<SqlitePool>,
    login: Login,
    Form(form): Form<CreateRequest>,
) -> Result<impl IntoResponse, InternalError> {
    let mut tx = db.begin().await?;
    let channel = tx.channels().create(&form.name).await?;
    tx.channels().join(&channel.id, &login.id).await?;
    tx.commit().await?;

    Ok(Redirect::to("/"))
}