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

feat(integrations): fixed source

Browse source
This commit is contained in:
Taha Yassine Kraiem 2022-01-28 15:15:20 +01:00
parent 93be4b4ff1
commit 24653af5e2
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -136,13 +136,13 @@ func (es *elasticsearch) Request(c *client) error {
doc := hit.(map[string]interface{})
source := doc["_source"].(map[string]interface{})
if _, ok := esResp["message"]; !ok {
if _, ok := source["message"]; !ok {
log.Printf("message not found in doc \n%v\n", doc)
c.errChan <- fmt.Errorf("message not found in doc '%v' ", doc)
continue
}
if _, ok := esResp["utc_time"]; !ok {
if _, ok := source["utc_time"]; !ok {
log.Printf("utc_time not found in doc \n%v\n", doc)
c.errChan <- fmt.Errorf("utc_time not found in doc '%v' ", doc)
continue