1 files changed, 0 insertions, 139 deletions

diff --git a/server/initializers/migrator.js b/server/initializers/migrator.js
deleted file mode 100644
index 9a6415b1a..000000000
--- a/server/initializers/migrator.js
+++ /dev/null
@@ -1,139 +0,0 @@
-'use strict'
-
-const waterfall = require('async/waterfall')
-const eachSeries = require('async/eachSeries')
-const fs = require('fs')
-const path = require('path')
-
-const constants = require('./constants')
-const db = require('./database')
-const logger = require('../helpers/logger')
-
-const migrator = {
-  migrate: migrate
-}
-
-function migrate (finalCallback) {
-  waterfall([
-
-    function checkApplicationTableExists (callback) {
-      db.sequelize.getQueryInterface().showAllTables().asCallback(function (err, tables) {
-        if (err) return callback(err)
-
-        // No tables, we don't need to migrate anything
-        // The installer will do that
-        if (tables.length === 0) return finalCallback(null)
-
-        return callback(null)
-      })
-    },
-
-    function loadMigrationVersion (callback) {
-      db.Application.loadMigrationVersion(callback)
-    },
-
-    function createMigrationRowIfNotExists (actualVersion, callback) {
-      if (actualVersion === null) {
-        db.Application.create({
-          migrationVersion: 0
-        }, function (err) {
-          return callback(err, 0)
-        })
-      }
-
-      return callback(null, actualVersion)
-    },
-
-    function abortMigrationIfNotNeeded (actualVersion, callback) {
-      // No need migrations
-      if (actualVersion >= constants.LAST_MIGRATION_VERSION) return finalCallback(null)
-
-      return callback(null, actualVersion)
-    },
-
-    function getMigrations (actualVersion, callback) {
-      // If there are a new migration scripts
-      logger.info('Begin migrations.')
-
-      getMigrationScripts(function (err, migrationScripts) {
-        return callback(err, actualVersion, migrationScripts)
-      })
-    },
-
-    function doMigrations (actualVersion, migrationScripts, callback) {
-      eachSeries(migrationScripts, function (entity, callbackEach) {
-        executeMigration(actualVersion, entity, callbackEach)
-      }, function (err) {
-        if (err) return callback(err)
-
-        logger.info('Migrations finished. New migration version schema: %s', constants.LAST_MIGRATION_VERSION)
-        return callback(null)
-      })
-    }
-  ], finalCallback)
-}
-
-// ---------------------------------------------------------------------------
-
-module.exports = migrator
-
-// ---------------------------------------------------------------------------
-
-function getMigrationScripts (callback) {
-  fs.readdir(path.join(__dirname, 'migrations'), function (err, files) {
-    if (err) return callback(err)
-
-    const filesToMigrate = []
-
-    files.forEach(function (file) {
-      // Filename is something like 'version-blabla.js'
-      const version = file.split('-')[0]
-      filesToMigrate.push({
-        version,
-        script: file
-      })
-    })
-
-    return callback(err, filesToMigrate)
-  })
-}
-
-function executeMigration (actualVersion, entity, callback) {
-  const versionScript = parseInt(entity.version)
-
-  // Do not execute old migration scripts
-  if (versionScript <= actualVersion) return callback(null)
-
-  // Load the migration module and run it
-  const migrationScriptName = entity.script
-  logger.info('Executing %s migration script.', migrationScriptName)
-
-  const migrationScript = require(path.join(__dirname, 'migrations', migrationScriptName))
-
-  db.sequelize.transaction().asCallback(function (err, t) {
-    if (err) return callback(err)
-
-    const options = {
-      transaction: t,
-      queryInterface: db.sequelize.getQueryInterface(),
-      sequelize: db.sequelize,
-      Sequelize: db.Sequelize
-    }
-    migrationScript.up(options, function (err) {
-      if (err) {
-        t.rollback()
-        return callback(err)
-      }
-
-      // Update the new migration version
-      db.Application.updateMigrationVersion(versionScript, t, function (err) {
-        if (err) {
-          t.rollback()
-          return callback(err)
-        }
-
-        t.commit().asCallback(callback)
-      })
-    })
-  })
-}