Feat: Model Fix, Fetch Transactions

src/controllers/transaction.controller.js

@@ -0,0 +1,18 @@
+const { fetUserTransactions } = require("../utils/transaction.Util");
+
+const getAllUserTransactions = async (req, res, next) => {
+  const { userId } = req.params;
+  try {
+    const transactions = await fetUserTransactions(userId);
+
+    return res.status(200).json({
+      msg: "Transactions fetched successfully",
+      transactions,
+    });
+  } catch (error) {
+    console.log(error);
+    next();
+  }
+};
+
+module.exports = { getAllUserTransactions };

src/model/model.js

@@ -169,10 +169,11 @@ const Transaction = sequelize.define("Transaction", {
   },
   creditWalletId: {
     type: UUID,
-    allowNull: false,
+    allowNull: true,
   },
   debitWalletId: {
     type: UUID,
+    allowNull: true,
   },
 });
 
@@ -192,7 +193,8 @@ User.prototype.compareTransactionPin = async function (transactionPin) {
   return isMatch;
 };
 
-Wallet.belongsTo(User, { foreignKey: "userId", onDelete: "cascade" });
+User.hasOne(Wallet, { foreignKey: "userId" });
+Wallet.belongsTo(User, { foreignKey: "userId" });
 Transaction.belongsTo(Wallet, {
   as: "creditWallet",
   foreignKey: "creditWalletId",

src/routes/transaction.route.js

@@ -1,4 +1,9 @@
 const express = require("express");
 const router = express.Router();
+const {
+  getAllUserTransactions,
+} = require("../controllers/transaction.controller");
+
+router.get("/transactions/:userId", getAllUserTransactions);
 
 module.exports = router;

src/utils/transaction.Util.js

@@ -0,0 +1,32 @@
+const { User, Transaction, Wallet } = require("../model/model");
+const { Op } = require("sequelize");
+const { NotFoundError } = require("../errors");
+async function fetUserTransactions(userId) {
+  const user = await User.findByPk(userId, {
+    include: {
+      model: Wallet,
+      attributes: ["id"],
+    },
+  });
+
+  if (!user) {
+    throw new NotFoundError("User not found");
+  }
+
+  const transactions = await Transaction.findAll({
+    where: {
+      [Op.or]: [
+        {
+          creditWalletId: user.Wallet.id,
+        },
+        {
+          debitWalletId: user.Wallet.id,
+        },
+      ],
+    },
+  });
+  console.log(transactions);
+  return transactions;
+}
+
+module.exports = { fetUserTransactions };