Refactor logging levels for session and metrics in Teltonika adapter
This commit is contained in:
@@ -112,7 +112,7 @@ export function createTeltonikaAdapter(options: TeltonikaAdapterOptions): Adapte
|
|||||||
|
|
||||||
// Accept the device
|
// Accept the device
|
||||||
socket.write(Buffer.from([0x01]));
|
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
|
// Phase 2: AVL frame read loop
|
||||||
|
|||||||
+1
-1
@@ -22,7 +22,7 @@ export async function runSession(
|
|||||||
const remoteAddress = `${socket.remoteAddress ?? 'unknown'}:${socket.remotePort ?? '?'}`;
|
const remoteAddress = `${socket.remoteAddress ?? 'unknown'}:${socket.remotePort ?? '?'}`;
|
||||||
const sessionLogger = ctx.logger.child({ remote_address: remoteAddress });
|
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) => {
|
socket.on('error', (err) => {
|
||||||
sessionLogger.debug({ err }, 'socket error');
|
sessionLogger.debug({ err }, 'socket error');
|
||||||
|
|||||||
+2
-2
@@ -34,8 +34,8 @@ logger.info('tcp-ingestion starting');
|
|||||||
// Placeholder metrics implementation — replaced in task 1.10.
|
// Placeholder metrics implementation — replaced in task 1.10.
|
||||||
// Using the Metrics interface from types.ts (no prom-client yet).
|
// Using the Metrics interface from types.ts (no prom-client yet).
|
||||||
const metrics: Metrics = {
|
const metrics: Metrics = {
|
||||||
inc: (name, labels) => logger.debug({ metric: name, labels }, 'metric inc'),
|
inc: (name, labels) => logger.trace({ metric: name, labels }, 'metric inc'),
|
||||||
observe: (name, value, labels) => logger.debug({ metric: name, value, labels }, 'metric observe'),
|
observe: (name, value, labels) => logger.trace({ metric: name, value, labels }, 'metric observe'),
|
||||||
};
|
};
|
||||||
|
|
||||||
// -------------------------------------------------------------------------
|
// -------------------------------------------------------------------------
|
||||||
|
|||||||
Reference in New Issue
Block a user