#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
//#include "list.h"

 #define port_1 htons(5577);
 #define port_2 htons(1234);
  int sockfd_me;
  struct sockaddr_in meAddr;
  char buffer_me[1024];
  int me_addr_size;

  int sockfd_other;
  struct sockaddr_in otherAddr;
  char buffer_other[1024];
  int other_addr_size;


  char str_send[20];
  int addr_size;

  pthread_mutex_t mutex;
  pthread_cond_t cond;

  pthread_mutex_t mutex2;
  pthread_cond_t cond2;

  pthread_mutex_t mutex3;
  pthread_cond_t cond3;

void* get_input()
{
  pthread_mutex_lock(&mutex2);
  pthread_mutex_lock(&mutex);
  while(buffer_other[1]==0){

    pthread_cond_wait(&cond, &mutex);
    printf("enter: ");
    scanf("%[^\n]", str_send);
    pthread_mutex_lock(&mutex3);
    if(str_send[1]!=0)
    {
      pthread_mutex_unlock(&mutex3);
      pthread_cond_signal(&cond3);
    }

  }

    pthread_mutex_unlock(&mutex2);
    pthread_cond_signal(&cond2);

  pthread_mutex_unlock(&mutex);
  pthread_exit(0);



}

void* send_msg(void* str_send[])
{
  pthread_mutex_lock(&mutex3);
  while(str_send[1]==0){
    pthread_cond_wait(&cond3, &mutex3);
  }
  strcpy(buffer_me, str_send);
  sendto(sockfd_other, buffer_me, 1024, 0, (struct sockaddr*)&otherAddr, sizeof(otherAddr));
  memset(buffer_me, '\0', sizeof(buffer_me));
  pthread_mutex_unlock(&mutex3);
   pthread_exit(0);
}

void* print_msg()
{

    pthread_mutex_lock(&mutex2);
  while(buffer_other[1]==0){
    pthread_cond_wait(&cond2, &mutex2);
  }
  // do what we want
  printf("[+]printing from print: %s \n", buffer_other);
  memset(buffer_other, '\0', sizeof(buffer_other));

  pthread_exit(0);
}



void* receive_msg()
{
  pthread_mutex_lock(&mutex);

  //-----code------
  addr_size=sizeof(otherAddr);
  recvfrom(sockfd_me, buffer_other, 1024, 0, (struct sockaddr*)& otherAddr, &addr_size);
  //------------


  if(buffer_other[1]!=0){
    pthread_mutex_unlock(&mutex);
    pthread_cond_signal(&cond);
  }
  pthread_exit(0);
}


void main(){
  //the other port
  sockfd_other = socket(AF_INET, SOCK_DGRAM, 0);
  otherAddr.sin_family = AF_INET;
  otherAddr.sin_port = port_2;
  otherAddr.sin_addr.s_addr = inet_addr("127.0.0.1");

  //my port
  sockfd_me = socket(AF_INET, SOCK_DGRAM, 0);
  meAddr.sin_family = AF_INET;
  meAddr.sin_port = port_1;
  meAddr.sin_addr.s_addr = htonl(INADDR_ANY);

  bind(sockfd_me, (struct sockaddr*)&meAddr, sizeof(meAddr));

  //bind(sockfd_receiver, (struct sockaddr*)&receiverAddr, sizeof(receiverAddr));


  //get input thread
  pthread_t thread_input;
  pthread_attr_t attr;
  pthread_attr_init(&attr);
  pthread_create(&thread_input, &attr, &get_input, NULL);


  //send message thread
  pthread_t thread_send;
  pthread_attr_t attr1;
  pthread_attr_init(&attr1);
  pthread_create(&thread_send, &attr1, &send_msg, &str_send);


  //receive message thread
  pthread_t thread_receive;
  pthread_attr_t attr3;
  pthread_attr_init(&attr3);
  pthread_create(&thread_receive, &attr3, &receive_msg, NULL);


  //print thread
  pthread_t thread_print;
  pthread_attr_t attr2;
  pthread_attr_init(&attr2);
  pthread_create(&thread_print, &attr2, &print_msg, NULL);


  pthread_join(thread_receive,NULL);
  pthread_join(thread_input,NULL);
  pthread_join(thread_send,NULL);
  pthread_join(thread_print,NULL);


}