saltbo__agent-kanban/server/http/middleware/errorHandler.ts

import { EnborApiError } from "@realmroot/enbor-sdk";
import { applyRequestIdHeader } from "@server/http/middleware/requestContext";
import { isPublishedV2Operation, v2Problem } from "@server/http/middleware/v2Contract";
import { AgencyProjectInitializationBusy } from "@server/usecases/agency/ensureAgencyProject";
import { RealmrootDelegationFailure } from "@server/usecases/agency/failures";
import { ApplicationError } from "@server/usecases/applicationError";
import type { ErrorHandler } from "hono";
import { HTTPException } from "hono/http-exception";

export const apiErrorHandler: ErrorHandler = (error, c) => {
  applyRequestIdHeader(c);
  c.set("requestError", error);
  const published = isPublishedV2Operation(c.req.method, c.req.path);
  if (error instanceof RealmrootDelegationFailure) {
    const status = delegationStatus(error.kind);
    return v2Problem(
      c,
      status,
      status === 401 || status === 403 ? "delegation-denied" : "delegation-unavailable",
      status === 401 || status === 403 ? "Delegation denied" : "Realmroot delegation unavailable",
      error.message,
    );
  }
  if (error instanceof AgencyProjectInitializationBusy) {
    c.header("Retry-After", "1");
    return v2Problem(c, 503, "enbor-initialization-busy", "Enbor initialization in progress", error.message);
  }
  if (error instanceof EnborApiError) {
    const status = upstreamStatus(error.status);
    return v2Problem(
      c,
      status,
      "enbor-request-failed",
      status === 503 ? "Enbor unavailable" : "Enbor request failed",
      status === 503 ? "Enbor is unavailable" : "Enbor rejected the request",
    );
  }
  if (error instanceof ApplicationError) {
    const status = applicationStatus(error.kind);
    if (published) {
      const title =
        status === 404 ? "Resource not found" : status === 409 ? "Request conflict" : status === 500 ? "Internal server error" : "Request rejected";
      const detail = status === 500 ? "The server could not complete the request" : error.message;
      return v2Problem(c, status, status === 500 ? "internal-error" : "request-rejected", title, detail);
    }
    return c.json(
      {
        error: {
          code: status === 500 ? "INTERNAL_ERROR" : error.message,
          message: status === 500 ? "Internal server error" : error.message,
        },
      },
      status,
    );
  }
  if (error instanceof HTTPException) {
    if (published) {
      const title = error.status === 404 ? "Resource not found" : error.status === 403 ? "Permission denied" : "Request rejected";
      return v2Problem(c, error.status, "request-rejected", title, error.message);
    }
    return c.json({ error: { code: error.message, message: error.message } }, error.status);
  }
  if (published) {
    const invalidJson = error instanceof SyntaxError;
    return v2Problem(
      c,
      invalidJson ? 400 : 500,
      invalidJson ? "invalid-json" : "internal-error",
      invalidJson ? "Invalid JSON" : "Internal server error",
      invalidJson ? "The request body must be valid JSON" : "The server could not complete the request",
    );
  }
  return c.json({ error: { code: "INTERNAL_ERROR", message: "Internal server error" } }, 500);
};

function applicationStatus(kind: ApplicationError["kind"]): 400 | 404 | 409 | 500 {
  if (kind === "not-found") return 404;
  if (kind === "conflict") return 409;
  return kind === "invariant-failed" ? 500 : 400;
}

function upstreamStatus(status: number | undefined): 403 | 404 | 409 | 502 | 503 {
  if (status === 404) return 404;
  if (status === 401 || status === 403) return 403;
  if (status === undefined || status === 408 || status === 429 || (status >= 500 && status !== 502)) return 503;
  if (status === 502 || (status >= 200 && status < 300)) return 502;
  return 409;
}

function delegationStatus(kind: RealmrootDelegationFailure["kind"]): 401 | 403 | 502 | 503 {
  if (kind === "reauthenticate") return 401;
  if (kind === "authority-required" || kind === "denied") return 403;
  return kind === "invalid-response" ? 502 : 503;
}