(event: MessageEvent)
| 92 | }; |
| 93 | |
| 94 | const onMessage = (event: MessageEvent) => { |
| 95 | try { |
| 96 | const data = JSON.parse(event.data); |
| 97 | const responseType = pendingRequestType; |
| 98 | |
| 99 | if (pendingRequestType === 'ps') { |
| 100 | isPsFetching.value = false; |
| 101 | } else if (pendingRequestType === 'net') { |
| 102 | isNetFetching.value = false; |
| 103 | } |
| 104 | pendingRequestType = null; |
| 105 | |
| 106 | if (responseType === activePollingType.value) { |
| 107 | if (responseType === 'ps') { |
| 108 | psData.value = data || []; |
| 109 | psLoading.value = false; |
| 110 | } else if (responseType === 'net') { |
| 111 | netData.value = data || []; |
| 112 | netLoading.value = false; |
| 113 | } |
| 114 | } |
| 115 | |
| 116 | if (queuedRequestType && isWsOpen()) { |
| 117 | const typeToSend = queuedRequestType; |
| 118 | queuedRequestType = null; |
| 119 | doSendMessage(typeToSend); |
| 120 | } |
| 121 | } catch (e) { |
| 122 | console.error('Failed to parse WebSocket message:', e); |
| 123 | } |
| 124 | }; |
| 125 | |
| 126 | const onError = () => { |
| 127 | console.error('WebSocket error'); |
nothing calls this directly
no test coverage detected