dependencies {
    implementation("io.github.kotlinmania:socket2-kotlin:0.2.0")
}

kotlin {
    sourceSets {
        commonMain.dependencies {
            implementation("io.github.kotlinmania:socket2-kotlin:0.2.0")
        }
    }
}

import io.github.kotlinmania.socket2.Domain
import io.github.kotlinmania.socket2.SocketProtocol
import io.github.kotlinmania.socket2.SockAddr
import io.github.kotlinmania.socket2.Socket
import io.github.kotlinmania.socket2.SocketAddr
import io.github.kotlinmania.socket2.SocketType
import kotlin.time.Duration.Companion.seconds

// Create an IPv4 non-blocking TCP socket
val server = Socket.new(Domain.IPV4, SocketType.STREAM.nonblocking(), SocketProtocol.TCP)

// Fine-grained socket options
server.setReuseAddress(true)
server.setTcpNodelay(true)
server.setKeepalive(true)
server.setSendBufferSize(65536)
server.setRecvBufferSize(65536)

// Bind to local loopback port 8080
val bindAddr = SockAddr.from(SocketAddr.V4("127.0.0.1", 8080))
server.bind(bindAddr)

// Listen with a connection backlog of 128
server.listen(128)

// Accept client connection
val (clientSocket, clientAddr) = server.accept()
println("Client connected from: ${clientAddr.asSocketIpv4()}")

val client = Socket.new(Domain.IPV4, SocketType.STREAM, SocketProtocol.TCP)
val destination = SockAddr.from(SocketAddr.V4("93.184.216.34", 80))

// Connect with a 5-second timeout
client.connectTimeout(destination, 5.seconds)

val request = "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n".encodeToByteArray()
client.send(request)

val udpSocket = Socket.new(Domain.IPV4, SocketType.DGRAM, SocketProtocol.UDP)
val peerAddr = SockAddr.from(SocketAddr.V4("127.0.0.1", 9000))

val payload = "Hello from KotlinMania!".encodeToByteArray()
udpSocket.sendTo(payload, peerAddr)

val buffer = ByteArray(1024)
val (bytesReceived, sender) = udpSocket.recvFrom(buffer)
println("Received $bytesReceived bytes from $sender")

val unixSocket = Socket.new(Domain.UNIX, SocketType.STREAM, null)
val socketPath = SockAddr.unix("/tmp/kotlinmania-ipc.sock")

unixSocket.bind(socketPath)
unixSocket.listen(32)

val header = "HTTP/1.1 200 OK\r\nContent-SocketType: text/plain\r\n\r\n".encodeToByteArray()
val body = "Hello, World!".encodeToByteArray()

// Write multiple buffers in a single syscall
val totalWritten = clientSocket.writeVectored(listOf(header, body))