Improvements to the runs replication service, now ready for testing

Author: ericallam

apps/webapp/app/env.server.ts

@@ -765,6 +765,7 @@ const EnvironmentSchema = z.object({
   RUN_REPLICATION_LEADER_LOCK_TIMEOUT_MS: z.coerce.number().int().default(30_000),
   RUN_REPLICATION_LEADER_LOCK_EXTEND_INTERVAL_MS: z.coerce.number().int().default(10_000),
   RUN_REPLICATION_ACK_INTERVAL_SECONDS: z.coerce.number().int().default(10),
+  RUN_REPLICATION_LOG_LEVEL: z.enum(["log", "error", "warn", "info", "debug"]).default("info"),
 });
 
 export type Environment = z.infer<typeof EnvironmentSchema>;

apps/webapp/app/routes/admin.api.v1.runs-replication.start.ts

@@ -2,11 +2,6 @@ import { ActionFunctionArgs, json } from "@remix-run/server-runtime";
 import { prisma } from "~/db.server";
 import { authenticateApiRequestWithPersonalAccessToken } from "~/services/personalAccessToken.server";
 import { runsReplicationInstance } from "~/services/runsReplicationInstance.server";
-import { z } from "zod";
-
-const schema = z.object({
-  insertStrategy: z.enum(["streaming", "batching"]).optional(),
-});
 
 export async function action({ request }: ActionFunctionArgs) {
   // Next authenticate the request
@@ -31,10 +26,7 @@ export async function action({ request }: ActionFunctionArgs) {
   }
 
   try {
-    const body = await request.json();
-    const { insertStrategy } = schema.parse(body);
-
-    await runsReplicationInstance?.start(insertStrategy);
+    await runsReplicationInstance?.start();
 
     return json({
       success: true,

apps/webapp/app/services/runsReplicationInstance.server.ts

@@ -46,6 +46,7 @@ function initializeRunsReplicationInstance() {
     leaderLockTimeoutMs: env.RUN_REPLICATION_LEADER_LOCK_TIMEOUT_MS,
     leaderLockExtendIntervalMs: env.RUN_REPLICATION_LEADER_LOCK_EXTEND_INTERVAL_MS,
     ackIntervalSeconds: env.RUN_REPLICATION_ACK_INTERVAL_SECONDS,
+    logLevel: env.RUN_REPLICATION_LOG_LEVEL,
   });
 
   if (env.RUN_REPLICATION_ENABLED === "1") {