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

feat(integrations): logs and changes

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 10:51:59 +01:00
parent 30d0886a20
commit 835827b8be
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -8,7 +8,6 @@ import (
"fmt"
elasticlib "github.com/elastic/go-elasticsearch/v7"
"log"
"strconv"
"time"
"openreplay/backend/pkg/messages"
@ -87,7 +86,8 @@ func (es *elasticsearch) Request(c *client) error {
map[string]interface{}{
"range": map[string]interface{}{
"utc_time": map[string]interface{}{
"gte": strconv.FormatUint(gteTs, 10),
//"gte": strconv.FormatUint(gteTs, 10),
"gte": gteTs,
"lte": "now",
},
},
@ -142,6 +142,7 @@ func (es *elasticsearch) Request(c *client) error {
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
}