node-pg-migrate - npm Package Compare versions

Comparing version 1.1.0 to 1.2.0

lib/runner.js

@@ -77,16 +77,7 @@ var async = require('async');
 
-        var doneMigrations = [];
-        var runMigrations = [];
-
-        // filter out undone and done migrations from list of files
-        for (var i = 0; i < migrations.length; i++) {
-          if (runNames.indexOf(migrations[i].name) < 0) {
-            // if specific migration file is requested
-            if (options.file && options.file === migrations[i].name) {
-              runMigrations = [ migrations[i] ];
-              break;
+        if (options.checkOrder) {
+          for (var i = 0; i < runNames.length; i++) {
+            if (runNames[i] !== migrations[i].name) {
+              return exitCallback(new Error('Not run migration ' + migrations[i].name + ' is preceding already run migration ' + runNames[i]));
             }
-            runMigrations.push(migrations[i]);
-          } else {
-            doneMigrations.push(migrations[i]);
           }
@@ -98,22 +89,28 @@ }
 
-        // down gets by default one migration at the time, if not set otherwise
         if (options.direction === 'down') {
-          to_run = doneMigrations.slice(-1);
-          // up gets all undone migrations by default
+          to_run = runNames
+            .filter(function(migration_name) {
+              return !options.file || options.file === migration_name;
+            })
+            .map(function(migration_name) {
+              return migrations.find(function(migration) {
+                return migration.name === migration_name;
+              }) || migration_name;
+            })
+            .slice(-Math.abs(options.count || 1))
+            .reverse();
+          var deletedMigrations = to_run.filter(function(migration) {
+            return typeof migration === 'string';
+          });
+          if (deletedMigrations.length) {
+            return exitCallback(new Error('Definitions of migrations ' + deletedMigrations.join(', ') + ' have been deleted.'));
+          }
         } else {
-          to_run = runMigrations;
+          to_run = migrations
+            .filter(function(migration) {
+              return runNames.indexOf(migration.name) < 0 && (!options.file || options.file === migration.name);
+            })
+            .slice(0, Math.abs(options.count || Infinity));
         }
 
-        // if specific count of migrations is requested
-        if (options.count) {
-          // infinity is set in the bin file
-          if (options.count !== Infinity) {
-            if (options.direction === 'up') {
-              to_run = runMigrations.slice(0, options.count);
-            } else {
-              to_run = doneMigrations.slice(options.count * -1).reverse();
-            }
-          }
-        }
-
         if (!to_run.length) {
@@ -120,0 +117,0 @@ console.log('No migrations to run!');

package.json

@@ -18,3 +18,3 @@ {
   ],
-  "version": "1.1.0",
+  "version": "1.2.0",
   "engines": {
@@ -21,0 +21,0 @@ "node": ">=0.6.0"

README.md

@@ -35,2 +35,4 @@ # pg-migrate
 
+* `check-order` - Check order of migrations before running them. (There should be no migration with timestamp lesser than last run migration.)
+
 See all by running `pg-migrate --help`.
@@ -37,0 +39,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

95046

increased by0.56%

Number of lines in readme file

336

increased by0.6%

Worsened metrics

Lines of code

668

decreased by-0.15%

No dependency changes