mirror of
https://github.com/HeyPuter/puter.git
synced 2026-01-05 12:40:26 -06:00
fix TLS stream premature close issue
This commit is contained in:
@@ -12,7 +12,7 @@ export class PSocket extends EventListener {
|
||||
_events = new Map();
|
||||
_streamID;
|
||||
constructor(host, port) {
|
||||
super(["data", "drain", "open", "error", "close", "tlsdata", "tlsopen"]);
|
||||
super(["data", "drain", "open", "error", "close", "tlsdata", "tlsopen", "tlsclose"]);
|
||||
|
||||
(async () => {
|
||||
if(!puter.authToken && puter.env === 'web'){
|
||||
|
||||
@@ -70,14 +70,16 @@ export class PTLSSocket extends PSocket {
|
||||
this.emit("tlsdata", value);
|
||||
}
|
||||
}
|
||||
this.emit("tlsclose", false);
|
||||
} catch (e) {
|
||||
this.emit("error", e)
|
||||
this.emit("tlsclose", true);
|
||||
}
|
||||
// this.emit("close", undefined);
|
||||
|
||||
}));
|
||||
}
|
||||
on(event, callback) {
|
||||
if (event === "data" || event === "open") {
|
||||
if (event === "data" || event === "open" || event === "close") {
|
||||
return super.on("tls" + event, callback)
|
||||
} else {
|
||||
return super.on(event, callback);
|
||||
|
||||
Reference in New Issue
Block a user