summaryrefslogtreecommitdiff
path: root/op_crates
diff options
context:
space:
mode:
Diffstat (limited to 'op_crates')
-rw-r--r--op_crates/websocket/01_websocket.js2
-rw-r--r--op_crates/websocket/lib.rs8
2 files changed, 9 insertions, 1 deletions
diff --git a/op_crates/websocket/01_websocket.js b/op_crates/websocket/01_websocket.js
index d9b1455bd..4a303679b 100644
--- a/op_crates/websocket/01_websocket.js
+++ b/op_crates/websocket/01_websocket.js
@@ -350,6 +350,7 @@
});
event.target = this;
this.dispatchEvent(event);
+ core.close(this.#rid);
break;
}
@@ -364,6 +365,7 @@
const closeEv = new CloseEvent("close");
closeEv.target = this;
this.dispatchEvent(closeEv);
+ core.close(this.#rid);
break;
}
diff --git a/op_crates/websocket/lib.rs b/op_crates/websocket/lib.rs
index f43ce8b42..c914f11c5 100644
--- a/op_crates/websocket/lib.rs
+++ b/op_crates/websocket/lib.rs
@@ -322,7 +322,13 @@ pub async fn op_ws_next_event(
"reason": frame.reason.as_ref()
}
}),
- Some(Ok(Message::Close(None))) => json!({ "kind": "close" }),
+ Some(Ok(Message::Close(None))) => json!({
+ "kind": "close",
+ "data": {
+ "code": 1005,
+ "reason": ""
+ }
+ }),
Some(Ok(Message::Ping(_))) => json!({ "kind": "ping" }),
Some(Ok(Message::Pong(_))) => json!({ "kind": "pong" }),
Some(Err(_)) => json!({ "kind": "error" }),