fix: full-sync not scheduling jobs

Author: wei

deno.json

@@ -17,7 +17,7 @@
     "@probot/pino": "npm:@probot/pino@^2.5.0",
     "@std/assert": "jsr:@std/assert@1",
     "@std/http": "jsr:@std/http@1",
-    "@wei/probot-scheduler": "jsr:@wei/[email protected].13",
+    "@wei/probot-scheduler": "jsr:@wei/[email protected].15",
     "bullmq": "npm:bullmq@^5.26.2",
     "express": "npm:express@^4.21.1",
     "ioredis": "npm:ioredis@^5.4.1",

deno.lock

@@ -15,7 +15,7 @@ services:
     ## Skip full-sync on startup:
     # command: deno task dev:skip-full-sync
     ## Run full-sync manually:
-    # > docker exec -it <CONTAINER_NAME> deno task full-sync
+    # > docker exec -it pull-app-1 deno task full-sync
 
   worker:
     build: .

docker-compose.yml

@@ -2,6 +2,7 @@ import { connectMongoDB, disconnectMongoDB } from "@/src/configs/database.ts";
 import { fullSync } from "@wei/probot-scheduler";
 import { createProbot } from "probot";
 import logger from "@/src/utils/logger.ts";
+import { getRepositorySchedule } from "@/src/utils/get-repository-schedule.ts";
 
 async function main() {
   let exitCode = 0;
@@ -10,7 +11,9 @@ async function main() {
     await connectMongoDB();
 
     const probot = createProbot({ overrides: { log: logger } });
-    await fullSync(probot, null);
+    await fullSync(probot, {
+      getRepositorySchedule,
+    });
   } catch (error) {
     logger.error(error, "Error during full sync");
     exitCode = 1;

scripts/full-sync.ts

@@ -1,18 +1,13 @@
 import express from "express";
 import { createNodeMiddleware, createProbot } from "probot";
-import {
-  createSchedulerService,
-  JobPriority,
-  RepositoryMetadataSchemaType,
-  RepositorySchemaType,
-} from "@wei/probot-scheduler";
+import { createSchedulerService } from "@wei/probot-scheduler";
 import createSchedulerApp from "@/src/app.ts";
 import { appConfig } from "@/src/configs/app-config.ts";
 import log from "@/src/utils/logger.ts";
 import { connectMongoDB, disconnectMongoDB } from "@/src/configs/database.ts";
-import { getRandomCronSchedule } from "@/src/utils/helpers.ts";
 import { getRedisClient } from "@/src/configs/redis.ts";
 import createRouter from "@/src/router/index.ts";
+import { getRepositorySchedule } from "@/src/utils/get-repository-schedule.ts";
 
 const args = Deno.args;
 const skipFullSync = args.includes("--skip-full-sync");
@@ -26,17 +21,6 @@ const probot = createProbot({
     log,
   },
 });
-// deno-lint-ignore require-await
-async function getRepositorySchedule(
-  repository: RepositorySchemaType,
-  currentMetadata?: RepositoryMetadataSchemaType,
-) {
-  return {
-    repository_id: repository.id,
-    cron: currentMetadata?.cron ?? getRandomCronSchedule(),
-    job_priority: currentMetadata?.job_priority ?? JobPriority.Normal,
-  };
-}
 const schedulerApp = createSchedulerApp.bind(null, probot, {
   // Optional: Skip the initial full sync
   skipFullSync,

src/index.ts

@@ -0,0 +1,18 @@
+import {
+  JobPriority,
+  type RepositoryMetadataSchemaType,
+  type RepositorySchemaType,
+} from "@wei/probot-scheduler";
+import { getRandomCronSchedule } from "@/src/utils/helpers.ts";
+
+// deno-lint-ignore require-await
+export async function getRepositorySchedule(
+  repository: RepositorySchemaType,
+  currentMetadata?: RepositoryMetadataSchemaType,
+) {
+  return {
+    repository_id: repository.id,
+    cron: currentMetadata?.cron ?? getRandomCronSchedule(),
+    job_priority: currentMetadata?.job_priority ?? JobPriority.Normal,
+  };
+}