From 473b64b37673fce8d058aa73dbd6adafca5024ce Mon Sep 17 00:00:00 2001
From: Mathieu Lecarme <mathieu@garambrogne.net>
Date: Mon, 20 Jun 2022 17:14:03 +0200
Subject: [PATCH] Better error report, and more logical variable place.

---
 pkg/acquisition/modules/loki/loki.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/pkg/acquisition/modules/loki/loki.go b/pkg/acquisition/modules/loki/loki.go
index ae0339d75..d09cec2fa 100644
--- a/pkg/acquisition/modules/loki/loki.go
+++ b/pkg/acquisition/modules/loki/loki.go
@@ -358,14 +358,15 @@ func (l *LokiSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) er
 				if err2 == nil {
 					return fmt.Errorf("loki websocket (%s) error %v : %s", l.lokiWebsocket, err, string(buf))
 				}
+
 				return err2
 			}
 			defer c.Close()
-			var resp Tail
 			_, reader, err := c.NextReader()
 			if err != nil {
-				return errors.Wrap(err, "OneShotAcquisition error while reading JSON websocket")
+				return errors.Wrap(err, "loki OneShotAcquisition error while reading JSON websocket")
 			}
+			var resp Tail
 			decoder := json.NewDecoder(reader)
 			for { // draining the websocket
 				if !t.Alive() { // someone want to close this loop