2021-02-13 00:39:39 +03:00
|
|
|
use crate::config::Config;
|
2021-02-16 18:11:39 +03:00
|
|
|
use crate::databases::*;
|
2021-02-13 00:39:39 +03:00
|
|
|
use crate::error::{ErrorKind, StdResult};
|
2021-02-18 12:29:09 +03:00
|
|
|
use crate::migration::{
|
|
|
|
filter_pending_migrations, DatabaseMigrationManager, Migration, MigrationManager,
|
|
|
|
};
|
2021-02-13 00:39:39 +03:00
|
|
|
|
|
|
|
const EM_DASH: char = '—';
|
|
|
|
|
|
|
|
pub(crate) fn print_migration_lists(config: Config) -> StdResult<()> {
|
2021-02-18 12:29:09 +03:00
|
|
|
let applied_migration_names = match config.database.connection_string() {
|
2021-02-13 00:39:39 +03:00
|
|
|
Ok(ref database_connection_string) => {
|
2021-02-18 12:29:09 +03:00
|
|
|
let connection_manager = DatabaseConnectionManager::new(&config.database);
|
|
|
|
let conn = connection_manager.connect_with_string(database_connection_string)?;
|
|
|
|
let mut manager = MigrationManager::new(conn);
|
2021-02-15 13:06:09 +03:00
|
|
|
|
|
|
|
let applied_migration_names = manager.applied_migration_names()?;
|
|
|
|
|
|
|
|
show_applied_migrations(&applied_migration_names);
|
|
|
|
|
|
|
|
applied_migration_names
|
2021-02-13 00:39:39 +03:00
|
|
|
}
|
|
|
|
Err(e) if *e.kind() == ErrorKind::MissedEnvVar(String::new()) => {
|
|
|
|
println!("{}", e.kind());
|
|
|
|
println!("No connection to database");
|
|
|
|
|
|
|
|
Vec::new()
|
|
|
|
}
|
2021-02-21 17:53:43 +03:00
|
|
|
Err(e) => panic!("{}", e),
|
2021-02-13 00:39:39 +03:00
|
|
|
};
|
|
|
|
|
|
|
|
println!();
|
|
|
|
|
2021-02-15 13:06:09 +03:00
|
|
|
let pending_migrations =
|
|
|
|
filter_pending_migrations(config.migrations()?, &applied_migration_names);
|
|
|
|
show_pending_migrations(&pending_migrations);
|
|
|
|
|
|
|
|
Ok(())
|
|
|
|
}
|
|
|
|
|
|
|
|
fn show_applied_migrations(applied_migration_names: &[String]) {
|
|
|
|
println!("Applied migrations:");
|
|
|
|
if applied_migration_names.is_empty() {
|
|
|
|
println!("{}", EM_DASH);
|
|
|
|
} else {
|
|
|
|
applied_migration_names
|
|
|
|
.iter()
|
|
|
|
.rev()
|
|
|
|
.for_each(|name| println!("{}", name));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
fn show_pending_migrations(pending_migrations: &[Migration]) {
|
2021-02-13 00:39:39 +03:00
|
|
|
println!("Pending migrations:");
|
|
|
|
if pending_migrations.is_empty() {
|
|
|
|
println!("{}", EM_DASH);
|
|
|
|
} else {
|
|
|
|
pending_migrations.iter().for_each(|m| {
|
|
|
|
println!("{}", m.name());
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|