jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(integrations): add sessionId to Event

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 15:36:53 +01:00
parent 24653af5e2
commit 193668e87a
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
backend/services/integrations/integration/elasticsearch.go
View file

@ -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),
},
}
}