add error param when doing sync error event

Author: sidorares

test/integration/promise-wrappers/test-async-stack.js

@@ -1,4 +1,4 @@
-/*
+const code = `
 var config = require('../../common.js').config;
 
 var assert = require('assert');
@@ -23,23 +23,25 @@ function test() {
 
   let e1, e2;
 
-  // TODO: investigate why connaction is still open after ENETUNREACH
+  // TODO: investigate why connection is still open after ENETUNREACH
   async function test1() {
     e1 = new Error();
     const conn = await createConnection({ host: '0.42.42.42' });
     let [rows, fields] = conn.query('select 1 + 1');
     await Promise.all([conn.query('select 1+1'), conn.query('syntax error')]);
   }
 
+  /*
   test1().catch(err => {
     const stack = ErrorStackParser.parse(err);
     const stackExpected = ErrorStackParser.parse(e1);
     assert(stack[1].getLineNumber() === stackExpected[0].getLineNumber() + 1);
   });
+  */
 
   async function test2() {
     const conn = await createConnection(config);
-    let [rows, fields] = conn.query('select 1 + 1');
+    let [rows, fields] = await conn.query('select 1 + 1');
     try {
       e2 = new Error();
       await Promise.all([conn.query('select 1+1'), conn.query('syntax error')]);
@@ -55,4 +57,27 @@ function test() {
 }
 
 test();
-*/
+
+`;
+
+process.on('unhandledRejection', function(err) {
+  console.log(err.stack);
+});
+
+const vm = require('vm');
+
+try {
+  vm.runInNewContext(
+    code,
+    {
+      require: require
+    },
+    {
+      fileName: __filename,
+      lineOffset: 1
+    }
+  );
+} catch (err) {
+  // ignore sync errors (must be syntax - async/await not supported)
+  console.log(err);
+}

test/integration/promise-wrappers/test-promise-wrappers.js

@@ -51,9 +51,6 @@ function testErrors() {
   var connResolved;
   var connPromise = createConnection(config);
 
-  console.log('=== 1', connPromise);
-  console.log('=== 2', connPromise.end);
-
   connPromise
     .then(function(conn) {
       connResolved = conn;
@@ -154,7 +151,7 @@ function testEventsConnect() {
         doneEventsConnect = events === 5;
       });
 
-    conn.connection.emit('error');
+    conn.connection.emit('error', new Error());
     conn.connection.emit('drain');
     conn.connection.emit('connect');
     conn.connection.emit('enqueue');