refactor: disconnect create from connect

Signed-off-by: Tobias Gurtzick <[email protected]>

Author: wzrdtales

connect.js

@@ -11,7 +11,6 @@ var log = require('db-migrate-shared').log;
 exports.connect = function (config, PassedClass, callback) {
   var internals = {};
   var prefix = 'migration';
-  var migrationsDir;
   if (config.config) {
     prefix = config.prefix || prefix;
     internals = config.internals;
@@ -191,14 +190,3 @@ function migrationFiles (
     }
   });
 }
-
-exports.createMigration = function (migration, callback) {
-  migration.write(function (err) {
-    if (err) {
-      callback(err);
-      return;
-    }
-
-    callback(null, migration);
-  });
-};

lib/commands/create-migration.js

@@ -42,7 +42,6 @@ function executeCreateMigration (internals, config, callback) {
   }
 
   createMigrationDir(migrationsDir, function (err) {
-    const index = require('../../connect');
     const Migration = require('../template.js');
 
     if (err) {
@@ -91,7 +90,7 @@ function executeCreateMigration (internals, config, callback) {
       internals.runTimestamp,
       templateType
     );
-    index.createMigration(migration, function (err, migration) {
+    migration.write(function (err) {
       if (_assert(err, callback)) {
         log.info(util.format('Created migration at %s', migration.file.path));
         if (shouldCreateSqlFiles(internals, config)) {
@@ -128,7 +127,6 @@ function createSqlFiles (internals, config, callback) {
 
   const sqlDir = migrationsDir + '/sqls';
   createMigrationDir(sqlDir, function (err) {
-    const index = require('../../connect');
     const Migration = require('../template.js');
 
     if (err) {
@@ -148,12 +146,12 @@ function createSqlFiles (internals, config, callback) {
       internals.runTimestamp,
       templateTypeDefaultSQL
     );
-    index.createMigration(migrationUpSQL, function (err, migration) {
+    migrationUpSQL.write(function (err) {
       if (_assert(err, callback)) {
         log.info(
           util.format(
             'Created migration up sql file at %s',
-            migration.file.path
+            migrationUpSQL.file.path
           )
         );
 
@@ -163,12 +161,12 @@ function createSqlFiles (internals, config, callback) {
           internals.runTimestamp,
           templateTypeDefaultSQL
         );
-        index.createMigration(migrationDownSQL, function (err, migration) {
+        migrationDownSQL.write(function (err) {
           if (_assert(err, callback)) {
             log.info(
               util.format(
                 'Created migration down sql file at %s',
-                migration.file.path
+                migrationDownSQL.file.path
               )
             );
             if (typeof callback === 'function') callback();