further steps for migrations

lib/migrator.js

-var fs    = require("fs")
-  , path  = require("path")
-  , Utils = require("./utils")
+var fs        = require("fs")
+  , path      = require("path")
+  , moment    = require("moment")
+  , Utils     = require("./utils")
+  , DataTypes = require("./data-types")
 
 
 module.exports = (function() {
 module.exports = (function() {
-  var Migrator = function(options) {
-    this.options = Utils._.extend({
+  var Migrator = function(sequelize, options) {
+    this.sequelize = sequelize
+    this.options   = Utils._.extend({
       path: __dirname + '/../migrations',
       path: __dirname + '/../migrations',
       from: null,
       from: null,
       to: null
       to: null
@@ -12,17 +15,80 @@ module.exports = (function() {
   }
   }
 
 
   Migrator.prototype.migrate = function() {
   Migrator.prototype.migrate = function() {
-    getLastMigrationId.call(this)
+    var self = this
+
+    return new Utils.CustomEventEmitter(function(emitter) {
+      getLastMigrationId.call(self).success(function(migrationId) {
+        migrationId = migrationId || '19700101000000'
+console.log(migrationId)
+        var nonMigratedFiles = getMigrationsFilesSince.call(self, migrationId)
+        console.log(nonMigratedFiles)
+        emitter.emit('success')
+      })
+    }).run()
   }
   }
 
 
   // private
   // private
 
 
   var getLastMigrationId = function() {
   var getLastMigrationId = function() {
+    var self = this
+
+    return new Utils.CustomEventEmitter(function(emitter) {
+      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)
+        })
+      }
+
+      if(SequelizeMeta) {
+        findLastMigrationId()
+      } else {
+        SequelizeMeta = self.sequelize.define('SequelizeMeta', {
+          lastMigrationId: DataTypes.STRING
+        })
+
+        SequelizeMeta.sync().success(function() {
+          findLastMigrationId()
+        }).error(function(err) {
+          emitter.emit('failure', err)
+        })
+      }
+    }).run()
+  }
+
+  var getFormattedDateString = function(s) {
     var result = null
     var result = null
 
 
-    fs.readdirSync(this.options.path).filter(function(file) {
-      console.log(file)
+    try {
+      result = s.match(/(\d{4})(\d{2})(\d{2})(\d{2})(\d{2})(\d{2})/).slice(1, 6).join('-')
+    } catch(e) {
+      throw new Error(s + ' is no valid migration timestamp format! Use YYYYMMDDHHmmss!')
+    }
+
+    return result
+  }
+
+  var stringToDate = function(s) {
+    var formattedString = getFormattedDateString(s)
+      , date            = moment(formattedString, "YYYYMMDDHHmmss")
+
+    return date
+  }
+
+  var getMigrationsFilesSince = function(sinceString)  {
+    var result = []
+      , since  = stringToDate(sinceString)
+
+    var undoneMigrationFiles = fs.readdirSync(this.options.path).filter(function(file) {
+      var fileDateString = file.split("-")[0]
+        , fileDate       = stringToDate(fileDateString)
+
+      return fileDate.diff(since) > 0
     })
     })
+
+    return undoneMigrationFiles
   }
   }
 
 
   return Migrator
   return Migrator

package.json

@@ -11,7 +11,8 @@
     "underscore": "=1.2.1",
     "underscore": "=1.2.1",
     "underscore.string": "=1.2.0",
     "underscore.string": "=1.2.0",
     "lingo": "=0.0.4",
     "lingo": "=0.0.4",
-    "validator": "=0.3.5"
+    "validator": "=0.3.5",
+    "moment": "=1.1.1"
   },
   },
   "devDependencies": {
   "devDependencies": {
     "jasmine-node": "=1.0.12",
     "jasmine-node": "=1.0.12",

spec/migrator.spec.js

@@ -7,7 +7,11 @@ var config    = require("./config/config")
 describe('Migrator', function() {
 describe('Migrator', function() {
   describe('getLastMigrationId', function() {
   describe('getLastMigrationId', function() {
     it("should correctly transform array into IN", function() {
     it("should correctly transform array into IN", function() {
-      new Migrator({ path: __dirname + '/assets/migrations'}).migrate()
+      Helpers.async(function(done) {
+        new Migrator(sequelize, { path: __dirname + '/assets/migrations'}).migrate().success(function() {
+          done()
+        })
+      })
     })
     })
   })
   })
 })
 })