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

feat(integrations): logs and parsers

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 11:15:01 +01:00
parent 835827b8be
commit 1f4c6da02a
1 changed files with 12 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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