github/directus
1
1
Fork 0
mirror of https://github.com/directus/directus.git synced 2026-04-25 03:00:53 -04:00
Code Issues Packages Projects Releases Wiki Activity

Load cjs custom migrations (#18385)

Browse Source
This commit is contained in:
Brainslug
2023-05-02 21:10:19 +02:00
committed by GitHub
parent 80bcc35af3
commit 1fba5ebf94
3 changed files with 23 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
api/src/database/migrations/run.ts
View File

@@ -9,6 +9,7 @@ import { flushCaches } from '../../cache.js';
import env from '../../env.js';
import logger from '../../logger.js';
import type { Migration } from '../../types/index.js';
import getModuleDefault from '../../utils/get-module-default.js';
const __dirname = dirname(fileURLToPath(import.meta.url));
@@ -21,7 +22,8 @@ export default async function run(database: Knex, direction: 'up' | 'down' | 'la
((await fse.pathExists(customMigrationsPath)) && (await fse.readdir(customMigrationsPath))) || [];
migrationFiles = migrationFiles.filter((file: string) => /^[0-9]+[A-Z]-[^.]+\.(?:js|ts)$/.test(file));
customMigrationFiles = customMigrationFiles.filter((file: string) => file.endsWith('.js'));
customMigrationFiles = customMigrationFiles.filter((file: string) => /\.(c|m)?js$/.test(file));
const completedMigrations = await database.select<Migration[]>('*').from('directus_migrations').orderBy('version');
@@ -113,7 +115,7 @@ export default async function run(database: Knex, direction: 'up' | 'down' | 'la
for (const migration of migrations) {
if (migration.completed === false) {
needsCacheFlush = true;
const { up } = await import(`file://${migration.file}`);
const { up } = getModuleDefault(await import(`file://${migration.file}`));
if (log) {
logger.info(`Applying ${migration.name}...`);