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

feat(integrations): reset main

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 00:35:08 +01:00
parent e05b81892a
commit 52557afaff
1 changed files with 2 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -18,8 +18,7 @@ import (
)
func main() {
//log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
log.SetFlags(0)
log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
TOPIC_RAW_WEB := env.String("TOPIC_RAW_WEB")
POSTGRES_STRING := env.String("POSTGRES_STRING")
@ -70,22 +69,16 @@ 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: