refactored sequelize meta

lib/migrator.js

@@ -42,7 +42,7 @@ module.exports = (function() {
           migrations.forEach(function(migration) {
           migrations.forEach(function(migration) {
             chainer.add(migration, 'execute', [options], {
             chainer.add(migration, 'execute', [options], {
               success: function(migration, callback) {
               success: function(migration, callback) {
-                saveSuccessfulMigration.call(self, migration, callback)
+                saveSuccessfulMigration.call(self, migrations[0], migration, callback)
               }
               }
             })
             })
           })
           })
@@ -115,7 +115,8 @@ module.exports = (function() {
 
 
       if(!storedModel) {
       if(!storedModel) {
         SequelizeMeta = self.sequelize.define('SequelizeMeta', {
         SequelizeMeta = self.sequelize.define('SequelizeMeta', {
-          lastMigrationId: DataTypes.STRING
+          from: DataTypes.STRING,
+          to:   DataTypes.STRING
         })
         })
       }
       }
 
 
@@ -151,7 +152,7 @@ module.exports = (function() {
     return new Utils.CustomEventEmitter(function(emitter) {
     return new Utils.CustomEventEmitter(function(emitter) {
       getLastMigrationFromDatabase.call(self)
       getLastMigrationFromDatabase.call(self)
         .success(function(meta) {
         .success(function(meta) {
-          emitter.emit('success', meta ? meta.lastMigrationId : null)
+          emitter.emit('success', meta ? meta.to : null)
         })
         })
         .error(function(err) {
         .error(function(err) {
           emitter.emit('failure', err)
           emitter.emit('failure', err)
@@ -175,23 +176,14 @@ module.exports = (function() {
     return moment(getFormattedDateString(s), "YYYYMMDDHHmmss")
     return moment(getFormattedDateString(s), "YYYYMMDDHHmmss")
   }
   }
 
 
-  var saveSuccessfulMigration = function(migration, callback) {
+  var saveSuccessfulMigration = function(from, to, callback) {
     var self = this
     var self = this
 
 
-    getLastMigrationFromDatabase.call(this).success(function(dbEntry) {
-      if(dbEntry) {
-        dbEntry
-          .updateAttributes({ lastMigrationId: migration.migrationId })
-          .success(callback)
-          .error(function(err) { throw new Error(err) })
-      } else {
-        self.findOrCreateSequelizeMetaModel().success(function(SequelizeMeta) {
-          SequelizeMeta
-            .create({ lastMigrationId: migration.migrationId })
-            .success(callback)
-        })
-      }
-    }).error(function(err) { throw new Error(err) })
+    self.findOrCreateSequelizeMetaModel().success(function(SequelizeMeta) {
+      SequelizeMeta
+        .create({ from: from.migrationId, to: to.migrationId })
+        .success(callback)
+    })
   }
   }
 
 
   return Migrator
   return Migrator

spec/migrator.spec.js

@@ -90,7 +90,7 @@ describe('Migrator', function() {
       setup()
       setup()
 
 
       Helpers.async(function(done) {
       Helpers.async(function(done) {
-        SequelizeMeta.create({ lastMigrationId: '20111117063700' }).success(function() {
+        SequelizeMeta.create({ from: null, to: '20111117063700' }).success(function() {
           migrator.getUndoneMigrations(function(err, migrations) {
           migrator.getUndoneMigrations(function(err, migrations) {
             expect(err).toBeNull()
             expect(err).toBeNull()
             expect(migrations.length).toEqual(7)
             expect(migrations.length).toEqual(7)