#include <windows.h>
#include <iostream>

using namespace std;

DWORD WINAPI serverFunction(LPVOID param) {
    SOCKET recvSocket = (SOCKET)param;
    char buffer[1024];
    int result = 0;
    while (strcmp(buffer, "end") && strcmp(buffer, "exit") && result != SOCKET_ERROR) {
        result = recv(recvSocket, buffer, 1024, 0);
        if (result != SOCKET_ERROR) cout << recvSocket << ": " << buffer << "\n";
    }

    closesocket(recvSocket);

    return 0;
}

int main() {

    WSADATA wsa;
    SOCKET mainSocket, recvSocket;

    if (WSAStartup(MAKEWORD(2,2), &wsa) != 0) {
        cout << "WSAStartup() error: " << WSAGetLastError();
        return 0;
    }


    mainSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (mainSocket == INVALID_SOCKET) {
        cout << "mainSocket error: " << WSAGetLastError();
        WSACleanup();
        return 0;
    }

    sockaddr_in server;
    server.sin_family = AF_INET;
    server.sin_addr.s_addr = inet_addr("127.0.0.1");
    server.sin_port = htons(12000);

    if (bind(mainSocket, (SOCKADDR*)&server, sizeof(server)) == SOCKET_ERROR) {
        cout << "bind() error: " << WSAGetLastError();
        closesocket(mainSocket);
        WSACleanup();
        return 0;
    }

    DWORD threadCounter = 1;

    listen(mainSocket, 100);
    while (true) {

        recvSocket = accept(mainSocket, NULL, NULL);
        ++threadCounter;
        CreateThread(0, 0, serverFunction, (LPVOID)recvSocket, 0, &threadCounter);

    }
    closesocket(mainSocket);
    WSACleanup();

    system("pause");
    return 0;
}