boki/stock-bot
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

fixed questdb files

Browse source
This commit is contained in:
Boki 2025-06-19 21:14:44 -04:00
parent 4aa8b7a42d
commit 691d259a67
3 changed files with 6 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

8
libs/questdb-client/src/influx-writer.ts
View file

@ -1,5 +1,5 @@
import { getLogger } from '@stock-bot/logger'; import { getLogger } from '@stock-bot/logger';
import type { BaseTimeSeriesData, InfluxLineData, InfluxWriteOptions } from './types'; import type { InfluxLineData, InfluxWriteOptions } from './types';
// Interface to avoid circular dependency // Interface to avoid circular dependency
interface QuestDBClientInterface { interface QuestDBClientInterface {
@ -185,11 +185,11 @@ export class QuestDBInfluxWriter {
}; };
if (execution.orderId) { if (execution.orderId) {
tags.order_id = execution.orderId; tags['order_id'] = execution.orderId;
} }
if (execution.strategy) { if (execution.strategy) {
tags.strategy = execution.strategy; tags['strategy'] = execution.strategy;
} }
await this.writePoint( await this.writePoint(
@ -224,7 +224,7 @@ export class QuestDBInfluxWriter {
}; };
if (metrics.errorCode) { if (metrics.errorCode) {
tags.error_code = metrics.errorCode; tags['error_code'] = metrics.errorCode;
} }
await this.writePoint( await this.writePoint(

2
libs/questdb-client/src/query-builder.ts
View file

@ -1,10 +1,8 @@
import { getLogger } from '@stock-bot/logger'; import { getLogger } from '@stock-bot/logger';
import type { import type {
AggregationQuery,
QueryResult, QueryResult,
TableNames, TableNames,
TimeRange, TimeRange,
TimeSeriesQuery,
} from './types'; } from './types';
// Interface to avoid circular dependency // Interface to avoid circular dependency

14
libs/questdb-client/src/schema.ts
View file

@ -1,5 +1,5 @@
import { getLogger } from '@stock-bot/logger'; import { getLogger } from '@stock-bot/logger';
import type { IndexDefinition, QueryResult, TableNames, TableSchema } from './types'; import type { QueryResult, TableSchema } from './types';
// Interface to avoid circular dependency // Interface to avoid circular dependency
interface QuestDBClientInterface { interface QuestDBClientInterface {
@ -299,7 +299,7 @@ export class QuestDBSchemaManager {
/** /**
* Create table partitions for future dates * Create table partitions for future dates
*/ */
public async createPartitions(tableName: string, days: number = 30): Promise<void> { public async createPartitions(tableName: string, _days: number = 30): Promise<void> {
// QuestDB handles partitioning automatically based on the PARTITION BY clause // QuestDB handles partitioning automatically based on the PARTITION BY clause
// This method is for future extensibility // This method is for future extensibility
this.logger.info(`Partitioning is automatic for table ${tableName}`); this.logger.info(`Partitioning is automatic for table ${tableName}`);
@ -337,16 +337,6 @@ export class QuestDBSchemaManager {
return sql; return sql;
} }
/**
* Build index creation SQL (for future use)
*/
private buildCreateIndexSQL(tableName: string, index: IndexDefinition): string {
const indexName = `idx_${tableName}_${index.columns.join('_')}`;
const columns = index.columns.join(', ');
// QuestDB uses different index syntax, this is for future compatibility
return `CREATE INDEX ${indexName} ON ${tableName} (${columns})`;
}
/** /**
* Validate schema definition * Validate schema definition