diff --git a/packages/@nodepack/db-migrator/package.json b/packages/@nodepack/db-migrator/package.json index 4a43bba..10561c6 100644 --- a/packages/@nodepack/db-migrator/package.json +++ b/packages/@nodepack/db-migrator/package.json @@ -25,7 +25,8 @@ "prepublishOnly": "yarn build" }, "dependencies": { - "@nodepack/env-migrator": "^0.8.9" + "@nodepack/env-migrator": "^0.8.9", + "consola": "^2.11.3" }, "devDependencies": { "@nodepack/service": "^0.8.9" diff --git a/packages/@nodepack/db-migrator/src/lib/Migrator.ts b/packages/@nodepack/db-migrator/src/lib/Migrator.ts index 63ee393..701ddee 100644 --- a/packages/@nodepack/db-migrator/src/lib/Migrator.ts +++ b/packages/@nodepack/db-migrator/src/lib/Migrator.ts @@ -1,4 +1,5 @@ import { Migrator as EnvMigrator } from '@nodepack/env-migrator' +import consola from 'consola' export interface FileMigrationRecord { file: string @@ -17,23 +18,32 @@ export class Migrator extends EnvMigrator { * @private */ async readMigrationRecords () { - if (!this.context.readDbMigrationRecords) { - throw new Error(`No 'readDbMigrationRecords' method provided by context`) + try { + if (!this.context.readDbMigrationRecords) { + throw new Error(`No 'readDbMigrationRecords' method provided by context`) + } + const data = await this.context.readDbMigrationRecords() + this.fileMigrationRecords = data.files + } catch (e) { + consola.error('Could not read migration records. Error:', e.stack) + this.fileMigrationRecords = [] } - const data = await this.context.readDbMigrationRecords() - this.fileMigrationRecords = data.files } /** * @private */ async writeMigrationRecords () { - if (!this.context.writeDbMigrationRecords) { - throw new Error(`No 'writeDbMigrationRecords' method provided by context`) + try { + if (!this.context.writeDbMigrationRecords) { + throw new Error(`No 'writeDbMigrationRecords' method provided by context`) + } + await this.context.writeDbMigrationRecords({ + files: this.fileMigrationRecords, + plugins: [], + }) + } catch (e) { + consola.error('Could not write migration records. Error:', e.stack) } - await this.context.writeDbMigrationRecords({ - files: this.fileMigrationRecords, - plugins: [], - }) } }