Function toAdaptedResponse

server/src/training-agent/framework-server.ts:152–182

(result: unknown, callerContext: unknown)

// ── Response shaping ─────────────────────────────────────────────

function toAdaptedResponse(result: unknown, callerContext: unknown): AdaptedResponse {
  const errsField = (result as { errors?: unknown[] } | null | undefined)?.errors;
  if (Array.isArray(errsField) && errsField.length > 0) {
    const first = errsField[0] as InlineError;
    const errorObj: Record<string, unknown> = { code: first.code, message: first.message };
    if (first.field) errorObj.field = first.field;
    if (first.details !== undefined) errorObj.details = first.details;
    if (first.recovery) errorObj.recovery = first.recovery;
    const body = wrapEnvelope({ adcp_error: errorObj }, { context: callerContext });
    return {
      isError: true,
      content: [{ type: 'text', text: JSON.stringify(body) }],
      structuredContent: body,
    };
  }
  const inner = (result ?? {}) as Record<string, unknown>;
  // wrapEnvelope stamps the AdCP context-echo envelope. `replayed` is
  // intentionally NOT set here — per protocol-envelope.json and the
  // SDK's injectReplayed helper, fresh executions MUST omit the field
  // (the framework stamps `replayed: true` only on idempotency replays).
  const withEnvelope = wrapEnvelope(inner, {
    ...(callerContext !== undefined && typeof callerContext === 'object' && callerContext !== null
      ? { context: callerContext }
      : {}),
  });
  const response = withEnvelope as Record<string, unknown>;
  return {
    content: [{ type: 'text', text: JSON.stringify(response) }],
    structuredContent: response,
  };
}

function serviceUnavailable(err: unknown, callerContext: unknown): AdaptedResponse {
  const errorObj: Record<string, unknown> = {