mb/d3
1
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix handle invalid session requests

Browse source
This commit is contained in:
Matthieu Jolimaitre 2024-04-10 14:11:19 +02:00
parent 7ce02e45c8
commit 3056b42ace
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
server/network.ts
View file

@ -34,8 +34,10 @@ export class ClientInterface {
const [input_sender, input_receiver] = channel<MsgToServer>(); const [input_sender, input_receiver] = channel<MsgToServer>();
const [output_sender, output_receiver] = channel<MsgToClient>(); const [output_sender, output_receiver] = channel<MsgToClient>();
input_sender.send_all(parsed_stream(mts.message_to_server_parser())(connection.readable)) input_sender.send_all(parsed_stream(mts.message_to_server_parser())(connection.readable))
.catch((err) => log("Deserialisation failure :", err.message))
.finally(() => input_sender.send({ kind: "exit" })); .finally(() => input_sender.send({ kind: "exit" }));
serialized_stream(output_receiver.iter())(connection.writable) serialized_stream(output_receiver.iter())(connection.writable)
.catch((err) => log("Serialisation failure :", err.message))
.finally(() => input_sender.send({ kind: "exit" })); .finally(() => input_sender.send({ kind: "exit" }));
return new ClientInterface(input_receiver, output_sender); return new ClientInterface(input_receiver, output_sender);
} }