// Messenger.cpp : Defines the entry point for the console application.
//
#include "stdafx.h"
#include <conio.h>
#include <stdio.h>
#include <iostream.h>
#include <winsock2.h>
#include <Ws2tcpip.h>

char message[]="Hello, thread!";
SOCKET socketToSend;
sockaddr_in destAddress;
sockaddr_in sourceAddress;

DWORD WINAPI thread_function(PVOID arg)
{
    char buff[ 256 ];
    int bRes;

    SOCKET sock = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
    char localname[ 256 ];
    gethostname(localname, 256 );
    hostent* hosts;
    hosts = gethostbyname(localname);
    char * ipStr = hosts->h_addr_list[ 0 ];
    sockaddr_in address;
    address.sin_family = AF_INET;
    address.sin_port = htons( 4777 );
    address.sin_addr.s_addr = *((u_long*)ipStr);

    bRes = bind(sock,(sockaddr*)&address,sizeof(address));

    

    listen(sock,SOMAXCONN);
    SOCKET newSocket;
    int strLen =  0 ;
    while (true)
    {
        newSocket = accept(sock,NULL,NULL);
        strLen = recv(newSocket,buff, 255 , 0 );
        buff[strLen] =  0 ;
        printf("%s\n",buff);
        closesocket(newSocket);
        if (!strcmp(buff,"bye-bye-bye"))
            break;
    }

    closesocket(sock);
    return  0 ;
}


bool SendString(char*str)
{
    int i;
//    i = WSAGetLastError();
    socketToSend = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
    bind(socketToSend,(sockaddr*)&sourceAddress,sizeof(sourceAddress));
    connect(socketToSend,(sockaddr*)&destAddress,sizeof(destAddress));
    send(socketToSend,str,strlen(str)+ 1 , 0 );
    closesocket(socketToSend);
    return  0 ;
}



int main(int argc, char* argv[])
{

    WSADATA wsaData;
    WORD wVersionRequested;
    wVersionRequested = MAKEWORD( 1 , 1 );
    WSAStartup(wVersionRequested,&wsaData);
    
    
    char localname[ 256 ];
    gethostname(localname, 256 );
    hostent* hosts;
    hosts = gethostbyname(localname);
    char * ipStr = hosts->h_addr_list[ 0 ];
    sourceAddress.sin_family = AF_INET;
    sourceAddress.sin_port = htons( 4666 );
    sourceAddress.sin_addr.s_addr = *((u_long*)ipStr);
    
    
    destAddress.sin_family = AF_INET;
    destAddress.sin_port = htons( 4777 );
    destAddress.sin_addr.S_un.S_un_b.s_b1 =  192 ;
    destAddress.sin_addr.S_un.S_un_b.s_b2 =  168 ;
    destAddress.sin_addr.S_un.S_un_b.s_b3 =  211 ;
    destAddress.sin_addr.S_un.S_un_b.s_b4 =  128 ;
    
    
    HANDLE a_thread;
    DWORD a_threadId;
    DWORD thread_result;
    
    a_thread = CreateThread(NULL,  0 , thread_function, (PVOID)message,
         0 , &a_threadId);
    
    if (a_thread == NULL) {
        perror("Thread creation failed");
        exit(EXIT_FAILURE);
    }
    

    
    
    
    char strToSend[ 258 ];
    cin >> strToSend;
    while (strcmp(strToSend,"exit"))
    {
        SendString(strToSend);
        cin >> strToSend;
    }

    destAddress.sin_addr.S_un.S_un_b.s_b4 =  129 ;
    SendString("bye-bye-bye");

    printf("Waiting for thread to finish...\n");
    if (WaitForSingleObject(a_thread, INFINITE) != WAIT_OBJECT_0) {
        perror("Thread join failed");
        exit(EXIT_FAILURE);
    }
    
    GetExitCodeThread(a_thread, &thread_result);
    
    printf("Thread joined, it returned %d\n", thread_result);
    printf("Message is now %s\n", message);


//    closesocket(socketToSend);
    WSACleanup();

    return  0 ;
}

// Messenger.cpp : Defines the entry point for the console application.
//
}