dirtydishes
d30513119a
- Route live terminal data through a shared live session socket - Fetch missing evidence for alerts and classifier hits - Add live type definitions and storage/API tests
60 lines
1.7 KiB
TypeScript
60 lines
1.7 KiB
TypeScript
import { describe, expect, it } from "bun:test";
|
|
import { createClickHouseClient, fetchFlowPacketById, fetchFlowPacketsBefore } from "../src/clickhouse";
|
|
import {
|
|
flowPacketsTableDDL,
|
|
FLOW_PACKETS_TABLE,
|
|
fromFlowPacketRecord,
|
|
toFlowPacketRecord
|
|
} from "../src/flow-packets";
|
|
|
|
const packet = {
|
|
source_ts: 10,
|
|
ingest_ts: 20,
|
|
seq: 1,
|
|
trace_id: "fp-1",
|
|
id: "fp-1",
|
|
members: ["p1", "p2"],
|
|
features: {
|
|
option_contract_id: "SPY-2025-01-17-450-C",
|
|
count: 2,
|
|
total_size: 30
|
|
},
|
|
join_quality: {
|
|
nbbo_age_ms: 5
|
|
}
|
|
};
|
|
|
|
describe("flow-packets storage helpers", () => {
|
|
it("includes the correct table name in the DDL", () => {
|
|
const ddl = flowPacketsTableDDL();
|
|
expect(ddl).toContain(FLOW_PACKETS_TABLE);
|
|
expect(ddl).toContain("CREATE TABLE IF NOT EXISTS");
|
|
});
|
|
|
|
it("round-trips flow packet records", () => {
|
|
const record = toFlowPacketRecord(packet);
|
|
const restored = fromFlowPacketRecord(record);
|
|
expect(restored.features).toEqual(packet.features);
|
|
expect(restored.join_quality).toEqual(packet.join_quality);
|
|
});
|
|
|
|
it("builds before-history and id lookup queries", async () => {
|
|
const queries: string[] = [];
|
|
const client = createClickHouseClient({ url: "http://127.0.0.1:8123" });
|
|
client.query = async ({ query }) => {
|
|
queries.push(query);
|
|
return {
|
|
async json<T>() {
|
|
return [] as T;
|
|
}
|
|
};
|
|
};
|
|
|
|
await fetchFlowPacketsBefore(client, 200, 3, 15);
|
|
await fetchFlowPacketById(client, "fp-1");
|
|
|
|
expect(queries[0]).toContain("(source_ts, seq) < (200, 3)");
|
|
expect(queries[0]).toContain("ORDER BY source_ts DESC, seq DESC LIMIT 15");
|
|
expect(queries[1]).toContain("WHERE id = 'fp-1'");
|
|
});
|
|
});
|