tsk-61: code formatting

.gitea/workflows/workflow.yml

@@ -76,7 +76,6 @@ jobs:
           SECRET_KEY: ${{ secrets.TOKEN_SECRET_KEY }}
           # Make SSH agent available if tests fetch private dependencies
           SSH_AUTH_SOCK: ${{ env.SSH_AUTH_SOCK }}
-          ENABLE_REGISTRATION: 'TRUE'
         run: |
           mkdir -p ~/.ssh
           echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/icarus_models_deploy_key

Cargo.lock

@@ -748,7 +748,7 @@ dependencies = [
 
 [[package]]
 name = "icarus_auth"
-version = "0.6.4"
+version = "0.6.2"
 dependencies = [
  "argon2",
  "axum",

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "icarus_auth"
-version = "0.6.4"
+version = "0.6.2"
 edition = "2024"
 rust-version = "1.90"
 

src/db/init.rs

@@ -1,20 +0,0 @@
-use sqlx::postgres::PgPoolOptions;
-
-pub async fn create_pool() -> Result<sqlx::PgPool, sqlx::Error> {
-    let database_url = icarus_envy::environment::get_db_url().await.value;
-    println!("Database url: {database_url}");
-
-    PgPoolOptions::new()
-        .max_connections(super::connection_settings::MAXCONN)
-        .connect(&database_url)
-        .await
-}
-
-pub async fn migrations(pool: &sqlx::PgPool) {
-    // Run migrations using the sqlx::migrate! macro
-    // Assumes your migrations are in a ./migrations folder relative to Cargo.toml
-    sqlx::migrate!("./migrations")
-        .run(pool)
-        .await
-        .expect("Failed to run migrations");
-}

src/db/mod.rs

@@ -1,5 +0,0 @@
-pub mod init;
-
-mod connection_settings {
-    pub const MAXCONN: u32 = 5;
-}

src/lib.rs

@@ -0,0 +1,36 @@
+// TODO: Get rid of this file and place the code in more appropriate places
+pub mod callers;
+pub mod config;
+pub mod hashing;
+pub mod repo;
+pub mod token_stuff;
+
+mod connection_settings {
+    pub const MAXCONN: u32 = 5;
+}
+
+pub mod db {
+
+    use sqlx::postgres::PgPoolOptions;
+
+    use crate::connection_settings;
+
+    pub async fn create_pool() -> Result<sqlx::PgPool, sqlx::Error> {
+        let database_url = icarus_envy::environment::get_db_url().await.value;
+        println!("Database url: {database_url}");
+
+        PgPoolOptions::new()
+            .max_connections(connection_settings::MAXCONN)
+            .connect(&database_url)
+            .await
+    }
+
+    pub async fn migrations(pool: &sqlx::PgPool) {
+        // Run migrations using the sqlx::migrate! macro
+        // Assumes your migrations are in a ./migrations folder relative to Cargo.toml
+        sqlx::migrate!("./migrations")
+            .run(pool)
+            .await
+            .expect("Failed to run migrations");
+    }
+}

src/main.rs

@@ -1,9 +1,5 @@
-pub mod callers;
+use icarus_auth::callers;
-pub mod config;
+use icarus_auth::config;
-pub mod db;
-pub mod hashing;
-pub mod repo;
-pub mod token_stuff;
 
 #[tokio::main]
 async fn main() {
@@ -25,7 +21,7 @@ mod init {
     };
     use utoipa::OpenApi;
 
-    use super::callers;
+    use crate::callers;
     use callers::common as common_callers;
     use callers::login as login_caller;
     use callers::register as register_caller;
@@ -128,11 +124,11 @@ mod init {
     }
 
     pub async fn app() -> Router {
-        let pool = super::db::init::create_pool()
+        let pool = icarus_auth::db::create_pool()
             .await
             .expect("Failed to create pool");
 
-        super::db::init::migrations(&pool).await;
+        icarus_auth::db::migrations(&pool).await;
 
         routes()
             .await
@@ -220,8 +216,8 @@ mod tests {
         }
     }
 
-    fn get_test_register_request() -> callers::register::request::Request {
+    fn get_test_register_request() -> icarus_auth::callers::register::request::Request {
-        callers::register::request::Request {
+        icarus_auth::callers::register::request::Request {
             username: String::from("somethingsss"),
             password: String::from("Raindown!"),
             email: String::from("dev@null.com"),
@@ -231,7 +227,9 @@ mod tests {
         }
     }
 
-    fn get_test_register_payload(usr: &callers::register::request::Request) -> serde_json::Value {
+    fn get_test_register_payload(
+        usr: &icarus_auth::callers::register::request::Request,
+    ) -> serde_json::Value {
         json!({
             "username": &usr.username,
             "password": &usr.password,
@@ -247,7 +245,7 @@ mod tests {
 
         pub async fn register(
             app: &axum::Router,
-            usr: &super::callers::register::request::Request,
+            usr: &icarus_auth::callers::register::request::Request,
         ) -> Result<axum::response::Response, std::convert::Infallible> {
             let payload = super::get_test_register_payload(&usr);
             let req = axum::http::Request::builder()
@@ -300,7 +298,7 @@ mod tests {
 
         let pool = db_mgr::connect_to_db(&db_name).await.unwrap();
 
-        db::init::migrations(&pool).await;
+        icarus_auth::db::migrations(&pool).await;
 
         let app = init::routes().await.layer(axum::Extension(pool));
 
@@ -357,7 +355,7 @@ mod tests {
 
         let pool = db_mgr::connect_to_db(&db_name).await.unwrap();
 
-        db::init::migrations(&pool).await;
+        icarus_auth::db::migrations(&pool).await;
 
         let app = init::routes().await.layer(axum::Extension(pool));
 
@@ -445,7 +443,7 @@ mod tests {
 
         let pool = db_mgr::connect_to_db(&db_name).await.unwrap();
 
-        db::init::migrations(&pool).await;
+        icarus_auth::db::migrations(&pool).await;
 
         let app = init::routes().await.layer(axum::Extension(pool));
         let passphrase =
@@ -499,13 +497,13 @@ mod tests {
 
         let pool = db_mgr::connect_to_db(&db_name).await.unwrap();
 
-        db::init::migrations(&pool).await;
+        icarus_auth::db::migrations(&pool).await;
 
         let app = init::routes().await.layer(axum::Extension(pool));
         let id = uuid::Uuid::parse_str("22f9c775-cce9-457a-a147-9dafbb801f61").unwrap();
         let key = icarus_envy::environment::get_secret_key().await.value;
 
-        match token_stuff::create_service_token(&key, &id) {
+        match icarus_auth::token_stuff::create_service_token(&key, &id) {
             Ok((token, _expire)) => {
                 let payload = serde_json::json!({
                     "access_token": token