X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Finitializers%2Fmigrator.ts;h=77203ae24139ac9f40cceb7a86f1927af545687f;hb=35b30b643cf9870b0934f34253ffb23cf6a264b0;hp=adc2f9fb370ddd9f15ddbd4838a2b5d6be6cac13;hpb=62689b942b71cd1dd0d050c6ed05f884a0b325c2;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/initializers/migrator.ts b/server/initializers/migrator.ts index adc2f9fb3..77203ae24 100644 --- a/server/initializers/migrator.ts +++ b/server/initializers/migrator.ts @@ -3,6 +3,7 @@ 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() @@ -13,8 +14,13 @@ async function migrate () { let actualVersion: number | null = null - const [ rows ] = await sequelizeTypescript.query('SELECT "migrationVersion" FROM "application"') - if (rows && rows[0] && rows[0].migrationVersion) { + const query = 'SELECT "migrationVersion" FROM "application"' + const options = { + type: QueryTypes.SELECT as QueryTypes.SELECT + } + + const rows = await sequelizeTypescript.query<{ migrationVersion: number }>(query, options) + if (rows?.[0]?.migrationVersion) { actualVersion = rows[0].migrationVersion } @@ -54,7 +60,7 @@ export { async function getMigrationScripts () { const files = await readdir(path.join(__dirname, 'migrations')) const filesToMigrate: { - version: string, + version: string script: string }[] = []