From e2b3bc421c6f6e1dbd6b647721bbffdb40d2a19a Mon Sep 17 00:00:00 2001 From: Julian Cuni Date: Thu, 30 Apr 2026 19:13:35 +0200 Subject: [PATCH] Refactor logging levels for session and metrics in Teltonika adapter --- src/adapters/teltonika/index.ts | 2 +- src/core/session.ts | 2 +- src/main.ts | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/adapters/teltonika/index.ts b/src/adapters/teltonika/index.ts index 1c9c313..ecb74c3 100644 --- a/src/adapters/teltonika/index.ts +++ b/src/adapters/teltonika/index.ts @@ -112,7 +112,7 @@ export function createTeltonikaAdapter(options: TeltonikaAdapterOptions): Adapte // Accept the device socket.write(Buffer.from([0x01])); - sessionLogger.debug({ known: knownLabel }, 'IMEI handshake accepted'); + sessionLogger.info({ known: knownLabel }, 'IMEI handshake accepted'); // ------------------------------------------------------------------ // // Phase 2: AVL frame read loop diff --git a/src/core/session.ts b/src/core/session.ts index 80de6c3..912284d 100644 --- a/src/core/session.ts +++ b/src/core/session.ts @@ -22,7 +22,7 @@ export async function runSession( const remoteAddress = `${socket.remoteAddress ?? 'unknown'}:${socket.remotePort ?? '?'}`; const sessionLogger = ctx.logger.child({ remote_address: remoteAddress }); - sessionLogger.debug({ adapter: adapter.name }, 'session opened'); + sessionLogger.info({ adapter: adapter.name }, 'session opened'); socket.on('error', (err) => { sessionLogger.debug({ err }, 'socket error'); diff --git a/src/main.ts b/src/main.ts index 1b3452f..fba738f 100644 --- a/src/main.ts +++ b/src/main.ts @@ -34,8 +34,8 @@ logger.info('tcp-ingestion starting'); // Placeholder metrics implementation — replaced in task 1.10. // Using the Metrics interface from types.ts (no prom-client yet). const metrics: Metrics = { - inc: (name, labels) => logger.debug({ metric: name, labels }, 'metric inc'), - observe: (name, value, labels) => logger.debug({ metric: name, value, labels }, 'metric observe'), + inc: (name, labels) => logger.trace({ metric: name, labels }, 'metric inc'), + observe: (name, value, labels) => logger.trace({ metric: name, value, labels }, 'metric observe'), }; // -------------------------------------------------------------------------