(null);
@@ -1034,6 +1026,7 @@ const StudioPage: React.FC = () => {
Boolean(authSessionQuery.data?.authenticated);
const studioHostReady =
studioHostAccessResolved && studioHostAuthenticated;
+ const studioAppearance = defaultStudioAppearance;
useEffect(() => {
if (typeof window === 'undefined') {
@@ -1281,30 +1274,6 @@ const StudioPage: React.FC = () => {
}),
});
- useEffect(() => {
- if (typeof window === 'undefined') {
- return undefined;
- }
-
- const syncStudioAppearance = () => {
- setStudioAppearance(readStudioAppearancePreferences());
- };
-
- window.addEventListener(
- CONSOLE_PREFERENCES_UPDATED_EVENT,
- syncStudioAppearance,
- );
- window.addEventListener('storage', syncStudioAppearance);
-
- return () => {
- window.removeEventListener(
- CONSOLE_PREFERENCES_UPDATED_EVENT,
- syncStudioAppearance,
- );
- window.removeEventListener('storage', syncStudioAppearance);
- };
- }, []);
-
useEffect(() => {
if (
selectedWorkflowId ||
diff --git a/apps/aevatar-console-web/src/pages/workflows/index.tsx b/apps/aevatar-console-web/src/pages/workflows/index.tsx
index cd21dd6bf..4e25d5a40 100644
--- a/apps/aevatar-console-web/src/pages/workflows/index.tsx
+++ b/apps/aevatar-console-web/src/pages/workflows/index.tsx
@@ -65,6 +65,7 @@ import {
tallScrollPanelStyle,
stretchColumnStyle,
} from "@/shared/ui/proComponents";
+import { describeError } from "@/shared/ui/errorText";
import WorkflowYamlViewer from "./WorkflowYamlViewer";
import {
buildStepRows,
@@ -1602,7 +1603,7 @@ const WorkflowsPage: React.FC = () => {
showIcon
type="error"
title="Failed to load workflow catalog"
- description={String(catalogQuery.error)}
+ description={describeError(catalogQuery.error)}
/>
) : null}
@@ -1658,7 +1659,7 @@ const WorkflowsPage: React.FC = () => {
showIcon
type="error"
title="Failed to load workflow detail"
- description={String(detailQuery.error)}
+ description={describeError(detailQuery.error)}
/>
) : detailQuery.data ? (
diff --git a/apps/aevatar-console-web/src/shared/api/http/client.ts b/apps/aevatar-console-web/src/shared/api/http/client.ts
index 8d2bf9053..f92a2f41b 100644
--- a/apps/aevatar-console-web/src/shared/api/http/client.ts
+++ b/apps/aevatar-console-web/src/shared/api/http/client.ts
@@ -1,5 +1,6 @@
import { authFetch } from "@/shared/auth/fetch";
import type { Decoder } from "../decodeUtils";
+import { readResponseError } from "./error";
export type QueryValue =
| string
@@ -14,24 +15,6 @@ const JSON_HEADERS = {
"Content-Type": "application/json",
};
-async function readError(response: Response): Promise {
- const text = await response.text();
- if (!text) {
- return `HTTP ${response.status}`;
- }
-
- try {
- const payload = JSON.parse(text) as {
- message?: string;
- error?: string;
- code?: string;
- };
- return payload.message || payload.error || payload.code || text;
- } catch {
- return text;
- }
-}
-
export function withQuery(
path: string,
query?: Record
@@ -70,7 +53,7 @@ export async function requestJson(
): Promise {
const response = await authFetch(input, init);
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
return decoder(await response.json());
diff --git a/apps/aevatar-console-web/src/shared/api/http/error.ts b/apps/aevatar-console-web/src/shared/api/http/error.ts
new file mode 100644
index 000000000..ff23b0bef
--- /dev/null
+++ b/apps/aevatar-console-web/src/shared/api/http/error.ts
@@ -0,0 +1,73 @@
+function normalizeWhitespace(value: string | null | undefined): string {
+ return String(value ?? "")
+ .replace(/\s+/g, " ")
+ .trim();
+}
+
+function formatHttpError(status: number, statusText: string): string {
+ const normalizedStatusText = normalizeWhitespace(statusText);
+ return normalizedStatusText ? `HTTP ${status} ${normalizedStatusText}` : `HTTP ${status}`;
+}
+
+function stripHtmlTags(value: string): string {
+ return value
+ .replace(/)<[^<]*)*<\/script>/gi, " ")
+ .replace(/)<[^<]*)*<\/style>/gi, " ")
+ .replace(/<[^>]+>/g, " ");
+}
+
+function extractHtmlErrorSummary(value: string): string | null {
+ const trimmed = value.trimStart();
+ const looksLikeHtml =
+ /^]/i.test(trimmed) ||
+ /]/i.test(trimmed) ||
+ /]/i.test(trimmed);
+
+ if (!looksLikeHtml) {
+ return null;
+ }
+
+ const titleMatch = value.match(/]*>([\s\S]*?)<\/title>/i);
+ const headingMatch = value.match(/]*>([\s\S]*?)<\/h1>/i);
+ const summary = normalizeWhitespace(
+ stripHtmlTags(titleMatch?.[1] ?? headingMatch?.[1] ?? value)
+ );
+
+ return summary || null;
+}
+
+export async function readResponseError(response: Pick): Promise {
+ const text = await response.text();
+ if (!text) {
+ return formatHttpError(response.status, response.statusText);
+ }
+
+ try {
+ const payload = JSON.parse(text) as {
+ code?: string;
+ error?: string;
+ message?: string;
+ };
+ return payload.message || payload.error || payload.code || text;
+ } catch {
+ const htmlSummary = extractHtmlErrorSummary(text);
+ if (!htmlSummary) {
+ return normalizeWhitespace(text);
+ }
+
+ const httpError = formatHttpError(response.status, response.statusText);
+ const normalizedHttpError = httpError.toLowerCase();
+ const normalizedHtmlSummary = htmlSummary.toLowerCase();
+ const normalizedStatusText = normalizeWhitespace(response.statusText).toLowerCase();
+
+ if (
+ normalizedHttpError.includes(normalizedHtmlSummary) ||
+ normalizedHtmlSummary.includes(normalizedStatusText)
+ ) {
+ return httpError;
+ }
+
+ return `${httpError}: ${htmlSummary}`;
+ }
+}
diff --git a/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.test.ts b/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.test.ts
index 3f4b5e1ec..d3a5d77a0 100644
--- a/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.test.ts
+++ b/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.test.ts
@@ -37,6 +37,63 @@ describe("runtimeRunsApi", () => {
).rejects.toThrow("invalid workflow yaml");
});
+ it("collapses HTML error pages for streaming runtime responses", async () => {
+ const fetchMock = jest.fn().mockResolvedValue({
+ ok: false,
+ status: 502,
+ statusText: "Bad Gateway",
+ text: async () => `
+
+
+ runtime gateway | 502: Bad gateway
+
+
+ Bad gateway
+
+`,
+ } satisfies Partial);
+
+ global.fetch = fetchMock as typeof global.fetch;
+
+ await expect(
+ runtimeRunsApi.streamChat(
+ "scope-1",
+ {
+ prompt: "Run it",
+ },
+ new AbortController().signal
+ )
+ ).rejects.toThrow("HTTP 502 Bad Gateway");
+ });
+
+ it("collapses HTML error pages for JSON runtime requests", async () => {
+ const fetchMock = jest.fn().mockResolvedValue({
+ ok: false,
+ status: 502,
+ statusText: "Bad Gateway",
+ text: async () => `
+
+
+ runtime gateway | 502: Bad gateway
+
+
+ Bad gateway
+
+`,
+ } satisfies Partial);
+
+ global.fetch = fetchMock as typeof global.fetch;
+
+ await expect(
+ runtimeRunsApi.resume("scope-1", {
+ actorId: "actor-1",
+ runId: "run-1",
+ stepId: "step-1",
+ approved: true,
+ })
+ ).rejects.toThrow("HTTP 502 Bad Gateway");
+ });
+
it("decodes resume responses from the runtime boundary", async () => {
const fetchMock = jest.fn().mockResolvedValue({
ok: true,
diff --git a/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.ts b/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.ts
index f1add86a6..90927cb5e 100644
--- a/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.ts
+++ b/apps/aevatar-console-web/src/shared/api/runtimeRunsApi.ts
@@ -11,6 +11,7 @@ import {
decodeWorkflowSignalResponseBody,
} from "./runtimeDecoders";
import { requestJson } from "./http/client";
+import { readResponseError } from "./http/error";
import {
encodeAppScriptCommandBase64,
encodeStringValueBase64,
@@ -36,24 +37,6 @@ function compactObject>(value: T): T {
) as T;
}
-async function readError(response: Response): Promise {
- const text = await response.text();
- if (!text) {
- return `HTTP ${response.status}`;
- }
-
- try {
- const payload = JSON.parse(text) as {
- message?: string;
- error?: string;
- code?: string;
- };
- return payload.message || payload.error || payload.code || text;
- } catch {
- return text;
- }
-}
-
function encodeSegment(value: string): string {
return encodeURIComponent(value.trim());
}
@@ -198,7 +181,7 @@ export const runtimeRunsApi = {
);
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
return response;
@@ -229,7 +212,7 @@ export const runtimeRunsApi = {
});
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
return response;
@@ -358,7 +341,7 @@ export const runtimeRunsApi = {
);
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
return (await response.json()) as WorkflowStopResponse;
diff --git a/apps/aevatar-console-web/src/shared/navigation/runtimeRoutes.ts b/apps/aevatar-console-web/src/shared/navigation/runtimeRoutes.ts
index 1a6900bfe..f690d5882 100644
--- a/apps/aevatar-console-web/src/shared/navigation/runtimeRoutes.ts
+++ b/apps/aevatar-console-web/src/shared/navigation/runtimeRoutes.ts
@@ -3,7 +3,6 @@ const runtimePaths = {
primitives: "/runtime/primitives",
runs: "/runtime/runs",
explorer: "/runtime/explorer",
- observability: "/runtime/observability",
} as const;
type QueryValue = string | undefined;
@@ -75,13 +74,3 @@ export function buildRuntimeExplorerHref(options?: {
}): string {
return buildHref(runtimePaths.explorer, options);
}
-
-export function buildRuntimeObservabilityHref(options?: {
- workflow?: string;
- actorId?: string;
- commandId?: string;
- runId?: string;
- stepId?: string;
-}): string {
- return buildHref(runtimePaths.observability, options);
-}
diff --git a/apps/aevatar-console-web/src/shared/observability/observabilityLinks.test.ts b/apps/aevatar-console-web/src/shared/observability/observabilityLinks.test.ts
deleted file mode 100644
index 245f179e8..000000000
--- a/apps/aevatar-console-web/src/shared/observability/observabilityLinks.test.ts
+++ /dev/null
@@ -1,49 +0,0 @@
-import type { ConsolePreferences } from '@/shared/preferences/consolePreferences';
-import {
- buildObservabilityTargets,
- normalizeBaseUrl,
- type ObservabilityContext,
-} from './observabilityLinks';
-
-const preferences: ConsolePreferences = {
- preferredWorkflow: 'direct',
- actorTimelineTake: 50,
- actorGraphDepth: 3,
- actorGraphTake: 100,
- actorGraphDirection: 'Both',
- studioAppearanceTheme: 'blue',
- studioColorMode: 'light',
- grafanaBaseUrl: 'https://grafana.example.com/',
- jaegerBaseUrl: ' https://jaeger.example.com ',
- lokiBaseUrl: '',
-};
-
-const context: ObservabilityContext = {
- workflow: 'direct',
- actorId: 'actor-1',
- commandId: 'cmd-1',
- runId: '',
- stepId: '',
-};
-
-describe('observabilityLinks', () => {
- it('normalizes base urls and builds target links', () => {
- expect(normalizeBaseUrl(' https://grafana.example.com/ ')).toBe(
- 'https://grafana.example.com',
- );
-
- const targets = buildObservabilityTargets(preferences, context);
-
- expect(targets[0].exploreUrl).toBe('https://grafana.example.com/explore');
- expect(targets[1].exploreUrl).toBe('https://jaeger.example.com/search');
- expect(targets[2].status).toBe('missing');
- });
-
- it('includes selected context summary in target metadata', () => {
- const targets = buildObservabilityTargets(preferences, context);
-
- expect(targets[0].contextSummary).toContain('workflow=direct');
- expect(targets[0].contextSummary).toContain('actorId=actor-1');
- expect(targets[0].contextSummary).toContain('commandId=cmd-1');
- });
-});
diff --git a/apps/aevatar-console-web/src/shared/observability/observabilityLinks.ts b/apps/aevatar-console-web/src/shared/observability/observabilityLinks.ts
deleted file mode 100644
index 6091add80..000000000
--- a/apps/aevatar-console-web/src/shared/observability/observabilityLinks.ts
+++ /dev/null
@@ -1,75 +0,0 @@
-import type { ConsolePreferences } from '@/shared/preferences/consolePreferences';
-
-export type ObservabilityContext = {
- workflow: string;
- actorId: string;
- commandId: string;
- runId: string;
- stepId: string;
-};
-
-export type ObservabilityTarget = {
- id: 'grafana' | 'jaeger' | 'loki';
- label: string;
- status: 'configured' | 'missing';
- homeUrl: string;
- exploreUrl: string;
- description: string;
- contextSummary: string;
-};
-
-export function normalizeBaseUrl(value: string): string {
- return value.trim().replace(/\/+$/, '');
-}
-
-function buildContextSummary(context: ObservabilityContext): string {
- const parts = [
- context.workflow ? `workflow=${context.workflow}` : '',
- context.actorId ? `actorId=${context.actorId}` : '',
- context.commandId ? `commandId=${context.commandId}` : '',
- context.runId ? `runId=${context.runId}` : '',
- context.stepId ? `stepId=${context.stepId}` : '',
- ].filter(Boolean);
-
- return parts.length > 0 ? parts.join(' | ') : 'No context selected';
-}
-
-export function buildObservabilityTargets(
- preferences: ConsolePreferences,
- context: ObservabilityContext,
-): ObservabilityTarget[] {
- const grafanaBaseUrl = normalizeBaseUrl(preferences.grafanaBaseUrl);
- const jaegerBaseUrl = normalizeBaseUrl(preferences.jaegerBaseUrl);
- const lokiBaseUrl = normalizeBaseUrl(preferences.lokiBaseUrl);
- const contextSummary = buildContextSummary(context);
-
- return [
- {
- id: 'grafana',
- label: 'Grafana',
- status: grafanaBaseUrl ? 'configured' : 'missing',
- homeUrl: grafanaBaseUrl,
- exploreUrl: grafanaBaseUrl ? `${grafanaBaseUrl}/explore` : '',
- description: 'Dashboards and Explore entrypoint for traces, logs, and linked views.',
- contextSummary,
- },
- {
- id: 'jaeger',
- label: 'Jaeger',
- status: jaegerBaseUrl ? 'configured' : 'missing',
- homeUrl: jaegerBaseUrl,
- exploreUrl: jaegerBaseUrl ? `${jaegerBaseUrl}/search` : '',
- description: 'Trace search and timeline inspection for distributed workflow execution.',
- contextSummary,
- },
- {
- id: 'loki',
- label: 'Loki',
- status: lokiBaseUrl ? 'configured' : 'missing',
- homeUrl: lokiBaseUrl,
- exploreUrl: lokiBaseUrl,
- description: 'Log aggregation entrypoint for actor, workflow, and command correlations.',
- contextSummary,
- },
- ];
-}
diff --git a/apps/aevatar-console-web/src/shared/preferences/consolePreferences.test.ts b/apps/aevatar-console-web/src/shared/preferences/consolePreferences.test.ts
deleted file mode 100644
index df748c558..000000000
--- a/apps/aevatar-console-web/src/shared/preferences/consolePreferences.test.ts
+++ /dev/null
@@ -1,46 +0,0 @@
-import {
- defaultConsolePreferences,
- loadConsolePreferences,
- resetConsolePreferences,
- saveConsolePreferences,
-} from './consolePreferences';
-
-describe('consolePreferences', () => {
- beforeEach(() => {
- window.localStorage.clear();
- });
-
- it('loads defaults when storage is empty and persists sanitized values', () => {
- expect(loadConsolePreferences()).toEqual(defaultConsolePreferences);
-
- const saved = saveConsolePreferences({
- preferredWorkflow: ' human_input_manual_triage ',
- actorTimelineTake: 30.9,
- actorGraphDepth: 2,
- actorGraphTake: 80,
- actorGraphDirection: 'Outbound',
- studioAppearanceTheme: 'forest',
- studioColorMode: 'dark',
- grafanaBaseUrl: ' https://grafana.example.com ',
- jaegerBaseUrl: ' https://jaeger.example.com ',
- lokiBaseUrl: ' https://loki.example.com ',
- });
-
- expect(saved).toEqual({
- preferredWorkflow: 'human_input_manual_triage',
- actorTimelineTake: 30,
- actorGraphDepth: 2,
- actorGraphTake: 80,
- actorGraphDirection: 'Outbound',
- studioAppearanceTheme: 'forest',
- studioColorMode: 'dark',
- grafanaBaseUrl: 'https://grafana.example.com',
- jaegerBaseUrl: 'https://jaeger.example.com',
- lokiBaseUrl: 'https://loki.example.com',
- });
-
- expect(loadConsolePreferences()).toEqual(saved);
- expect(resetConsolePreferences()).toEqual(defaultConsolePreferences);
- expect(loadConsolePreferences()).toEqual(defaultConsolePreferences);
- });
-});
diff --git a/apps/aevatar-console-web/src/shared/preferences/consolePreferences.ts b/apps/aevatar-console-web/src/shared/preferences/consolePreferences.ts
deleted file mode 100644
index 39842a7c7..000000000
--- a/apps/aevatar-console-web/src/shared/preferences/consolePreferences.ts
+++ /dev/null
@@ -1,133 +0,0 @@
-export type ActorGraphDirection = 'Both' | 'Outbound' | 'Inbound';
-export type StudioAppearanceTheme = 'blue' | 'coral' | 'forest';
-export type StudioColorMode = 'light' | 'dark';
-
-export interface ConsolePreferences {
- preferredWorkflow: string;
- actorTimelineTake: number;
- actorGraphDepth: number;
- actorGraphTake: number;
- actorGraphDirection: ActorGraphDirection;
- studioAppearanceTheme: StudioAppearanceTheme;
- studioColorMode: StudioColorMode;
- grafanaBaseUrl: string;
- jaegerBaseUrl: string;
- lokiBaseUrl: string;
-}
-
-export const CONSOLE_PREFERENCES_UPDATED_EVENT =
- 'aevatar-console-preferences-updated';
-
-const STORAGE_KEY = 'aevatar-console-preferences';
-
-export const defaultConsolePreferences: ConsolePreferences = {
- preferredWorkflow: 'direct',
- actorTimelineTake: 50,
- actorGraphDepth: 3,
- actorGraphTake: 100,
- actorGraphDirection: 'Both',
- studioAppearanceTheme: 'blue',
- studioColorMode: 'light',
- grafanaBaseUrl: '',
- jaegerBaseUrl: '',
- lokiBaseUrl: '',
-};
-
-function parsePositiveInt(value: unknown, fallback: number): number {
- if (typeof value !== 'number' || Number.isNaN(value) || value <= 0) {
- return fallback;
- }
-
- return Math.floor(value);
-}
-
-function parseDirection(value: unknown): ActorGraphDirection {
- if (value === 'Inbound' || value === 'Outbound' || value === 'Both') {
- return value;
- }
-
- return defaultConsolePreferences.actorGraphDirection;
-}
-
-function parseStudioAppearanceTheme(value: unknown): StudioAppearanceTheme {
- if (value === 'coral' || value === 'forest' || value === 'blue') {
- return value;
- }
-
- return defaultConsolePreferences.studioAppearanceTheme;
-}
-
-function parseStudioColorMode(value: unknown): StudioColorMode {
- return value === 'dark' ? 'dark' : defaultConsolePreferences.studioColorMode;
-}
-
-function sanitizePreferences(
- value: Partial | null | undefined,
-): ConsolePreferences {
- return {
- preferredWorkflow:
- typeof value?.preferredWorkflow === 'string' &&
- value.preferredWorkflow.trim().length > 0
- ? value.preferredWorkflow.trim()
- : defaultConsolePreferences.preferredWorkflow,
- actorTimelineTake: parsePositiveInt(
- value?.actorTimelineTake,
- defaultConsolePreferences.actorTimelineTake,
- ),
- actorGraphDepth: parsePositiveInt(
- value?.actorGraphDepth,
- defaultConsolePreferences.actorGraphDepth,
- ),
- actorGraphTake: parsePositiveInt(
- value?.actorGraphTake,
- defaultConsolePreferences.actorGraphTake,
- ),
- actorGraphDirection: parseDirection(value?.actorGraphDirection),
- studioAppearanceTheme: parseStudioAppearanceTheme(
- value?.studioAppearanceTheme,
- ),
- studioColorMode: parseStudioColorMode(value?.studioColorMode),
- grafanaBaseUrl:
- typeof value?.grafanaBaseUrl === 'string' ? value.grafanaBaseUrl.trim() : '',
- jaegerBaseUrl:
- typeof value?.jaegerBaseUrl === 'string' ? value.jaegerBaseUrl.trim() : '',
- lokiBaseUrl:
- typeof value?.lokiBaseUrl === 'string' ? value.lokiBaseUrl.trim() : '',
- };
-}
-
-export function loadConsolePreferences(): ConsolePreferences {
- if (typeof window === 'undefined') {
- return defaultConsolePreferences;
- }
-
- const raw = window.localStorage.getItem(STORAGE_KEY);
- if (!raw) {
- return defaultConsolePreferences;
- }
-
- try {
- return sanitizePreferences(JSON.parse(raw) as Partial);
- } catch {
- return defaultConsolePreferences;
- }
-}
-
-export function saveConsolePreferences(value: ConsolePreferences): ConsolePreferences {
- const sanitized = sanitizePreferences(value);
- if (typeof window !== 'undefined') {
- window.localStorage.setItem(STORAGE_KEY, JSON.stringify(sanitized));
- window.dispatchEvent(new Event(CONSOLE_PREFERENCES_UPDATED_EVENT));
- }
-
- return sanitized;
-}
-
-export function resetConsolePreferences(): ConsolePreferences {
- if (typeof window !== 'undefined') {
- window.localStorage.removeItem(STORAGE_KEY);
- window.dispatchEvent(new Event(CONSOLE_PREFERENCES_UPDATED_EVENT));
- }
-
- return defaultConsolePreferences;
-}
diff --git a/apps/aevatar-console-web/src/shared/studio/api.test.ts b/apps/aevatar-console-web/src/shared/studio/api.test.ts
index 93fbf5476..eddda0868 100644
--- a/apps/aevatar-console-web/src/shared/studio/api.test.ts
+++ b/apps/aevatar-console-web/src/shared/studio/api.test.ts
@@ -108,6 +108,28 @@ describe('studioApi host-session requests', () => {
);
});
+ it('collapses HTML error pages into a compact HTTP error message', async () => {
+ const fetchMock = jest.fn().mockResolvedValue({
+ ok: false,
+ status: 502,
+ statusText: 'Bad Gateway',
+ text: async () => `
+
+
+ aevatar.ai | 502: Bad gateway
+
+
+ Bad gateway
+
+`,
+ } as Response);
+ global.fetch = fetchMock as typeof global.fetch;
+
+ await expect(studioApi.getAuthSession()).rejects.toThrow(
+ 'HTTP 502 Bad Gateway',
+ );
+ });
+
it('sends available step types when parsing workflow yaml', async () => {
persistAuthSession({
tokens: {
diff --git a/apps/aevatar-console-web/src/shared/studio/api.ts b/apps/aevatar-console-web/src/shared/studio/api.ts
index 9dcc637ec..16320dd78 100644
--- a/apps/aevatar-console-web/src/shared/studio/api.ts
+++ b/apps/aevatar-console-web/src/shared/studio/api.ts
@@ -44,6 +44,7 @@ import {
readNumber,
readString,
} from "@/shared/api/http/decoders";
+import { readResponseError } from "@/shared/api/http/error";
import { decodeWorkflowCatalogItemDetailResponse } from "@/shared/api/runtimeDecoders";
import { authFetch } from "@/shared/auth/fetch";
@@ -80,28 +81,10 @@ function compactObject>(value: T): T {
) as T;
}
-async function readError(response: Response): Promise {
- const text = await response.text();
- if (!text) {
- return `HTTP ${response.status}`;
- }
-
- try {
- const payload = JSON.parse(text) as {
- message?: string;
- error?: string;
- code?: string;
- };
- return payload.message || payload.error || payload.code || text;
- } catch {
- return text;
- }
-}
-
async function requestJson(input: string, init?: RequestInit): Promise {
const response = await studioHostFetch(input, init);
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
if (response.status === 204) {
@@ -118,7 +101,7 @@ async function requestDecodedJson(
): Promise {
const response = await studioHostFetch(input, init);
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
if (response.status === 204) {
@@ -144,7 +127,7 @@ async function request(input: string, init?: RequestInit): Promise {
headers,
});
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
if (response.status === 204) {
@@ -174,7 +157,7 @@ async function streamSse(
signal,
});
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
if (!response.body) {
diff --git a/apps/aevatar-console-web/src/shared/studio/scriptsApi.test.ts b/apps/aevatar-console-web/src/shared/studio/scriptsApi.test.ts
index c8173dd41..421ce195a 100644
--- a/apps/aevatar-console-web/src/shared/studio/scriptsApi.test.ts
+++ b/apps/aevatar-console-web/src/shared/studio/scriptsApi.test.ts
@@ -123,4 +123,30 @@ describe('scriptsApi host-session requests', () => {
runtimeActorId: 'runtime-1',
});
});
+
+ it('collapses HTML error pages for Studio script endpoints', async () => {
+ const fetchMock = jest.fn().mockResolvedValue({
+ ok: false,
+ status: 502,
+ statusText: 'Bad Gateway',
+ text: async () => `
+
+
+ scripts gateway | 502: Bad gateway
+
+
+ Bad gateway
+
+`,
+ } as Response);
+ global.fetch = fetchMock as typeof global.fetch;
+
+ await expect(
+ scriptsApi.validateDraft({
+ scriptId: 'demo',
+ scriptRevision: 'draft-1',
+ source: 'public class Demo {}',
+ }),
+ ).rejects.toThrow('HTTP 502 Bad Gateway');
+ });
});
diff --git a/apps/aevatar-console-web/src/shared/studio/scriptsApi.ts b/apps/aevatar-console-web/src/shared/studio/scriptsApi.ts
index 2853769d9..70fae7f56 100644
--- a/apps/aevatar-console-web/src/shared/studio/scriptsApi.ts
+++ b/apps/aevatar-console-web/src/shared/studio/scriptsApi.ts
@@ -1,4 +1,5 @@
import { authFetch } from '@/shared/auth/fetch';
+import { readResponseError } from '@/shared/api/http/error';
import type {
DraftRunResult,
GeneratedScriptResult,
@@ -44,31 +45,13 @@ function isJsonContentType(contentType: string | null): boolean {
return value.includes('application/json') || value.includes('+json');
}
-async function readError(response: Response): Promise {
- const text = await response.text();
- if (!text) {
- return `HTTP ${response.status}`;
- }
-
- try {
- const payload = JSON.parse(text) as {
- code?: string;
- error?: string;
- message?: string;
- };
- return payload.message || payload.error || payload.code || text;
- } catch {
- return text;
- }
-}
-
async function requestJson(
input: string,
init?: RequestInit,
): Promise {
const response = await scriptsFetch(input, init);
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
if (response.status === 204) {
@@ -159,7 +142,7 @@ async function streamSse(
});
if (!response.ok) {
- throw new Error(await readError(response));
+ throw new Error(await readResponseError(response));
}
if (!response.body) {
diff --git a/apps/aevatar-console-web/src/shared/ui/errorText.ts b/apps/aevatar-console-web/src/shared/ui/errorText.ts
new file mode 100644
index 000000000..523d808f2
--- /dev/null
+++ b/apps/aevatar-console-web/src/shared/ui/errorText.ts
@@ -0,0 +1,26 @@
+function normalizeWhitespace(value: string): string {
+ return value.replace(/\s+/g, " ").trim();
+}
+
+export function describeError(
+ error: unknown,
+ fallback = "Unexpected error."
+): string {
+ if (error instanceof Error) {
+ const message = normalizeWhitespace(error.message || error.name || "");
+ return message || fallback;
+ }
+
+ if (error && typeof error === "object" && !Array.isArray(error)) {
+ const record = error as { message?: unknown };
+ if (typeof record.message === "string") {
+ const message = normalizeWhitespace(record.message);
+ if (message) {
+ return message;
+ }
+ }
+ }
+
+ const text = normalizeWhitespace(String(error ?? ""));
+ return text || fallback;
+}