Testing updates

example/client/dub.selections.json

@@ -2,6 +2,6 @@
 	"fileVersion": 1,
 	"versions": {
 		"bformat": "1.0.8",
-		"tristanable": "0.0.11"
+		"tristanable": "0.0.13"
 	}
 }

example/client/source/app.d

@@ -8,4 +8,10 @@ void main()
 	Socket socket = new Socket(AddressFamily.INET, SocketType.STREAM, ProtocolType.TCP);
 	socket.connect(parseAddress("127.0.0.1",7777));
 	Manager manager = new Manager(socket);
+
+	manager.sendMessage(69, [77]);
+
+
+	byte[] receivedKaka = manager.receiveMessage(69);
+	writeln(receivedKaka);
 }

example/server/dub.json

@@ -3,6 +3,10 @@
 		"Tristan B. Kildaire"
 	],
 	"copyright": "Copyright © 2020, Tristan B. Kildaire",
+	"dependencies": {
+		"bformat": "~>1.0.8",
+		"tristanable": "~>0.0.13"
+	},
 	"description": "A minimal D application.",
 	"license": "proprietary",
 	"name": "server"

example/server/dub.selections.json

@@ -0,0 +1,7 @@
+{
+	"fileVersion": 1,
+	"versions": {
+		"bformat": "1.0.8",
+		"tristanable": "0.0.13"
+	}
+}

example/server/source/app.d

@@ -1,5 +1,7 @@
 import std.stdio;
 import std.socket;
+import tristanable.encoding : DataMessage;
+import bmessage;
 
 void main()
 {
@@ -7,8 +9,25 @@ void main()
 	Socket socket = new Socket(AddressFamily.INET, SocketType.STREAM, ProtocolType.TCP);
 	socket.bind(parseAddress("127.0.0.1",7777));
 	socket.listen(1);
+	
+	Socket conn = socket.accept();
+	byte[] receivedData;
+
 	while(true)
 	{
-		socket.accept();
+		receiveMessage(conn, receivedData);
+
+		DataMessage message = DataMessage.decode(receivedData);
+
+		writeln("Tag: ", message.tag);
+		writeln("Data: ", message.data);
+
+		DataMessage d = new DataMessage(69, [1]);
+
+		sendMessage(conn, d.encode());
 	}
+	
+	
+
+	
 }