From 5b763dc7b458ee0e1fe22c0787fd2a171cb8d79e Mon Sep 17 00:00:00 2001
From: Darius klein <darius.klein@dariusklein.nl>
Date: Wed, 19 Nov 2025 21:57:32 +0100
Subject: [PATCH] Improved logging and stdin buffering

---
 wazuh-notify-go-v2/notify.go | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/wazuh-notify-go-v2/notify.go b/wazuh-notify-go-v2/notify.go
index baa9276..5dd16ba 100644
--- a/wazuh-notify-go-v2/notify.go
+++ b/wazuh-notify-go-v2/notify.go
@@ -1,6 +1,7 @@
 package main
 
 import (
+	"bufio"
 	"context"
 	"encoding/json"
 	"fmt"
@@ -60,13 +61,15 @@ func flags() []cli.Flag {
 }
 
 func action(context context.Context, c *cli.Command) error {
+	logger.Log("Notify starting")
 	sourcePath := c.String(constants.Source)
 	var input io.Reader
 
 	if sourcePath == "" {
-		fmt.Println("Reading from standard input (stdin)...")
-		input = os.Stdin
+		logger.Log("Reading from standard input (stdin)...")
+		input = bufio.NewReader(os.Stdin)
 	} else {
+		logger.Log("Reading from file (stdin)...")
 		file, err := common.ReadFile(sourcePath)
 		if err != nil {
 			return err
@@ -133,13 +136,14 @@ func action(context context.Context, c *cli.Command) error {
 }
 
 func readInput(input io.Reader) (common.ActiveResponse, error) {
+	logger.Log("Parsing input")
 	var ar common.ActiveResponse
 
 	decoder := json.NewDecoder(input)
 
 	err := decoder.Decode(&ar)
 	if err != nil {
-		fmt.Fprintf(os.Stderr, "Error decoding JSON from stdin: %v\n", err)
+		logger.Log(fmt.Sprintf("Error decoding JSON from stdin: %v\n", err))
 		return ar, err
 	}