#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <stdbool.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>

#include <pthread.h>

/* mutex declaration */
pthread_mutex_t keyy;


/* Server port  */
#define PORT 4040


/* Buffer length */
#define BUFFER_LENGTH 4096

  /* File descriptors of client and server */
int serverfd, clientfd;

char buffer[BUFFER_LENGTH];
char buffer2[BUFFER_LENGTH];

void* recebeMsg(){
    int message_len;
    while(1){
        memset(buffer, 0x0, BUFFER_LENGTH);
        pthread_mutex_lock(&keyy);
        if((message_len = recv(clientfd, buffer, BUFFER_LENGTH, MSG_DONTWAIT)) > 0) {
            buffer[message_len - 1] = '';
            printf("Client says:  %sn", buffer);
        }
        pthread_mutex_unlock(&keyy);
    }
}



void* enviaMsg(){
    while(1){
        memset(buffer2, 0x0, BUFFER_LENGTH);
        fgets(buffer2, BUFFER_LENGTH, stdin);
        //sleep(0.5);
        pthread_mutex_lock(&keyy);
        send(clientfd, buffer2, strlen(buffer2), 0);
        pthread_mutex_unlock(&keyy);
    }
}

/*
 * Main execution of the server program of the simple protocol
 */
int main() {

    if (pthread_mutex_init(&keyy, NULL) != 0)
    {
        printf("n mutex initalization failedn");
        return -1;
    }

    /* Client and Server socket structures */
    struct sockaddr_in client, server;

    char buffer[BUFFER_LENGTH];
    char buffer2[BUFFER_LENGTH];

    fprintf(stdout, "Starting servern");

    /* Creates a IPv4 socket */
    serverfd = socket(AF_INET, SOCK_STREAM, 0);
    if(serverfd == -1) {
        perror("Can't create the server socket:");
        return EXIT_FAILURE;
    }
    fprintf(stdout, "Server socket created with fd: %dn", serverfd);


    /* Defines the server socket properties */
    server.sin_family = AF_INET;
    server.sin_port = htons(PORT);
    memset(server.sin_zero, 0x0, 8);


    /* Handle the error of the port already in use */
    int yes = 1;
    if(setsockopt(serverfd, SOL_SOCKET, SO_REUSEADDR,
                  &yes, sizeof(int)) == -1) {
        perror("Socket options error:");
        return EXIT_FAILURE;
    }


    /* bind the socket to a port */
    if(bind(serverfd, (struct sockaddr*)&server, sizeof(server)) == -1 ) {
        perror("Socket bind error:");
        return EXIT_FAILURE;
    }


    /* Starts to wait connections from clients */
    if(listen(serverfd, 1) == -1) {
        perror("Listen error:");
        return EXIT_FAILURE;
    }
    fprintf(stdout, "Listening on port %dn", PORT);

    socklen_t client_len = sizeof(client);
    if ((clientfd=accept(serverfd,
        (struct sockaddr *) &client, &client_len )) == -1) {
        perror("Accept error:");
        return EXIT_FAILURE;
    }

    /* Copies into buffer our welcome messaage */
    strcpy(buffer, "Hello, client!n");
    send(clientfd, buffer, BUFFER_LENGTH, 0);


    pthread_t t1, t2;

    pthread_create(&t1, NULL, recebeMsg, NULL);
    pthread_create(&t2, NULL, enviaMsg, NULL);

    while(1);

    /* Client connection Close */
    close(clientfd);

    /* Close the local socket */
    close(serverfd);

    printf("Connection closednn");

    return EXIT_SUCCESS;
}