github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-09-03 19:48:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

FE miss WS entries (#1010)

Browse Source
This commit is contained in:
lirazyehezkel
2022-04-17 15:34:21 +03:00
committed by GitHub
parent e104128df8
commit a527fc6c51
1 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
ui-common/src/components/TrafficViewer/EntriesList.tsx
View File

@@ -118,23 +118,31 @@ export const EntriesList: React.FC<EntriesListProps> = ({
const scrollbarVisible = scrollableRef.current?.childWrapperRef.current.clientHeight > scrollableRef.current?.wrapperRef.current.clientHeight; const scrollbarVisible = scrollableRef.current?.childWrapperRef.current.clientHeight > scrollableRef.current?.wrapperRef.current.clientHeight;
useEffect(() => {
if (!focusedEntryId && entries.length > 0)
setFocusedEntryId(entries[0].id);
}, [focusedEntryId, entries])
useEffect(() => {
const newEntries = [...entries];
if (newEntries.length > 10000) {
setLeftOffTop(newEntries[0].id);
newEntries.splice(0, newEntries.length - 10000)
setNoMoreDataTop(false);
setEntries(newEntries);
}
}, [entries])
if (ws.current) { if(ws.current && !ws.current.onmessage) {
ws.current.onmessage = (e) => { ws.current.onmessage = (e) => {
if (!e?.data) return; if (!e?.data) return;
const message = JSON.parse(e.data); const message = JSON.parse(e.data);
switch (message.messageType) { switch (message.messageType) {
case "entry": case "entry":
const entry = message.data; setEntries(entriesState => {
if (!focusedEntryId) setFocusedEntryId(entry.id); const newEntries = [...entriesState, message.data];
const newEntries = [...entries, entry]; return newEntries;
if (newEntries.length > 10000) { });
setLeftOffTop(newEntries[0].id);
newEntries.splice(0, newEntries.length - 10000)
setNoMoreDataTop(false);
}
setEntries(newEntries);
break; break;
case "status": case "status":
setTappingStatus(message.tappingStatus); setTappingStatus(message.tappingStatus);