chore(deps): KEEP-1371 bump next from 16.0.10 to 16.1.5

.env.example

@@ -32,4 +32,8 @@ NEXT_PUBLIC_GITHUB_CLIENT_ID=
 
 GOOGLE_CLIENT_ID=
 GOOGLE_CLIENT_SECRET=
-NEXT_PUBLIC_GOOGLE_CLIENT_ID=
+NEXT_PUBLIC_GOOGLE_CLIENT_ID=
+
+# Workflow SDK World (leave unset for local world auto-detection in dev)
+# WORKFLOW_TARGET_WORLD=@workflow/world-postgres
+# WORKFLOW_POSTGRES_URL=postgresql://postgres:postgres@localhost:5433/keeperhub

.gitignore

@@ -29,6 +29,7 @@
 # misc
 .DS_Store
 *.pem
+.workflow-data/
 
 # OS files
 Thumbs.db

.npmrc

@@ -0,0 +1,35 @@
+# Force-hoist the full transitive dependency tree of @workflow/world-postgres.
+# Next.js standalone output tracing cannot follow the dynamic
+# require(process.env.WORKFLOW_TARGET_WORLD) in the workflow SDK.
+# pnpm strict mode keeps transitive deps in .pnpm/ where the
+# outputFileTracingIncludes globs in next.config.ts can't reach them.
+#
+# Regenerate with: node scripts/list-world-deps.mjs
+public-hoist-pattern[]=@vercel/oidc
+public-hoist-pattern[]=@vercel/queue
+public-hoist-pattern[]=@workflow/*
+public-hoist-pattern[]=async-sema
+public-hoist-pattern[]=cbor-x
+public-hoist-pattern[]=cbor-extract
+public-hoist-pattern[]=cron-parser
+public-hoist-pattern[]=luxon
+public-hoist-pattern[]=mixpart
+public-hoist-pattern[]=ms
+public-hoist-pattern[]=pg
+public-hoist-pattern[]=pg-boss
+public-hoist-pattern[]=pg-connection-string
+public-hoist-pattern[]=pg-int8
+public-hoist-pattern[]=pg-pool
+public-hoist-pattern[]=pg-protocol
+public-hoist-pattern[]=pg-types
+public-hoist-pattern[]=pgpass
+public-hoist-pattern[]=postgres-array
+public-hoist-pattern[]=postgres-bytea
+public-hoist-pattern[]=postgres-date
+public-hoist-pattern[]=postgres-interval
+public-hoist-pattern[]=serialize-error
+public-hoist-pattern[]=split2
+public-hoist-pattern[]=type-fest
+public-hoist-pattern[]=ulid
+public-hoist-pattern[]=undici
+public-hoist-pattern[]=xtend

CLAUDE.md

@@ -122,7 +122,7 @@ When you must use an ignore comment:
 - **Database**: PostgreSQL + Drizzle ORM
 - **Testing**: Vitest (unit/integration), Playwright (E2E)
 - **AI**: Vercel AI SDK with Anthropic/OpenAI
-- **Workflow**: Workflow DevKit 4.0.1-beta.17
+- **Workflow**: Workflow DevKit 4.1.0-beta.51
 - **Package Manager**: pnpm
 
 ## Project Structure

app/api/workflow/[workflowId]/execute/route.ts

@@ -39,17 +39,17 @@ async function executeWorkflowBackground(
     });
 
     // Use start() from workflow/api to properly execute the workflow
-    start(executeWorkflow, [
+    const run = await start(executeWorkflow, [
       {
         nodes,
         edges,
         triggerInput: input,
         executionId,
-        workflowId, // Pass workflow ID so steps can fetch credentials
+        workflowId,
       },
     ]);
 
-    console.log("[Workflow Execute] Workflow started successfully");
+    console.log("[Workflow Execute] Workflow started, runId:", run.runId);
   } catch (error) {
     console.error("[Workflow Execute] Error during execution:", error);
     console.error(

app/api/workflows/[workflowId]/webhook/route.ts

@@ -95,7 +95,7 @@ async function executeWorkflowBackground(
       workflowId,
     });
 
-    start(executeWorkflow, [
+    const run = await start(executeWorkflow, [
       {
         nodes,
         edges,
@@ -105,7 +105,7 @@ async function executeWorkflowBackground(
       },
     ]);
 
-    console.log("[Webhook] Workflow started successfully");
+    console.log("[Webhook] Workflow started, runId:", run.runId);
   } catch (error) {
     console.error("[Webhook] Error during execution:", error);
     console.error(

deploy/keeperhub/prod/values.yaml

@@ -3,6 +3,10 @@ shared_env: &shared_env
     type: parameterStore
     name: db-url
     parameter_name: /eks/maker-prod/keeperhub/db-url
+  WORKFLOW_POSTGRES_URL:
+    type: parameterStore
+    name: workflow-postgres-url
+    parameter_name: /eks/maker-prod/keeperhub/db-url
   CHAIN_RPC_CONFIG:
     type: parameterStore
     name: chain-rpc-config
@@ -50,6 +54,19 @@ deployment:
         - -c
       args:
         - |
+          echo "Setting up workflow postgres tables..."
+          export WORKFLOW_POSTGRES_URL=$(node -e "
+            const u = process.env.WORKFLOW_POSTGRES_URL || process.env.DATABASE_URL || '';
+            try { new URL(u); console.log(u); } catch {
+              const s = u.indexOf('://') + 3;
+              const a = u.lastIndexOf('@');
+              const c = u.indexOf(':', s);
+              if (s > 3 && a > c && c > s) {
+                console.log(u.slice(0, s) + encodeURIComponent(u.slice(s, c)) + ':' + encodeURIComponent(u.slice(c + 1, a)) + u.slice(a));
+              } else { console.log(u); }
+            }
+          ")
+          pnpm exec workflow-postgres-setup
           echo "Running database migrations..."
           pnpm db:push
           echo "Seeding chains..."
@@ -123,9 +140,9 @@ env:
   PARA_ENVIRONMENT:
     type: kv
     value: "prod"
-  WORKFLOW_EMBEDDED_DATA_DIR:
+  WORKFLOW_TARGET_WORLD:
     type: kv
-    value: "/tmp/workflow-data"
+    value: "@workflow/world-postgres"
   NEXT_PUBLIC_API_URL:
     type: kv
     value: "http://localhost:3000"

deploy/keeperhub/staging/values.yaml

@@ -3,6 +3,10 @@ shared_env: &shared_env
     type: parameterStore
     name: db-url
     parameter_name: /eks/maker-staging/keeperhub/db-url
+  WORKFLOW_POSTGRES_URL:
+    type: parameterStore
+    name: workflow-postgres-url
+    parameter_name: /eks/maker-staging/keeperhub/db-url
   CHAIN_RPC_CONFIG:
     type: parameterStore
     name: chain-rpc-config
@@ -50,6 +54,19 @@ deployment:
         - -c
       args:
         - |
+          echo "Setting up workflow postgres tables..."
+          export WORKFLOW_POSTGRES_URL=$(node -e "
+            const u = process.env.WORKFLOW_POSTGRES_URL || process.env.DATABASE_URL || '';
+            try { new URL(u); console.log(u); } catch {
+              const s = u.indexOf('://') + 3;
+              const a = u.lastIndexOf('@');
+              const c = u.indexOf(':', s);
+              if (s > 3 && a > c && c > s) {
+                console.log(u.slice(0, s) + encodeURIComponent(u.slice(s, c)) + ':' + encodeURIComponent(u.slice(c + 1, a)) + u.slice(a));
+              } else { console.log(u); }
+            }
+          ")
+          pnpm exec workflow-postgres-setup
           echo "Running database migrations..."
           pnpm db:push
           echo "Seeding chains..."
@@ -114,9 +131,9 @@ env:
   PARA_ENVIRONMENT:
     type: kv
     value: "beta"
-  WORKFLOW_EMBEDDED_DATA_DIR:
+  WORKFLOW_TARGET_WORLD:
     type: kv
-    value: "/tmp/workflow-data"
+    value: "@workflow/world-postgres"
   NEXT_PUBLIC_API_URL:
     type: kv
     value: "http://localhost:3000"

deploy/pr-environment/values.template.yaml

@@ -5,6 +5,9 @@ shared_env: &shared_env
   DATABASE_URL:
     type: kv
     value: "postgresql://keeperhub:${DB_PASSWORD}@keeperhub-pr-${PR_NUMBER}-db-rw.pr-${PR_NUMBER}.svc.cluster.local:5432/keeperhub"
+  WORKFLOW_POSTGRES_URL:
+    type: kv
+    value: "postgresql://keeperhub:${DB_PASSWORD}@keeperhub-pr-${PR_NUMBER}-db-rw.pr-${PR_NUMBER}.svc.cluster.local:5432/keeperhub"
   CHAIN_RPC_CONFIG:
     type: parameterStore
     name: chain-rpc-config
@@ -52,6 +55,19 @@ deployment:
         - -c
       args:
         - |
+          echo "Setting up workflow postgres tables..."
+          export WORKFLOW_POSTGRES_URL=$(node -e "
+            const u = process.env.WORKFLOW_POSTGRES_URL || process.env.DATABASE_URL || '';
+            try { new URL(u); console.log(u); } catch {
+              const s = u.indexOf('://') + 3;
+              const a = u.lastIndexOf('@');
+              const c = u.indexOf(':', s);
+              if (s > 3 && a > c && c > s) {
+                console.log(u.slice(0, s) + encodeURIComponent(u.slice(s, c)) + ':' + encodeURIComponent(u.slice(c + 1, a)) + u.slice(a));
+              } else { console.log(u); }
+            }
+          ")
+          pnpm exec workflow-postgres-setup
           echo "Running database migrations..."
           pnpm db:push
           echo "Seeding chains..."
@@ -105,9 +121,9 @@ env:
   PARA_ENVIRONMENT:
     type: kv
     value: "beta"
-  WORKFLOW_EMBEDDED_DATA_DIR:
+  WORKFLOW_TARGET_WORLD:
     type: kv
-    value: "/tmp/workflow-data"
+    value: "@workflow/world-postgres"
   NEXT_PUBLIC_API_URL:
     type: kv
     value: "http://localhost:3000"

instrumentation.ts

@@ -4,6 +4,30 @@
  * https://nextjs.org/docs/app/building-your-application/optimizing/instrumentation
  */
 
+// start custom keeperhub code //
+/**
+ * Ensure special characters in postgres URL passwords are percent-encoded.
+ * postgres.js parses connection strings via new URL() which requires encoding.
+ * CNPG-generated passwords often contain +/= (base64) that break URL parsing.
+ */
+function encodePostgresPassword(url: string): string {
+  try {
+    new URL(url);
+    return url;
+  } catch {
+    const schemeEnd = url.indexOf("://") + 3;
+    const atIdx = url.lastIndexOf("@");
+    const colonIdx = url.indexOf(":", schemeEnd);
+    if (schemeEnd > 3 && atIdx > colonIdx && colonIdx > schemeEnd) {
+      const user = url.slice(schemeEnd, colonIdx);
+      const pass = url.slice(colonIdx + 1, atIdx);
+      return `${url.slice(0, schemeEnd)}${encodeURIComponent(user)}:${encodeURIComponent(pass)}${url.slice(atIdx)}`;
+    }
+    return url;
+  }
+}
+// end keeperhub code //
+
 export async function register() {
   // Patch console with LOG_LEVEL support
   // This must be imported dynamically to ensure it runs at startup
@@ -32,6 +56,24 @@ export async function register() {
       console.log("[Metrics] Prometheus dual-write collector initialized");
     }
 
+    // start custom keeperhub code //
+    // Initialize Workflow Postgres World (pg-boss queue polling)
+    if (process.env.WORKFLOW_TARGET_WORLD === "@workflow/world-postgres") {
+      const rawUrl =
+        process.env.WORKFLOW_POSTGRES_URL || process.env.DATABASE_URL;
+      if (rawUrl) {
+        process.env.WORKFLOW_POSTGRES_URL = encodePostgresPassword(rawUrl);
+      }
+
+      const { getWorld } = await import("workflow/runtime");
+      const world = getWorld();
+      if (world.start) {
+        await world.start();
+        console.log("[Workflow] Postgres World initialized");
+      }
+    }
+    // end keeperhub code //
+
     // Catch unhandled promise rejections (would otherwise be silent)
     process.on("unhandledRejection", (reason) => {
       console.error(

lib/db/schema.ts

@@ -4,6 +4,7 @@ import {
   index,
   integer,
   jsonb,
+  pgEnum,
   pgTable,
   text,
   timestamp,
@@ -12,6 +13,26 @@ import {
 import type { IntegrationType } from "../types/integration";
 import { generateId } from "../utils/id";
 
+// start custom keeperhub code //
+// These enums are created by @workflow/world-postgres migrations in the public
+// schema and referenced by workflow.workflow_runs / workflow.workflow_steps.
+// Declaring them here prevents drizzle-kit from trying to drop them.
+export const workflowRunStatus = pgEnum("status", [
+  "pending",
+  "running",
+  "completed",
+  "failed",
+  "cancelled",
+]);
+export const workflowStepStatus = pgEnum("step_status", [
+  "pending",
+  "running",
+  "completed",
+  "failed",
+  "cancelled",
+]);
+// end keeperhub code //
+
 // Better Auth tables
 export const users = pgTable("users", {
   id: text("id").primaryKey(),