#include <allegro5/allegro.h>
#include <allegro5/allegro_primitives.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <iostream>
#include <math.h>
#define BUFLEN 512
#define PORT 9930

char buf[BUFLEN];
char send_buf[BUFLEN];
int lenght;

struct posxy
{
    int x;
    int y;
};

struct posxy player_1;
struct posxy player_2;

void err(const char *str)
{
    perror(str);
    exit(1);
}

void *game(void *data)
{
    std::cout<<(int*)data<<std::endl;
    ALLEGRO_DISPLAY *display;
    ALLEGRO_EVENT_QUEUE *event_queue;
    ALLEGRO_EVENT events;
    ALLEGRO_KEYBOARD_STATE keyState;

    int x = 0, y = 0;

    al_init();
    al_set_new_display_flags(ALLEGRO_WINDOWED);

    display = al_create_display(800, 600);

    event_queue = al_create_event_queue();

    al_set_window_title(display, "GameServer");

    al_set_window_position(display, 200, 100);

    al_init_primitives_addon();

    al_install_keyboard();


    ALLEGRO_TIMER *timer = al_create_timer(1.0 / 60);

    al_register_event_source(event_queue, al_get_timer_event_source(timer));
    al_register_event_source(event_queue, al_get_display_event_source(display));
    al_register_event_source(event_queue, al_get_keyboard_event_source());


    al_start_timer(timer);
    while(1)
    {
        al_wait_for_event(event_queue, &events);
        if (events.type == ALLEGRO_EVENT_TIMER)
        {

            al_get_keyboard_state(&keyState);
            if (al_key_down(&keyState, ALLEGRO_KEY_DOWN))
            {

                y += 5;

            }
            else if (al_key_down(&keyState, ALLEGRO_KEY_UP))
            {

                y -= 5;

            }
            else if (al_key_down(&keyState, ALLEGRO_KEY_RIGHT))
            {

                 x += 5;

            }
            else if (al_key_down(&keyState, ALLEGRO_KEY_LEFT))
            {

                 x -= 5;
            }
            player_1.x = x;
            player_1.y = y;



    }
    al_clear_to_color(al_map_rgb(0, 0, 0));
    al_draw_rectangle(x, y, x + 32, y + 32, al_map_rgb(255,0,255), 1);
    al_draw_rectangle(player_2.x, player_2.y, player_2.x + 32, player_2.y + 32, al_map_rgb(255,0,255), 1);
    al_flip_display();

}
}

void *multiplayer(void *data)
{

   struct sockaddr_in my_addr, cli_addr;
   int sockfd, i;
   socklen_t slen = sizeof(cli_addr);

   if ((sockfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP))==-1)
      err("socket");
    else
      printf("Server : Socket() successful\n");

    bzero(&my_addr, sizeof(my_addr));
    my_addr.sin_family = AF_INET;
    my_addr.sin_port = htons(PORT);
    my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

    if (bind(sockfd, (struct sockaddr* ) &my_addr, sizeof(my_addr))==-1)
      err("bind");
    else
      printf("Server : bind() successful\n");

    while(1)
     {

        if (recvfrom(sockfd, &player_2, sizeof(struct posxy), 0, (struct sockaddr*)&cli_addr, &slen) == -1)
            err("recvfrom()");
        /*printf("Received packet from %s:%d\nData: %s\n\n",
               inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port), buf);*/

               if (sendto(sockfd, &player_1, sizeof(struct posxy), 0, (struct sockaddr*)&cli_addr, slen) == -1)
            err("sendto()");

    }

    close(sockfd);
}

int main(int argc, char **argv){
   for (int i = 0; i < sizeof(send_buf); ++i)
   {
       send_buf[i] = '0';
   }
   pthread_t t1, t2;

   int x = 0;

   pthread_create(&t1, NULL, multiplayer, (void *)(&x));
   pthread_create(&t2, NULL, game, (void *)(&x));

   pthread_join(t1, NULL);
   pthread_join(t2, NULL);

   return 0;
}