feat: add calculation vs CRUD service type templates

- Add separate templates for calculation services (scoring, analysis, transformation)
- Add separate templates for CRUD services (entity management)
- Auto-generate operations/index.ts barrel export
- Auto-register routes in app.ts
- Add db-extensions make target for pgvector support
- Add generate:cli script alias
- Fix notifyCreation critical flag (should be false)
- Improve prompts with better defaults based on service type

Author: scotty595

Makefile

@@ -1,4 +1,4 @@
-.PHONY: help setup up down restart logs dev test test-watch lint format typecheck build clean generate db-migrate db-studio db-push db-reset docker-clean all
+.PHONY: help setup up down restart logs dev test test-watch lint format typecheck build clean generate db-extensions db-migrate db-studio db-push db-reset docker-clean all
 
 # Default target - show help
 help:
@@ -32,6 +32,7 @@ help:
 	@echo "  make typecheck      - Run TypeScript type checking"
 	@echo ""
 	@echo "🗄️  Database:"
+	@echo "  make db-extensions  - Install PostgreSQL extensions (pgvector, etc.)"
 	@echo "  make db-migrate     - Run Prisma migrations"
 	@echo "  make db-studio      - Open Prisma Studio"
 	@echo "  make db-push        - Push schema changes"
@@ -74,12 +75,18 @@ logs:
 	@echo "📜 Showing Docker logs..."
 	@npm run docker:logs
 
+# Initialize PostgreSQL extensions (required for pgvector, etc.)
+db-extensions:
+	@echo "🔌 Ensuring PostgreSQL extensions are installed..."
+	@docker exec fastify_postgres psql -U postgres -d fastify_starter -c 'CREATE EXTENSION IF NOT EXISTS "uuid-ossp"; CREATE EXTENSION IF NOT EXISTS "pgcrypto"; CREATE EXTENSION IF NOT EXISTS "vector";' 2>/dev/null || true
+
 # Main entry point - like DriftOS!
 up: docker-up
 	@echo "⏳ Waiting for PostgreSQL to be ready..."
 	@sleep 8
-	@echo "🗄️  Running database migrations..."
-	@npm run db:migrate
+	@$(MAKE) db-extensions
+	@echo "🗄️  Pushing database schema..."
+	@npm run db:push
 	@echo "📊 Generating Grafana dashboards..."
 	@npm run generate:dashboards || echo "⚠️  No orchestrators found yet"
 	@echo ""

package.json

@@ -33,6 +33,7 @@
     "generate:operation": "plop operation",
     "generate:route": "plop route",
     "generate:dashboards": "tsx scripts/generate-dashboards.ts",
+    "generate:cli": "node scripts/gen-service.mjs",
     "load-test": "tsx scripts/load-test.ts",
     "prepare": "husky install || true"
   },

plop-templates/service/facade-calculation.hbs

@@ -0,0 +1,77 @@
+import { {{pascalCase name}}Orchestrator } from './orchestrator.js';
+import type { {{pascalCase name}}Result, {{pascalCase name}}Policy, {{pascalCase name}}Input } from './types/index.js';
+import type { OrchestratorResult } from '@core/orchestration/index.js';
+
+/**
+ * {{pascalCase name}} Service (Calculation)
+ *
+ * Service facade implementing the singleton pattern.
+ * Adapts external params to internal orchestrator.
+ *
+ * Generated by: npm run generate
+ */
+
+/**
+ * Default policy
+ */
+const DEFAULT_POLICY: {{pascalCase name}}Policy = {
+  threshold: 0.75
+  // TODO: Add policy defaults
+};
+
+export class {{pascalCase name}}Service {
+  private static instance: {{pascalCase name}}Service;
+  private orchestrator: {{pascalCase name}}Orchestrator;
+
+  private constructor() {
+    this.orchestrator = new {{pascalCase name}}Orchestrator();
+  }
+
+  /**
+   * Get singleton instance
+   */
+  public static getInstance(): {{pascalCase name}}Service {
+    if (!{{pascalCase name}}Service.instance) {
+      {{pascalCase name}}Service.instance = new {{pascalCase name}}Service();
+    }
+    return {{pascalCase name}}Service.instance;
+  }
+
+  /**
+   * Calculate {{camelCase name}}
+   *
+   * @param id - Entity ID
+   * @param data - Input data
+   * @param policy - Optional policy override
+   * @returns Calculation result
+   */
+  async calculate(
+    id: string,
+    data: Record<string, unknown>,
+    policy: Partial<{{pascalCase name}}Policy> = {}
+  ): Promise<OrchestratorResult<{{pascalCase name}}Result>> {
+    const mergedPolicy: {{pascalCase name}}Policy = {
+      ...DEFAULT_POLICY,
+      ...policy
+    };
+
+    return this.orchestrator.execute({
+      id,
+      data,
+      policy: mergedPolicy
+    });
+  }
+
+  /**
+   * Health check
+   */
+  public async healthCheck(): Promise<{ status: string; service: string }> {
+    return {
+      status: 'healthy',
+      service: '{{pascalCase name}}Service',
+    };
+  }
+}
+
+// Export singleton instance
+export const {{camelCase name}}Service = {{pascalCase name}}Service.getInstance();

plop-templates/service/facade-crud.hbs

@@ -0,0 +1,52 @@
+import { Create{{pascalCase name}}Orchestrator } from './orchestrator.js';
+import type { Create{{pascalCase name}}Input, {{pascalCase name}} } from './types/index.js';
+import type { OrchestratorResult } from '@core/orchestration/index.js';
+
+/**
+ * {{pascalCase name}} Service (CRUD)
+ *
+ * Service facade implementing the singleton pattern.
+ * Public API for all {{camelCase name}} operations.
+ *
+ * Generated by: npm run generate
+ */
+export class {{pascalCase name}}Service {
+  private static instance: {{pascalCase name}}Service;
+  private createOrchestrator: Create{{pascalCase name}}Orchestrator;
+
+  private constructor() {
+    this.createOrchestrator = new Create{{pascalCase name}}Orchestrator();
+  }
+
+  /**
+   * Get singleton instance
+   */
+  public static getInstance(): {{pascalCase name}}Service {
+    if (!{{pascalCase name}}Service.instance) {
+      {{pascalCase name}}Service.instance = new {{pascalCase name}}Service();
+    }
+    return {{pascalCase name}}Service.instance;
+  }
+
+  /**
+   * Create a new {{camelCase name}}
+   */
+  public async create{{pascalCase name}}(
+    input: Create{{pascalCase name}}Input
+  ): Promise<OrchestratorResult<{{pascalCase name}}>> {
+    return this.createOrchestrator.execute(input);
+  }
+
+  /**
+   * Health check
+   */
+  public async healthCheck(): Promise<{ status: string; service: string }> {
+    return {
+      status: 'healthy',
+      service: '{{pascalCase name}}Service',
+    };
+  }
+}
+
+// Export singleton instance
+export const {{camelCase name}}Service = {{pascalCase name}}Service.getInstance();

plop-templates/service/operation-calculation.hbs

@@ -0,0 +1,28 @@
+import type { {{pascalCase name}}Context } from '../types/index.js';
+
+/**
+ * {{pascalCase operation}} Operation
+ *
+ * This is a pure function that takes context and returns context.
+ * Implement your calculation logic here.
+ *
+ * Generated by: npm run generate
+ */
+export async function {{camelCase operation}}(
+  ctx: {{pascalCase name}}Context
+): Promise<{{pascalCase name}}Context> {
+  // Skip if previous errors
+  if (ctx.errors.length > 0) {
+    return ctx;
+  }
+
+  // TODO: Implement your operation logic
+
+  // Store results in context
+  ctx.results.{{camelCase operation}} = {
+    completed: true,
+    timestamp: new Date().toISOString(),
+  };
+
+  return ctx;
+}

plop-templates/service/operation-crud.hbs

@@ -0,0 +1,28 @@
+import type { {{pascalCase name}}PipelineContext } from '../types/index.js';
+
+/**
+ * {{pascalCase operation}} Operation
+ *
+ * This is a pure function that takes context and returns context.
+ * Implement your business logic here.
+ *
+ * Generated by: npm run generate
+ */
+export async function {{camelCase operation}}(
+  context: {{pascalCase name}}PipelineContext
+): Promise<{{pascalCase name}}PipelineContext> {
+  // Skip if previous errors
+  if (context.errors.length > 0) {
+    return context;
+  }
+
+  // TODO: Implement your operation logic
+
+  // Store results in context
+  context.results.{{camelCase operation}} = {
+    completed: true,
+    timestamp: new Date().toISOString(),
+  };
+
+  return context;
+}

plop-templates/service/operations-index.hbs

@@ -0,0 +1,10 @@
+/**
+ * {{pascalCase name}} Operations
+ * Barrel export
+ *
+ * Generated by: npm run generate
+ */
+
+{{#each operations}}
+export { {{camelCase this}} } from './{{kebabCase this}}.js';
+{{/each}}

plop-templates/service/orchestrator-calculation.hbs

@@ -0,0 +1,68 @@
+import { BaseOrchestrator, DefaultPerformanceTracker } from '@core/orchestration/index.js';
+import type { PipelineStage } from '@core/orchestration/index.js';
+import type {
+  {{pascalCase name}}Context,
+  {{pascalCase name}}Result,
+  {{pascalCase name}}Input
+} from './types/index.js';
+import * as ops from './operations/index.js';
+
+/**
+ * {{pascalCase name}} Orchestrator (Calculation)
+ *
+ * Internal orchestrator - called via {{pascalCase name}}Service facade.
+ *
+ * Generated by: npm run generate
+ */
+export class {{pascalCase name}}Orchestrator extends BaseOrchestrator<
+  {{pascalCase name}}Context,
+  {{pascalCase name}}Result,
+  {{pascalCase name}}Input
+> {
+  constructor() {
+    super({
+      name: '{{pascalCase name}}Orchestrator',
+      timeout: 5000,
+      enableMetrics: true,
+      logErrors: true,
+    });
+  }
+
+  protected async initializeContext(input: {{pascalCase name}}Input): Promise<{{pascalCase name}}Context> {
+    return {
+      ...input,
+      policy: input.policy ?? { threshold: 0.75 },
+      requestId: Math.random().toString(36).substr(2, 9),
+      startTime: Date.now(),
+      perfTracker: new DefaultPerformanceTracker(),
+      results: {},
+      errors: [],
+      metadata: {
+        orchestrator: this.getName(),
+      },
+      reasonCodes: []
+    };
+  }
+
+  protected getPipeline(): PipelineStage<{{pascalCase name}}Context>[] {
+    return [
+      {{#each operations}}
+      {
+        name: '{{kebabCase this}}',
+        operation: ops.{{camelCase this}},
+        critical: true,
+        timeout: 2000,
+      },
+      {{/each}}
+    ];
+  }
+
+  protected buildResult(ctx: {{pascalCase name}}Context): {{pascalCase name}}Result {
+    return {
+      score: ctx.score,
+      reasonCodes: ctx.reasonCodes,
+      metadata: ctx.metadata
+      // TODO: Add result fields from context
+    };
+  }
+}

plop-templates/service/orchestrator-crud.hbs

@@ -0,0 +1,67 @@
+import { BaseOrchestrator, DefaultPerformanceTracker } from '@core/orchestration/index.js';
+import type { PipelineStage } from '@core/orchestration/index.js';
+import type {
+  {{pascalCase name}}PipelineContext,
+  Create{{pascalCase name}}Input,
+  {{pascalCase name}}
+} from './types/index.js';
+import * as ops from './operations/index.js';
+
+/**
+ * {{pascalCase name}} Orchestrator (CRUD)
+ *
+ * Implements the Golden Orchestrator pattern for {{pascalCase name}} operations.
+ *
+ * Generated by: npm run generate
+ */
+export class Create{{pascalCase name}}Orchestrator extends BaseOrchestrator<
+  {{pascalCase name}}PipelineContext,
+  {{pascalCase name}},
+  Create{{pascalCase name}}Input
+> {
+  constructor() {
+    super({
+      name: 'Create{{pascalCase name}}Orchestrator',
+      timeout: 5000,
+      enableMetrics: true,
+      logErrors: true,
+    });
+  }
+
+  protected async initializeContext(
+    input: Create{{pascalCase name}}Input
+  ): Promise<{{pascalCase name}}PipelineContext> {
+    return {
+      requestId: Math.random().toString(36).substr(2, 9),
+      startTime: Date.now(),
+      perfTracker: new DefaultPerformanceTracker(),
+      input,
+      results: {},
+      errors: [],
+      metadata: {
+        orchestrator: this.getName(),
+        inputType: 'Create{{pascalCase name}}Input',
+      },
+    };
+  }
+
+  protected getPipeline(): PipelineStage<{{pascalCase name}}PipelineContext>[] {
+    return [
+      {{#each operations}}
+      {
+        name: '{{kebabCase this}}',
+        operation: ops.{{camelCase this}},
+        critical: true,
+        timeout: 2000,
+      },
+      {{/each}}
+    ];
+  }
+
+  protected buildResult(context: {{pascalCase name}}PipelineContext): {{pascalCase name}} {
+    if (!context.{{camelCase name}}) {
+      throw new Error('{{pascalCase name}} creation failed - no {{camelCase name}} in context');
+    }
+    return context.{{camelCase name}};
+  }
+}