feat: add full-sync and manual-process

Author: wei

deno.jsonc

@@ -3,6 +3,8 @@
     "dev": "deno run --env-file --allow-all src/index.ts",
     "dev:skip-full-sync": "deno task dev --skip-full-sync",
     "worker": "deno run --env-file --allow-all src/worker.ts",
+    "full-sync": "deno run --env-file --allow-all scripts/full-sync.ts",
+    "manual-process": "deno run --env-file --allow-all scripts/manual-process.ts",
     "hook": "deno run --allow-read --allow-run --allow-write https://deno.land/x/[email protected]/mod.ts",
     "install-hooks": "deno task hook install",
     "test": "deno test --allow-net --allow-env --allow-read",

scripts/full-sync.ts

@@ -0,0 +1,25 @@
+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";
+
+async function main() {
+  let exitCode = 0;
+
+  try {
+    await connectMongoDB();
+
+    const probot = createProbot({ overrides: { log: logger } });
+    await fullSync(probot, null);
+  } catch (error) {
+    logger.error(error, "Error during full sync");
+    exitCode = 1;
+  } finally {
+    await disconnectMongoDB();
+    Deno.exit(exitCode);
+  }
+}
+
+if (import.meta.main) {
+  await main();
+}

scripts/manual-process.ts

@@ -0,0 +1,74 @@
+import { connectMongoDB, disconnectMongoDB } from "@/src/configs/database.ts";
+import { JobPriority, RepositoryModel } from "@wei/probot-scheduler";
+import { createProbot } from "probot";
+import logger from "@/src/utils/logger.ts";
+import { getPullConfig } from "@/src/utils/get-pull-config.ts";
+import { Pull } from "@/src/processor/pull.ts";
+
+async function main(full_name: string) {
+  let exitCode = 0;
+
+  try {
+    await connectMongoDB();
+
+    logger.info(`🏃 Processing repo job ${full_name}`);
+
+    try {
+      // Get Octokit
+      const probot = createProbot({ overrides: { log: logger } });
+
+      const repoRecord = await RepositoryModel.findOne({ full_name });
+
+      if (!repoRecord) {
+        logger.error({ full_name }, `❌ Repo record not found`);
+        throw new Error(`❌ Repo record not found`);
+      }
+
+      const { installation_id, owner: { login: owner }, name: repo } =
+        repoRecord;
+
+      const octokit = await probot.auth(installation_id);
+
+      const config = await getPullConfig(octokit, logger, {
+        installation_id,
+        owner,
+        repo,
+        repository_id: 0,
+        metadata: {
+          cron: "",
+          job_priority: JobPriority.Normal,
+          repository_id: 0,
+        },
+      });
+      if (!config) {
+        logger.info(`⚠️ No config found, skipping`);
+        return;
+      }
+
+      const pull = new Pull(octokit, { owner, repo, logger }, config);
+      await pull.routineCheck();
+
+      logger.info(`✅ Repo job processed successfully`);
+    } catch (error) {
+      logger.error(error, "❌ Repo job failed");
+    }
+  } catch (error) {
+    logger.error(error, "Error processing");
+    exitCode = 1;
+  } finally {
+    await disconnectMongoDB();
+    Deno.exit(exitCode);
+  }
+}
+
+if (import.meta.main) {
+  const args = Deno.args;
+  if (args.length !== 1) {
+    logger.error(
+      "Usage: deno task manual-process <owner>/<repo>",
+    );
+    Deno.exit(1);
+  }
+
+  await main(args[0]);
+}