Int32 Test

1import { describe, expect, it } from "vitest";
2import { query } from "./clickhouse.js";
3import { NeedMoreData, Cursor } from "../src/readers/core.js";
4import { readInt32 } 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("readInt32", () => {
11  it("decodes 0", async () => {
12    const r = await reader("toInt32(0)");
13    expect(readInt32(r)).toBe(0);
14    expect(r.pos).toBe(4);
15  });
16
17  it("decodes -1", async () => {
18    expect(readInt32(await reader("toInt32(-1)"))).toBe(-1);
19  });
20
21  it("decodes 2147483647 (max)", async () => {
22    expect(readInt32(await reader("toInt32(2147483647)"))).toBe(2147483647);
23  });
24
25  it("decodes -2147483648 (min)", async () => {
26    expect(readInt32(await reader("toInt32(-2147483648)"))).toBe(-2147483648);
27  });
28
29  describe("advance() edge cases", () => {
30    it("throws NeedMoreData for every incomplete prefix (0 .. full.length-1)", async () => {
31      const full = await query("SELECT toInt32(-5) FORMAT RowBinary");
32      for (let len = 0; len < full.length; len++) {
33        const r = new Cursor(full.subarray(0, len));
34        let thrown: unknown;
35        try {
36          readInt32(r);
37        } catch (e) {
38          thrown = e;
39        }
40        expect(thrown, `prefix length ${len} of ${full.length}`).toBe(
41          NeedMoreData,
42        );
43      }
44    });
45  });
46});