homeio

1import { EventEmitter } from "node:events";
2import { beforeEach, describe, expect, it, vi } from "vitest";
3
4const createConnectionMock = vi.fn();
5
6vi.mock("node:net", () => ({
7  default: {
8    createConnection: (...args: unknown[]) => createConnectionMock(...args),
9  },
10}));
11
12import {
13  getNetworkStatusFromHelper,
14} from "@/lib/server/modules/network/helper-client";
15import type { NetworkHelperError } from "@/lib/server/modules/network/helper-client";
16
17class MockSocket extends EventEmitter {
18  write = vi.fn((payload: string) => {
19    const request = JSON.parse(payload.trim()) as { id: string };
20    queueMicrotask(() => {
21      this.emit(
22        "data",
23        Buffer.from(
24          `${JSON.stringify({
25            id: request.id,
26            ok: true,
27            result: {
28              connected: true,
29              iface: "wlan0",
30              ssid: "HomeNet",
31              ipv4: "192.168.1.12",
32              signalPercent: 66,
33            },
34          })}\n`,
35        ),
36      );
37    });
38
39    return true;
40  });
41
42  end = vi.fn();
43  destroy = vi.fn(() => {
44    this.emit("close");
45  });
46}
47
48describe("network helper client", () => {
49  beforeEach(() => {
50    vi.clearAllMocks();
51  });
52
53  it("encodes helper call and decodes success response", async () => {
54    createConnectionMock.mockImplementation(() => {
55      const socket = new MockSocket();
56      queueMicrotask(() => {
57        socket.emit("connect");
58      });
59      return socket;
60    });
61
62    const status = await getNetworkStatusFromHelper({
63      requestId: "req-1",
64    });
65
66    expect(status.connected).toBe(true);
67    expect(status.ssid).toBe("HomeNet");
68  });
69
70  it("maps socket unavailable errors to helper_unavailable", async () => {
71    createConnectionMock.mockImplementation(() => {
72      const socket = new MockSocket();
73      queueMicrotask(() => {
74        const error = Object.assign(new Error("missing socket"), {
75          code: "ENOENT",
76        });
77        socket.emit("error", error);
78      });
79      return socket;
80    });
81
82    await expect(getNetworkStatusFromHelper()).rejects.toMatchObject({
83      code: "helper_unavailable",
84      statusCode: 503,
85    } satisfies Partial<NetworkHelperError>);
86  });
87});
88