From 7ed0ffe4f73a29b856344b33e57a0c692307aff9 Mon Sep 17 00:00:00 2001
From: jejolare <jejolare@gmail.com>
Date: Thu, 26 Sep 2024 18:11:08 +0700
Subject: [PATCH] fix pool duplicates

---
 server/server.ts | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/server/server.ts b/server/server.ts
index 936bd98..59e3fd6 100644
--- a/server/server.ts
+++ b/server/server.ts
@@ -1538,12 +1538,17 @@ const requestsLimiter = rateLimit({
                                 // Fetch details of the new transactions
                                 let response = await get_pool_txs_details(new_ids);
                                 if (response.data.result && response.data.result.txs) {
+
+                                    const existingTransactions = await Pool.findAll({
+                                        attributes: ['tx_id']
+                                    });
+
                                     const txInserts = response.data.result.txs.map(tx => ({
                                         blob_size: tx.blob_size,
                                         fee: tx.fee,
                                         tx_id: tx.id,
                                         timestamp: tx.timestamp * 1e3,
-                                    }));
+                                    })).filter(tx => !existingTransactions.map(e => e.tx_id).includes(tx.tx_id));
 
                                     // Insert the new transactions into the pool
                                     if (txInserts.length > 0) {