Close connection; fix

json-schema-faker · Jun 16, 2019 · 5e0cc07 · 5e0cc07
1 parent 81ba049
commit 5e0cc07
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 19 deletions.
diff --git a/cli/migrate.js b/cli/migrate.js
@@ -252,5 +252,7 @@ module.exports = (conn, config) => {
       }
 
       return check();
-    });
+    })
+    .then(() => conn.close())
+    .then(() => process.exit());
 };
diff --git a/lib/umzug.js b/lib/umzug.js
@@ -123,26 +123,14 @@ module.exports = (sequelize, options, bind) => {
     return umzug;
   }
 
-  function end(p) {
-    return p.then(x => {
-      try {
-        sequelize.close();
-      } catch (e) {
-        console.warn(e);
-      } finally {
-        return x;
-      }
-    });
-  }
-
   return {
-    run: script => end(Promise.resolve().then(() => fs.existsSync(script) && wrap(sequelize, require(script)))),
-    up: params => end(cmdMigrate(_umzug(), params || {})),
-    down: params => end(cmdReset(_umzug(), params || {})),
-    next: () => end(cmdMigrateNext(_umzug())),
-    prev: () => end(cmdResetPrev(_umzug())),
+    run: script => Promise.resolve().then(() => fs.existsSync(script) && wrap(sequelize, require(script))),
+    up: params => cmdMigrate(_umzug(), params || {}),
+    down: params => cmdReset(_umzug(), params || {}),
+    next: () => cmdMigrateNext(_umzug()),
+    prev: () => cmdResetPrev(_umzug()),
     status: () => (fs.existsSync(_umzug().options.migrations.path)
-      ? end(cmdStatus(_umzug()))
+      ? cmdStatus(_umzug())
       : Promise.resolve({
         pending: [],
         executed: [],