Reorganize migrations and database stuff

scripts/add_migration.sh

@@ -18,7 +18,7 @@ if [[ -z "$MIGRATION_NAME" ]]; then
     exit 1
 fi
 
-MIGRATIONS_DIR="$PROJECT_ROOT/src/migrations"
+MIGRATIONS_DIR="$PROJECT_ROOT/src/database/migrations"
 
 # echo "MIGRATIONS_DIR: $MIGRATIONS_DIR"
 
@@ -57,9 +57,9 @@ for SUFFIX in "up" "down"; do
     touch "$migration_file"
 done
 
-LINE_TO_INSERT="    migs.add(include_file_migration!($NEXT_MIGRATION, \"$NEXT_MIGRATION_PREFIX-$MIGRATION_NAME\"));"
+LINE_TO_INSERT="\ \ \ \ migs.add(include_file_migration!($NEXT_MIGRATION, \"$NEXT_MIGRATION_PREFIX-$MIGRATION_NAME\"));"
 
-MIGRATIONS_RS="$PROJECT_ROOT/src/db.rs"
+MIGRATIONS_RS="$PROJECT_ROOT/src/database/migrations/mod.rs"
 echo "Inserting line in $MIGRATIONS_RS"
 sed -i "/INSERT MIGRATION ABOVE/i \
 $LINE_TO_INSERT" "$MIGRATIONS_RS"

src/database/migrations/mod.rs

@@ -1,11 +1,11 @@
-use crate::migrations::{Migrations, SimpleMigration};
+use super::migration::{Migrations, SimpleMigration};
 
 macro_rules! include_file_migration {
     ($mig_version:expr, $mig_name:literal) => {
         SimpleMigration::new_box(
             $mig_version,
-            include_str!(concat!("migrations/", $mig_name, "-up.sql")),
-            include_str!(concat!("migrations/", $mig_name, "-down.sql")),
+            include_str!(concat!($mig_name, "-up.sql")),
+            include_str!(concat!($mig_name, "-down.sql")),
         )
     };
 }

src/database/mod.rs

@@ -0,0 +1,5 @@
+mod migration;
+mod migrations;
+
+pub use migration::*;
+pub use migrations::create_migrations;

src/main.rs

@@ -7,8 +7,7 @@ use rusqlite::NO_PARAMS;
 use tracing::info;
 use tracing_subscriber::EnvFilter;
 
-mod db;
-mod migrations;
+mod database;
 mod model;
 mod option_future;
 mod program_runner;
@@ -25,7 +24,7 @@ fn setup_db() -> Result<DbConnection> {
     // let conn = DbConnection::open_in_memory()?;
     let mut conn = DbConnection::open("test.db")?;
 
-    let migs = db::create_migrations();
+    let migs = database::create_migrations();
     migs.apply(&mut conn)?;
 
     Ok(conn)