Merge pull request #187 from thesamiroli/fail-on-sync-error

Fail synchronization if any error occurs while running sql scripts

Author: mesaugat

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@leapfrogtechnology/sync-db",
   "description": "Command line utility to synchronize and version control relational database objects across databases",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "license": "MIT",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

src/config.ts

@@ -119,7 +119,7 @@ export async function resolveConnections(config: Configuration, resolver?: strin
   } else if (resolver || config.connectionResolver) {
     connections = await resolveConnectionsUsingResolver(resolver || config.connectionResolver, config);
   } else {
-    log('Connections file not provided.');
+    log('Connections file not provided. Loading connection details from env.');
 
     connections = resolveConnectionsFromEnv();
   }

src/service/sync.ts

@@ -41,7 +41,7 @@ async function setup(trx: Knex.Transaction, context: SynchronizeContext): Promis
     log('PRE-SYNC: End');
   }
 
-  // Run the migration scripts.
+  // Run the synchronization scripts.
   await sqlRunner.runSequentially(trx, sqlScripts, connectionId);
 
   if (postMigrationScripts.length > 0) {

src/util/promise.ts

@@ -25,15 +25,17 @@ export async function runSequentially<T>(promisers: Promiser<T>[]): Promise<T[]>
 
       result.push(value);
     } catch (err) {
-      const errors = err as any;
-
-      if (errors.originalError) {
-        result.push(errors.originalError);
-      } else if (errors.error) {
-        result.push(errors.error);
-      } else {
-        throw err;
+      const error = err as any;
+
+      if (error.error) {
+        throw error.error;
+      }
+
+      if (error.originalError) {
+        throw error.originalError;
       }
+
+      throw error;
     }
   }