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:01:25 +01:00
parent c95b8b97b3
commit d909181d21
1 changed files with 35 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -8,7 +8,7 @@ import (
"fmt"
elasticlib "github.com/elastic/go-elasticsearch/v7"
"log"
"strconv"
"strings"
"time"
"openreplay/backend/pkg/messages"
@ -75,35 +75,39 @@ func (es *elasticsearch) Request(c *client) error {
gteTs := c.getLastMessageTimestamp() + 1000 // Sec or millisec to add ?
log.Printf("gteTs: %v ", gteTs)
var buf bytes.Buffer
query := map[string]interface{}{
"query": map[string]interface{}{
"bool": map[string]interface{}{
"filter": []map[string]interface{}{
map[string]interface{}{
"match": map[string]interface{}{
"message": map[string]interface{}{
"query": "openReplaySessionToken=", // asayer_session_id=
},
},
},
map[string]interface{}{
"range": map[string]interface{}{
"utc_time": map[string]interface{}{
"gte": strconv.FormatUint(gteTs, 10),
"lte": "now",
},
},
},
map[string]interface{}{
"term": map[string]interface{}{
"tags": "error",
},
},
},
},
},
}
if err := json.NewEncoder(&buf).Encode(query); err != nil {
//query := map[string]interface{}{
// "query": map[string]interface{}{
// "bool": map[string]interface{}{
// "filter": []map[string]interface{}{
// map[string]interface{}{
// "match": map[string]interface{}{
// "message": map[string]interface{}{
// "query": "openReplaySessionToken=", // asayer_session_id=
// },
// },
// },
// map[string]interface{}{
// "range": map[string]interface{}{
// "utc_time": map[string]interface{}{
// "gte": strconv.FormatUint(gteTs, 10),
// "lte": "now",
// },
// },
// },
// map[string]interface{}{
// "term": map[string]interface{}{
// "tags": "error",
// },
// },
// },
// },
// },
//}
query := `{ "query": { "bool": { "filter": [ { "match": { "message": { "query": "openReplaySessionToken=" } } }, { "range": { "utc_time": { "gte": 1643231522874, "lte": "now" } } }, { "term": { "tags": "error" } } ] } } }`
var b strings.Builder
b.WriteString(query)
read := strings.NewReader(b.String())
if err := json.NewEncoder(&buf).Encode(read); err != nil {
return fmt.Errorf("Error encoding the query: %s", err)
}
log.Print("looking for logs in index:")
@ -115,7 +119,7 @@ func (es *elasticsearch) Request(c *client) error {
esC.Search.WithIndex(es.Indexes),
esC.Search.WithSize(1000),
esC.Search.WithScroll(time.Minute*2),
esC.Search.WithBody(&buf),
esC.Search.WithBody(read),
esC.Search.WithSort("timestamp:asc"),
)
log.Print("after looking for logs")