Feat/crypto wallet

src/controllers/wallet.js

@@ -114,3 +114,88 @@ export const createWallet = async (req, res) => {
     }
 };
 
+// Get all wallets
+export const getAllWallets = async (req, res) => {
+    try {
+        if (!BITNOB_API_KEY) {
+            return res.status(500).json({
+                status: false,
+                message: 'API key is not configured'
+            });
+        }
+
+        const response = await axios({
+            method: 'GET',
+            url: `${BITNOB_API_URL}/wallets`,
+            headers: {
+                'accept': 'application/json',
+                'Authorization': `Bearer ${BITNOB_API_KEY.trim()}`
+            }
+        });
+
+        return res.status(200).json(response.data);
+    } catch (error) {
+        console.error('Error fetching wallets:', error.message);
+
+        if (error.response) {
+            return res.status(error.response.status).json({
+                status: false,
+                message: error.response.data?.message || 'Failed to fetch wallets',
+                details: error.response.data
+            });
+        }
+
+        return res.status(500).json({
+            status: false,
+            message: 'Error fetching wallets'
+        });
+    }
+};
+
+// Get wallet by coin
+export const getWalletByCoin = async (req, res) => {
+    try {
+        const { coin } = req.params;
+
+        if (!coin || !['trx', 'bnb'].includes(coin)) {
+            return res.status(400).json({
+                status: false,
+                message: 'Invalid coin type. Must be either "trx" or "bnb"'
+            });
+        }
+
+        if (!BITNOB_API_KEY) {
+            return res.status(500).json({
+                status: false,
+                message: 'API key is not configured'
+            });
+        }
+
+        const response = await axios({
+            method: 'GET',
+            url: `${BITNOB_API_URL}/wallets/crypto-wallet/${coin}`,
+            headers: {
+                'accept': 'application/json',
+                'Authorization': `Bearer ${BITNOB_API_KEY.trim()}`
+            }
+        });
+
+        return res.status(200).json(response.data);
+    } catch (error) {
+        console.error('Error fetching wallet:', error.message);
+
+        if (error.response) {
+            return res.status(error.response.status).json({
+                status: false,
+                message: error.response.data?.message || 'Failed to fetch wallet',
+                details: error.response.data
+            });
+        }
+
+        return res.status(500).json({
+            status: false,
+            message: 'Error fetching wallet'
+        });
+    }
+};
+

src/index.js

@@ -3,7 +3,7 @@ import hpp from 'hpp';
 import helmet from 'helmet';
 import cors from 'cors';
 import compression from 'compression';
-import { createWallet } from './controllers/wallet.js';
+import walletRoute from './routes/walletRoute.js';
 import { config } from './configs/config.env.js';
 import { customersRouter } from './routes/customersRoutes.js';
 import { BaseError } from './errors/errors.js';
@@ -29,7 +29,7 @@ app.use(compression());
 app.use(json({ limit: '200mb' }));
 app.use(urlencoded({ extended: true, limit: '200mb' }));
 
-createWallet(); // Example usage of createWallet function
+app.use('/api/wallet', walletRoute);
 
 app.use(`${BASE_URL}/customers`, customersRouter);
 
@@ -47,7 +47,7 @@ const start = async () => {
     console.log('Connected to postgres DB');
 
     // Sync all table models
-    await sequelize.sync({alter: true, force: true})
+    await sequelize.sync({alter: true})
     console.log("Models synchronized");
 
     // Start the server

src/routes/walletRoute.js

@@ -1,8 +1,15 @@
 import express from 'express';
-import { createWallet } from '../controllers/wallet.js';
+import { createWallet, getAllWallets, getWalletByCoin } from '../controllers/wallet.js';
 
 const router = express.Router();
 
+// Create wallet
 router.post('/create', createWallet);
 
+// List all wallets
+router.get('/', getAllWallets);
+
+// Get wallet by Coin
+router.get('/coin/:coin', getWalletByCoin);
+
 export default router;