3 files changed, 23 insertions, 4 deletions
diff --git a/src/channel/app.rs b/src/channel/app.rs
new file mode 100644
index 0000000..84822cb
--- /dev/null
+++ b/src/channel/app.rs
@@ -0,0 +1,21 @@
+use sqlx::sqlite::SqlitePool;
+
+use super::repo::Provider as _;
+use crate::error::BoxedError;
+
+pub struct Channels<'a> {
+    db: &'a SqlitePool,
+}
+
+impl<'a> Channels<'a> {
+    pub fn new(db: &'a SqlitePool) -> Self {
+        Self { db }
+    }
+
+    pub async fn create(&self, name: &str) -> Result<(), BoxedError> {
+        let mut tx = self.db.begin().await?;
+        tx.channels().create(name).await?;
+        tx.commit().await?;
+        Ok(())
+    }
+}
diff --git a/src/channel/mod.rs b/src/channel/mod.rs
index 238e116..f67ea04 100644
--- a/src/channel/mod.rs
+++ b/src/channel/mod.rs
@@ -1,3 +1,4 @@
+pub mod app;
 pub mod repo;
 mod routes;
 
diff --git a/src/channel/routes.rs b/src/channel/routes.rs
index 6e06cc9..864f1b3 100644
--- a/src/channel/routes.rs
+++ b/src/channel/routes.rs
@@ -5,7 +5,6 @@ use axum::{
     Router,
 };
 
-use super::repo::Provider as _;
 use crate::{app::App, error::InternalError, login::repo::logins::Login};
 
 pub fn router() -> Router<App> {
@@ -22,9 +21,7 @@ async fn on_create(
     _: Login, // requires auth, but doesn't actually care who you are
     Form(form): Form<CreateRequest>,
 ) -> Result<impl IntoResponse, InternalError> {
-    let mut tx = app.db.begin().await?;
-    tx.channels().create(&form.name).await?;
-    tx.commit().await?;
+    app.channels().create(&form.name).await?;
 
     Ok(Redirect::to("/"))
 }