libsalmo/workflows/
migrate.rs

1use crate::{salmo_contex::SalmoContext, backend::MigrationStatus};
2
3pub fn run_migrations(ctx: &SalmoContext) -> anyhow::Result<()> {
4    let commits = ctx.commits()?;
5    let migrations_registry = ctx.migrations()?;
6    let committed_migrations = commits.commits.iter().map(|c| migrations_registry.db[&c.id].clone()).collect::<Vec<_>>();
7    for env in ctx.environments.iter() {
8        let mut backend = env.backend()?;
9        let to_be_executed = backend.migration_status(&commits, &committed_migrations)?.into_iter()
10            .filter(|m| matches!(m.status, MigrationStatus::Committed { tried: _ } ))
11            .collect::<Vec<_>>();
12        backend.execute_migrations(&to_be_executed)?;
13    }
14    Ok(())
15}