feature/tcp

Sources/Hobbits/TCP/TCPConnection.swift

@@ -0,0 +1,35 @@
+import Foundation
+
+class TCPConnection {
+
+    // @todo not sure if this is the way to go yet
+    fileprivate var input: InputStream
+    fileprivate var output: OutputStream
+
+    init(input: InputStream, output: OutputStream) {
+        self.input = input
+        self.output = output
+    }
+
+    func read(length: Int) -> [UInt8] {
+        if length == 0 {
+            return [UInt8]()
+        }
+
+        var buffer = [UInt8](repeating: 0, count: length)
+        input?.read(&buffer, maxLength: length)
+        return buffer
+    }
+
+    func write(_ response: Response) throws {
+        let data = String(describing: response)
+        let bytes = data.bytes
+
+        output?.write(bytes, maxLength: bytes.count)
+    }
+
+    func close() {
+
+    }
+
+}

Sources/Hobbits/TCP/TCPServer.swift

@@ -0,0 +1,29 @@
+import Foundation
+
+class TCPServer: NSObject {
+
+    func start() {
+        let service = NetService(domain: "", type: "", name: "")
+        service.publish(options: [NetService.Options.listenForConnections])
+    }
+
+}
+
+extension TCPServer: NetServiceDelegate {
+
+    public func netService(
+        _ sender: NetService,
+        didAcceptConnectionWith inputStream: InputStream,
+        outputStream: OutputStream
+    ) {
+        let connection = TCPConnection(input: inputStream, output: outputStream)
+        // @todo handle connection
+    }
+}
+
+extension TCPServer {
+
+    func handle(connection: TCPConnection) {
+
+    }
+}