foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2024-11-28 16:20:57 -05:00
Code Issues Packages 1 Wiki Activity

fix(websocket): ignore resource close error (#9755)

Browse source 
It is possible that the WebSocket is already closed when we try to
close it with `WebSocket#close` or in the `error` or `close` events.
Currently this leads to an uncatchable promise rejection. This changes
this so that closing an already closed WebSocket is a noop.
This commit is contained in:
Luca Casonato 2021-04-02 00:55:22 +02:00
parent a9e6c16d8b
commit 5562b190d6
No known key found for this signature in database
GPG key ID: 789878CF6382A84F
1 changed files with 17 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
op_crates/websocket/01_websocket.js
View file

@ -25,6 +25,19 @@
}
}
/**
* Tries to close the resource (and ignores BadResource errors).
* @param {number} rid
*/
function tryClose(rid) {
try {
core.close(rid);
} catch (err) {
// Ignore error if the socket has already been closed.
if (!(err instanceof Deno.errors.BadResource)) throw err;
}
}
const handlerSymbol = Symbol("eventHandlers");
function makeWrappedHandler(handler) {
function wrappedHandler(...args) {
@ -125,7 +138,7 @@
const event = new CloseEvent("close");
event.target = this;
this.dispatchEvent(event);
core.close(this.#rid);
tryClose(this.#rid);
});
} else {
this.#readyState = OPEN;
@ -289,7 +302,7 @@
});
event.target = this;
this.dispatchEvent(event);
core.close(this.#rid);
tryClose(this.#rid);
});
}
}
@ -350,7 +363,7 @@
});
event.target = this;
this.dispatchEvent(event);
core.close(this.#rid);
tryClose(this.#rid);
break;
}
@ -365,7 +378,7 @@
const closeEv = new CloseEvent("close");
closeEv.target = this;
this.dispatchEvent(closeEv);
core.close(this.#rid);
tryClose(this.#rid);
break;
}