Salastil/streamwall
1
0
Fork 0
mirror of https://github.com/streamwall/streamwall.git synced 2026-04-03 20:32:08 -04:00
Code Issues Packages Projects Releases Wiki Activity

Prevent control page echoing back CRDT updates

Browse Source
This commit is contained in:
Max Goodhart
2020-07-05 22:56:00 -07:00
parent 904049646d
commit 2cbfc49a2b
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/web/control.js
View File

@@ -144,14 +144,17 @@ function useStreamwallConnection(wsEndpoint) {
}, []) }, [])
useEffect(() => { useEffect(() => {
function sendUpdate(update) { function sendUpdate(update, origin) {
if (origin === 'server') {
return
}
wsRef.current.send(update) wsRef.current.send(update)
} }
function receiveUpdate(ev) { function receiveUpdate(ev) {
if (!(ev.data instanceof ArrayBuffer)) { if (!(ev.data instanceof ArrayBuffer)) {
return return
} }
Y.applyUpdate(stateDoc, new Uint8Array(ev.data)) Y.applyUpdate(stateDoc, new Uint8Array(ev.data), 'server')
} }
stateDoc.on('update', sendUpdate) stateDoc.on('update', sendUpdate)
wsRef.current.addEventListener('message', receiveUpdate) wsRef.current.addEventListener('message', receiveUpdate)