Function assertClientEvent

packages/http-recorder/src/websocket.ts:53–62

(actual: string, expected: WebSocketEvent | undefined, index: number, asJson: boolean)

const jsonOrText = (value: string) => Option.match(decodeJson(value), { onNone: () => value, onSome: canonicalizeJson })

const assertClientEvent = (actual: string, expected: WebSocketEvent | undefined, index: number, asJson: boolean) =>
  Effect.sync(() => {
    const matches =
      expected?.direction === "client" &&
      expected.kind === "text" &&
      JSON.stringify(asJson ? jsonOrText(actual) : actual) ===
        JSON.stringify(asJson ? jsonOrText(expected.body) : expected.body)
    if (matches) return
    throw new Error(`WebSocket client frame ${index + 1}: expected ${safeText(expected)}, received ${safeText(actual)}`)
  })

export const makeWebSocketExecutor = <E>(
  options: WebSocketRecordReplayOptions<E>,