function auditEntry()

in src/rds/create.js [54:87]
32 lines of code
4 McCabe index (conditional complexity)

function auditEntry(req, cb) {
  let body = req.payload.msg
  let dbConfig = req.rdsConfig

  let orderId = body.orderId
  let requestId = body.requestId
  let msgId = body.messageId
  let ids = { requestId: requestId, orderId: orderId, messageId: msgId }

  getToken(dbConfig, ids, (iamErr, dbToken) => {
    if (iamErr) {
      cb({ type: 'iam', msg: `Error obtaining token - ${iamErr.code} ${iamErr.message}` })
    } else {
      getDbConnection(dbToken, ids, (dbErr, conn) => {
        if (dbErr) {
          cb({ type: 'dbconn', msg: `Database connection failed - ${dbErr.code} ${dbErr.message}.` })
        } else {
          let q = `INSERT INTO ${dbToken.db}.order_trail (order_id, saga_us, saga_us_status, saga_us_msg, trail_timestamp) VALUES(?,?,?,?,?);`
          let v = [orderId, req.payload.us, req.payload.msgType, body.msg, body.ts]
          conn.query(q, v, (qryErr) => {
            conn.end()
            if (qryErr) {
              logger.error(`RequestId: ${ids.requestId} - MessageId: ${ids.messageId} - OrderId: ${orderId} - Error running query - ${qryErr.code} - ${qryErr.message}`)
              cb({ type: 'dbquery', msg: `Error running query - ${qryErr.code} - ${qryErr.message}` })
            } else {
              logger.info(`RequestId: ${ids.requestId} - MessageId: ${ids.messageId} - OrderId: ${orderId} - Trail updated.`)
              cb(null)
            }
          })
        }
      })
    }
  })
}