Run migrations in the library function only

api/src/lib.rs

@@ -1,3 +1,5 @@
+use utils::run_migrations;
+
 pub mod app_state;
 pub mod auth;
 pub mod db_connection;
@@ -12,6 +14,7 @@ pub mod utils;
 pub enum RustError {
     Ok = 0,
     Error = 1,
+    MigrationError = 2,
 }
 
 #[no_mangle]
@@ -24,6 +27,14 @@ pub extern "C" fn run_server() -> RustError {
 
     // Run the server logic in a blocking thread
     let result = runtime.block_on(async {
+        match run_migrations().await {
+            Ok(_) => (),
+            Err(err) => {
+                // Handle migration errors here (log, convert to RustError)
+                eprintln!("Migration error: {:?}", err);
+                return RustError::MigrationError;
+            }
+        };
         match server::server_start().await {
             Ok(_) => RustError::Ok,
             Err(err) => {
@@ -34,8 +45,5 @@ pub extern "C" fn run_server() -> RustError {
         }
     });
 
-    // Free the runtime resources
-    drop(runtime);
-
     result
 }

api/src/server.rs

@@ -8,10 +8,7 @@ use tower_http::{
     services::ServeDir,
 };
 
-use crate::{
-    app_state,
-    utils::{copy_database_if_not_exists /* run_migrations */},
-};
+use crate::{app_state, utils::copy_database_if_not_exists};
 
 use super::modbus_register::routes::modbus_register_routes;
 use super::user::routes::user_routes;
@@ -49,8 +46,6 @@ pub async fn server_start() -> Result<(), Box<dyn Error>> {
 
     copy_database_if_not_exists()?;
 
-    // run_migrations().await?;
-
     let app = create_app().await?;
 
     let server_port = env::var("PORT").unwrap_or_else(|_| "9103".to_string());