fix: current prices after initial sync

Author: chedieck

jobs/initJobs.ts

@@ -16,19 +16,7 @@ const main = async (): Promise<void> => {
   await blockchainQueue.obliterate({ force: true })
   await cleanupQueue.obliterate({ force: true })
 
-  await pricesQueue.add('syncCurrentPrices',
-    {},
-    {
-      jobId: 'syncCurrentPrices',
-      removeOnFail: false,
-      repeat: {
-        every: CURRENT_PRICE_REPEAT_DELAY
-      }
-    }
-  )
-
-  await syncCurrentPricesWorker(pricesQueue.name)
-
+  // Start blockchain sync first; current prices job starts only after it completes
   await blockchainQueue.add('syncBlockchainAndPrices',
     {},
     {
@@ -37,7 +25,20 @@ const main = async (): Promise<void> => {
       removeOnFail: true
     }
   )
-  await syncBlockchainAndPricesWorker(blockchainQueue.name)
+  void await syncBlockchainAndPricesWorker(blockchainQueue.name, async () => {
+    await pricesQueue.add('syncCurrentPrices',
+      {},
+      {
+        jobId: 'syncCurrentPrices',
+        removeOnFail: false,
+        repeat: {
+          every: CURRENT_PRICE_REPEAT_DELAY
+        }
+      }
+    )
+    await syncCurrentPricesWorker(pricesQueue.name)
+    console.log('Current prices sync job started after blockchain sync completion.')
+  })
 
   await cleanupQueue.add(
     'cleanupClientPayments',

jobs/workers.ts

@@ -31,7 +31,7 @@ export const syncCurrentPricesWorker = async (queueName: string): Promise<void>
   })
 }
 
-export const syncBlockchainAndPricesWorker = async (queueName: string): Promise<void> => {
+export const syncBlockchainAndPricesWorker = async (queueName: string, onComplete?: () => Promise<void> | void): Promise<void> => {
   const worker = new Worker(
     queueName,
     async (job) => {
@@ -53,6 +53,7 @@ export const syncBlockchainAndPricesWorker = async (queueName: string): Promise<
       await multiBlockchainClient.destroy()
       console.log('Done.')
       console.log(`job ${job.id as string}: blockchain + prices sync finished`)
+      await onComplete?.()
     })()
   })