feat(011): delete custom execution plumbing + integration tests (WP03+WP04)

.gitignore

@@ -75,6 +75,10 @@ kitty-specs/**/tasks/*.md
 !kitty-specs/009-automated-pipelines-framework/tasks/WP08-api-mcp-tools.md
 !kitty-specs/009-automated-pipelines-framework/tasks/WP09-analytics.md
 !kitty-specs/009-automated-pipelines-framework/tasks/WP10-integration-validation.md
+!kitty-specs/011-inngest-migration/tasks/WP01-port-remaining-pipelines.md
+!kitty-specs/011-inngest-migration/tasks/WP02-update-routes.md
+!kitty-specs/011-inngest-migration/tasks/WP03-delete-custom-plumbing.md
+!kitty-specs/011-inngest-migration/tasks/WP04-integration-tests.md
 
 # Generated artifacts
 **/tmp/

joyus-ai-mcp-server/src/index.ts

@@ -26,7 +26,9 @@ import { requireBearerToken } from './auth/middleware.js';
 import { inngest, allFunctions } from './inngest/index.js';
 import { db, auditLogs } from './db/client.js';
 import { initializeContentModule } from './content/index.js';
-import { initializePipelineModule, type PipelineModule } from './pipelines/init.js';
+import { createStepRegistry } from './pipelines/steps/registry.js';
+import { DecisionRecorder } from './pipelines/review/decision.js';
+import { createPipelineRouter } from './pipelines/routes.js';
 import { initializeScheduler } from './scheduler/index.js';
 import { taskRouter } from './scheduler/routes.js';
 import { executeTool, setPipelineContext } from './tools/executor.js';
@@ -312,22 +314,18 @@ app.listen(PORT, async () => {
   }
 
   // Initialize pipeline module (failure is isolated — won't crash the server)
-  let pipelineModule: PipelineModule | null = null;
   try {
-    pipelineModule = await initializePipelineModule({
-      db: db as unknown as import('drizzle-orm/node-postgres').NodePgDatabase,
-      connectionString: process.env.DATABASE_URL ?? '',
-    });
+    const stepRegistry = createStepRegistry({});
+    const decisionRecorder = new DecisionRecorder(
+      db as unknown as import('drizzle-orm/node-postgres').NodePgDatabase,
+    );
+    const pipelineRouter = createPipelineRouter({ db: db as unknown as import('drizzle-orm/node-postgres').NodePgDatabase, stepRegistry, decisionRecorder });
 
     // Mount pipeline routes
-    app.use('/api', pipelineModule.router);
+    app.use('/api', pipelineRouter);
 
     // Inject pipeline deps into tool executor
-    setPipelineContext({
-      stepRegistry: pipelineModule.stepRegistry,
-      decisionRecorder: pipelineModule.decisionRecorder,
-      eventBus: pipelineModule.eventBus,
-    });
+    setPipelineContext({ stepRegistry, decisionRecorder });
 
     console.log(`   Pipelines: http://localhost:${PORT}/api/pipelines`);
     console.log(`   Inngest:   http://localhost:${PORT}/api/inngest`);
@@ -337,9 +335,6 @@ app.listen(PORT, async () => {
 
   // Graceful shutdown
   const shutdown = async () => {
-    if (pipelineModule) {
-      await pipelineModule.shutdown();
-    }
     process.exit(0);
   };
   process.on('SIGTERM', shutdown);

joyus-ai-mcp-server/src/inngest/adapter.test.ts

@@ -9,7 +9,7 @@ import { inngest } from './client.js';
 import { createCorpusUpdatePipeline } from './functions/corpus-update-pipeline.js';
 import { createScheduleTickPipeline } from './functions/schedule-tick-pipeline.js';
 import type { InngestStep } from './adapter.js';
-import type { PipelineStepHandler, ExecutionContext, StepHandlerRegistry } from '../pipelines/engine/step-runner.js';
+import type { PipelineStepHandler, ExecutionContext, StepHandlerRegistry } from '../pipelines/types.js';
 import type { StepResult } from '../pipelines/types.js';
 
 // ---------------------------------------------------------------------------

joyus-ai-mcp-server/src/inngest/adapter.ts

@@ -5,7 +5,7 @@
  * `step.run()` call. This gives Inngest durable-execution semantics
  * (checkpointing, retries) around existing handler logic.
  */
-import type { PipelineStepHandler, ExecutionContext } from '../pipelines/engine/step-runner.js';
+import type { PipelineStepHandler, ExecutionContext } from '../pipelines/types.js';
 import type { StepResult } from '../pipelines/types.js';
 
 // ---------------------------------------------------------------------------

joyus-ai-mcp-server/src/inngest/functions/content-audit-pipeline.test.ts

@@ -8,7 +8,7 @@
 import { describe, it, expect, vi, beforeEach } from 'vitest';
 import { createContentAuditPipeline } from './content-audit-pipeline.js';
 import type { InngestStep } from '../adapter.js';
-import type { PipelineStepHandler, ExecutionContext, StepHandlerRegistry } from '../../pipelines/engine/step-runner.js';
+import type { PipelineStepHandler, ExecutionContext, StepHandlerRegistry } from '../../pipelines/types.js';
 import type { StepResult } from '../../pipelines/types.js';
 
 // ---------------------------------------------------------------------------

joyus-ai-mcp-server/src/inngest/functions/content-audit-pipeline.ts

@@ -15,7 +15,7 @@
 import { createId } from '@paralleldrive/cuid2';
 import { inngest } from '../client.js';
 import { createInngestAdapter } from '../adapter.js';
-import type { StepHandlerRegistry, ExecutionContext } from '../../pipelines/engine/step-runner.js';
+import type { StepHandlerRegistry, ExecutionContext } from '../../pipelines/types.js';
 import type { StepResult } from '../../pipelines/types.js';
 
 // ---------------------------------------------------------------------------

joyus-ai-mcp-server/src/inngest/functions/corpus-update-pipeline.ts

@@ -16,7 +16,7 @@
 import { createId } from '@paralleldrive/cuid2';
 import { inngest } from '../client.js';
 import { createInngestAdapter } from '../adapter.js';
-import type { StepHandlerRegistry, ExecutionContext } from '../../pipelines/engine/step-runner.js';
+import type { StepHandlerRegistry, ExecutionContext } from '../../pipelines/types.js';
 import type { StepResult } from '../../pipelines/types.js';
 
 // ---------------------------------------------------------------------------