import { describe, expect, it } from "vitest"; import { isTransportConnectionErrorMessage, sanitizeThreadErrorMessage } from "./transportError"; describe("isTransportConnectionErrorMessage", () => { it("returns true for SocketCloseError", () => { expect(isTransportConnectionErrorMessage("SocketCloseError: connection reset")).toBe(true); }); it("returns true for SocketOpenError", () => { expect(isTransportConnectionErrorMessage("SocketOpenError: ECONNREFUSED")).toBe(true); }); it("returns true for the T3 server WebSocket message", () => { expect(isTransportConnectionErrorMessage("Unable to connect to the T3 server WebSocket.")).toBe( true, ); }); it("returns true for ping timeout", () => { expect(isTransportConnectionErrorMessage("ping timeout")).toBe(true); }); it("returns false for business logic errors", () => { expect(isTransportConnectionErrorMessage("Thread not found")).toBe(false); expect(isTransportConnectionErrorMessage("Invalid model selection")).toBe(false); }); it("returns false for null, undefined, and empty strings", () => { expect(isTransportConnectionErrorMessage(null)).toBe(false); expect(isTransportConnectionErrorMessage(undefined)).toBe(false); expect(isTransportConnectionErrorMessage("")).toBe(false); expect(isTransportConnectionErrorMessage(" ")).toBe(false); });}); describe("sanitizeThreadErrorMessage", () => { it("strips transport errors", () => { expect(sanitizeThreadErrorMessage("SocketCloseError: oops")).toBeNull(); }); it("preserves non-transport errors", () => { expect(sanitizeThreadErrorMessage("Thread not found")).toBe("Thread not found"); }); it("returns null for null/undefined", () => { expect(sanitizeThreadErrorMessage(null)).toBeNull(); expect(sanitizeThreadErrorMessage(undefined)).toBeNull(); });});
import { describe, expect, it } from "vitest";
import { isTransportConnectionErrorMessage, sanitizeThreadErrorMessage } from "./transportError";
describe("isTransportConnectionErrorMessage", () => {
it("returns true for SocketCloseError", () => {
expect(isTransportConnectionErrorMessage("SocketCloseError: connection reset")).toBe(true);
});
it("returns true for SocketOpenError", () => {
expect(isTransportConnectionErrorMessage("SocketOpenError: ECONNREFUSED")).toBe(true);
});
it("returns true for the T3 server WebSocket message", () => {
expect(isTransportConnectionErrorMessage("Unable to connect to the T3 server WebSocket.")).toBe(
true,
);
});
it("returns true for ping timeout", () => {
expect(isTransportConnectionErrorMessage("ping timeout")).toBe(true);
});
it("returns false for business logic errors", () => {
expect(isTransportConnectionErrorMessage("Thread not found")).toBe(false);
expect(isTransportConnectionErrorMessage("Invalid model selection")).toBe(false);
});
it("returns false for null, undefined, and empty strings", () => {
expect(isTransportConnectionErrorMessage(null)).toBe(false);
expect(isTransportConnectionErrorMessage(undefined)).toBe(false);
expect(isTransportConnectionErrorMessage("")).toBe(false);
expect(isTransportConnectionErrorMessage(" ")).toBe(false);
});
});
describe("sanitizeThreadErrorMessage", () => {
it("strips transport errors", () => {
expect(sanitizeThreadErrorMessage("SocketCloseError: oops")).toBeNull();
});
it("preserves non-transport errors", () => {
expect(sanitizeThreadErrorMessage("Thread not found")).toBe("Thread not found");
});
it("returns null for null/undefined", () => {
expect(sanitizeThreadErrorMessage(null)).toBeNull();
expect(sanitizeThreadErrorMessage(undefined)).toBeNull();
});
});