Missing Import

Author: James Cori

src/services/paymentService.js

@@ -2,6 +2,7 @@
  * Payment Service
  * Interacts with InformixDB
  */
+const util = require('util')
 const logger = require('../common/logger')
 const helper = require('../common/helper')
 const config = require('config');
@@ -58,7 +59,7 @@ async function paymentExists(payment) {
     logger.debug(`Checking if paymentExists - ${query}`)
     return connection.queryAsync(query)
   } catch (e) {
-    logger.error(`Error in 'getGroupsForChallenge' ${e}`)
+    logger.error(`Error in 'paymentExists' ${e}`)
     throw e
   } finally {
     await connection.closeAsync()

src/services/processorService.js

@@ -57,7 +57,8 @@ async function processUpdate(message) {
           }, basePayment)
 
           const paymentExists = await paymentService.paymentExists(payment)
-          if(!paymentExists) {
+          logger.debug(`Payment Exists Response: ${JSON.stringify(paymentExists)}`)
+          if(!paymentExists || paymentExists.length === 0) {
             await paymentService.createPayment(payment)
           } else {
             logger.error(`Payment Exists for ${v5ChallengeId}, skipping - ${JSON.stringify(paymentExists)}`)
@@ -86,7 +87,8 @@ async function processUpdate(message) {
           typeId: config.COPILOT_PAYMENT_TYPE_ID
         }, basePayment)
         const paymentExists = await paymentService.paymentExists(copilotPayment)
-        if(!paymentExists) {
+        logger.debug(`Copilot Payment Exists Response: ${JSON.stringify(paymentExists)}`)
+        if(!paymentExists || paymentExists.length === 0) {
           await paymentService.createPayment(copilotPayment)
         } else {
           logger.error(`Copilot Payment Exists for ${v5ChallengeId}, skipping - ${JSON.stringify(paymentExists)}`)