Skip to content

Commit 6039b89

Browse files
chore: generate
1 parent b4fc5ef commit 6039b89

4 files changed

Lines changed: 28 additions & 8 deletions

File tree

packages/http-recorder/README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -196,8 +196,8 @@ type RecordReplayOptions = {
196196
197197
## Layout
198198
199-
| File | Purpose |
200-
| -------------- | -------------------------------------------------------------------------------- |
199+
| File | Purpose |
200+
| -------------- | --------------------------------------------------------------------------- |
201201
| `effect.ts` | `cassetteLayer` / `recordingLayer` — the `HttpClient` adapter. |
202202
| `websocket.ts` | `makeWebSocketExecutor` — WebSocket record/replay. |
203203
| `cassette.ts` | `Cassette.Service``fileSystem` / `memory` adapters, error types. |

packages/http-recorder/src/cassette.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,12 @@ export const fileSystem = (
120120
Effect.map((files) =>
121121
files
122122
.filter((file) => file.endsWith(".json"))
123-
.map((file) => path.relative(directory, file).replace(/\\/g, "/").replace(/\.json$/, ""))
123+
.map((file) =>
124+
path
125+
.relative(directory, file)
126+
.replace(/\\/g, "/")
127+
.replace(/\.json$/, ""),
128+
)
124129
.toSorted((a, b) => a.localeCompare(b)),
125130
),
126131
),

packages/http-recorder/src/effect.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,9 @@ export const recordingLayer = (
102102
}
103103
yield* cassetteService
104104
.append(name, interaction, options.metadata)
105-
.pipe(Effect.catchTag("UnsafeCassetteError", (error) => Effect.fail(transportError(request, error.message))))
105+
.pipe(
106+
Effect.catchTag("UnsafeCassetteError", (error) => Effect.fail(transportError(request, error.message))),
107+
)
106108
return HttpClientResponse.fromWeb(
107109
request,
108110
new Response(decodeResponseBody(interaction.response), interaction.response),

packages/http-recorder/test/record-replay.test.ts

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,10 @@ describe("http-recorder", () => {
326326

327327
test("auto mode records to disk when the cassette is missing", async () => {
328328
const directory = fs.mkdtempSync(path.join(os.tmpdir(), "http-recorder-auto-record-"))
329-
using server = Bun.serve({ port: 0, fetch: () => new Response('{"reply":"recorded"}', { headers: { "content-type": "application/json" } }) })
329+
using server = Bun.serve({
330+
port: 0,
331+
fetch: () => new Response('{"reply":"recorded"}', { headers: { "content-type": "application/json" } }),
332+
})
330333
const url = `http://127.0.0.1:${server.port}/echo`
331334
// CI=true forces replay; clear it so we exercise the local-dev auto-record path.
332335
const previous = process.env.CI
@@ -370,10 +373,18 @@ describe("http-recorder", () => {
370373
test("Cassette.list enumerates recorded cassette names", async () => {
371374
const directory = fs.mkdtempSync(path.join(os.tmpdir(), "http-recorder-list-"))
372375
await seedCassetteDirectory(directory, "alpha/one", [
373-
{ transport: "http", request: { method: "GET", url: "https://x.test/a", headers: {}, body: "" }, response: { status: 200, headers: {}, body: "a" } },
376+
{
377+
transport: "http",
378+
request: { method: "GET", url: "https://x.test/a", headers: {}, body: "" },
379+
response: { status: 200, headers: {}, body: "a" },
380+
},
374381
])
375382
await seedCassetteDirectory(directory, "beta", [
376-
{ transport: "http", request: { method: "GET", url: "https://x.test/b", headers: {}, body: "" }, response: { status: 200, headers: {}, body: "b" } },
383+
{
384+
transport: "http",
385+
request: { method: "GET", url: "https://x.test/b", headers: {}, body: "" },
386+
response: { status: 200, headers: {}, body: "b" },
387+
},
377388
])
378389

379390
const names = await Effect.runPromise(
@@ -415,7 +426,9 @@ describe("http-recorder", () => {
415426
transport: "websocket",
416427
open: { url: "wss://example.test/binary", headers: {} },
417428
client: [],
418-
server: [{ kind: "binary", body: Buffer.from(binaryServer).toString("base64"), bodyEncoding: "base64" }],
429+
server: [
430+
{ kind: "binary", body: Buffer.from(binaryServer).toString("base64"), bodyEncoding: "base64" },
431+
],
419432
},
420433
],
421434
}),

0 commit comments

Comments
 (0)