Merge pull request #888 from PayButton/fix/missing-prices

fix: missing prices

Author: Klakurka

jobs/workers.ts

@@ -87,10 +87,13 @@ export const connectAllTransactionsToPricesWorker = async (queueName: string): P
     queueName,
     async (job) => {
       console.log(`job ${job.id as string}: connecting prices to transactions...`)
+      const noPricesTxs = await transactionService.fetchAllTransactionsWithNoPrices()
+      const wrongNumberOfPricesTxs = await transactionService.fetchAllTransactionsWithIrregularPrices()
       const txs = [
-        ...await transactionService.fetchAllTransactionsWithNoPrices(),
-        ...await transactionService.fetchAllTransactionsWithIrregularPrices()
+        ...noPricesTxs,
+        ...wrongNumberOfPricesTxs
       ]
+      console.log(`found ${noPricesTxs.length} with no prices and ${wrongNumberOfPricesTxs.length} txs with wrong number of prices`)
       void await transactionService.connectTransactionsListToPrices(txs)
     },
     {

services/transactionService.ts

@@ -314,9 +314,9 @@ export async function connectTransactionsListToPrices (txList: Transaction[]): P
         }
       }
     })
-    for (const tx of txList) {
+    await Promise.all(txList.map(async tx =>
       await connectTransactionToPrices(tx, prisma, false)
-    }
+    ))
   })
 }