jb/paseo
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(app/relay): parse test responses with Zod (T1.d typeaware sweep) (#749)

Browse Source 
Replace unsafe type assertions with Zod schema parsing:
- app/utils/project-config-form.test.ts: Use PaseoConfigRawSchema.parse()
  instead of 'as unknown as PaseoConfigRaw' (~10 errors fixed)
- server/daemon-e2e/relay-transport.e2e.test.ts: Use ConnectionOfferSchema
  and WSOutboundMessageSchema.parse() instead of inline type casts (~8 errors fixed)

Deferred to follow-up cluster (architectural decisions needed):
- host-runtime.test.ts: FakeDaemonClient mock needs proper interface
  implementation (requires source file changes)
- cloudflare-adapter.test.ts: WebSocket/DurableObjectState mocks need
  design review (external Cloudflare types)

Target rule: typescript-eslint(no-unsafe-type-assertion)
Errors cleared: 18/76 in cluster (61 deferred)
This commit is contained in:
Mohamed Boudra
2026-05-05 19:58:56 +07:00
parent 0d80394180
commit 006a79ed01
2 changed files with 37 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/server/daemon-e2e/relay-transport.e2e.test.ts
+17 -66
View File
@@ -11,6 +11,8 @@ import { generateLocalPairingOffer } from "../pairing-offer.js";
import { createTestPaseoDaemon } from "../test-utils/paseo-daemon.js";
import { createClientChannel, type Transport } from "@getpaseo/relay/e2ee";
import { buildRelayWebSocketUrl } from "../../shared/daemon-endpoints.js";
import { ConnectionOfferSchema } from "../../shared/connection-offer.js";
import { WSOutboundMessageSchema } from "../../shared/messages.js";
const nodeMajor = Number((process.versions.node ?? "0").split(".")[0] ?? "0");
const shouldRunRelayE2e = process.env.FORCE_RELAY_E2E === "1" || nodeMajor < 25;
@@ -59,10 +61,7 @@ function decodeOfferFromFragmentUrl(url: string): {
}
const encoded = url.slice(idx + marker.length);
const json = Buffer.from(encoded, "base64url").toString("utf8");
const offer = JSON.parse(json) as { v?: unknown; serverId?: string; daemonPublicKeyB64?: string };
if (offer.v !== 2) throw new Error("expected offer.v=2");
if (!offer.serverId) throw new Error("offer.serverId missing");
if (!offer.daemonPublicKeyB64) throw new Error("offer.daemonPublicKeyB64 missing");
const offer = ConnectionOfferSchema.parse(JSON.parse(json));
return { serverId: offer.serverId, daemonPublicKeyB64: offer.daemonPublicKeyB64 };
}
@@ -282,27 +281,12 @@ async function waitForRelayWebSocketReady(port: number, timeout = 60000): Promis
onmessage: (data) => {
try {
const payload = typeof data === "string" ? JSON.parse(data) : data;
const wsMsg = WSOutboundMessageSchema.safeParse(payload);
if (
payload &&
typeof payload === "object" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).type === "session" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).message?.type === "status" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).message?.payload?.status === "server_info"
wsMsg.success &&
wsMsg.data.type === "session" &&
wsMsg.data.message.type === "status" &&
wsMsg.data.message.payload?.status === "server_info"
) {
if (!pingSent && channelRef) {
pingSent = true;
@@ -310,17 +294,8 @@ async function waitForRelayWebSocketReady(port: number, timeout = 60000): Promis
}
return;
}
if (
payload &&
typeof payload === "object" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).type === "pong"
) {
settleResolve(payload);
if (wsMsg.success && wsMsg.data.type === "pong") {
settleResolve(wsMsg.data);
ws.close();
}
} catch (err) {
@@ -432,27 +407,12 @@ async function waitForRelayWebSocketReady(port: number, timeout = 60000): Promis
const channel = await createClientChannel(transport, daemonPublicKeyB64, {
onmessage: (data) => {
const payload = typeof data === "string" ? JSON.parse(data) : data;
const wsMsg = WSOutboundMessageSchema.safeParse(payload);
if (
payload &&
typeof payload === "object" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).type === "session" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).message?.type === "status" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).message?.payload?.status === "server_info"
wsMsg.success &&
wsMsg.data.type === "session" &&
wsMsg.data.message.type === "status" &&
wsMsg.data.message.payload?.status === "server_info"
) {
if (!pingSent && channelRef) {
pingSent = true;
@@ -460,18 +420,9 @@ async function waitForRelayWebSocketReady(port: number, timeout = 60000): Promis
}
return;
}
if (
payload &&
typeof payload === "object" &&
(
payload as {
type?: string;
message?: { type?: string; payload?: { status?: string } };
}
).type === "pong"
) {
if (wsMsg.success && wsMsg.data.type === "pong") {
clearTimeout(timeout);
resolve(payload);
resolve(wsMsg.data);
ws.close();
}
},