add: added receivers

back/api/@me.js

@@ -1,6 +1,6 @@
 const express = require('express');
 const router = express.Router();
-const { getConnection, getUserAccounts, getUserCards, getUserTransfers, setAccountBalance, getAccount, addTransfer } = require('../libs/mysql');
+const { getConnection, getUserAccounts, getUserCards, getUserTransfers, setAccountBalance, getAccount, addTransfer, getUserReceivers, addReceiver, removeReceiver } = require('../libs/mysql');
 const { checkAuth } = require('../libs/middlewares');
 
 router.post('/', checkAuth, async (req, res) => {
@@ -32,6 +32,60 @@ router.post('/transfers', checkAuth, async (req, res) => {
     res.send(transfers);
 });
 
+router.post('/receivers', checkAuth, async (req, res) => {
+    const user = req.user;
+    const connection = await getConnection();
+    const receivers = await getUserReceivers(connection, user.id);
+    connection.end();
+    res.send(receivers);
+});
+
+router.post('/add-receiver', checkAuth, async (req, res) => {
+    const user = req.user;
+    const { account_id, name } = req.body;
+
+    if (!account_id || !name) {
+        return res.status(400).send({ error: 'Missing required fields' });
+    }
+
+    const connection = await getConnection();
+    const account = await getAccount(connection, account_id);
+
+    if (!account[0]) {
+        return res.status(400).send({ error: 'Invalid account ID' });
+    }
+
+    await addReceiver(connection, user.id, account_id, name);
+    connection.end();
+
+    res.send({ message: 'Receiver added successfully' });
+});
+
+router.post('/remove-receiver', checkAuth, async (req, res) => {
+    const user = req.user;
+    const { id } = req.body;
+
+    if (!id) {
+        return res.status(400).send({ error: 'Missing required fields' });
+    }
+
+    const connection = await getConnection();
+    const receiver = await getUserReceivers(connection, user.id);
+
+    if (!receiver[0]) {
+        return res.status(400).send({ error: 'Invalid receiver ID' });
+    }
+
+    if (receiver[0].user_id !== user.id) {
+        return res.status(403).send({ error: 'You are not authorized to remove this receiver' });
+    }
+
+    await removeReceiver(connection, id);
+    connection.end();
+
+    res.send({ message: 'Receiver removed successfully' });
+});
+
 router.post('/send-money', checkAuth, async (req, res) => {
     const user = req.user;
     const { account_from_id, account_to_id, amount, name } = req.body;

back/bank.sql

@@ -3,7 +3,7 @@
 -- https://www.phpmyadmin.net/
 --
 -- Host: mysql
--- Generation Time: Apr 27, 2025 at 01:27 PM
+-- Generation Time: Apr 28, 2025 at 06:36 AM
 -- Server version: 10.11.3-MariaDB-1:10.11.3+maria~ubu2204
 -- PHP Version: 8.1.19
 
@@ -48,8 +48,8 @@ CREATE TABLE IF NOT EXISTS `accounts` (
 CREATE TABLE IF NOT EXISTS `cards` (
   `id` int(11) NOT NULL AUTO_INCREMENT,
   `account_id` int(11) NOT NULL,
-  `number` int(11) NOT NULL,
-  `expiration` timestamp NOT NULL,
+  `number` int(11) UNSIGNED NOT NULL,
+  `expiration` varchar(10) NOT NULL,
   `cvc` int(11) NOT NULL,
   PRIMARY KEY (`id`),
   KEY `account_id` (`account_id`)
@@ -57,6 +57,22 @@ CREATE TABLE IF NOT EXISTS `cards` (
 
 -- --------------------------------------------------------
 
+--
+-- Table structure for table `receivers`
+--
+
+CREATE TABLE IF NOT EXISTS `receivers` (
+  `id` int(11) NOT NULL AUTO_INCREMENT,
+  `user_id` int(11) NOT NULL,
+  `account_id` int(11) NOT NULL,
+  `name` varchar(30) NOT NULL,
+  PRIMARY KEY (`id`),
+  KEY `user_id` (`user_id`),
+  KEY `account_id2` (`account_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+
+-- --------------------------------------------------------
+
 --
 -- Table structure for table `transfers`
 --
@@ -105,6 +121,13 @@ ALTER TABLE `accounts`
 ALTER TABLE `cards`
   ADD CONSTRAINT `account_id` FOREIGN KEY (`account_id`) REFERENCES `accounts` (`id`) ON DELETE CASCADE ON UPDATE CASCADE;
 
+--
+-- Constraints for table `receivers`
+--
+ALTER TABLE `receivers`
+  ADD CONSTRAINT `account_id2` FOREIGN KEY (`account_id`) REFERENCES `accounts` (`id`) ON DELETE CASCADE ON UPDATE CASCADE,
+  ADD CONSTRAINT `user_id` FOREIGN KEY (`user_id`) REFERENCES `users` (`id`) ON DELETE CASCADE ON UPDATE CASCADE;
+
 --
 -- Constraints for table `transfers`
 --

back/libs/mysql.js

@@ -211,10 +211,11 @@ function removeCard(connection, id) {
 function getUserTransfers(connection, id) {
 	return new Promise((resolve, reject) => {
 		connection.query(
-			`SELECT * 
+			`SELECT transfers.*, sender.name AS sender_name, users.name AS receiver_name, users.lastname AS receiver_lastname
 			 FROM transfers
 			 JOIN accounts as sender ON transfers.account_from_id = sender.id
 			 JOIN accounts as receiver ON transfers.account_to_id = receiver.id
+			 JOIN users ON receiver.client_id = users.id
 			 WHERE sender.client_id = ? OR receiver.client_id = ?`,
 			[id, id],
 			(error, result) => {
@@ -242,6 +243,59 @@ function addTransfer(connection, account_from_id, account_to_id, name, amount) {
 	});
 }
 
+// +-------------------------------+
+// |          Receivers            |
+// +-------------------------------+
+
+function getUserReceivers(connection, id) {
+	return new Promise((resolve, reject) => {
+		connection.query(
+			`SELECT receivers.*
+			 FROM receivers 
+			 JOIN users ON receivers.user_id = users.id
+			 JOIN accounts ON receivers.account_id = accounts.id
+			 WHERE users.id = ?`,
+			[id],
+			(error, result) => {
+				if (error) {
+					reject(new Error(error));
+				}
+				resolve(result);
+			}
+		);
+	});
+}
+
+function addReceiver(connection, user_id, account_id, name) {
+	return new Promise((resolve, reject) => {
+		connection.query(
+			`INSERT INTO receivers (user_id, account_id, name) VALUES (?, ?, ?)`,
+			[user_id, account_id, name],
+			(error, result) => {
+				if (error) {
+					reject(new Error(error));
+				}
+				resolve(result);
+			}
+		);
+	});
+}
+
+function removeReceiver(connection, id) {
+	return new Promise((resolve, reject) => {
+		connection.query(
+			`DELETE FROM receivers WHERE id = ?`,
+			[id],
+			(error, result) => {
+				if (error) {
+					reject(new Error(error));
+				}
+				resolve(result);
+			}
+		);
+	});
+}
+
 module.exports = {
 	getConnection,
 
@@ -262,4 +316,8 @@ module.exports = {
 
 	getUserTransfers,
 	addTransfer,
+
+	getUserReceivers,
+	addReceiver,
+	removeReceiver,
 };