Use Swift-NIO instead of Network lib to make it viable wherever Swift is, i.e. Server side, iOS, Windows.

[shial4]

I've got a suggestion to drop Network and use Swift-NIO for connection.
Swift-NIO is an asynchronous event-driven network application framework.

Initialization: The connection is established using a ClientBootstrap and a MultiThreadedEventLoopGroup.
Sending Data: Data sending is managed using ByteBuffers and the writeAndFlush method.
Receiving Data: Data reception is handled with a custom ByteToMessageDecoder to process incoming data.
Connection Lifecycle: The connection start and stop methods are adjusted for handling with Swift-NIO’s asynchronous patterns.

This focuses on integrating Swift-NIO effectively while preserving the logic and flow of your original application.
Here’s refactored the IBConnection and IBClient classes to use Swift-NIO:

import NIO
import Foundation

class IBConnection {
    let channel: Channel
    var didStopCallback: ((Error?) -> Void)?

    init(channel: Channel) {
        self.channel = channel
    }

    func start() {
        let greeting = createGreeting()
        send(data: greeting)
        receiveNextMessage()
    }

    func send(data: Data) {
        var buffer = channel.allocator.buffer(capacity: data.count)
        buffer.writeBytes(data)
        _ = channel.writeAndFlush(buffer)
    }

    func receiveNextMessage() {
        channel.read().whenComplete { result in
            switch result {
            case .success(let buffer):
                // Process buffer here
                print("Data received")
            case .failure(let error):
                print("Failed to read data: \(error)")
            }
        }
    }

    func stop(error: Error?) {
        channel.close().whenComplete { _ in
            self.didStopCallback?(error)
        }
    }

    private func createGreeting() -> Data {
        var greeting = Data()
        let prefix = "API\0"
        greeting += prefix.data(using: .ascii)!
        let versions = "v1..100"
        greeting += Data([UInt8(versions.count)])
        greeting += versions.data(using: .ascii)!
        return greeting
    }
}

open class IBClient {
    var channel: Channel?
    var host: String
    var port: Int

    public init(host: String, port: Int) {
        self.host = host
        self.port = port
    }

    public func connect() throws {
        let group = MultiThreadedEventLoopGroup(numberOfThreads: System.coreCount)
        let bootstrap = ClientBootstrap(group: group)
            .channelOption(ChannelOptions.socketOption(.so_reuseaddr), value: 1)
            .channelInitializer { channel in
                channel.pipeline.addHandler(ByteToMessageHandler(FramingHandler()))
            }

        self.channel = try bootstrap.connect(host: host, port: port).wait()
        if let channel = self.channel {
            let connection = IBConnection(channel: channel)
            connection.start()
        }
    }

    public func disconnect() {
        _ = channel?.close()
        channel = nil
    }
}

class FramingHandler: ByteToMessageDecoder {
    typealias InboundOut = ByteBuffer

    func decode(context: ChannelHandlerContext, buffer: inout ByteBuffer) throws -> DecodingState {
        // Example decoding logic
        return .needMoreData
    }
}

[shial4]

I'm happy to contribute this change, if you are willing to accept it

[stensoosaar]

Many thanks! I am cleaning and fixing old code right now, hope to make it available in a few days. Seems like the perfect spot to test your suggestion, and all help is most welcome!

[shial4]

Got initial draft (untested) for swift nio. Will clean it up and make a draft or tomorrow so you can have a look

[shial4]

Ok, got initial PR here, have a look when you can :) Thanks!
#5

[shial4]

PR is working and ready! :) closing this discussion