diff --git a/src/handlers/advisor/index.ts b/src/handlers/advisor/index.ts index 782d9ce..e982ef0 100644 --- a/src/handlers/advisor/index.ts +++ b/src/handlers/advisor/index.ts @@ -55,7 +55,7 @@ export default async function onMessage (message: Message) { probes.advisorIssueUnknown(host_id, issues); } - probes.advisorUpdateSuccess(message, host_id, issues, 2); // TODO: Fix Probes + probes.advisorUpdateSuccess(host_id, issues, 2); // TODO: Fix Probes } catch (e) { if (e instanceof Error) { probes.advisorUpdateError(host_id, issues, e); diff --git a/src/handlers/compliance/index.ts b/src/handlers/compliance/index.ts index 5f8f0ed..975af5b 100644 --- a/src/handlers/compliance/index.ts +++ b/src/handlers/compliance/index.ts @@ -56,7 +56,7 @@ export default async function onMessage (message: Message) { probes.complianceIssueUnknown(host_id, issues); } - probes.complianceUpdateSuccess(message, host_id, issues, 2); // TODO: Fix Probes + probes.complianceUpdateSuccess(host_id, issues, 2); // TODO: Fix Probes } catch (e) { if (e instanceof Error) { probes.complianceUpdateError(host_id, issues, e); diff --git a/src/handlers/patch/index.ts b/src/handlers/patch/index.ts index 1298cca..4063288 100644 --- a/src/handlers/patch/index.ts +++ b/src/handlers/patch/index.ts @@ -55,7 +55,7 @@ export default async function onMessage (message: Message) { probes.patchIssueUnknown(host_id, issues); } - probes.patchUpdateSuccess(message, host_id, issues, 2); // TODO: Fix Probes + probes.patchUpdateSuccess(host_id, issues, 2); // TODO: Fix Probes } catch (e) { if (e instanceof Error) { probes.patchUpdateError(host_id, issues, e); diff --git a/src/handlers/vulnerability/index.ts b/src/handlers/vulnerability/index.ts index 1f7da5d..0060471 100644 --- a/src/handlers/vulnerability/index.ts +++ b/src/handlers/vulnerability/index.ts @@ -56,7 +56,7 @@ export default async function onMessage (message: Message) { probes.vulnerabilityIssueUnknown(host_id, issues); } - probes.vulnerabilityUpdateSuccess(message, host_id, issues, 2); // TODO: Fix Probes + probes.vulnerabilityUpdateSuccess(host_id, issues, 2); // TODO: Fix Probes } catch (e) { if (e instanceof Error) { probes.vulnerabilityUpdateError(host_id, issues, e); diff --git a/src/probes.ts b/src/probes.ts index 06c31f8..0043f53 100644 --- a/src/probes.ts +++ b/src/probes.ts @@ -46,7 +46,6 @@ const counters = { export function incomingMessage (topic: string, message: Message) { log.trace({ message }, 'incoming message'); - log.info({ message }, 'incoming message'); counters.incoming.labels(topic).inc(); }; @@ -99,8 +98,8 @@ export function lostUpdateMessage (message: ReceptorMessage) counters.lostMessage.inc() } -export function advisorUpdateSuccess (message: Message, host_id: string, issues: string[], references: number) { - log.info({ message, host_id, references }, 'advisor issues successfully updated'); +export function advisorUpdateSuccess (host_id: string, issues: string[], references: number) { + log.info({ host_id, references }, 'advisor issues successfully updated'); log.debug({ issues }, 'updated advisor issues'); counters.advisor.labels('success').inc(); }; @@ -125,8 +124,8 @@ export function advisorUpdateErrorParse (message: Message, err: Error) { counters.compliance.labels('error_parse').inc(); }; -export function complianceUpdateSuccess (message: Message, host_id: string, issues: string[], references: number) { - log.info({ message, host_id, references }, 'compliance issues successfully updated'); +export function complianceUpdateSuccess (host_id: string, issues: string[], references: number) { + log.info({ host_id, references }, 'compliance issues successfully updated'); log.debug({ issues }, 'updated compliance issues'); counters.compliance.labels('success').inc(); }; @@ -151,8 +150,8 @@ export function complianceUpdateErrorParse (message: Message, err: Error) { counters.compliance.labels('error_parse').inc(); }; -export function patchUpdateSuccess (message: Message, host_id: string, issues: string[], references: number) { - log.info({ message, host_id, references }, 'patch issues successfully updated'); +export function patchUpdateSuccess (host_id: string, issues: string[], references: number) { + log.info({ host_id, references }, 'patch issues successfully updated'); log.debug({ issues }, 'updated patch issues') counters.patch.labels('success').inc(); }; @@ -177,8 +176,8 @@ export function patchUpdateErrorParse (message: Message, err: Error) { counters.patch.labels('error_parse').inc(); }; -export function vulnerabilityUpdateSuccess (message: Message, host_id: string, issues: string[], references: number) { - log.info({ message, host_id, references }, 'vulnerability issues successfully updated'); +export function vulnerabilityUpdateSuccess (host_id: string, issues: string[], references: number) { + log.info({ host_id, references }, 'vulnerability issues successfully updated'); log.debug({ issues }, 'updated vulnerabilitiy issues'); counters.vulnerability.labels('success').inc(); };