butterfly
/
butterflyd
mirror of https://github.com/thebutterflyprotocol/butterflyd
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Close conneciton on failed receive.

This commit is contained in:
Tristan B. Kildaire 2020-06-20 16:17:32 +02:00
parent 767122b969
commit 557e04a0db
1 changed files with 24 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
source/client/client.d
View File

@ -77,11 +77,12 @@ public final class ButterflyClient : Thread
bool recvStatus = receiveMessage(clientSocket, receivedBytes);
writeln(recvStatus);
/* Reset the response JSON */
responseBlock = JSONValue();
/* If the receive succeeded */
if(recvStatus)
{
/* Reset the response JSON */
responseBlock = JSONValue();
/* TODO: Add error handling catch for all JSON here */
/* Parse the incoming JSON */
@ -289,7 +290,6 @@ public final class ButterflyClient : Thread
/* TODO: Add error handling */
}
}
else if(cmp(command, "totsiens") == 0)
{
/* Close the connection on next loop condition check */
@ -299,28 +299,32 @@ public final class ButterflyClient : Thread
{
/* TODO: Add error handling for invalid commands */
}
/* Generate the `status` field */
responseBlock["status"] = status;
/* Write the response block to the client */
writeln("Writing back response: "~responseBlock.toPrettyString());
bool sendStatus = sendMessage(clientSocket, cast(byte[])toJSON(responseBlock));
writeln(sendStatus);
/* If there was an error writing the response back */
if(!sendStatus)
{
/* End the session */
active = false;
writeln("Response write back failed");
}
}
else
{
/* TODO: Add error handling here */
}
/* TODO: Write response here */
/* Generate the `status` field */
responseBlock["status"] = status;
/* Write the response block to the client */
writeln("Writing back response: "~responseBlock.toPrettyString());
bool sendStatus = sendMessage(clientSocket, cast(byte[])toJSON(responseBlock));
writeln(sendStatus);
/* If there was an error writing the response back */
if(!sendStatus)
{
/* End the session */
/**
* If we failed to receive, then close the connection
*/
active = false;
writeln("Response write back failed");
}
}