Merge pull request #17 from solana-developers/adding-transactions

adding transaction routes

Author: notEduardo

src/db/transactions.js

@@ -0,0 +1,46 @@
+import db from './config.js';
+
+const createTransaction = async (signature, ip_address, wallet_address, github_username, timestamp) => {
+    const query = `
+    INSERT INTO faucet.transactions (signature, ip_address, wallet_address, github_username, timestamp)
+    VALUES ($1, $2, $3, $4, $5)
+    RETURNING *;
+  `;
+    const values = [signature, ip_address, wallet_address, github_username, timestamp];
+    const result = await db.query(query, values);
+    return result.rows[0];
+};
+
+const getLastTransaction = async ({ wallet_address, github_username, ip_address }) => {
+    const query = `
+    SELECT * FROM faucet.transactions
+    WHERE 
+        (wallet_address = $1) OR
+        (github_username = $2) OR
+        (ip_address = $3)
+    ORDER BY timestamp DESC
+    LIMIT 1;
+  `;
+
+    const values = [wallet_address || null, github_username || null, ip_address || null];
+    const result = await db.query(query, values);
+    return result.rows[0]; // Returns the most recent transaction found
+};
+
+// Not currently needed, but may be used for implementing TTL
+const deleteTransaction = async (signature) => {
+    const query = `
+    DELETE FROM faucet.transactions
+    WHERE signature = $1
+    RETURNING *;
+  `;
+    const values = [signature];
+    const result = await db.query(query, values);
+    return result.rows[0];
+};
+
+export default {
+    createTransaction,
+    getLastTransaction,
+    deleteTransaction
+};

src/routes/index.js

@@ -1,5 +1,6 @@
 import express from 'express';
 import rateLimitRoute from './rateLimitRoute.js';
+import transactionsRoute from './transactionsRoute.js';
 import solanaBalancesRoute from "./solanaBalancesRoute.js";
 import githubValidationRoute from "./githubValidationRoute.js";
 
@@ -8,6 +9,9 @@ const router = express.Router();
 // Use rate limit routes
 router.use(rateLimitRoute);
 
+// Use transactions routes
+router.use(transactionsRoute);
+
 // Use Solana balances routes
 router.use(solanaBalancesRoute);
 

src/routes/transactionsRoute.js

@@ -0,0 +1,63 @@
+import express from 'express';
+import transactions from '../db/transactions.js';
+
+const router = express.Router();
+
+// POST a new transaction
+router.post('/transactions', async (req, res, next) => {
+    const { signature, ip_address, wallet_address, github_username, timestamp } = req.body;
+
+    if (!signature || !ip_address || !wallet_address || !timestamp) {
+        return res.status(400).json({ message: 'Missing required fields (signature, ip_address, wallet_address, timestamp).' });
+    }
+
+    try {
+        const newTransaction = await transactions.createTransaction(signature, ip_address, wallet_address, github_username ?? '', timestamp);
+        res.status(201).json(newTransaction);
+    } catch (error) {
+        console.error('Error creating transaction:', error);
+        next(error);
+    }
+});
+
+// GET the most recent transaction based on wallet, GitHub or IP
+router.get('/transactions/last', async (req, res, next) => {
+    const { wallet_address, github_username, ip_address } = req.query;
+
+    if (!wallet_address && !github_username && !ip_address) {
+        return res.status(400).json({ message: 'At least one parameter (wallet_address, github_username, or ip_address) is required.' });
+    }
+
+    try {
+        const lastTransaction = await transactions.getLastTransaction({ wallet_address, github_username, ip_address });
+
+        if (lastTransaction) {
+            res.status(200).json(lastTransaction);
+        } else {
+            res.status(204).json({ message: 'No transaction found for the given criteria.' });
+        }
+    } catch (error) {
+        console.error('Error fetching last transaction:', error);
+        next(error);
+    }
+});
+
+// DELETE a transaction by signature
+router.delete('/transactions/:signature', async (req, res, next) => {
+    const { signature } = req.params;
+
+    try {
+        const deletedTransaction = await transactions.deleteTransaction(signature);
+        if (deletedTransaction) {
+            res.status(200).json(deletedTransaction);
+        } else {
+            console.warn(`Transaction not found for signature "${signature}"`);
+            res.status(404).json({ message: 'Transaction not found' });
+        }
+    } catch (error) {
+        console.error(`Error deleting transaction for signature "${signature}":`, error);
+        next(error);
+    }
+});
+
+export default router;