Merge pull request #226 from BackendsByMTT/dev-g

test 3
BackendsByMTT · Sep 26, 2024 · 06d0971 · 06d0971
2 parents 6daa53c + cbe7d70
commit 06d0971
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/workers/processingQueueWorker.ts b/src/workers/processingQueueWorker.ts
@@ -193,6 +193,7 @@ class ProcessingQueueWorker {
         }
 
         currentBetDetail.status = result;
+        currentBetDetail.isResolved = true;
         await currentBetDetail.save();
         console.log(`BetDetail with ID ${currentBetDetail._id} updated to '${result}'`);
 

diff --git a/src/workers/waitingQueueWorker.ts b/src/workers/waitingQueueWorker.ts
@@ -116,7 +116,7 @@ async function getLatestOddsForAllEvents() {
 
 
 async function migrateAllBetsFromWaitingQueue() {
-  const bets = await redisClient.zrange('waitingQueue', 0, -1); 
+  const bets = await redisClient.zrange('waitingQueue', 0, -1);
 
   for (const bet of bets) {
     const data = JSON.parse(bet);
@@ -126,19 +126,19 @@ async function migrateAllBetsFromWaitingQueue() {
 
       if (!betDetail) {
         console.log(`BetDetail not found for betId: ${betId}, skipping this bet.`);
-        continue; 
+        continue;
       }
 
       if (!betDetail.key) {
         console.log(`BetDetail with ID ${betId} is missing the 'key' field, skipping.`);
-        continue; 
+        continue;
       }
 
       const betParent = await Bet.findById(betDetail.key).lean();
 
       if (!betParent) {
         console.log(`Parent Bet not found for betId: ${betId}, skipping.`);
-        continue; 
+        continue;
       }
 
       await migrateLegacyBet(betDetail);
@@ -150,7 +150,7 @@ async function migrateAllBetsFromWaitingQueue() {
 }
 
 async function migrateLegacyResolvedBets() {
-  const bets = await BetDetail.find({ isResolved: true, status: { $ne: 'pending' } }).lean();
+  const bets = await BetDetail.find({ status: { $ne: 'pending' } }).lean();
   for (const bet of bets) {
     try {
       await migrateLegacyBet(bet);