Merge c279a9b into 7a10113

test/01-migrator/create/withDateTimeMigrationNumberFormat.js

@@ -2,6 +2,7 @@
 
 const tap = require('tap');
 const expect = require('expect.js');
+const pEachSeries = require('p-each-series');
 const testUtils = require('../../../testUtils');
 
 tap.mochaGlobals();
@@ -38,7 +39,7 @@ describe('migrator create with date time migration number format', () => {
 		migrator.params.migrationNumberFormat = 'sequentialNumber';
 	});
 
-	it('should create new files with a dateTime prefix', () => {
+	it('should create migrations without errors', () => {
 		return Promise.resolve()
 			.then(() => testUtils.createMigrations({migrator, baseNames}))
 			.then((migrationNames) => {
@@ -51,4 +52,18 @@ describe('migrator create with date time migration number format', () => {
 			expect(name).to.match(new RegExp(`^[0-9]{14}_${baseNames[index]}$`));
 		});
 	});
+
+	it('created migrations should exist', () => {
+		return migrator.checkMigrationsExists(names);
+	});
+
+	it('created migrations should be loadable', () => {
+		return pEachSeries(names, (name) => migrator.loadMigration(name));
+	});
+
+	it('created migrations should be listed as `new`', () => {
+		return Promise.resolve()
+			.then(() => migrator.getNewMigrationNames())
+			.then((newNames) => expect(newNames).eql(names));
+	});
 });

test/01-migrator/create/withSequentialMigrationNumberFormat.js

@@ -31,7 +31,7 @@ describe('migrator create with sequential migration number format', () => {
 
 	after(() => testUtils.destroyEnv(testEnv));
 
-	it('should create migrations sequentially without errors', () => {
+	it('should create migrations without errors', () => {
 		return Promise.resolve()
 			.then(() => testUtils.createMigrations({migrator, baseNames}))
 			.then((migrationNames) => {

testUtils/createMigrator.js

@@ -16,6 +16,8 @@ module.exports = (params) => {
 
 	return Promise.resolve()
 		.then(() => migrator.configure(params.configureParams))
+		// always connect migrator coz `removeDirBefore` makes unmark executed
+		.then(() => migrator.connect())
 		.then(() => {
 			if (params.removeDirBefore) {
 				return removeMigratorDir(migrator);
@@ -27,8 +29,9 @@ module.exports = (params) => {
 			}
 		})
 		.then(() => {
-			if (params.connect) {
-				return migrator.connect();
+			// disconnect if connected was not required
+			if (!params.connect) {
+				return migrator.disconnect();
 			}
 		})
 		.then(() => migrator);