fix: event logger

internal/sources/webhook/events.go

@@ -31,21 +31,20 @@ var (
 type Events struct {
 	Supported          map[string]Event
 	EventTypeFieldPath string
-	logger             logrus.Logger
 }
 
 type Event struct {
 	Operation entities.Operation
 	FieldID   string
 }
 
-func (e *Events) getPipelineEvent(rawData []byte) (entities.PipelineEvent, error) {
+func (e *Events) getPipelineEvent(logger *logrus.Entry, rawData []byte) (entities.PipelineEvent, error) {
 	parsed := gjson.ParseBytes(rawData)
 	webhookEvent := parsed.Get(e.EventTypeFieldPath).String()
 
 	event, ok := e.Supported[webhookEvent]
 	if !ok {
-		e.logger.WithFields(logrus.Fields{
+		logger.WithFields(logrus.Fields{
 			"webhookEvent": webhookEvent,
 			"event":        string(rawData),
 		}).Trace("unsupported webhook event")
@@ -54,7 +53,7 @@ func (e *Events) getPipelineEvent(rawData []byte) (entities.PipelineEvent, error
 
 	id := parsed.Get(event.FieldID).String()
 	if id == "" {
-		e.logger.WithFields(logrus.Fields{
+		logger.WithFields(logrus.Fields{
 			"webhookEvent": webhookEvent,
 			"event":        string(rawData),
 		}).Trace("unsupported webhook event")

internal/sources/webhook/events_test.go

@@ -20,11 +20,15 @@ import (
 	"testing"
 
 	"github.com/mia-platform/integration-connector-agent/internal/entities"
+	"github.com/sirupsen/logrus"
+	"github.com/sirupsen/logrus/hooks/test"
 
 	"github.com/stretchr/testify/require"
 )
 
 func TestEvent(t *testing.T) {
+	logger, _ := test.NewNullLogger()
+
 	testCases := map[string]struct {
 		rawData string
 		events  *Events
@@ -86,7 +90,7 @@ func TestEvent(t *testing.T) {
 
 	for name, tc := range testCases {
 		t.Run(name, func(t *testing.T) {
-			event, err := tc.events.getPipelineEvent([]byte(tc.rawData))
+			event, err := tc.events.getPipelineEvent(logrus.NewEntry(logger), []byte(tc.rawData))
 			if tc.expectError != "" {
 				require.Error(t, err)
 				require.EqualError(t, err, tc.expectError)

internal/sources/webhook/service.go

@@ -78,7 +78,7 @@ func webhookHandler(config *Configuration, p pipeline.IPipeline) fiber.Handler {
 			return c.SendStatus(http.StatusOK)
 		}
 
-		event, err := config.Events.getPipelineEvent(body)
+		event, err := config.Events.getPipelineEvent(log, body)
 		if err != nil {
 			log.WithError(err).Error("error unmarshaling event")
 			return c.Status(http.StatusBadRequest).JSON(utils.ValidationError(err.Error()))