spring_sqlx_migration_plugin/
lib.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
use serde::Deserialize;
use spring::async_trait;
use spring::config::{ConfigRegistry, Configurable};
use spring::tracing::{error, info};
use spring::{app::AppBuilder, plugin::Plugin};
use spring_sqlx::ConnectPool;
use sqlx::migrate::Migrator;

pub struct SqlxMigrationPlugin;

#[async_trait]
impl Plugin for SqlxMigrationPlugin {
    async fn build(&self, app: &mut AppBuilder) {
        let Ok(SqlxMigrationConfig { migration_folder }) = app.get_config::<SqlxMigrationConfig>() else {
            error!("SqlxMigrationPlugin require the SqlxConfig");
            return;
        };

        let pool = app.get_component::<ConnectPool>().expect("sqlx connect pool not exists");

        let Ok(migration_path) = std::path::absolute(migration_folder) else {
            error!("Folder not found");
            return;
        };

        let Ok(migrator) = Migrator::new(migration_path).await else {
            error!("SQLX Migration plugin load failed");
            return;
        };

        let count = migrator.iter().count();
        info!("Migrations to run: {count}");

        migrator.iter().for_each(|migration| {
            let description = migration.description.clone();
            let version = migration.version;
            info!("{description} {version}");
        });

        if let Err(error) = migrator.run(&pool).await {
            error!("Ha ocurrido un error! {error}");
        }

    }
}

#[derive(Debug, Configurable, Deserialize)]
#[config_prefix = "sqlx-migration"]
pub struct SqlxMigrationConfig {
    migration_folder: String,
}