Feat: save highVolumeTxs on DB and plugins code refactor

Fix: remove unused module and add space before '('

Chore: add jest tests for transactionNotify

lib/notifier/index.js

@@ -1,12 +1,16 @@
-const { STALE, STALE_STATE } = require('./codes')
-
 const _ = require('lodash/fp')
-const queries = require('./queries')
+
+const configManager = require('../new-config-manager')
 const logger = require('../logger')
+const machineLoader = require('../machine-loader')
+const queries = require('./queries')
+const settingsLoader = require('../new-settings-loader')
+const customers = require('../customers')
 
 const utils = require('./utils')
 const emailFuncs = require('./email')
 const smsFuncs = require('./sms')
+const { STALE, STALE_STATE } = require('./codes')
 
 function buildMessage(alerts, notifications) {
   const smsEnabled = utils.isActive(notifications.sms)
@@ -132,8 +136,79 @@ function checkStuckScreen(deviceEvents, machineName) {
   return []
 }
 
+async function transactionNotify (tx, rec) {
+  const settings = await settingsLoader.loadLatest()
+  const notifSettings = configManager.getGlobalNotifications(settings.config)
+  const highValueTx = tx.fiat.gt(notifSettings.highValueTransaction || Infinity)
+  const isCashOut = tx.direction === 'cashOut'
+  
+  // high value tx on database
+  if(highValueTx) {
+    queries.addHighValueTx(tx)
+  }
+  
+  // alert through sms or email any transaction or high value transaction, if SMS || email alerts are enabled
+  const cashOutConfig = configManager.getCashOut(tx.deviceId, settings.config)
+  const zeroConfLimit = cashOutConfig.zeroConfLimit
+  const zeroConf = isCashOut && tx.fiat.lte(zeroConfLimit)
+  const notificationsEnabled = notifSettings.sms.transactions || notifSettings.email.transactions
+  const customerPromise = tx.customerId ? customers.getById(tx.customerId) : Promise.resolve({})
+  
+  if (!notificationsEnabled && !highValueTx) return Promise.resolve()
+  if (zeroConf && isCashOut && !rec.isRedemption && !rec.error) return Promise.resolve()
+  if (!zeroConf && rec.isRedemption) return sendRedemptionMessage(tx.id, rec.error)
+
+  return Promise.all([
+    machineLoader.getMachineName(tx.deviceId),
+    customerPromise
+  ])
+  .then(([machineName, customer]) => {
+    return utils.buildTransactionMessage(tx, rec, highValueTx, machineName, customer)
+  })
+  .then(([msg, highValueTx]) => sendTransactionMessage(msg, highValueTx))
+}
+
+function sendRedemptionMessage(txId, error) {
+  const subject = `Here's an update on transaction ${txId}`
+  const body = error
+    ? `Error: ${error}`
+    : 'It was just dispensed successfully'
+
+  const rec = {
+    sms: {
+      body: `${subject} - ${body}`
+    },
+    email: {
+      subject,
+      body
+    }
+  }
+  return sendTransactionMessage(rec)
+}
+
+async function sendTransactionMessage(rec, isHighValueTx) {
+  const settings = await settingsLoader.loadLatest()
+  const notifications = configManager.getGlobalNotifications(settings.config)
+
+  let promises = []
+
+  const emailActive =
+    notifications.email.active &&
+    (notifications.email.transactions || isHighValueTx)
+  if (emailActive) promises.push(emailFuncs.sendMessage(settings, rec))
+
+  const smsActive =
+    notifications.sms.active &&
+    (notifications.sms.transactions || isHighValueTx)
+  if (smsActive) promises.push(smsFuncs.sendMessage(settings, rec))
+
+  return Promise.all(promises)
+}
+
 module.exports = {
+  transactionNotify,
   checkNotification,
   checkPings,
-  checkStuckScreen
+  checkStuckScreen,
+  sendRedemptionMessage
 }