import Fastify from 'fastify';

import cors from '@fastify/cors';

import swagger from '@fastify/swagger';

import { z } from 'zod';

import {

  AgentIdentitySchema,

  DelegationCredentialSchema,

  FeedbackSchema,

  InteractionContractSchema,

  InteractionEventSchema,

  ReceiptSchema,

  FederatedInteractionSchema,

  LiveSessionEventSchema,

  InteractionCompletionReportSchema,

  InteractionFeedbackSchema,

} from '../../../packages/protocol/src/index.js';

import {

  MemoryAuditStore,

  TrustEngine,

  UnavailableFactCheckProvider,

} from '../../../packages/core/src/index.js';

import { buildPublicAgentCard } from '../../../packages/persistence/src/index.js';

import type { AgentProfile, HostedRepository } from '../../../packages/persistence/src/index.js';

import { toA2AAgentCard } from '../../../packages/sidecar/src/index.js';

import {

  approveAgentSetup,

  createHostedProviderAgent,

  getOnboardingState,

  rejectAgentSetup,

} from '../../../packages/persistence/src/onboarding.js';

import { FixedWindowRateLimiter } from './security.js';

type DashboardRepository = Pick<

  HostedRepository,

  | 'getSettings'

  | 'saveSettings'

  | 'upsert'

  | 'list'

  | 'publishAgent'

  | 'unpublishAgent'

  | 'getPublishedAgent'

  | 'resolveAgentReference'

  | 'searchPublishedAgents'

> & {

  dashboard(operatorId: string): Promise<Record<string, unknown>>;

} & Partial<

    Pick<

      HostedRepository,

      | 'createFederatedInteraction'

      | 'listFederatedInteractions'

      | 'getFederatedInteraction'

      | 'respondToFederatedInteraction'

      | 'proposeContractRevision'

      | 'respondToContractRevision'

      | 'getLiveSession'

      | 'getCounterpartyBrief'

      | 'submitCompletionReport'

      | 'recordSessionCompletionReport'

      | 'submitInteractionFeedback'

      | 'recordSessionFeedback'

      | 'listFeedbackRequests'

      | 'recordLiveSessionEvent'

      | 'touchAgentPresence'

      | 'getRuntimeVerificationKey'

      | 'registerAgentRuntime'

      | 'disableAgentRuntime'

      | 'deleteAgent'

      | 'issueAgentAccessToken'

      | 'listAgentAccessTokens'

      | 'revokeAgentAccessToken'

      | 'receiveTemporaryMessage'

      | 'sendTemporaryMessage'

      | 'listHostedThreads'

      | 'getHostedThread'

      | 'markHostedThreadRead'

      | 'closeHostedThread'

    >

  > & {

    listContextualIntelligence?: (

      operatorId: string,

      input?: { agentId?: string; taskCategory?: string },

    ) => Promise<any[]>;

    searchPersonalizedMarketplace?: (

      operatorId: string,

      input?: { agentId?: string; taskCategory?: string; query?: string; limit?: number },

    ) => Promise<any[]>;

  };

export function buildApi(

  engine = new TrustEngine(),

  factChecker = new UnavailableFactCheckProvider(),

  repository?: DashboardRepository,

  security: { internalAuthSecret?: string } = {},

) {

  const app = Fastify({

    bodyLimit: 256 * 1024,

    requestTimeout: 30_000,

    logger: {

      redact: [

        'req.headers.authorization',

        'req.headers.cookie',

        'req.headers.x-openclasp-internal-auth',

        'req.body.rawMessage',

        'req.body.privateKey',

      ],

    },

  });

  const engines = new Map<string, Promise<TrustEngine>>();

  const limiter = new FixedWindowRateLimiter();

  const allowedOrigin = process.env.OPENCLASP_PUBLIC_URL

    ? new URL(process.env.OPENCLASP_PUBLIC_URL).origin

    : undefined;

  void app.register(cors, {

    credentials: Boolean(repository),

    origin(origin, callback) {

      callback(null, !origin || !allowedOrigin || origin === allowedOrigin);

    },

  });

  void app.register(swagger, { openapi: { info: { title: 'OpenClasp API', version: '0.1.0' } } });

  app.addHook('onRequest', async (request, reply) => {

    const method = request.method.toUpperCase();

    if (['GET', 'HEAD', 'OPTIONS'].includes(method)) return;

    const operator = request.headers['x-openclasp-operator'];

    const bucket = typeof operator === 'string' ? `operator:${operator}` : `ip:${request.ip}`;

    const externalSession = request.url.startsWith('/sessions/') || request.url.startsWith('/a2a/');

    const result = limiter.consume(bucket, externalSession ? 300 : 120, 60_000);

    reply.header('x-ratelimit-remaining', result.remaining);

    if (!result.allowed)

      return reply

        .status(429)

        .header('retry-after', result.retryAfterSeconds)

        .send({ error: 'rate_limit_exceeded' });

  });

  app.addHook('onSend', async (_request, reply, payload) => {

    reply.header('x-content-type-options', 'nosniff');

    reply.header('referrer-policy', 'no-referrer');

    reply.header('permissions-policy', 'camera=(), microphone=(), geolocation=()');

    return payload;

  });

  app.setErrorHandler((error, _request, reply) =>

    reply

      .status(

        error instanceof Error && 'statusCode' in error && typeof error.statusCode === 'number'

          ? error.statusCode

          : 400,

      )

      .send({ error: error instanceof Error ? error.message : 'Unknown error' }),

  );

  void app.register(async (router) => {

    const operatorId = (request: { headers: Record<string, unknown> }) => {

      const value = request.headers['x-openclasp-operator'];

      if (

        repository &&

        security.internalAuthSecret &&

        request.headers['x-openclasp-internal-auth'] !== security.internalAuthSecret

      ) {

        const error = new Error('Trusted authentication boundary required');

        Object.assign(error, { statusCode: 401 });

        throw error;

      }

      if (repository && typeof value !== 'string') {

        const error = new Error('Authentication required');

        Object.assign(error, { statusCode: 401 });

        throw error;

      }

      return typeof value === 'string' ? value : undefined;

    };

    const boundAgentId = (request: { headers: Record<string, unknown> }) => {

      const value = request.headers['x-openclasp-bound-agent'];

      if (typeof value !== 'string' || !value) {

        const error = new Error('Agent-bound authentication required');

        Object.assign(error, { statusCode: 401 });

        throw error;

      }

      return value;

    };

    const enforceBoundAgent = (

      request: { headers: Record<string, unknown> },

      requestedAgentId: string,

    ) => {

      const value = request.headers['x-openclasp-bound-agent'];

      if (typeof value === 'string' && value !== requestedAgentId) {

        const error = new Error('Agent credential cannot access another agent');

        Object.assign(error, { statusCode: 403 });

        throw error;

      }

    };

    const scopedEngine = async (request: { headers: Record<string, unknown> }) => {

      const owner = operatorId(request);

      if (!repository || !owner) return engine;

      let pending = engines.get(owner);

      if (!pending) {

        pending = repository.list(owner).then((rows) => {

          const store = new MemoryAuditStore();

          for (const row of rows) {

            if (row.kind !== 'interaction') store.append(row.kind, row.recordId, row.payload);

          }

          return new TrustEngine(store);

        });

        engines.set(owner, pending);

      }

      return pending;

    };

    const persist = async (

      request: { headers: Record<string, unknown> },

      kind: Parameters<HostedRepository['upsert']>[1],

      id: string,

      value: unknown,

    ) => {

      const owner = operatorId(request);

      if (repository && owner) await repository.upsert(owner, kind, id, value);

    };

    const publicBaseUrl = (request: { headers: Record<string, unknown> }) => {

      const forwardedHost = request.headers['x-forwarded-host'];

      const host = typeof forwardedHost === 'string' ? forwardedHost : request.headers.host;

      const forwardedProtocol = request.headers['x-forwarded-proto'];

      const protocol = typeof forwardedProtocol === 'string' ? forwardedProtocol : 'https';

      return process.env.OPENCLASP_PUBLIC_URL ?? `${protocol}://${String(host ?? 'localhost')}`;

    };

    const escapeHtml = (value: string) =>

      value.replace(/[&<>"']/g, (character) => {

        const entities: Record<string, string> = {

          '&': '&',

          '<': '&lt;',

          '>': '>',

          '"': '"',

          "'": ''',

        };

        return entities[character]!;

      });

    router.get('/health', async () => ({ status: 'ok' }));

    router.get('/ready', async () => ({ status: 'ready' }));

    router.get('/openapi.json', async () => app.swagger());

    router.get('/.well-known/openclasp-session-key', async () => {

      if (!repository?.getRuntimeVerificationKey)

        throw new Error('Runtime verification is not configured');

      return repository.getRuntimeVerificationKey();

    });

    router.get('/extensions/trust/v0.1', async () => ({

      uri: 'https://openclasp.vercel.app/extensions/trust/v0.1',

      name: 'OpenClasp A2A assurance extension',

      version: '0.1',

      required: false,

      transportsMessages: false,

      temporaryChatAdapter: true,

      documentation: 'https://github.com/aryaamin/OpenClasp/blob/main/docs/A2A_EXTENSION.md',

    }));

    router.post('/sessions/:id/events', async (request, reply) => {

      if (!repository?.recordLiveSessionEvent)

        throw new Error('Live-session reporting is not configured');

      const authorization = request.headers.authorization;

      if (!authorization?.startsWith('Bearer ')) {

        reply.status(401);

        return { error: 'session_credential_required' };

      }

      const event = LiveSessionEventSchema.parse(request.body);

      if (event.interactionId !== (request.params as { id: string }).id)

        throw new Error('Interaction path does not match the event');

      return repository.recordLiveSessionEvent(authorization.slice(7), event);

    });

    router.post('/sessions/:id/completion-reports', async (request, reply) => {

      if (!repository?.recordSessionCompletionReport)

        throw new Error('Live-session completion reporting is not configured');

      const authorization = request.headers.authorization;

      if (!authorization?.startsWith('Bearer ')) {

        reply.status(401);

        return { error: 'session_credential_required' };

      }

      const report = InteractionCompletionReportSchema.parse(request.body);

      if (report.interactionId !== (request.params as { id: string }).id)

        throw new Error('Interaction path does not match the completion report');

      return repository.recordSessionCompletionReport(authorization.slice(7), report);

    });

    router.post('/sessions/:id/feedback', async (request, reply) => {

      if (!repository?.recordSessionFeedback)

        throw new Error('Live-session feedback is not configured');

      const authorization = request.headers.authorization;

      if (!authorization?.startsWith('Bearer ')) {

        reply.status(401);

        return { error: 'session_credential_required' };

      }

      const feedback = InteractionFeedbackSchema.parse(request.body);

      if (feedback.interactionId !== (request.params as { id: string }).id)

        throw new Error('Interaction path does not match the feedback');

      return repository.recordSessionFeedback(authorization.slice(7), feedback);

    });

    router.post('/a2a/temporary/:id', async (request, reply) => {

      if (!repository?.receiveTemporaryMessage)

        throw new Error('Temporary chat delivery is not configured');

      const authorization = request.headers.authorization;

      if (!authorization?.startsWith('Bearer '))

        return reply.status(401).send({ error: 'session_credential_required' });

      const rpc = z

        .object({

          jsonrpc: z.literal('2.0'),

          id: z.union([z.string().min(1).max(200), z.number()]),

          method: z.literal('message/send'),

          params: z.object({

            message: z.object({

              parts: z.array(z.record(z.string(), z.unknown())).min(1).max(100),

            }),

          }),

        })

        .parse(request.body);

      const content = rpc.params.message.parts

        .map((part) => (typeof part.text === 'string' ? part.text : ''))

        .filter(Boolean)

        .join('\n')

        .trim();

      if (!content) throw new Error('Temporary chat MVP accepts text parts only');

      const recipientAgentId = (request.params as { id: string }).id;

      const result = await repository.receiveTemporaryMessage(

        authorization.slice(7),

        recipientAgentId,

        String(rpc.id),

        content,

      );

      return {

        jsonrpc: '2.0',

        id: rpc.id,

        result: {

          task: { id: result.message.messageId, state: 'submitted' },

          privacyMode: 'openclasp_hosted_temporary',

          deduplicated: result.deduplicated,

        },

      };

    });

    router.get('/agents/:id/card.json', async (request) => {

      if (!repository) throw new Error('Hosted persistence is not configured');

      const card = await repository.getPublishedAgent((request.params as { id: string }).id);

      if (!card) throw new Error('Published agent not found');

      return card;

    });

    router.get('/agents/:id/.well-known/openclasp-agent.json', async (request) => {

      if (!repository) throw new Error('Hosted persistence is not configured');

      const card = await repository.getPublishedAgent((request.params as { id: string }).id);

      if (!card) throw new Error('Published agent not found');

      return card;

    });

    router.get('/agents/:id/a2a-agent-card.json', async (request) => {

      if (!repository) throw new Error('Hosted persistence is not configured');

      const card = await repository.getPublishedAgent((request.params as { id: string }).id);

      if (!card) throw new Error('Published agent not found');

      if (!card.transports.length) throw new Error('Agent has not published an A2A endpoint');

      return toA2AAgentCard(card);

    });

    router.get('/directory/resolve', async (request) => {

      if (!repository) throw new Error('Hosted persistence is not configured');

      const { reference } = z

        .object({ reference: z.string().min(1).max(2048) })

        .parse(request.query);

      const result = await repository.resolveAgentReference(reference);

      if (!result) throw new Error('Published agent not found');

      return result;

    });

    router.get('/directory/search', async (request) => {

      if (!repository) throw new Error('Hosted persistence is not configured');

      const input = z

        .object({

          query: z.string().trim().max(100).optional(),

          capability: z.string().trim().max(100).optional(),

          limit: z.coerce.number().int().min(1).max(50).optional(),

        })

        .parse(request.query);

      return repository.searchPublishedAgents(input);

    });

    router.get('/a/:reference', async (request, reply) => {

      if (!repository) throw new Error('Hosted persistence is not configured');

      const result = await repository.resolveAgentReference(

        (request.params as { reference: string }).reference,

      );

      if (!result) throw new Error('Published agent not found');

      const { card } = result;

      const capabilities = card.capabilities

        .map((capability) => `<li>${escapeHtml(capability)}</li>`)

        .join('');

      const limitations = card.limitations

        .map((limitation) => `<li>${escapeHtml(limitation)}</li>`)

        .join('');

      const structured = JSON.stringify({

        '@context': 'https://schema.org',

        '@type': 'SoftwareApplication',

        name: card.name,

        description: card.description,

        url: card.profileUrl,

      }).replace(/</g, '\\u003c');

      return reply.type('text/html; charset=utf-8').send(`<!doctype html>

<html lang="en"><head><meta charset="utf-8"><meta name="viewport" content="width=device-width,initial-scale=1">

<title>${escapeHtml(card.name)} · OpenClasp</title><meta name="description" content="${escapeHtml(card.description)}">

<meta property="og:title" content="${escapeHtml(card.name)} · OpenClasp verified agent"><meta property="og:description" content="${escapeHtml(card.description)}">

<style>color-scheme:dark;*{box-sizing:border-box}body{margin:0;background:#0c0a0a;color:#f6f1ee;font:15px/1.55 Inter,system-ui,sans-serif}main{max-width:760px;margin:0 auto;padding:64px 24px}.brand{color:#f04b2d;font-weight:700}.verified{display:inline-block;margin:24px 0 8px;padding:5px 9px;border:1px solid #2fbf71;color:#2fbf71;border-radius:999px;font-size:12px}h1{font-size:42px;line-height:1.05;margin:8px 0 12px}p{color:#a39a94}.grid{display:grid;grid-template-columns:1fr 1fr;gap:32px;margin:36px 0}h2{font-size:13px;text-transform:uppercase;letter-spacing:.08em;color:#a39a94}a{color:#f04b2d;overflow-wrap:anywhere}.links{padding-top:24px;border-top:1px solid #2b2523}.status{color:${card.presence?.status === 'online' ? '#2fbf71' : '#a39a94'}}@media(max-width:600px){.grid{grid-template-columns:1fr}h1{font-size:34px}}</style>

<script type="application/ld+json">${structured}</script></head><body><main><div class="brand">OpenClasp</div><div class="verified">✓ Account and agent ownership verified</div>

<h1>${escapeHtml(card.name)}</h1><p>${escapeHtml(card.description || 'No description provided.')}</p><p class="status">${escapeHtml(card.presence?.status ?? 'offline')} · ${escapeHtml(card.agentMode.replace('_', ' '))}</p>

<div class="grid"><section><h2>Capabilities</h2><ul>${capabilities || '<li>None published</li>'}</ul></section><section><h2>Limitations</h2><ul>${limitations || '<li>None published</li>'}</ul></section></div>

<div class="links"><p><strong>Agent ID</strong><br>${escapeHtml(card.agentId)}</p><p><a href="${escapeHtml(card.cardUrl)}">OpenClasp card</a> · <a href="${escapeHtml(card.a2aAgentCardUrl)}">A2A Agent Card</a></p></div></main></body></html>`);

    });

    router.get('/v0.1/dashboard', async (request) => {

      const owner = operatorId(request);

      if (repository && owner) return repository.dashboard(owner);

      return {

        agents: [...engine.agents.values()],

        projects: [],

        installations: [],

        setupRequests: [],

        publications: [],

        interactions: [],

        federatedInteractions: [],

        liveSessions: [],

        hostedThreads: [],

        events: [...engine.events.values()],

        conflicts: [...engine.conflicts.values()],

        receipts: [...engine.receipts.values()],

        profiles: [...engine.profiles.values()],

        counterpartyBriefs: [],

        completionReports: [],

        feedbackRequests: [],

        interactionFeedback: [],

        interactionConclusions: [],

        learningEligibility: [],

        profileDeltas: [],

        intelligenceSummaries: [],

        runtimes: [],

      };

    });

    router.get('/v0.1/intelligence', async (request) => {

      const owner = operatorId(request);

      if (!repository?.listContextualIntelligence || !owner)

        throw new Error('Contextual intelligence is not configured');

      const input = z

        .object({

          agentId: z.string().min(1).optional(),

          taskCategory: z.string().trim().min(1).max(100).optional(),

        })

        .parse(request.query);

      return repository.listContextualIntelligence(owner, {

        ...(input.agentId ? { agentId: input.agentId } : {}),

        ...(input.taskCategory ? { taskCategory: input.taskCategory } : {}),

      });

    });

    router.get('/v0.1/marketplace', async (request) => {

      const owner = operatorId(request);

      if (!repository?.searchPersonalizedMarketplace || !owner)

        throw new Error('Personalized marketplace is not configured');

      const input = z

        .object({

          agentId: z.string().min(1).optional(),

          taskCategory: z.string().trim().min(1).max(100).optional(),

          query: z.string().trim().max(100).optional(),

          limit: z.coerce.number().int().min(1).max(50).default(30),

        })

        .parse(request.query);

      return repository.searchPersonalizedMarketplace(owner, {

        ...(input.agentId ? { agentId: input.agentId } : {}),

        ...(input.taskCategory ? { taskCategory: input.taskCategory } : {}),

        ...(input.query ? { query: input.query } : {}),

        limit: input.limit,

      });

    });

    router.get('/v0.1/account', async (request) => {

      const owner = operatorId(request);

      return {

        operatorId: owner,

        email: decodeURIComponent(String(request.headers['x-openclasp-email'] ?? '')),

        name: decodeURIComponent(String(request.headers['x-openclasp-name'] ?? '')),

      };

    });

    router.get('/v0.1/settings', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner)

        return {

          displayName: '',

          contributionEnabled: false,

          retentionDays: 30,

          evidenceSharing: 'ask',

          rawConversationsStored: false,

        };

      return repository.getSettings(owner);

    });

    router.get('/v0.1/onboarding', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      return getOnboardingState(repository, owner);

    });

    router.get('/v0.1/runtime/bootstrap', async (request) => {

      const owner = operatorId(request);

      const agentId = boundAgentId(request);

      const rows = owner && repository ? await repository.list(owner) : [];

      const profile = rows.find((row) => row.kind === 'agent_profile' && row.recordId === agentId)

        ?.payload as AgentProfile | undefined;

      return {

        agentId,

        agentVersion: profile?.agentVersion ?? '1.0.0',

        capabilities: profile?.capabilities ?? [],

        limitations: profile?.limitations ?? [],

        openClaspUrl: publicBaseUrl(request),

        runtimeRegistrationEndpoint: `${publicBaseUrl(request)}/v0.1/runtime`,

        protocol: 'A2A/1.0',

        controlProtocol: 'OpenClasp/0.1',

      };

    });

    router.put('/v0.1/runtime', async (request) => {

      const owner = operatorId(request);

      if (!repository?.registerAgentRuntime || !owner)

        throw new Error('Hosted runtime delivery is not configured');

      const endpoint = z

        .object({ endpoint: z.string().url().max(2048) })

        .parse(request.body).endpoint;

      return repository.registerAgentRuntime(owner, boundAgentId(request), endpoint);

    });

    router.delete('/v0.1/runtime', async (request) => {

      const owner = operatorId(request);

      if (!repository?.disableAgentRuntime || !owner)

        throw new Error('Hosted runtime delivery is not configured');

      return repository.disableAgentRuntime(owner, boundAgentId(request));

    });

    router.post('/v0.1/runtime/heartbeat', async (request) => {

      const owner = operatorId(request);

      if (!repository?.touchAgentPresence || !owner)

        throw new Error('Agent presence is not configured');

      return repository.touchAgentPresence(owner, boundAgentId(request));

    });

    router.put('/v0.1/runtime/profile', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      const agentId = boundAgentId(request);

      const value = z

        .object({

          description: z.string().trim().max(500).optional(),

          capabilities: z.array(z.string().trim().min(1).max(100)).min(1).max(100),

          limitations: z.array(z.string().trim().min(1).max(300)).max(100).default([]),

        })

        .strict()

        .parse(request.body);

      const rows = await repository.list(owner);

      const current = rows.find((row) => row.kind === 'agent_profile' && row.recordId === agentId)

        ?.payload as AgentProfile | undefined;

      if (!current || current.status !== 'active') throw new Error('Active owned agent not found');

      const profile: AgentProfile = {

        ...current,

        ...(value.description !== undefined ? { description: value.description } : {}),

        capabilities: [...new Set(value.capabilities)],

        limitations: [...new Set(value.limitations)],

        updatedAt: new Date().toISOString(),

      };

      await repository.upsert(owner, 'agent_profile', agentId, profile);

      const publication = rows.find((row) => row.kind === 'publication' && row.recordId === agentId)

        ?.payload as { published?: boolean } | undefined;

      if (profile.autoPublish || publication?.published) {

        const previous = await repository.getPublishedAgent(agentId);

        const card = await repository.publishAgent(

          owner,

          buildPublicAgentCard(profile, publicBaseUrl(request), previous),

        );

        await repository.upsert(owner, 'publication', agentId, {

          agentId,

          published: true,

          updatedAt: card.updatedAt,

        });

        return { profile, card };

      }

      return { profile };

    });

    router.post('/v0.1/onboarding/:id/approve', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      const requestId = (request.params as { id: string }).id;

      const state = await getOnboardingState(repository, owner);

      const setup = state.setupRequests.find((item) => item.requestId === requestId);

      const result = await approveAgentSetup(repository, owner, requestId);

      if (result.status === 'connected' && setup?.autoPublish) {

        const previous = await repository.getPublishedAgent(result.agent.agentId);

        const card = await repository.publishAgent(

          owner,

          buildPublicAgentCard(result.agent, publicBaseUrl(request), previous),

        );

        await repository.upsert(owner, 'publication', result.agent.agentId, {

          agentId: result.agent.agentId,

          published: true,

          updatedAt: card.updatedAt,

        });

      }

      return result;

    });

    router.post('/v0.1/onboarding/:id/reject', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      return rejectAgentSetup(repository, owner, (request.params as { id: string }).id);

    });

    router.put('/v0.1/settings', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      const value = z

        .object({

          displayName: z.string().trim().max(100),

          contributionEnabled: z.boolean(),

          retentionDays: z.number().int().min(0).max(3650),

          evidenceSharing: z.enum(['never', 'ask', 'contract_only']),

        })

        .parse(request.body);

      return repository.saveSettings(owner, value);

    });

    router.post('/v0.1/provider-connections', async (request) => {

      const owner = operatorId(request);

      if (!repository?.issueAgentAccessToken || !owner)

        throw new Error('Hosted provider connections are not configured');

      const value = z

        .object({

          provider: z.enum(['botpress', 'custom']),

          agentName: z.string().trim().min(1).max(100),

          projectName: z.string().trim().min(1).max(100),

          description: z.string().trim().min(1).max(500),

          capabilities: z.array(z.string().trim().min(1).max(100)).min(1).max(100),

          limitations: z.array(z.string().trim().min(1).max(300)).max(100).default([]),

          expiresInDays: z.number().int().min(1).max(365).default(365),

        })

        .parse(request.body);

      const created = await createHostedProviderAgent(repository, owner, value);

      try {

        const accessToken = await repository.issueAgentAccessToken(owner, created.agent.agentId, {

          name: 'Botpress',

          expiresInDays: value.expiresInDays,

        });

        return { ...created, provider: value.provider, accessToken };

      } catch (error) {

        if (repository.deleteAgent)

          await repository.deleteAgent(owner, created.agent.agentId).catch(() => undefined);

        throw error;

      }

    });

    router.post('/v0.1/agents', async (request) => {

      const owner = operatorId(request);

      const current = await scopedEngine(request);

      const identity = AgentIdentitySchema.parse(request.body);

      if (owner && identity.operatorRef !== `auth0:${owner}`)

        throw new Error('Agent identity is not owned by the authenticated operator');

      const registered = current.registerAgent(identity);

      await persist(request, 'agent', identity.agentId, registered);

      return registered;

    });

    router.get('/v0.1/agents/:id', async (request) => {

      const { id } = request.params as { id: string };

      const value = (await scopedEngine(request)).agents.get(id);

      if (!value) throw new Error('Agent not found');

      return value;

    });

    router.post('/v0.1/agents/:id/publication', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      const { id } = request.params as { id: string };

      const { published } = z.object({ published: z.boolean() }).parse(request.body);

      const rows = await repository.list(owner);

      const agent = rows.find((row) => row.kind === 'agent_profile' && row.recordId === id)

        ?.payload as AgentProfile | undefined;

      if (!agent) throw new Error('Owned agent not found');

      if (agent.status !== 'active') throw new Error('Revoked agents cannot be published');

      if (!published) {

        await repository.unpublishAgent(owner, id);

        const publication = { agentId: id, published: false, updatedAt: new Date().toISOString() };

        await repository.upsert(owner, 'publication', id, publication);

        return publication;

      }

      const previous = await repository.getPublishedAgent(id);

      const card = await repository.publishAgent(

        owner,

        buildPublicAgentCard(agent, publicBaseUrl(request), previous),

      );

      const publication = { agentId: id, published: true, updatedAt: card.updatedAt };

      await repository.upsert(owner, 'publication', id, publication);

      return { ...publication, card };

    });

    router.put('/v0.1/agents/:id/automation', async (request) => {

      const owner = operatorId(request);

      if (!repository || !owner) throw new Error('Hosted persistence is not configured');

      const { id } = request.params as { id: string };

      const value = z

        .object({

          autoPublish: z.boolean(),

          autoAcceptPolicy: z.enum(['off', 'safe_matching']),

          autoAcceptTaskCategories: z.array(z.string().trim().min(1).max(100)).max(100),

        })

        .parse(request.body);

      const rows = await repository.list(owner);

      const current = rows.find((row) => row.kind === 'agent_profile' && row.recordId === id)

        ?.payload as AgentProfile | undefined;

      if (!current) throw new Error('Owned agent not found');

      const agent: AgentProfile = {

        ...current,

        transport: 'direct_a2a',

        description: current.description ?? '',

        agentVersion: current.agentVersion ?? '1.0.0',

        autoPublish: value.autoPublish,

        autoAcceptPolicy: value.autoAcceptPolicy,

        autoAcceptTaskCategories: [...new Set(value.autoAcceptTaskCategories)],

        updatedAt: new Date().toISOString(),

      };

      await repository.upsert(owner, 'agent_profile', id, agent);

      if (value.autoPublish) {

        const previous = await repository.getPublishedAgent(id);

        const card = await repository.publishAgent(

          owner,

          buildPublicAgentCard(agent, publicBaseUrl(request), previous),

        );

        await repository.upsert(owner, 'publication', id, {

          agentId: id,

          published: true,

          updatedAt: card.updatedAt,

        });

      } else {

        await repository.unpublishAgent(owner, id);

        await repository.upsert(owner, 'publication', id, {

          agentId: id,

          published: false,

          updatedAt: new Date().toISOString(),

        });

      }

      return agent;

    });

    router.put('/v0.1/agents/:id/runtime', async (request) => {

      const owner = operatorId(request);

      if (!repository?.registerAgentRuntime || !owner)

        throw new Error('Hosted runtime delivery is not configured');

      const endpoint = z

        .object({ endpoint: z.string().url().max(2048) })

        .parse(request.body).endpoint;

      return repository.registerAgentRuntime(

        owner,

        (request.params as { id: string }).id,

        endpoint,

      );

    });

    router.delete('/v0.1/agents/:id/runtime', async (request) => {

      const owner = operatorId(request);

      if (!repository?.disableAgentRuntime || !owner)

        throw new Error('Hosted runtime delivery is not configured');

      return repository.disableAgentRuntime(owner, (request.params as { id: string }).id);

    });

    router.get('/v0.1/agents/:id/access-tokens', async (request) => {

      const owner = operatorId(request);

      if (!repository?.listAgentAccessTokens || !owner)

        throw new Error('Agent access tokens are not configured');

      return repository.listAgentAccessTokens(owner, (request.params as { id: string }).id);

    });

    router.post('/v0.1/agents/:id/access-tokens', async (request) => {

      const owner = operatorId(request);

      if (!repository?.issueAgentAccessToken || !owner)

        throw new Error('Agent access tokens are not configured');

      const value = z

        .object({

          name: z.string().trim().min(1).max(100),

          expiresInDays: z.number().int().min(1).max(365).default(365),

        })

        .parse(request.body);

      return repository.issueAgentAccessToken(owner, (request.params as { id: string }).id, value);

    });

    router.delete('/v0.1/agents/:id/access-tokens/:tokenId', async (request) => {

      const owner = operatorId(request);

      if (!repository?.revokeAgentAccessToken || !owner)

        throw new Error('Agent access tokens are not configured');

      const params = request.params as { id: string; tokenId: string };

      return repository.revokeAgentAccessToken(owner, params.id, params.tokenId);

    });

    router.delete('/v0.1/agents/:id', async (request) => {

      const owner = operatorId(request);

      if (!repository?.deleteAgent || !owner)

        throw new Error('Hosted agent deletion is not configured');

      const result = await repository.deleteAgent(owner, (request.params as { id: string }).id);

      engines.delete(owner);

      return result;

    });

    router.get('/v0.1/agents/:id/threads', async (request) => {

      const owner = operatorId(request);

      if (!repository?.listHostedThreads || !owner)

        throw new Error('Temporary chat history is not configured');

      return repository.listHostedThreads(owner, (request.params as { id: string }).id);

    });

    router.get('/v0.1/agents/:id/threads/:threadId', async (request) => {

      const owner = operatorId(request);

      if (!repository?.getHostedThread || !owner)

        throw new Error('Temporary chat history is not configured');

      const params = request.params as { id: string; threadId: string };

      return repository.getHostedThread(owner, params.id, params.threadId);

    });

    router.post('/v0.1/agents/:id/messages', async (request) => {

      const owner = operatorId(request);

      if (!repository?.sendTemporaryMessage || !owner)

        throw new Error('Temporary chat delivery is not configured');

      const value = z

        .object({ interactionId: z.string().uuid(), content: z.string().trim().min(1).max(20_000) })

        .parse(request.body);

      return repository.sendTemporaryMessage(

        owner,

        (request.params as { id: string }).id,

        value.interactionId,

        value.content,

      );

    });

    router.post('/v0.1/agents/:id/threads/:threadId/read', async (request) => {

      const owner = operatorId(request);

      if (!repository?.markHostedThreadRead || !owner)

        throw new Error('Temporary chat history is not configured');

      const params = request.params as { id: string; threadId: string };

      return repository.markHostedThreadRead(owner, params.id, params.threadId);

    });

    router.post('/v0.1/agents/:id/threads/:threadId/close', async (request) => {

      const owner = operatorId(request);

      if (!repository?.closeHostedThread || !owner)

        throw new Error('Temporary chat history is not configured');

      const params = request.params as { id: string; threadId: string };

      return repository.closeHostedThread(owner, params.id, params.threadId);

    });

    router.get('/v0.1/directory', async (request) => {

      operatorId(request);

      if (!repository) throw new Error('Hosted persistence is not configured');

      const query = z

        .object({

          query: z.string().trim().max(100).optional(),

          capability: z.string().trim().max(100).optional(),

          limit: z.coerce.number().int().min(1).max(50).optional(),

        })

        .parse(request.query);

      return repository.searchPublishedAgents(query);

    });

    router.get('/v0.1/directory/:id', async (request) => {

      operatorId(request);

      if (!repository) throw new Error('Hosted persistence is not configured');

      const card = await repository.getPublishedAgent((request.params as { id: string }).id);

      if (!card) throw new Error('Published agent not found');

      return card;

    });

    router.get('/v0.1/federated-interactions', async (request) => {

      const owner = operatorId(request);

      if (!repository?.listFederatedInteractions || !owner)

        throw new Error('Federated interactions are not configured');

      return repository.listFederatedInteractions(owner);

    });

    router.get('/v0.1/federated-interactions/:id', async (request) => {

      const owner = operatorId(request);

      if (!repository?.getFederatedInteraction || !owner)

        throw new Error('Federated interactions are not configured');

      const interaction = await repository.getFederatedInteraction(

        owner,

        (request.params as { id: string }).id,

      );

      if (!interaction) throw new Error('Interaction not found');

      return interaction;

    });

    router.get('/v0.1/federated-interactions/:id/session', async (request) => {

      const owner = operatorId(request);

      if (!repository?.getLiveSession || !owner)

        throw new Error('Live sessions are not configured');

      const value = z.object({ agentId: z.string().min(1) }).parse(request.query);

      enforceBoundAgent(request, value.agentId);

      return repository.getLiveSession(owner, (request.params as { id: string }).id, value.agentId);

    });

    router.get('/v0.1/federated-interactions/:id/brief', async (request) => {

      const owner = operatorId(request);

      if (!repository?.getCounterpartyBrief || !owner)

        throw new Error('Counterparty briefs are not configured');

      const value = z.object({ agentId: z.string().min(1) }).parse(request.query);

      enforceBoundAgent(request, value.agentId);

      return repository.getCounterpartyBrief(

        owner,

        (request.params as { id: string }).id,

        value.agentId,

      );

    });

    router.post('/v0.1/federated-interactions/:id/completion-reports', async (request) => {

      const owner = operatorId(request);

      if (!repository?.submitCompletionReport || !owner)

        throw new Error('Completion reports are not configured');

      const report = InteractionCompletionReportSchema.parse(request.body);

      if (report.interactionId !== (request.params as { id: string }).id)

        throw new Error('Interaction path does not match the completion report');

      return repository.submitCompletionReport(

        owner,

        boundAgentId(request),

        report,

        request.headers['x-openclasp-credential-type'] === 'agent_access_token'

          ? 'agent_access_token'

          : 'oauth_installation',

      );

    });

    router.post('/v0.1/federated-interactions/:id/feedback', async (request) => {

      const owner = operatorId(request);

      if (!repository?.submitInteractionFeedback || !owner)

        throw new Error('Interaction feedback is not configured');

      const feedback = InteractionFeedbackSchema.parse(request.body);

      if (feedback.interactionId !== (request.params as { id: string }).id)

        throw new Error('Interaction path does not match the feedback');

      return repository.submitInteractionFeedback(

        owner,

        boundAgentId(request),

        feedback,

        request.headers['x-openclasp-credential-type'] === 'agent_access_token'

          ? 'agent_access_token'

          : 'oauth_installation',

      );

    });

    router.get('/v0.1/feedback-requests', async (request) => {

      const owner = operatorId(request);

      if (!repository?.listFeedbackRequests || !owner)

        throw new Error('Interaction feedback is not configured');

      const value = z.object({ agentId: z.string().min(1) }).parse(request.query);

      enforceBoundAgent(request, value.agentId);

      return repository.listFeedbackRequests(owner, value.agentId);

    });

    router.post('/v0.1/federated-interactions', async (request) => {

      const owner = operatorId(request);

      if (!repository?.createFederatedInteraction || !owner)

        throw new Error('Federated interactions are not configured');

      const interaction = FederatedInteractionSchema.parse(request.body);

      const acceptance = interaction.acceptances[interaction.initiatorAgentId];

      if (!acceptance) throw new Error('Initiator acceptance is required');

      return repository.createFederatedInteraction(owner, {

        ...interaction,

        acceptances: {

          [interaction.initiatorAgentId]: { ...acceptance, method: 'oauth_account' },

        },

      });

    });

    router.post('/v0.1/federated-interactions/:id/respond', async (request) => {

      const owner = operatorId(request);

      if (!repository?.respondToFederatedInteraction || !owner)

        throw new Error('Federated interactions are not configured');

      const value = z

        .object({ agentId: z.string().min(1), decision: z.enum(['accept', 'reject']) })

        .parse(request.body);

      return repository.respondToFederatedInteraction(

        owner,

        (request.params as { id: string }).id,

        value.agentId,

        value.decision,

        'oauth_account',

      );

    });

    router.post('/v0.1/federated-interactions/:id/contract-proposals', async (request) => {

      const owner = operatorId(request);

      if (!repository?.proposeContractRevision || !owner)

        throw new Error('Contract negotiation is not configured');

      const value = z

        .object({

          agentId: z.string().min(1),

          expectedTermsHash: z.string().min(1).optional(),

          contract: InteractionContractSchema,

        })

        .parse(request.body);

      enforceBoundAgent(request, value.agentId);

      return repository.proposeContractRevision(

        owner,

        (request.params as { id: string }).id,

        value.agentId,

        value.contract,

        value.expectedTermsHash,

        request.headers['x-openclasp-credential-type'] === 'agent_access_token'

          ? 'oauth_installation'

          : 'oauth_account',

      );

    });

    router.post(

      '/v0.1/federated-interactions/:id/contract-proposals/:revisionId/respond',

      async (request) => {

        const owner = operatorId(request);

        if (!repository?.respondToContractRevision || !owner)

          throw new Error('Contract negotiation is not configured');

        const value = z

          .object({ agentId: z.string().min(1), decision: z.enum(['accept', 'reject']) })

          .parse(request.body);

        enforceBoundAgent(request, value.agentId);

        const params = request.params as { id: string; revisionId: string };

        return repository.respondToContractRevision(

          owner,

          params.id,

          value.agentId,

          params.revisionId,

          value.decision,

          request.headers['x-openclasp-credential-type'] === 'agent_access_token'

            ? 'oauth_installation'

            : 'oauth_account',

        );

      },

    );

    router.post('/v0.1/delegations', async (request) => {

      const value = DelegationCredentialSchema.parse(request.body);

      const current = await scopedEngine(request);

      current.delegations.set(value.delegationId, value);

      await persist(request, 'delegation', value.delegationId, value);

      return { valid: current.verifyDelegation(value.delegationId) };

    });

    router.post('/v0.1/delegations/:id/verify', async (request) => ({

      valid: (await scopedEngine(request)).verifyDelegation((request.params as { id: string }).id),

    }));

    router.post('/v0.1/interactions/contracts', async (request) => {

      const contract = (await scopedEngine(request)).saveContract(

        InteractionContractSchema.parse(request.body),

      );

      await persist(request, 'contract', contract.interactionId, contract);

      return contract;

    });

    router.post('/v0.1/events', async (request) => {

      const event = (await scopedEngine(request)).recordEvent(

        InteractionEventSchema.parse(request.body),

      );

      await persist(request, 'event', event.eventId, event);

      return event;

    });

    router.post('/v0.1/risk/assess', async (request) =>

      (await scopedEngine(request)).assess(request.body as any),

    );

    router.get('/v0.1/profiles/:id', async (request) => {

      const { id } = request.params as { id: string };

      const query = request.query as { version?: string; taskCategory?: string };

      return (await scopedEngine(request)).getRisk(

        id,

        query.version ?? '1.0.0',

        query.taskCategory ?? 'general',

      );

    });

    router.post('/v0.1/claims/check', async (request) =>

      ((value) => factChecker.check(value.claim, value.permission))(

        z.object({ claim: z.string(), permission: z.boolean().optional() }).parse(request.body),

      ),

    );

    router.post('/v0.1/receipts', async (request) => {

      const receipt = (await scopedEngine(request)).submitReceipt(

        ReceiptSchema.parse(request.body),

      );

      await persist(request, 'receipt', receipt.receiptId, receipt);

      return receipt;

    });

    router.post('/v0.1/receipts/verify', async (request) => {

      try {

        (await scopedEngine(request)).verifyReceipt(ReceiptSchema.parse(request.body));

        return { valid: true };

      } catch {

        return { valid: false };

      }

    });

    router.post('/v0.1/feedback', async (request) => {

      const feedback = FeedbackSchema.parse(request.body);

      const current = await scopedEngine(request);

      const result = current.submitFeedback(feedback);

      await persist(request, 'feedback', feedback.feedbackId, feedback);

      for (const profile of current.profiles.values())

        await persist(

          request,

          'profile',

          `${profile.agentId}|${profile.agentVersion}|${profile.taskCategory}`,

          profile,

        );

      return result;

    });

    router.post('/v0.1/conflicts', async (request) => {

      const conflict = (await scopedEngine(request)).createConflict(request.body as any);

      await persist(request, 'conflict', conflict.conflictId, conflict);

      return conflict;

    });

    router.post('/v0.1/conflicts/:id/permit', async (request) => {

      const conflict = (await scopedEngine(request)).permitMediation(

        (request.params as { id: string }).id,

        (request.body as { agentId: string }).agentId,

      );

      await persist(request, 'conflict', conflict.conflictId, conflict);

      return conflict;

    });

    router.post('/v0.1/conflicts/:id/resolve', async (request) => {

      const conflict = (await scopedEngine(request)).resolveConflict(

        (request.params as { id: string }).id,

        (request.body as { resolution: string }).resolution,

      );

      await persist(request, 'conflict', conflict.conflictId, conflict);

      return conflict;

    });

    router.post('/v0.1/revocations/agents/:id', async (request) => {

      const id = (request.params as { id: string }).id;

      const current = await scopedEngine(request);

      current.revokeAgent(id);

      await persist(request, 'agent', id, current.agents.get(id));

      return { revoked: true };

    });

    router.post('/v0.1/revocations/delegations/:id', async (request) => {

      const id = (request.params as { id: string }).id;

      const current = await scopedEngine(request);

      current.revokeDelegation(id);

      await persist(request, 'delegation', id, current.delegations.get(id));

      return { revoked: true };

    });

    router.post('/v0.1/contributions/consent', async (request) => {

      const value = z.object({ agentId: z.string(), enabled: z.boolean() }).parse(request.body);

      const current = await scopedEngine(request);

      current.setContributionConsent(value.agentId, value.enabled);

      await persist(request, 'consent', value.agentId, {

        agentId: value.agentId,

        ...current.contributionConsent.get(value.agentId),

      });

      return value;

    });

  });

  return app;

}