diff options
author | Divy Srivastava <dj.srivastava23@gmail.com> | 2024-06-25 06:39:02 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-06-25 19:09:02 +0530 |
commit | a1ff1a453c309c2f14c64ec31a3c43ef784781e2 (patch) | |
tree | e10c6c6e84e70d02adcefc54dd4dd2e9ccc60203 /ext/websocket/lib.rs | |
parent | 13aa1d70e905f1e1ec57d7eb57ad57d09d09deb2 (diff) |
fix(ext/websocket): drop connection when close frame not ack (#24301)
Fixes #24292
Diffstat (limited to 'ext/websocket/lib.rs')
-rw-r--r-- | ext/websocket/lib.rs | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/ext/websocket/lib.rs b/ext/websocket/lib.rs index 87503120b..5c3e8d7b1 100644 --- a/ext/websocket/lib.rs +++ b/ext/websocket/lib.rs @@ -699,10 +699,14 @@ pub async fn op_ws_close( #[smi] code: Option<u16>, #[string] reason: Option<String>, ) -> Result<(), AnyError> { - let resource = state + let Ok(resource) = state .borrow_mut() .resource_table - .get::<ServerWebSocket>(rid)?; + .get::<ServerWebSocket>(rid) + else { + return Ok(()); + }; + let frame = reason .map(|reason| Frame::close(code.unwrap_or(1005), reason.as_bytes())) .unwrap_or_else(|| Frame::close_raw(vec![].into())); |