Infrastructure/zipline
1
Fork 0
Code Issues Pull requests Activity

fix: add a "skip" for fresh db's (#274)

Browse source 
* fix: add a "skip" for fresh db's

* fix: trimming

* fix: elevate logging!
This commit is contained in:
Jayvin Hernandez 2023-01-26 12:46:10 -08:00 committed by GitHub
parent c1a23faf1f
commit 55bd72aef8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 31 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
src/server/util.ts
View file

@ -10,10 +10,10 @@ export async function migrations() {
const logger = Logger.get('database::migrations'); const logger = Logger.get('database::migrations');
try { try {
logger.debug('establishing database connection'); logger.info('establishing database connection');
const migrate = new Migrate('./prisma/schema.prisma'); const migrate = new Migrate('./prisma/schema.prisma');
logger.debug('ensuring database exists, if not creating database - may error if no permissions'); logger.info('ensuring database exists, if not creating database - may error if no permissions');
await ensureDatabaseExists('apply', './prisma/schema.prisma'); await ensureDatabaseExists('apply', './prisma/schema.prisma');
const diagnose = await migrate.diagnoseMigrationHistory({ const diagnose = await migrate.diagnoseMigrationHistory({
@ -21,16 +21,39 @@ export async function migrations() {
}); });
if (diagnose.history?.diagnostic === 'databaseIsBehind') { if (diagnose.history?.diagnostic === 'databaseIsBehind') {
logger.debug('database is behind, attempting to migrate'); if (!diagnose.hasMigrationsTable) {
try { logger.debug('no migrations table found, attempting schema push');
logger.debug('migrating database'); try {
await migrate.applyMigrations(); logger.debug('pushing schema');
} finally { const migration = await migrate.push({ force: false });
if (migration.unexecutable && migration.unexecutable.length > 0)
throw new Error('This database is not empty, schema push is not possible.');
} catch (e) {
migrate.stop();
logger.error('failed to push schema');
throw e;
}
logger.debug('finished pushing schema, marking migrations as applied');
for (const migration of diagnose.history.unappliedMigrationNames) {
await migrate.markMigrationApplied({ migrationId: migration });
}
migrate.stop();
logger.info('finished migrating database');
} else if (diagnose.hasMigrationsTable) {
logger.debug('database is behind, attempting to migrate');
try {
logger.debug('migrating database');
await migrate.applyMigrations();
} catch (e) {
logger.error('failed to migrate database');
migrate.stop();
throw e;
}
migrate.stop(); migrate.stop();
logger.info('finished migrating database'); logger.info('finished migrating database');
} }
} else { } else {
logger.debug('exiting migrations engine - database is up to date'); logger.info('exiting migrations engine - database is up to date');
migrate.stop(); migrate.stop();
} }
} catch (error) { } catch (error) {