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

feat(api): hardcoded query

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 00:12:52 +01:00
parent d909181d21
commit 46b10702f6
1 changed files with 25 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -8,6 +8,7 @@ import (
"fmt"
elasticlib "github.com/elastic/go-elasticsearch/v7"
"log"
"reflect"
"strings"
"time"
@ -40,7 +41,7 @@ type elasticResponce struct {
}
ScrollId string `json:"_scroll_id"`
}
var mapResp map[string]interface{}
func (es *elasticsearch) Request(c *client) error {
address := es.Host + ":" + es.Port.String()
apiKey := b64.StdEncoding.EncodeToString([]byte(es.ApiKeyId + ":" + es.ApiKey))
@ -127,20 +128,31 @@ func (es *elasticsearch) Request(c *client) error {
return fmt.Errorf("Error getting response: %s", err)
}
defer res.Body.Close()
if res.IsError() {
var e map[string]interface{}
if err := json.NewDecoder(res.Body).Decode(&e); err != nil {
return fmt.Errorf("Error parsing the response body: %v", err)
} else {
return fmt.Errorf("Elasticsearch [%s] %s: %s",
res.Status(),
e["error"], //.(map[string]interface{})["type"],
e["error"], //.(map[string]interface{})["reason"],
)
}
}
//if res.IsError() {
// var e map[string]interface{}
// if err := json.NewDecoder(res.Body).Decode(&e); err != nil {
// return fmt.Errorf("Error parsing the response body: %v", err)
// } else {
// return fmt.Errorf("Elasticsearch [%s] %s: %s",
// res.Status(),
// e["error"], //.(map[string]interface{})["type"],
// e["error"], //.(map[string]interface{})["reason"],
// )
// }
//}
log.Print("no errors while looking for logs")
for {
if err := json.NewDecoder(res.Body).Decode(&mapResp); err != nil {
log.Fatalf("Error parsing the 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)
}
log.Println("end---")
var esResp elasticResponce
log.Println(">1")
if err := json.NewDecoder(res.Body).Decode(&esResp); err != nil {