Merge 3rd stream

app.js

@@ -4,6 +4,8 @@ const dotenv = require('dotenv');
 const { v4 } = require('uuid');
 const models = require('./models');
 const { creditAccount, debitAccount } = require('./helpers/transactions');
+const { hashArguments } = require('./hash');
+const { checkRedisHash } = require('./redis');
 
 dotenv.config();
 
@@ -167,6 +169,16 @@ async function transfer(sender_id, recipient_id, amount) {
       error: validation.error.details[0].message,
     };
   }
+  const requestHash = hashArguments(sender_id, recipient_id, amount);
+
+  const redisCheckResult = await checkRedisHash(sender_id, requestHash);
+
+  if (!redisCheckResult.success) {
+    return {
+      success: false,
+      error: 'Duplicate transaction',
+    };
+  }
 
   const t = await models.sequelize.transaction();
   try {
@@ -192,6 +204,7 @@ async function transfer(sender_id, recipient_id, amount) {
         metadata: {
           sender_id,
         },
+        t,
       }),
     ]);
 
@@ -215,6 +228,8 @@ async function transfer(sender_id, recipient_id, amount) {
   }
 }
 
+transfer(1, 2, 1000).then(console.log).catch(console.log);
+
 /**
  * @param {string} reference reference of the transaction to reverse
 */

card.js

@@ -60,6 +60,7 @@ async function completeSuccessfulCharge({ accountId, reference, amount }) {
     message: 'Account successfully credited',
   };
 }
+
 async function chargeCard({
   accountId, pan, expiry_month, expiry_year, cvv, email, amount,
 }) {
@@ -78,7 +79,6 @@ async function chargeCard({
         Authorization: `Bearer ${process.env.PAYSTACK_SECRET_KEY}`,
       },
     });
-
     const nextAction = processInitialCardCharge(charge.data);
     await models.card_transactions.create({
       external_reference: nextAction.data.reference,
@@ -302,3 +302,30 @@ async function submitPhone({
     return error.response ? error.response.data : error;
   }
 }
+
+async function chargeCardWithAuthorization(authorization) {
+  const charge = await axios.post(PAYSTACK_BASE_URL, {
+    authorization_code: authorization,
+    amount: 10000,
+    email: '[email protected]',
+  }, {
+    headers: {
+      Authorization: `Bearer ${process.env.PAYSTACK_SECRET_KEY}`,
+    },
+  });
+  return {
+    success: true,
+    data: charge.data.data,
+  };
+}
+
+chargeCardWithAuthorization('AUTH_zev61rikmn').then(console.log).catch(console.log);
+// chargeCard({
+//   accountId: 1,
+//   pan: '506066506066506067',
+//   amount: 1000000,
+//   cvv: '060',
+//   email: '[email protected]',
+//   expiry_month: '12',
+//   expiry_year: '25',
+// }).then(console.log).catch(console.log);

hash.js

@@ -0,0 +1,20 @@
+const crypto = require('crypto');
+
+const key = 'mysecret key';
+
+// create hahs
+// const hash = crypto.createHmac('sha512', key);
+// hash.update(text);
+// const value = hash.digest('hex');
+
+// print result
+// console.log(value);
+
+function hashArguments(...parameters) {
+  const concatenatedRequest = parameters.join('');
+  const hash = crypto.createHmac('sha512', key);
+  hash.update(concatenatedRequest);
+  return hash.digest('hex');
+}
+
+module.exports = { hashArguments };