fix #9 with this check

jeremydaly · Dec 7, 2018 · 27940bd · 27940bd
1 parent f4aacfd
commit 27940bd
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/index.js b/index.js
@@ -188,12 +188,10 @@ const query = async function(...args) {
           resetClient() // reset the client
           reject(err) // reject the promise with the error
         } else if (err && /^PROTOCOL_ENQUEUE_AFTER_/.test(err.code)) {
-
           resetClient() // reset the client
           return resolve(query(...args)) // attempt the query again
-          //reject(err) // reject the promise with the error
         } else if (err) {
-          if (this.rollback) {
+          if (this && this.rollback) {
             await query('ROLLBACK')
             this.rollback(err)
           }