deavmi
/
libdnet
mirror of https://github.com/deavminet/libdnet.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fixed missing bformat encode

This commit is contained in:
Tristan B. Kildaire 2020-10-16 16:51:08 +02:00
parent accf571fde
commit 03187a044e
2 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dub.json
View File

@ -4,11 +4,12 @@
],
"copyright": "Copyright © 2020, Tristan B. Kildaire",
"dependencies": {
"bformat": "~>1.0.8",
"tristanable": "~>0.1.0"
},
"description": "dnet client library",
"license": "LGPL v2.1",
"name": "libdnet",
"targetType": "library",
"targetPath": "bin"
"targetPath": "bin",
"targetType": "library"
}

15
source/libdnet/dclient.d
View File

@ -7,6 +7,7 @@ import std.socket;
import std.stdio;
import std.conv : to;
import std.string : split;
import bmessage : bSendMessage = sendMessage;
public final class DClient
{
@ -81,7 +82,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolData = new DataMessage(0, data);
socket.send(protocolData.encode());
bSendMessage(socket, protocolData.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();
@ -107,7 +108,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolData = new DataMessage(0, data);
socket.send(protocolData.encode());
bSendMessage(socket, protocolData.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();
@ -130,7 +131,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolDataMsg = new DataMessage(0, data);
socket.send(protocolDataMsg.encode());
bSendMessage(socket, protocolDataMsg.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();
@ -185,7 +186,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolDataMsg = new DataMessage(0, protocolData);
socket.send(protocolDataMsg.encode());
bSendMessage(socket, protocolDataMsg.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();
@ -212,7 +213,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolDataMsg = new DataMessage(0, protocolData);
socket.send(protocolDataMsg.encode());
bSendMessage(socket, protocolDataMsg.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();
@ -252,7 +253,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolDataMsg = new DataMessage(0, protocolData);
socket.send(protocolDataMsg.encode());
bSendMessage(socket, protocolDataMsg.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();
@ -301,7 +302,7 @@ public final class DClient
/* Send the protocol data */
DataMessage protocolDataMsg = new DataMessage(0, protocolData);
socket.send(protocolDataMsg.encode());
bSendMessage(socket, protocolDataMsg.encode());
/* Receive the server's response */
byte[] resp = reqRepQueue.dequeue().getData();