Add job to complete incomplete unboardings before releasing the new onboarding

We need to make sure all current users have the onboarding completed before removing the feature flag, else they will go through it when they already know how to use the app.

Author: learningbizz

apps/workers/src/workers/schedule.ts

@@ -51,4 +51,11 @@ export async function setupSchedules() {
     { pattern: '0 0 1 * * *' },
     { opts: { attempts: 1 } },
   )
+
+  // Every day at 9 PM to add smth - This will be deleted after its run once
+  await maintenanceQueue.upsertJobScheduler(
+    'fillOnboardingsAsCompletedJob',
+    { pattern: '0 0 21 * * *' },
+    { opts: { attempts: 1 } },
+  )
 }

apps/workers/src/workers/worker-definitions/maintenanceWorker.ts

@@ -16,6 +16,7 @@ const jobMappings = {
   requestDocumentSuggestionsJob: jobs.requestDocumentSuggestionsJob,
   scaleDownMcpServerJob: jobs.scaleDownMcpServerJob,
   updateMcpServerLastUsedJob: jobs.updateMcpServerLastUsedJob,
+  fillOnboardingsAsCompletedJob: jobs.fillOnboardingsAsCompletedJob,
 }
 
 export function startMaintenanceWorker() {

packages/core/src/jobs/job-definitions/maintenance/fillOnboardingsAsCompletedJob.ts

@@ -0,0 +1,24 @@
+import { Job } from 'bullmq'
+import { Result } from '../../../lib/Result'
+import { workspaceOnboarding } from '../../../schema/models/workspaceOnboarding'
+import { database } from '../../../client'
+import { isNull } from 'drizzle-orm'
+
+export type FillOnboardingsAsCompletedJobData = Record<string, never>
+
+export const fillOnboardingsAsCompletedJob = async (
+  _: Job<FillOnboardingsAsCompletedJobData>,
+) => {
+  const updatedOnboardings = await database
+    .update(workspaceOnboarding)
+    .set({
+      completedAt: new Date(),
+    })
+    .where(isNull(workspaceOnboarding.completedAt))
+    .returning()
+
+  return Result.ok({
+    success: true,
+    updatedOnboardings: updatedOnboardings.length,
+  })
+}

packages/core/src/jobs/job-definitions/maintenance/index.ts

@@ -4,3 +4,4 @@ export * from './refreshProjectsStatsCacheJob'
 export * from './refreshProjectStatsCacheJob'
 export * from './scheduleWorkspaceCleanupJobs'
 export * from './cleanupWorkspaceOldLogsJob'
+export * from './fillOnboardingsAsCompletedJob'