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

feat(api): logs

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-27 22:45:35 +01:00
parent 2af4600d74
commit 44156fca0b
2 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -150,6 +150,8 @@ func (es *elasticsearch) Request(c *client) error {
}
token, err := GetToken(esLog.Message)
if err != nil {
log.Println("match not found for:")
log.Println(esLog.Message)
c.errChan <- err
continue
}
@ -158,6 +160,8 @@ func (es *elasticsearch) Request(c *client) error {
// c.errChan <- err
// continue
//}
log.Println("found match using")
log.Println(esLog.Message)
timestamp := uint64(utime.ToMilliseconds(esLog.Time))
c.setLastMessageTimestamp(timestamp)
c.evChan <- &SessionErrorEvent{

8
backend/services/integrations/main.go
View file

@ -69,16 +69,22 @@ func main() {
log.Printf("Requesting all...\n")
manager.RequestAll()
case event := <-manager.Events:
// log.Printf("New integration event: %v\n", *event.RawErrorEvent)
log.Printf("New integration event: %v\n", *event.RawErrorEvent)
sessionID := event.SessionID
log.Print("sessionId:")
log.Println(sessionID)
if sessionID == 0 {
log.Println("sessionID != 0")
sessData, err := tokenizer.Parse(event.Token)
if err != nil && err != token.EXPIRED {
log.Printf("Error on token parsing: %v; Token: %v", err, event.Token)
continue
}
sessionID = sessData.ID
} else {
log.Println("sessionID != 0")
}
log.Println("sending to producer")
// TODO: send to ready-events topic. Otherwise it have to go through the events worker.
producer.Produce(TOPIC_RAW_WEB, sessionID, messages.Encode(event.RawErrorEvent))
case err := <-manager.Errors: