diff --git a/src/services/storage/db/storageProcessor.ts b/src/services/storage/db/storageProcessor.ts index f42cec42..549b9b0d 100644 --- a/src/services/storage/db/storageProcessor.ts +++ b/src/services/storage/db/storageProcessor.ts @@ -5,6 +5,7 @@ import { allMetricsMigrations, allMigrations } from '../migrations/runner.js'; import transactionsQueue from './transactionsQueue.js'; import { PickKeysByType } from 'typeorm/common/PickKeysByType'; import { deserializeRequest, WhereCondition } from './serializationHelpers.js'; +import { ProcessMetricsCollector } from '../tlv/processMetricsCollector.js'; export type DBNames = MainDbNames | MetricsDbNames export type QueryOptions = { @@ -164,6 +165,15 @@ class StorageProcessor { process.on('error', (error: Error) => { console.error('Error in storage processor:', error); }); + + new ProcessMetricsCollector((pMetrics) => { + this.sendResponse({ + success: true, + type: 'processMetrics', + data: pMetrics, + opId: Math.random().toString() + }) + }) } private async handleOperation(operation: StorageOperation) {