From 1f4c6da02a12fff209ad28c50ab9321c31ae8c5d Mon Sep 17 00:00:00 2001 From: Taha Yassine Kraiem Date: Fri, 28 Jan 2022 11:15:01 +0100 Subject: [PATCH] feat(integrations): logs and parsers --- .../integrations/integration/elasticsearch.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/backend/services/integrations/integration/elasticsearch.go b/backend/services/integrations/integration/elasticsearch.go index f1280401c..b18dcbe60 100644 --- a/backend/services/integrations/integration/elasticsearch.go +++ b/backend/services/integrations/integration/elasticsearch.go @@ -8,6 +8,7 @@ import ( "fmt" elasticlib "github.com/elastic/go-elasticsearch/v7" "log" + "reflect" "time" "openreplay/backend/pkg/messages" @@ -137,11 +138,22 @@ func (es *elasticsearch) Request(c *client) error { } for { + var mapResp map[string]interface{} + if err := json.NewDecoder(res.Body).Decode(&mapResp); err != nil { + log.Fatalf("Error parsing raw response body: %s", err) + + // If no error, then convert response to a map[string]interface + } else { + log.Println("mapResp TYPE:", reflect.TypeOf(mapResp), "\n") + log.Println(mapResp) + } + var esResp elasticResponce if err := json.NewDecoder(res.Body).Decode(&esResp); err != nil { log.Printf("Error parsing the response body: %s\n", err) return fmt.Errorf("Error parsing the response body: %s", err) } + log.Printf("parsed response: %v\n", esResp) if len(esResp.Hits.Hits) == 0 { break