Fix some issues

agent/main.go

@@ -75,6 +75,8 @@ func main() {
 			rlog.Infof("Filtering for the following authorities: %v", tap.GetFilterIPs())
 		}
 
+		time.Sleep(2 * time.Second)
+
 		// harOutputChannel, outboundLinkOutputChannel := tap.StartPassiveTapper(tapOpts)
 		filteredOutputItemsChannel := make(chan *tapApi.OutputChannelItem)
 		tap.StartPassiveTapper(tapOpts, filteredOutputItemsChannel, extensions)

agent/pkg/api/socket_routes.go

@@ -41,11 +41,7 @@ func init() {
 
 func WebSocketRoutes(app *gin.Engine, eventHandlers EventHandlers) {
 	app.GET("/ws", func(c *gin.Context) {
-		queryMap := c.Request.URL.Query()
+		query := c.DefaultQuery("q", "")
-		query := ""
-		if val, ok := queryMap["q"]; ok {
-			query = val[0]
-		}
 		websocketHandlerUI(c.Writer, c.Request, eventHandlers, false, query)
 	})
 	app.GET("/wsTapper", func(c *gin.Context) {

agent/pkg/controllers/entries_controller.go

@@ -139,6 +139,10 @@ func GetEntry(c *gin.Context) {
 	id, _ := strconv.Atoi(c.Param("entryId"))
 	fmt.Printf("GetEntry id: %v\n", id)
 	entry := api.Single(uint(id))
+	var response map[string]interface{}
+	if entry["response"] != nil {
+		response = entry["response"].(map[string]interface{})
+	}
 	entryData := tapApi.MizuEntry{
 		Protocol: tapApi.Protocol{
 			Name:            entry["proto"].(map[string]interface{})["name"].(string),
@@ -152,7 +156,7 @@ func GetEntry(c *gin.Context) {
 			Priority:        uint8(entry["proto"].(map[string]interface{})["priority"].(float64)),
 		},
 		Request:         entry["request"].(map[string]interface{}),
-		Response:        entry["response"].(map[string]interface{}),
+		Response:        response,
 		EntryId:         entry["entryId"].(string),
 		Entry:           entry["entry"].(string),
 		Url:             entry["url"].(string),

tap/extensions/amqp/main.go

@@ -269,7 +269,6 @@ func (d dissecting) Analyze(item *api.OutputChannelItem, entryId string, resolve
 	return &api.MizuEntry{
 		Protocol:            protocol,
 		Request:             reqDetails,
-		Response:            item.Pair.Response.Payload.(map[string]interface{})["details"].(map[string]interface{}),
 		EntryId:             entryId,
 		Entry:               string(entryBytes),
 		Url:                 fmt.Sprintf("%s%s", service, summary),