Int64 Test

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