fix(sync): restore worker incremental API DB resolution

2026-04-10 04:07:27 +00:00
parent b2cd26af30
commit afe56393e7
2 changed files with 19 additions and 0 deletions
@@ -107,6 +107,20 @@ const resolveApiDatabaseUrl = (): string => {
  if (process.env.OPTIMA_API_DATABASE_URL)
    return process.env.OPTIMA_API_DATABASE_URL;

+  // Worker/runtime fallback:
+  // In Kubernetes we often provide CW via CW_DATABASE_URL and API Postgres via
+  // DATABASE_URL. Only use DATABASE_URL as API when we can safely infer that.
+  if (process.env.CW_DATABASE_URL && process.env.DATABASE_URL) {
+    return process.env.DATABASE_URL;
+  }
+
+  if (
+    process.env.DATABASE_URL &&
+    /^(postgres|postgresql):\/\//i.test(process.env.DATABASE_URL)
+  ) {
+    return process.env.DATABASE_URL;
+  }
+
  const candidates = [
    resolve(import.meta.dir, "../../api/.env"),
    resolve(process.cwd(), "../api/.env"),