From 8c63d03cd8b1ce8270742976323c2cdcba0c863d Mon Sep 17 00:00:00 2001 From: Taha Yassine Kraiem Date: Fri, 28 Jan 2022 11:28:09 +0100 Subject: [PATCH] feat(integrations): changed query --- backend/services/integrations/integration/elasticsearch.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/backend/services/integrations/integration/elasticsearch.go b/backend/services/integrations/integration/elasticsearch.go index b18dcbe60..f70d3ee53 100644 --- a/backend/services/integrations/integration/elasticsearch.go +++ b/backend/services/integrations/integration/elasticsearch.go @@ -9,6 +9,7 @@ import ( elasticlib "github.com/elastic/go-elasticsearch/v7" "log" "reflect" + "strconv" "time" "openreplay/backend/pkg/messages" @@ -87,8 +88,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": gteTs, + "gte": strconv.FormatUint(gteTs, 10), + //"gte": gteTs, "lte": "now", }, }, @@ -102,6 +103,7 @@ func (es *elasticsearch) Request(c *client) error { }, }, } + if err := json.NewEncoder(&buf).Encode(query); err != nil { return fmt.Errorf("Error encoding the query: %s", err) }