refactored SequelizeMeta getter

lib/migrator.js

@@ -80,40 +80,46 @@ module.exports = (function() {
     }
     }
   }
   }
 
 
-  // private
-
-  var executeMigration = function(path, method) {
-    var migration = require(path)
-    migration[method || 'up'](this.queryInterface, DataTypes)
-  }
-
-  var getLastMigrationIdFromDatabase = function() {
+  Migrator.prototype.findOrCreateSequelizeMetaModel = function(syncOptions) {
     var self = this
     var self = this
 
 
     return new Utils.CustomEventEmitter(function(emitter) {
     return new Utils.CustomEventEmitter(function(emitter) {
       var SequelizeMeta = self.sequelize.modelManager.getModel('SequelizeMeta')
       var SequelizeMeta = self.sequelize.modelManager.getModel('SequelizeMeta')
 
 
-      var findLastMigrationId = function() {
-        SequelizeMeta.find({ order: 'id DESC' }).success(function(sequelizeMeta) {
-          emitter.emit('success', sequelizeMeta ? sequelizeMeta.lastMigrationId : null)
-        }).error(function(err) { emitter.emit('failure', err) })
-      }
-
       if(SequelizeMeta) {
       if(SequelizeMeta) {
-        findLastMigrationId()
+        emitter.emit('success', SequelizeMeta)
       } else {
       } else {
         SequelizeMeta = self.sequelize.define('SequelizeMeta', {
         SequelizeMeta = self.sequelize.define('SequelizeMeta', {
           lastMigrationId: DataTypes.STRING
           lastMigrationId: DataTypes.STRING
         })
         })
 
 
         SequelizeMeta
         SequelizeMeta
-          .sync()
-          .success(function() { findLastMigrationId() })
+          .sync(syncOptions || {})
+          .success(function() { emitter.emit('success', SequelizeMeta) })
           .error(function(err) { emitter.emit('failure', err) })
           .error(function(err) { emitter.emit('failure', err) })
       }
       }
     }).run()
     }).run()
   }
   }
 
 
+  // private
+
+  var executeMigration = function(path, method) {
+    var migration = require(path)
+    migration[method || 'up'](this.queryInterface, DataTypes)
+  }
+
+  var getLastMigrationIdFromDatabase = function() {
+    var self = this
+
+    return new Utils.CustomEventEmitter(function(emitter) {
+      self.findOrCreateSequelizeMetaModel().success(function(SequelizeMeta) {
+        SequelizeMeta.find({ order: 'id DESC' }).success(function(meta) {
+          emitter.emit('success', meta ? meta.lastMigrationId : null)
+        }).error(function(err) { emitter.emit('failure', err) })
+      }).error(function(err) { emitter.emit(err) })
+    }).run()
+  }
+
   var getFormattedDateString = function(s) {
   var getFormattedDateString = function(s) {
     var result = null
     var result = null