import std.stdio;
import std.socket;
import std.concurrency;
import core.thread;
import std.string;


/* BUILD A SOCKET - FUNCTION */
Socket build_socket(){
    auto sock = new Socket(AddressFamily.INET, SocketType.STREAM, ProtocolType.TCP);
    sock.setOption(SocketOptionLevel.SOCKET, SocketOption.REUSEADDR, true);
    return sock;
}


/* SEND MESSAGE - FUNCTION  */
void send_message(){
    for(;;){
        auto msg = readln.strip;
    sock.send(msg); // shared sock ?
    }
}


/* MAIN - FUNCTION */
void main(){
    auto sock = build_socket();
    auto address = getAddress("192.168.0.23", 6666);
    sock.connect(address[0]);
    spawn(&send_message); // ist nicht logisch ich weiss,
    for(;;){
        char[1024] buffer;
    auto received = sock.receive(buffer);
    writef("%s", buffer[0..received]);
    }
}