48 lines
1.3 KiB
TypeScript
48 lines
1.3 KiB
TypeScript
import { Table } from 'console-table-printer'
|
|
import { getMigrations, readMigrationFiles } from 'payload/database'
|
|
|
|
import type { PostgresAdapter } from './types.js'
|
|
|
|
import { migrationTableExists } from './utilities/migrationTableExists.js'
|
|
|
|
export async function migrateStatus(this: PostgresAdapter): Promise<void> {
|
|
const { payload } = this
|
|
const migrationFiles = await readMigrationFiles({ payload })
|
|
|
|
payload.logger.debug({
|
|
msg: `Found ${migrationFiles.length} migration files.`,
|
|
})
|
|
|
|
let existingMigrations = []
|
|
const hasMigrationTable = await migrationTableExists(this.drizzle)
|
|
|
|
if (hasMigrationTable) {
|
|
;({ existingMigrations } = await getMigrations({ payload }))
|
|
}
|
|
|
|
if (!migrationFiles.length) {
|
|
payload.logger.info({ msg: 'No migrations found.' })
|
|
return
|
|
}
|
|
|
|
// Compare migration files to existing migrations
|
|
const statuses = migrationFiles.map((migration) => {
|
|
const existingMigration = existingMigrations.find((m) => m.name === migration.name)
|
|
return {
|
|
Name: migration.name,
|
|
// eslint-disable-next-line perfectionist/sort-objects
|
|
Batch: existingMigration?.batch,
|
|
Ran: existingMigration ? 'Yes' : 'No',
|
|
}
|
|
})
|
|
|
|
const p = new Table()
|
|
|
|
statuses.forEach((s) => {
|
|
p.addRow(s, {
|
|
color: s.Ran === 'Yes' ? 'green' : 'red',
|
|
})
|
|
})
|
|
p.printTable()
|
|
}
|