From 193668e87aedfe16604f0e79beb0a9e7e000b185 Mon Sep 17 00:00:00 2001 From: Taha Yassine Kraiem Date: Fri, 28 Jan 2022 15:36:53 +0100 Subject: [PATCH] feat(integrations): add sessionId to Event --- .../integrations/integration/elasticsearch.go | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/backend/services/integrations/integration/elasticsearch.go b/backend/services/integrations/integration/elasticsearch.go index 8c85a3fe9..806777b09 100644 --- a/backend/services/integrations/integration/elasticsearch.go +++ b/backend/services/integrations/integration/elasticsearch.go @@ -165,14 +165,22 @@ func (es *elasticsearch) Request(c *client) error { } timestamp := uint64(utime.ToMilliseconds(esLog.Time)) c.setLastMessageTimestamp(timestamp) + + var sessionID uint64 + sessionID, err = strconv.ParseUint(token, 10, 64) + if err != nil { + log.Printf("Error converting token to uint46: %s\n", err) + sessionID = 0 + } c.evChan <- &SessionErrorEvent{ //SessionID: sessionID, - Token: token, + SessionID: sessionID, + Token: token, RawErrorEvent: &messages.RawErrorEvent{ Source: "elasticsearch", Timestamp: timestamp, - Name: fmt.Sprintf("%v", docID), - Payload: fmt.Sprintf("%v", source), + Name: fmt.Sprintf("%v", docID), + Payload: fmt.Sprintf("%v", source), }, } }