From 6b690a3eb3df20a6e58a727ba8879d511685d1e1 Mon Sep 17 00:00:00 2001 From: Jacquin Antoine Date: Mon, 2 Mar 2026 23:20:51 +0100 Subject: [PATCH] fix: log raw JSON on parse errors for debugging - Add raw JSON payload to parse error warnings - Helps diagnose malformed JSON from senders - Version bumped to 1.1.4 Co-authored-by: Qwen-Coder --- Makefile | 2 +- internal/adapters/inbound/unixsocket/source.go | 4 ++-- packaging/rpm/logcorrelator.spec | 5 ++++- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/Makefile b/Makefile index 11b27dc..c71eda6 100644 --- a/Makefile +++ b/Makefile @@ -15,7 +15,7 @@ BINARY_NAME=logcorrelator DIST_DIR=dist # Package version -PKG_VERSION ?= 1.1.3 +PKG_VERSION ?= 1.1.4 ## build: Build the logcorrelator binary locally build: diff --git a/internal/adapters/inbound/unixsocket/source.go b/internal/adapters/inbound/unixsocket/source.go index 6ff8fba..4a44e75 100644 --- a/internal/adapters/inbound/unixsocket/source.go +++ b/internal/adapters/inbound/unixsocket/source.go @@ -152,8 +152,8 @@ func (s *UnixSocketSource) readDatagrams(ctx context.Context, eventChan chan<- * event, err := parseJSONEvent(data, s.config.SourceType) if err != nil { - // Log parse errors as warnings - s.logger.Warnf("parse error: %v", err) + // Log parse errors with the raw data for debugging + s.logger.Warnf("parse error: %v | raw: %s", err, string(data)) continue } diff --git a/packaging/rpm/logcorrelator.spec b/packaging/rpm/logcorrelator.spec index 240aa24..42ae785 100644 --- a/packaging/rpm/logcorrelator.spec +++ b/packaging/rpm/logcorrelator.spec @@ -2,7 +2,7 @@ # Compatible with CentOS 7, Rocky Linux 8, 9, 10 # Define version before Version: field for RPM macro support -%global spec_version 1.1.3 +%global spec_version 1.1.4 Name: logcorrelator Version: %{spec_version} @@ -120,6 +120,9 @@ fi /etc/logrotate.d/logcorrelator %changelog +* Mon Mar 02 2026 logcorrelator - 1.1.4-1 +- Fix: Log raw JSON data on parse errors for debugging + * Mon Mar 02 2026 logcorrelator - 1.1.3-1 - Refactor: Switch Unix sockets from STREAM to DGRAM mode (SOCK_DGRAM) - Test: Comprehensive tests added - coverage improved to 74.4%