From 7ba6440a54e76fbfbf6d3f5729c6313a4eff44a2 Mon Sep 17 00:00:00 2001 From: Kenny Daniel Date: Tue, 25 Nov 2025 22:27:55 -0800 Subject: [PATCH] Add bigint to ParquetQueryValue types --- package.json | 6 +++--- src/query.js | 2 +- src/types.d.ts | 2 +- src/utils.js | 2 +- 4 files changed, 6 insertions(+), 6 deletions(-) diff --git a/package.json b/package.json index d142948..97f84f4 100644 --- a/package.json +++ b/package.json @@ -56,11 +56,11 @@ }, "devDependencies": { "@types/node": "24.10.1", - "@vitest/coverage-v8": "4.0.12", + "@vitest/coverage-v8": "4.0.14", "eslint": "9.39.1", - "eslint-plugin-jsdoc": "61.4.0", + "eslint-plugin-jsdoc": "61.4.1", "hyparquet-compressors": "1.1.1", "typescript": "5.9.3", - "vitest": "4.0.12" + "vitest": "4.0.14" } } diff --git a/src/query.js b/src/query.js index 1157fbf..110bfbf 100644 --- a/src/query.js +++ b/src/query.js @@ -123,7 +123,7 @@ export async function parquetQuery(options) { */ async function parquetReadRows(options) { const { file, rows } = options - options.metadata ||= await parquetMetadataAsync(file, options) + options.metadata ??= await parquetMetadataAsync(file, options) const { row_groups: rowGroups } = options.metadata // Compute row groups to fetch const groupIncluded = Array(rowGroups.length).fill(false) diff --git a/src/types.d.ts b/src/types.d.ts index b1cacae..9c3a506 100644 --- a/src/types.d.ts +++ b/src/types.d.ts @@ -57,7 +57,7 @@ export type ParquetQueryFilter = | { $or: ParquetQueryFilter[] } | { $nor: ParquetQueryFilter[] } type ParquetQueryColumnsFilter = { [key: string]: ParquetQueryOperator } -export type ParquetQueryValue = string | number | boolean | object | null | undefined +export type ParquetQueryValue = string | number | bigint | boolean | object | null | undefined export type ParquetQueryOperator = { $gt?: ParquetQueryValue $gte?: ParquetQueryValue diff --git a/src/utils.js b/src/utils.js index 8d6fdba..030c9a1 100644 --- a/src/utils.js +++ b/src/utils.js @@ -146,7 +146,7 @@ export async function asyncBufferFromUrl({ url, byteLength, requestInit, fetch: if (!url) throw new Error('missing url') const fetch = customFetch ?? globalThis.fetch // byte length from HEAD request - byteLength ||= await byteLengthFromUrl(url, requestInit, fetch) + byteLength ??= await byteLengthFromUrl(url, requestInit, fetch) /** * A promise for the whole buffer, if range requests are not supported.