From 52557afaff5493ad114dc8607f3298adbb642800 Mon Sep 17 00:00:00 2001 From: Taha Yassine Kraiem Date: Fri, 28 Jan 2022 00:35:08 +0100 Subject: [PATCH] feat(integrations): reset main --- backend/services/integrations/main.go | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/backend/services/integrations/main.go b/backend/services/integrations/main.go index 66e5c98db..35c3ff21e 100644 --- a/backend/services/integrations/main.go +++ b/backend/services/integrations/main.go @@ -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: