diff --git a/api/pkg/api/socket_server_handlers.go b/api/pkg/api/socket_server_handlers.go index 595a6eb55..12bf42adf 100644 --- a/api/pkg/api/socket_server_handlers.go +++ b/api/pkg/api/socket_server_handlers.go @@ -65,7 +65,7 @@ func (h *RoutesEventHandlers) WebSocketMessage(ep *ikisocket.EventPayload) { var tappedEntryMessage models.WebSocketTappedEntryMessage err := json.Unmarshal(ep.Data, &tappedEntryMessage) if err != nil { - fmt.Printf("Could not unmarshal message of message type %s %v", socketMessageBase.MessageType, err) + fmt.Printf("Could not unmarshal message of message type %s %v\n", socketMessageBase.MessageType, err) } else { h.SocketHarOutChannel <- tappedEntryMessage.Data } @@ -73,11 +73,13 @@ func (h *RoutesEventHandlers) WebSocketMessage(ep *ikisocket.EventPayload) { var statusMessage shared.WebSocketStatusMessage err := json.Unmarshal(ep.Data, &statusMessage) if err != nil { - fmt.Printf("Could not unmarshal message of message type %s %v", socketMessageBase.MessageType, err) + fmt.Printf("Could not unmarshal message of message type %s %v\n", socketMessageBase.MessageType, err) } else { controllers.TapStatus = statusMessage.TappingStatus broadcastToBrowserClients(ep.Data) } + default: + fmt.Printf("Received socket message of type %s for which no handlers are defined", socketMessageBase.MessageType) } } } diff --git a/cli/cmd/tapRunner.go b/cli/cmd/tapRunner.go index dca16c538..43d780963 100644 --- a/cli/cmd/tapRunner.go +++ b/cli/cmd/tapRunner.go @@ -211,7 +211,7 @@ func syncApiStatus(ctx context.Context, cancel context.CancelFunc, tappingOption if err != nil { fmt.Printf("error Sending message via control socket %s\n", err) } - time.Sleep(5 * time.Second) + time.Sleep(10 * time.Second) } } diff --git a/ui/src/components/HarPage.tsx b/ui/src/components/HarPage.tsx index 33e7cc525..11edf80fa 100644 --- a/ui/src/components/HarPage.tsx +++ b/ui/src/components/HarPage.tsx @@ -50,7 +50,7 @@ export const HarPage: React.FC = () => { const [statusFilter, setStatusFilter] = useState([]); const [pathFilter, setPathFilter] = useState(""); - const [apiStatus, setApiStatus] = useState(null); + const [tappingStatus, setTappingStatus] = useState(null); const ws = useRef(null); @@ -81,7 +81,7 @@ export const HarPage: React.FC = () => { setEntries([...newEntries, entry]) break case "status": - setApiStatus(message.tappingStatus); + setTappingStatus(message.tappingStatus); break default: console.error(`unsupported websocket message type, Got: ${message.messageType}`) @@ -93,7 +93,7 @@ export const HarPage: React.FC = () => { openWebSocket(); fetch(`http://localhost:8899/api/tapStatus`) .then(response => response.json()) - .then(data => setApiStatus(data)); + .then(data => setTappingStatus(data)); }, []); @@ -172,7 +172,7 @@ export const HarPage: React.FC = () => { {selectedHarEntry && } } - {apiStatus?.pods != null && } + {tappingStatus?.pods != null && } ) };