homeio

1import { describe, expect, it, vi } from "vitest";
2
3vi.mock("@/lib/server/env", () => ({
4  serverEnv: {
5    SSE_HEARTBEAT_MS: 60_000,
6  },
7}));
8
9vi.mock("@/lib/server/modules/network/events", () => ({
10  getLatestNetworkEvent: vi.fn(),
11  subscribeToNetworkEvents: vi.fn(),
12}));
13
14import { GET } from "@/app/api/v1/network/events/stream/route";
15import {
16  getLatestNetworkEvent,
17  subscribeToNetworkEvents,
18} from "@/lib/server/modules/network/events";
19
20describe("GET /api/v1/network/events/stream", () => {
21  it("streams network events as SSE", async () => {
22    vi.mocked(getLatestNetworkEvent).mockReturnValueOnce({
23      type: "network.connection.changed",
24      timestamp: "2026-02-23T00:00:01.000Z",
25      iface: "wlan0",
26      ssid: "HomeNet",
27      connected: true,
28    });
29    vi.mocked(subscribeToNetworkEvents).mockImplementation(() => () => undefined);
30
31    const response = await GET(new Request("http://localhost"));
32
33    expect(response.status).toBe(200);
34    expect(response.headers.get("Content-Type")).toBe("text/event-stream");
35
36    const reader = response.body?.getReader();
37    const chunk = await reader?.read();
38    const text = new TextDecoder().decode(chunk?.value ?? new Uint8Array());
39
40    expect(text).toContain("event: network.connection.changed");
41    await reader?.cancel();
42  });
43});
44