]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blobdiff - server/initializers/migrator.ts
Type functions
[github/Chocobozzz/PeerTube.git] / server / initializers / migrator.ts
index 379d43af528f0e16456dd9e8c7a635870620dadf..d72c60638a2c58a23290a1308446d3abb7bc5e6c 100644 (file)
@@ -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