apps/gateway/src/services/event-router.ts

Metadata

• Purpose: Gateway service module implementing business logic or integrations.
• Domain: applications
• Language: ts
• Bytes: 1077
• Lines: 28
• Content hash (short): 149cb822
• Source (start): apps/gateway/src/services/event-router.ts:1
• Source (end): apps/gateway/src/services/event-router.ts:28

Indexed Symbols

• routeTelemetryEvent (line 9, function) - Implements route telemetry event for service-layer operations.

Markdown Headings (if applicable)

No markdown headings detected.

Source Preview

import type { TelemetryEvent } from "@anchor/contracts";

type RoutedAction = {
  topic: string;
  agent: string;
  reasoner: string;
};

export function routeTelemetryEvent(event: TelemetryEvent): RoutedAction[] {
  switch (event.kind) {
    case "BackupFailure":
      return [
        { topic: "alert.triggered", agent: "backup-assurance-agent", reasoner: "backup-failure-triage" },
        { topic: "ticket.created", agent: "triage-agent", reasoner: "open-backup-incident" }
      ];
    case "PatchCompliance":
      return [{ topic: "asset.state_changed", agent: "patch-agent", reasoner: "patch-compliance-plan" }];
    case "PipelineFailure":
      return [{ topic: "pipeline.failed", agent: "pipeline-observer-agent", reasoner: "pipeline-failure-analysis" }];
    case "ServiceDegraded":
      return [{ topic: "alert.triggered", agent: "runbook-agent", reasoner: "service-restoration-plan" }];
    case "HostHeartbeat":
      return [{ topic: "asset.state_changed", agent: "asset-drift-agent", reasoner: "heartbeat-drift-check" }];
    default:
      return [];