X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Finitializers%2Fmigrator.ts;h=7ac20127e866a0deee77d6179b0ea8c1706fb5e5;hb=84cae54e7a2595bea0c3ea106a4d111fd11a4ec6;hp=1cb0116b7bfc145633e6baf1b2bb3fac294dc503;hpb=1735c825726edaa0af5035cb6cbb0cc0db502c6d;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/initializers/migrator.ts b/server/initializers/migrator.ts index 1cb0116b7..7ac20127e 100644 --- a/server/initializers/migrator.ts +++ b/server/initializers/migrator.ts @@ -1,9 +1,9 @@ -import * as path from 'path' +import { readdir } from 'fs-extra' +import { join } from 'path' +import { QueryTypes } from 'sequelize' import { logger } from '../helpers/logger' import { LAST_MIGRATION_VERSION } from './constants' import { sequelizeTypescript } from './database' -import { readdir } from 'fs-extra' -import { QueryTypes } from 'sequelize' async function migrate () { const tables = await sequelizeTypescript.getQueryInterface().showAllTables() @@ -20,7 +20,7 @@ async function migrate () { } const rows = await sequelizeTypescript.query<{ migrationVersion: number }>(query, options) - if (rows && rows[0] && rows[0].migrationVersion) { + if (rows?.[0]?.migrationVersion) { actualVersion = rows[0].migrationVersion } @@ -58,14 +58,14 @@ export { // --------------------------------------------------------------------------- async function getMigrationScripts () { - const files = await readdir(path.join(__dirname, 'migrations')) + const files = await readdir(join(__dirname, 'migrations')) const filesToMigrate: { - version: string, + version: string script: string }[] = [] files - .filter(file => file.endsWith('.js.map') === false) + .filter(file => file.endsWith('.js')) .forEach(file => { // Filename is something like 'version-blabla.js' const version = file.split('-')[0] @@ -88,7 +88,7 @@ async function executeMigration (actualVersion: number, entity: { version: strin const migrationScriptName = entity.script logger.info('Executing %s migration script.', migrationScriptName) - const migrationScript = require(path.join(__dirname, 'migrations', migrationScriptName)) + const migrationScript = require(join(__dirname, 'migrations', migrationScriptName)) return sequelizeTypescript.transaction(async t => { const options = {