Time64 Test

1import { describe, expect, it } from "vitest";
2import { query } from "./clickhouse.js";
3import { NeedMoreData, Cursor } from "../src/readers/core.js";
4import { formatTime64, readTime64 } from "../src/readers/time.js";
5
6async function reader(expr: string): Promise<Cursor> {
7  return new Cursor(
8    await query(
9      `SELECT ${expr} SETTINGS enable_time_time64_type = 1 FORMAT RowBinary`,
10    ),
11  );
12}
13
14describe("readTime64", () => {
15  it("decodes millisecond ticks (P=3)", async () => {
16    const r = await reader("toTime64('12:34:56.123', 3)");
17    const t = readTime64(3)(r);
18    expect(t).toEqual([45296123n, 3]);
19    expect(r.pos).toBe(8);
20    expect(formatTime64(t)).toBe("12:34:56.123");
21  });
22
23  it("decodes a negative time with fractional seconds", async () => {
24    const t = readTime64(3)(await reader("toTime64('-01:00:00.500', 3)"));
25    expect(t).toEqual([-3600500n, 3]);
26    expect(formatTime64(t)).toBe("-01:00:00.500");
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(
32        "SELECT toTime64('12:34:56.123', 3) SETTINGS enable_time_time64_type = 1 FORMAT RowBinary",
33      );
34      for (let len = 0; len < full.length; len++) {
35        const r = new Cursor(full.subarray(0, len));
36        let thrown: unknown;
37        try {
38          readTime64(3)(r);
39        } catch (e) {
40          thrown = e;
41        }
42        expect(thrown, `prefix length ${len} of ${full.length}`).toBe(
43          NeedMoreData,
44        );
45      }
46    });
47  });
48});