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

feat(integrations): changed response marshaling

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 11:56:51 +01:00
parent 8c63d03cd8
commit 0b51a40254
1 changed files with 13 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -8,7 +8,6 @@ import (
"fmt"
elasticlib "github.com/elastic/go-elasticsearch/v7"
"log"
"reflect"
"strconv"
"time"
@ -37,10 +36,9 @@ type elasticResponce struct {
Hits []struct {
Id string `json:"_id"`
Source json.RawMessage `json:"_source"`
}
}
} `json:"hits"`
} `json:"hits"`
ScrollId string `json:"_scroll_id"`
Error map[string]interface{}
}
func (es *elasticsearch) Request(c *client) error {
@ -57,6 +55,8 @@ func (es *elasticsearch) Request(c *client) error {
esC, err := elasticlib.NewClient(cfg)
if err != nil {
log.Println("Error while creating new ES client")
log.Println(err)
return err
}
// TODO: ping/versions/ client host check
@ -140,15 +140,15 @@ 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 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 {