| import type { StudioApiEnvelope } from '../protocol/studio-agent-types' | |
| import { getConnectionHeaders } from '../../connection/connection-request' | |
| const STUDIO_API_BASE = '/api/studio-agent' | |
| export class StudioApiRequestError extends Error { | |
| readonly code: string | |
| readonly details?: unknown | |
| constructor(message: string, code = 'STUDIO_REQUEST_FAILED', details?: unknown) { | |
| super(message) | |
| this.name = 'StudioApiRequestError' | |
| this.code = code | |
| this.details = details | |
| } | |
| } | |
| export function getStudioApiBase(): string { | |
| return STUDIO_API_BASE | |
| } | |
| export function getStudioAuthHeaders(contentType?: string): HeadersInit { | |
| return getConnectionHeaders(contentType) | |
| } | |
| export async function studioRequest<T>(path: string, init?: RequestInit): Promise<T> { | |
| const response = await fetch(`${STUDIO_API_BASE}${path}`, init) | |
| const payload = await parseStudioEnvelope<T>(response) | |
| if (!response.ok || !payload.ok) { | |
| if (payload.ok) { | |
| throw new StudioApiRequestError(`Studio request failed with status ${response.status}`) | |
| } | |
| throw new StudioApiRequestError(payload.error.message, payload.error.code, payload.error.details) | |
| } | |
| return payload.data | |
| } | |
| async function parseStudioEnvelope<T>(response: Response): Promise<StudioApiEnvelope<T>> { | |
| const raw = await response.text() | |
| try { | |
| return JSON.parse(raw) as StudioApiEnvelope<T> | |
| } catch { | |
| const snippet = raw.trim().slice(0, 240) | |
| throw new StudioApiRequestError( | |
| snippet | |
| ? `Studio API returned invalid JSON (${response.status}): ${snippet}` | |
| : `Studio API returned invalid JSON (${response.status})` | |
| ) | |
| } | |
| } | |