github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-08-13 22:27:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Handle item.Pair.Response.Payload is nil case in AMQP

Browse Source
This commit is contained in:
M. Mert Yildiran 2022-07-14 13:51:06 +03:00
parent d4b9fea5a7
commit 5457bdf56b
No known key found for this signature in database
GPG Key ID: D42ADB236521BF7A
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tap/extensions/amqp/main.go
View File

@ -264,9 +264,7 @@ func (d dissecting) Dissect(b *bufio.Reader, reader api.TcpReader, options *api.
func (d dissecting) Analyze(item *api.OutputChannelItem, resolvedSource string, resolvedDestination string, namespace string) *api.Entry {
request := item.Pair.Request.Payload.(map[string]interface{})
response := item.Pair.Response.Payload.(map[string]interface{})
reqDetails := request["details"].(map[string]interface{})
resDetails := response["details"].(map[string]interface{})
elapsedTime := item.Pair.Response.CaptureTime.Sub(item.Pair.Request.CaptureTime).Round(time.Millisecond).Milliseconds()
if elapsedTime < 0 {
@ -274,7 +272,14 @@ func (d dissecting) Analyze(item *api.OutputChannelItem, resolvedSource string,
}
reqDetails["method"] = request["method"]
var resDetails map[string]interface{}
if item.Pair.Response.Payload != nil {
response := item.Pair.Response.Payload.(map[string]interface{})
resDetails := response["details"].(map[string]interface{})
resDetails["method"] = response["method"]
}
return &api.Entry{
Protocol: protocol.ProtocolSummary,
Capture: item.Capture,