From 4aa8b7a42dc2e0ca65682e29e378e3ab96779f81 Mon Sep 17 00:00:00 2001 From: Boki Date: Thu, 19 Jun 2025 21:11:50 -0400 Subject: [PATCH] fixed postgres-client --- libs/postgres-client/src/client.ts | 2 +- libs/postgres-client/src/transactions.ts | 1 - libs/postgres-client/src/types.ts | 2 +- libs/questdb-client/src/client.ts | 4 +--- 4 files changed, 3 insertions(+), 6 deletions(-) diff --git a/libs/postgres-client/src/client.ts b/libs/postgres-client/src/client.ts index 5526f65..a50d324 100644 --- a/libs/postgres-client/src/client.ts +++ b/libs/postgres-client/src/client.ts @@ -224,7 +224,7 @@ export class PostgreSQLClient { } const { chunkSize = 1000, excludeColumns = [] } = options; - const columns = Object.keys(data[0]).filter(col => !excludeColumns.includes(col)); + const columns = Object.keys(data[0] ?? {}).filter(col => !excludeColumns.includes(col)); const updateColumns = columns.filter(col => col !== conflictColumn); let totalInserted = 0; diff --git a/libs/postgres-client/src/transactions.ts b/libs/postgres-client/src/transactions.ts index 4506ded..47f2587 100644 --- a/libs/postgres-client/src/transactions.ts +++ b/libs/postgres-client/src/transactions.ts @@ -1,4 +1,3 @@ -import { PoolClient } from 'pg'; import { getLogger } from '@stock-bot/logger'; import type { PostgreSQLClient } from './client'; import type { TransactionCallback } from './types'; diff --git a/libs/postgres-client/src/types.ts b/libs/postgres-client/src/types.ts index 614c0a5..0caf612 100644 --- a/libs/postgres-client/src/types.ts +++ b/libs/postgres-client/src/types.ts @@ -1,4 +1,4 @@ -import type { QueryResult as PgQueryResult, Pool, PoolClient, QueryResultRow } from 'pg'; +import type { QueryResult as PgQueryResult, PoolClient, QueryResultRow } from 'pg'; /** * PostgreSQL Client Configuration diff --git a/libs/questdb-client/src/client.ts b/libs/questdb-client/src/client.ts index 9080b42..b3121f7 100644 --- a/libs/questdb-client/src/client.ts +++ b/libs/questdb-client/src/client.ts @@ -5,8 +5,6 @@ import { QuestDBInfluxWriter } from './influx-writer'; import { QuestDBQueryBuilder } from './query-builder'; import { QuestDBSchemaManager } from './schema'; import type { - BaseTimeSeriesData, - InsertResult, QueryResult, QuestDBClientConfig, QuestDBConnectionOptions, @@ -226,7 +224,7 @@ export class QuestDBClient { table: TableNames, columns: string[], interval: string, - timeColumn: string = 'timestamp', + _timeColumn: string = 'timestamp', where?: string, params?: any[] ): Promise> {