X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Finitializers%2Fmigrator.ts;h=d72c60638a2c58a23290a1308446d3abb7bc5e6c;hb=69818c9394366b954b6ba3bd697bd9d2b09f2a16;hp=379d43af528f0e16456dd9e8c7a635870620dadf;hpb=4d4e5cd4dca78480ec7f40e747f424cd107376a4;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/initializers/migrator.ts b/server/initializers/migrator.ts index 379d43af5..d72c60638 100644 --- a/server/initializers/migrator.ts +++ b/server/initializers/migrator.ts @@ -8,7 +8,7 @@ import { LAST_MIGRATION_VERSION } from './constants' import { logger } from '../helpers' import { ApplicationInstance } from '../models' -function migrate (finalCallback) { +function migrate (finalCallback: (err: Error) => void) { waterfall([ function checkApplicationTableExists (callback) { @@ -56,7 +56,7 @@ function migrate (finalCallback) { }, function doMigrations (actualVersion, migrationScripts, callback) { - eachSeries(migrationScripts, function (entity, callbackEach) { + eachSeries(migrationScripts, function (entity: any, callbackEach) { executeMigration(actualVersion, entity, callbackEach) }, function (err) { if (err) return callback(err) @@ -76,7 +76,8 @@ export { // --------------------------------------------------------------------------- -function getMigrationScripts (callback) { +type GetMigrationScriptsCallback = (err: Error, filesToMigrate?: { version: string, script: string }[]) => void +function getMigrationScripts (callback: GetMigrationScriptsCallback) { fs.readdir(path.join(__dirname, 'migrations'), function (err, files) { if (err) return callback(err) @@ -95,7 +96,7 @@ function getMigrationScripts (callback) { }) } -function executeMigration (actualVersion, entity, callback) { +function executeMigration (actualVersion: number, entity: { version: string, script: string }, callback: (err: Error) => void) { const versionScript = parseInt(entity.version, 10) // Do not execute old migration scripts