refactor: move socket (#92)

* feat: impl Iterator for Transport

* feat: iterate over packets instead

* feat: prepare for iter()

* refactor: moved client side logic

* feat: qol

* fix: broken format!

* feat: fix socketio test

* feat: add tls_connector dynamic secure

* feat: less need to clone

* feat: move socket

Author: ctrlaltf24

ci/socket-io.js

@@ -1,11 +1,18 @@
 const server = require('http').createServer();
 const io = require('socket.io')(server);
 
-console.log("Started");
+console.log('Started');
 io.on('connection', client => {
-    console.log("Connected!");
-    client.on('test', data => { console.log(data) });
-    client.on('message', data => { console.log(data) });
+    console.log('Connected!');
+    client.on('test', data => {
+        // Send a message back to the server to confirm the message was received
+        client.emit('test-received', data);
+        console.log(['test', data]);
+    });
+    client.on('message', data => {
+        client.emit('message-received', data);
+        console.log(['message', data]);
+    });
     client.on('test', function (arg, ack) {
         console.log('Ack received')
         if (ack) {
@@ -15,21 +22,24 @@ io.on('connection', client => {
 
     client.on('binary', data => {
         var bufView = new Uint8Array(data);
-        console.log("Yehaa binary payload!");
+        console.log(['binary', 'Yehaa binary payload!']);
         for (elem in bufView) {
-            console.log(elem);
+            console.log(['binary', elem]);
         }
+        client.emit('binary-received', data);
+        console.log(['binary', data]);
     });
 
     client.on('binary', function (arg, ack) {
-        console.log('Ack received, answer with binary')
+        console.log(['binary', 'Ack received, answer with binary'])
         if (ack) {
             ack(Buffer.from([1, 2, 3]));
         }
     });
-    client.emit("test", "Hello Wld");
-    client.emit("test", Buffer.from([1, 2, 3]));
-    client.emit("Hello from the message event!");
+    client.emit('Hello from the message event!');
+    client.emit('test', 'Hello from the test event!');
+    client.emit(Buffer.from([4, 5, 6]));
+    client.emit('test', Buffer.from([1, 2, 3]));
 });
 // the socket.io client runs on port 4201
 server.listen(4200);

ci/start_test_server.sh

@@ -0,0 +1,3 @@
+mod socket;
+pub(crate) use socket::Iter;
+pub use {socket::Iter as SocketIter, socket::Socket, socket::SocketBuilder};