enricobuehler
f012ebbcba
Drop Orval for the first-party @effect/openapi-generator (OpenAPI 3.1 -> Effect Schema + a typed HttpClient client) and bump effect 3.19 -> 4.0.0-beta.98. Port the hand-written surfaces to the v4 API (Result over Either, Context.Service, Codec, Literals/Union arrays, Stream/Schedule/ Effect renames). Transport (CA-pinning fetch) and the reconnecting SSE source are kept intact. Make the SDK approachable for non-Effect users: - Add pf.api.* on the Promise facade: the generated client surfaced as typed, Promise-native methods (await pf.api.listPairedClients()), so REST calls are autocompleted and checked instead of stringly-typed pf.request(method, path, body) + `as` casts. Zero-drift veneer over make(httpClient), backed by the same pinning fetch. pf.request stays as the untyped escape hatch. - Re-tier examples into a 1-4 complexity ladder, rewritten onto pf.api.* (the typed payloads caught a wrong `launch` shape in provider-sync); the Effect example is labelled advanced. Add examples/ to tsconfig so they are typechecked (stops rot). typecheck + 19 tests green. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
64 lines
2.2 KiB
TypeScript
64 lines
2.2 KiB
TypeScript
// The wire schemas must decode EXACTLY what the host emits — the JSON literals here are the
|
|
// Rust side's snapshot-test strings (crates/punktfunk-host/src/events.rs), the schema gate.
|
|
import { describe, expect, test } from "bun:test";
|
|
import { decodeHostEvent, kindMatches } from "../src/wire.js";
|
|
|
|
describe("wire", () => {
|
|
test("decodes the host's snapshot frames", () => {
|
|
const stream = decodeHostEvent(
|
|
JSON.parse(
|
|
'{"seq":4182,"ts_ms":1700000000000,"schema":1,"kind":"stream.started","stream":{"mode":"3840x2160@120","hdr":true,"client":"Living Room TV","app":"steam:570","plane":"native"}}',
|
|
),
|
|
);
|
|
expect(stream._tag).toBe("Success");
|
|
if (stream._tag === "Success" && stream.success.kind === "stream.started") {
|
|
expect(stream.success.stream.mode).toBe("3840x2160@120");
|
|
expect(stream.success.stream.app).toBe("steam:570");
|
|
}
|
|
|
|
const disc = decodeHostEvent(
|
|
JSON.parse(
|
|
'{"seq":1,"ts_ms":1700000000000,"schema":1,"kind":"client.disconnected","client":{"name":"Deck","fingerprint":"b1c2","plane":"gamestream"},"reason":"timeout"}',
|
|
),
|
|
);
|
|
expect(disc._tag).toBe("Success");
|
|
if (disc._tag === "Success" && disc.success.kind === "client.disconnected") {
|
|
expect(disc.success.reason).toBe("timeout");
|
|
}
|
|
|
|
const stopping = decodeHostEvent(
|
|
JSON.parse('{"seq":2,"ts_ms":1700000000000,"schema":1,"kind":"host.stopping"}'),
|
|
);
|
|
expect(stopping._tag).toBe("Success");
|
|
});
|
|
|
|
test("tolerates unknown keys (additive-only wire)", () => {
|
|
const r = decodeHostEvent({
|
|
seq: 9,
|
|
ts_ms: 1,
|
|
schema: 1,
|
|
kind: "library.changed",
|
|
source: "manual",
|
|
future_field: { anything: true },
|
|
});
|
|
expect(r._tag).toBe("Success");
|
|
});
|
|
|
|
test("unknown kinds fail decode (they ride the raw channel)", () => {
|
|
const r = decodeHostEvent({
|
|
seq: 9,
|
|
ts_ms: 1,
|
|
schema: 1,
|
|
kind: "totally.new",
|
|
});
|
|
expect(r._tag).toBe("Failure");
|
|
});
|
|
|
|
test("kindMatches mirrors the host filter semantics", () => {
|
|
expect(kindMatches("stream.started", "stream.started")).toBe(true);
|
|
expect(kindMatches("stream.*", "stream.stopped")).toBe(true);
|
|
expect(kindMatches("stream.*", "streamx.started")).toBe(false);
|
|
expect(kindMatches("stream.started", "stream.stopped")).toBe(false);
|
|
});
|
|
});
|