Fix: put host only for CloudTrail with correct priority

ndakkoune · ndakkoune · commit a97dc93593ef · 2026-05-05T13:37:40.000+02:00
diff --git a/aws/logs_monitoring_go/internal/handling/s3.go b/aws/logs_monitoring_go/internal/handling/s3.go
@@ -94,9 +94,8 @@ func (h S3Handler) processRecord(ctx context.Context, client S3APIClient, out ch
 		}
 
 		if isCloudTrail {
-			entry.Host = cloudtrailHost(message)
+			entry.Host = cmp.Or(h.cfg.Host, cloudtrailHost(message))
 		}
-		entry.Host = cmp.Or(h.cfg.Host, entry.Host)
 		entry.Message = h.cfg.Scrubber.Scrub(entry.Message)
 		if err := concurrent.SafeSender(ctx, out, entry); err != nil {
 			return err

Original file line number	Diff line number	Diff line change
`@@ -94,9 +94,8 @@ func (h S3Handler) processRecord(ctx context.Context, client S3APIClient, out ch`
`94`	`94`	`}`
`95`	`95`
`96`	`96`	`if isCloudTrail {`
`97`		`- entry.Host = cloudtrailHost(message)`
	`97`	`+ entry.Host = cmp.Or(h.cfg.Host, cloudtrailHost(message))`
`98`	`98`	`}`
`99`		`- entry.Host = cmp.Or(h.cfg.Host, entry.Host)`
`100`	`99`	`entry.Message = h.cfg.Scrubber.Scrub(entry.Message)`
`101`	`100`	`if err := concurrent.SafeSender(ctx, out, entry); err != nil {`
`102`	`101`	`return err`