github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-08-31 18:17:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix the encoding of AMQP BasicPublish and BasicDeliver body

Browse Source
This commit is contained in:
M. Mert Yildiran
2021-08-22 17:18:29 +03:00
parent 58b744bc6c
commit 8f9e584025
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tap/extensions/amqp/helpers.go
View File

@@ -256,7 +256,7 @@ func representBasicPublish(event map[string]interface{}) []interface{} {
})
properties := event["Properties"].(map[string]interface{})
rep, contentType, contentEncoding := representProperties(properties, rep)
rep, contentType, _ := representProperties(properties, rep)
if properties["Headers"] != nil {
headers := make([]map[string]string, 0)
@@ -278,10 +278,10 @@ func representBasicPublish(event map[string]interface{}) []interface{} {
rep = append(rep, map[string]string{
"type": "body",
"title": "Body",
"encoding": contentEncoding,
"encoding": "base64",
"mime_type": contentType,
"data": event["Body"].(string),
}) // FIXME: `Body` value seems wrong
})
}
return rep
@@ -333,7 +333,7 @@ func representBasicDeliver(event map[string]interface{}) []interface{} {
})
properties := event["Properties"].(map[string]interface{})
rep, contentType, contentEncoding := representProperties(properties, rep)
rep, contentType, _ := representProperties(properties, rep)
if properties["Headers"] != nil {
headers := make([]map[string]string, 0)
@@ -355,10 +355,10 @@ func representBasicDeliver(event map[string]interface{}) []interface{} {
rep = append(rep, map[string]string{
"type": "body",
"title": "Body",
"encoding": contentEncoding,
"encoding": "base64",
"mime_type": contentType,
"data": event["Body"].(string),
}) // FIXME: `Body` value seems wrong
})
}
return rep