From cae21da31ff795cc21ec19288fcdc5fdb8a713c7 Mon Sep 17 00:00:00 2001
From: Owen Jacobson <owen@grimoire.ca>
Date: Wed, 4 Sep 2024 12:13:54 -0400
Subject: Allow any login to create channels.

---
 src/channel/routes.rs | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)
 create mode 100644 src/channel/routes.rs

(limited to 'src/channel/routes.rs')

diff --git a/src/channel/routes.rs b/src/channel/routes.rs
new file mode 100644
index 0000000..c8d6c3f
--- /dev/null
+++ b/src/channel/routes.rs
@@ -0,0 +1,32 @@
+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("/"))
+}
-- 
cgit v1.2.3