diff --git a/source/dnetd/dconnection.d b/source/dnetd/dconnection.d index 2fd8c44..09982e4 100644 --- a/source/dnetd/dconnection.d +++ b/source/dnetd/dconnection.d @@ -389,6 +389,8 @@ public class DConnection : Thread /* Set the type of this connection to `server` */ connType = ConnectionType.SERVER; hasAuthed = true; + + reply ~= [0]; // Testing for now } /* If `register` command (requires: unauthed, client) */ else if(command == Command.REGISTER && !hasAuthed && connType == ConnectionType.CLIENT) diff --git a/source/dnetd/dlink.d b/source/dnetd/dlink.d index 877ba47..026a6a0 100644 --- a/source/dnetd/dlink.d +++ b/source/dnetd/dlink.d @@ -168,7 +168,9 @@ public final class DLink : Thread /* TODO: Await an acknowledgement [status] */ byte[] receivedResponseBytes; - bReceiveMessage(outboundSocket, receivedResponseBytes); + bool recvStatus = bReceiveMessage(outboundSocket, receivedResponseBytes); + gprintln("Recev status: "~to!(string)(recvStatus), DebugType.WARNING); + DataMessage receivedResponse = DataMessage.decode(receivedResponseBytes); ubyte[] dataReply = cast(ubyte[])receivedResponse.getData();