shu/woweb-poc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

log ws close event

Browse Source
This commit is contained in:
Sebastian Hugentobler 2023-02-23 13:32:49 +01:00
parent 90f8bb67b3
commit 869efdd56a
Signed by: shu
GPG Key ID: BB32CF3CA052C2F0
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
assets/index.js
View File

@ -30,7 +30,8 @@ function setupUi() {
} }
function setupWs() { function setupWs() {
ws.onclose = function () { ws.onclose = function (e) {
console.log(e);
setTimeout(() => { setTimeout(() => {
ws = new WebSocket(wsUrl); ws = new WebSocket(wsUrl);
}, 2000); }, 2000);

2
src/ws.rs
View File

@ -56,6 +56,8 @@ async fn handle_socket(stream: WebSocket, state: Arc<AppState>) {
while let Some(Ok(Message::Text(text))) = receiver.next().await { while let Some(Ok(Message::Text(text))) = receiver.next().await {
if let Ok(action) = serde_json::from_str::<Action>(&text) { if let Ok(action) = serde_json::from_str::<Action>(&text) {
let client = action.client.clone(); let client = action.client.clone();
tracing::debug!("update from {}", client.clone());
action.execute(state.clone()).await; action.execute(state.clone()).await;
let doc = state.doc.read().await; let doc = state.doc.read().await;