fix: dailySatSummary job depends on views-days

stackernews · Jan 7, 2025 · 4a67890 · 4a67890
1 parent 3a09439
commit 4a67890
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 18 deletions.
diff --git a/prisma/migrations/20241223184742_satsummary_job/migration.sql b/prisma/migrations/20241223184742_satsummary_job/migration.sql
diff --git a/worker/index.js b/worker/index.js
@@ -14,7 +14,6 @@ import { ApolloClient, HttpLink, InMemoryCache } from '@apollo/client'
 import { indexItem, indexAllItems } from './search'
 import { timestampItem } from './ots'
 import { computeStreaks, checkStreak } from './streak'
-import { dailySatSummary } from './satSummary'
 import { nip57 } from './nostr'
 import fetch from 'cross-fetch'
 import { authenticatedLndGrpc } from '@/lib/lnd'
@@ -132,7 +131,6 @@ async function work () {
   await boss.work('earn', jobWrapper(earn))
   await boss.work('streak', jobWrapper(computeStreaks))
   await boss.work('checkStreak', jobWrapper(checkStreak))
-  await boss.work('dailySatSummary', jobWrapper(dailySatSummary))
   await boss.work('nip57', jobWrapper(nip57))
   await boss.work('views-*', jobWrapper(views))
   await boss.work('rankViews', jobWrapper(rankViews))

diff --git a/worker/satSummary.js b/worker/satSummary.js
@@ -1,6 +1,7 @@
 import { notifySatSummary } from '@/lib/webPush'
 import { msatsToSats } from '@/lib/format'
 export async function dailySatSummary ({ models }) {
+  console.log('running dailySatSummary')
   try {
     const stats = await models.$queryRaw`
       SELECT 
@@ -26,5 +27,7 @@ export async function dailySatSummary ({ models }) {
     }
   } catch (err) {
     console.error('failed to process daily sat summary', err)
+  } finally {
+    console.log('finished dailySatSummary')
   }
 }
diff --git a/worker/views.js b/worker/views.js
@@ -1,4 +1,5 @@
 import createPrisma from '@/lib/create-prisma'
+import { dailySatSummary } from './satSummary'
 
 const viewPrefixes = ['reg_growth', 'spender_growth', 'item_growth', 'spending_growth',
   'stackers_growth', 'stacking_growth', 'user_stats', 'sub_stats']
@@ -22,6 +23,7 @@ export async function views ({ data: { period } = { period: 'days' } }) {
       await models.$queryRawUnsafe(`REFRESH MATERIALIZED VIEW CONCURRENTLY ${view}_${period}`)
     }
   } finally {
+    if (period === 'days') await dailySatSummary({ models }).catch(console.error) // run dailySatSummary after views-days refresh
     await models.$disconnect()
   }
 }