fix: add gsc worker to bullboard

Author: lindesvard

apps/worker/src/index.ts

@@ -5,16 +5,16 @@ import { createInitialSalts } from '@openpanel/db';
 import {
   cronQueue,
   eventsGroupQueues,
+  gscQueue,
   importQueue,
   insightsQueue,
   miscQueue,
   notificationQueue,
   sessionsQueue,
 } from '@openpanel/queue';
 import express from 'express';
-import client from 'prom-client';
-
 import { BullBoardGroupMQAdapter } from 'groupmq';
+import client from 'prom-client';
 import sourceMapSupport from 'source-map-support';
 import { bootCron } from './boot-cron';
 import { bootWorkers } from './boot-workers';
@@ -39,16 +39,17 @@ async function start() {
     createBullBoard({
       queues: [
         ...eventsGroupQueues.map(
-          (queue) => new BullBoardGroupMQAdapter(queue) as any,
+          (queue) => new BullBoardGroupMQAdapter(queue) as any
         ),
         new BullMQAdapter(sessionsQueue),
         new BullMQAdapter(cronQueue),
         new BullMQAdapter(notificationQueue),
         new BullMQAdapter(miscQueue),
         new BullMQAdapter(importQueue),
         new BullMQAdapter(insightsQueue),
+        new BullMQAdapter(gscQueue),
       ],
-      serverAdapter: serverAdapter,
+      serverAdapter,
     });
 
     app.use('/', serverAdapter.getRouter());

apps/worker/src/jobs/gsc.ts

@@ -1,18 +1,20 @@
 import { db, syncGscData } from '@openpanel/db';
-import { gscQueue } from '@openpanel/queue';
 import type { GscQueuePayload } from '@openpanel/queue';
+import { gscQueue } from '@openpanel/queue';
 import type { Job } from 'bullmq';
 import { logger } from '../utils/logger';
 
 const BACKFILL_MONTHS = 6;
 const CHUNK_DAYS = 14;
 
-export async function gscJob(job: Job<GscQueuePayload>) {
+export function gscJob(job: Job<GscQueuePayload>) {
   switch (job.data.type) {
     case 'gscProjectSync':
       return gscProjectSyncJob(job.data.payload.projectId);
     case 'gscProjectBackfill':
       return gscProjectBackfillJob(job.data.payload.projectId);
+    default:
+      throw new Error('Unknown GSC job type');
   }
 }
 
@@ -59,7 +61,9 @@ async function gscProjectSyncJob(projectId: string) {
 async function gscProjectBackfillJob(projectId: string) {
   const conn = await db.gscConnection.findUnique({ where: { projectId } });
   if (!conn?.siteUrl) {
-    logger.warn('GSC backfill skipped: no connection or siteUrl', { projectId });
+    logger.warn('GSC backfill skipped: no connection or siteUrl', {
+      projectId,
+    });
     return;
   }