UInt16 Test

1import { describe, expect, it } from "vitest";
2import { query } from "./clickhouse.js";
3import { NeedMoreData, Cursor } from "../src/readers/core.js";
4import { readUInt16 } from "../src/readers/integers.js";
5
6async function reader(expr: string): Promise<Cursor> {
7  return new Cursor(await query(`SELECT ${expr} FORMAT RowBinary`));
8}
9
10describe("readUInt16", () => {
11  it("decodes 0", async () => {
12    const r = await reader("toUInt16(0)");
13    expect(readUInt16(r)).toBe(0);
14    expect(r.pos).toBe(2);
15  });
16
17  // Confirms little-endian byte order: 258 = 0x0102 -> bytes 02 01.
18  it("decodes 258 (little-endian byte order)", async () => {
19    expect(readUInt16(await reader("toUInt16(258)"))).toBe(258);
20  });
21
22  it("decodes 65535 (max)", async () => {
23    expect(readUInt16(await reader("toUInt16(65535)"))).toBe(65535);
24  });
25
26  describe("advance() edge cases", () => {
27    it("throws NeedMoreData for every incomplete prefix (0 .. full.length-1)", async () => {
28      const full = await query("SELECT toUInt16(258) FORMAT RowBinary");
29      for (let len = 0; len < full.length; len++) {
30        const r = new Cursor(full.subarray(0, len));
31        let thrown: unknown;
32        try {
33          readUInt16(r);
34        } catch (e) {
35          thrown = e;
36        }
37        expect(thrown, `prefix length ${len} of ${full.length}`).toBe(
38          NeedMoreData,
39        );
40      }
41    });
42  });
43});