50 lines · 1.8 KB · TypeScript
RawDownload
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();  });});