Improved tasks

nimiq · Jun 11, 2024 · 59aa906 · 59aa906
1 parent 0bcd399
commit 59aa906
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/nuxt.config.ts b/nuxt.config.ts
@@ -53,7 +53,7 @@ export default defineNuxtConfig({
     },
 
     scheduledTasks: {
-      '0 */12 * * *': ['fetch']
+      '0 */12 * * *': ['fetch', 'seed', 'score'],
     }
   },
 

diff --git a/server/database/utils.ts b/server/database/utils.ts
@@ -103,7 +103,7 @@ type ValidatorParams = Record<
  */
 export async function getMissingEpochs(range: Range) {
   const existingEpochs = await useDrizzle()
-    .select({ epochBlockNumber: tables.activity.epochBlockNumber })
+    .selectDistinct({ epochBlockNumber: tables.activity.epochBlockNumber })
     .from(tables.activity)
     .where(and(gte(tables.activity.epochBlockNumber, range.fromEpoch), lte(tables.activity.epochBlockNumber, range.toEpoch)))
     .execute().then(r => r.map(r => r.epochBlockNumber))

diff --git a/server/tasks/fetch.ts b/server/tasks/fetch.ts
@@ -47,6 +47,6 @@ export default defineTask({
       await storeActivities(epochsActivities);
     }
 
-    return { result: `Task initialized` }
+    return { result: `${epochBlockNumbers.length} epochs fetched` }
   },
 })
diff --git a/server/tasks/score.ts b/server/tasks/score.ts
@@ -7,7 +7,7 @@ import { getValidatorParams, storeScores } from '../database/utils'
 export default defineTask({
   meta: {
     name: "db:compute-score",
-    description: "computes the VTS score",
+    description: "Computes the VTS score",
   },
   async run() {
     consola.info("Running db:compute-score task...")