#include <sys/types.h>
  #include <sys/socket.h>
  #include <arpa/inet.h>
  #include <netdb.h>

  #include <stdio.h>
  #include <stdlib.h>
  #include <pthread.h>
  #include <string.h>
  #include <unistd.h>

  #include <time.h>
  #include "http.h"
  #include "libnet.h"
  #include "libthrd.h"

  void vider_interfaces(Arg_Thread* argument)

  {

  	pthread_mutex_lock(&(argument->requete_mutex)); // Section critique
  

  	for(int i=0; i<20; i++)
  	{

  		if(argument->interfaces[i]!=NULL)

  		{

  			free(argument->interfaces[i]);
  			argument->interfaces[i]=NULL;

  		}
  	}

  	pthread_mutex_unlock(&(argument->requete_mutex)); // Libération de la section critique

  }

  int httpReponse(FILE* sockdial_stream, Arg_Thread* argument)

  {	
  	char message[]={0x00,0x00};

  	char message2[]={0x60,0x00};

  	sendUDPBroadcast(message, 2020);

  	sendUDPBroadcast(message2, 2020);

  	struct PageWeb* page; 

  	sleep(2); // Temps d'attente avant de recevoir les informations

  	pthread_mutex_lock(&(argument->requete_mutex)); // Section critique
  
  	createPage(&page, argument->interfaces); // Permet de creer la pageweb (http.c)
  	
  	pthread_mutex_unlock(&(argument->requete_mutex)); // Libération de la section critique

  	char buffer[BUFF_SIZE];	// Le buffer de message pour l'emission

  	strcat(buffer,"HTTP/1.1 200 OK\r\nServer: Serveur Sioux\r\nContent-Type: text/html; charset=UTF-8\r\nConnection: Keep-alive\r\n\r\n"); // Header HTTP

  	fprintf(sockdial_stream, "%s", buffer);

  	strcpy(buffer, page->html_contents);

  	fprintf(sockdial_stream, "%s", buffer);

  	freePage(&page);

  	return 0;
  }

  int interfaceReponse(char packet[BUFF_SIZE], Arg_Thread* argument, char adresse[20])

  {

  	// On lock le mutex car on rentre dans la section critique (modification de la structure interfaces)
  
  	pthread_mutex_lock(&(argument->requete_mutex));
  

  	int i=0;

  	while(i<=19 && argument->interfaces[i]!=NULL && strcmp(adresse, argument->interfaces[i]->adresse)!=0)

  	{

  		i++;	

  	}

  	/* if(argument->interfaces[0]!=NULL) */
  	/* 	printf("Il y a %d associations\n", i+1); */
  	/* else */
  	/* 	printf("Il n'y aucune association\n"); */

  	if(packet[0]==0x20 && (packet[1]==0x01 || packet[1]==0x00) )

  	{		

  	  //L'interface a correctement répondu au broadcast de GETSTATUS

  		printf("L'interface a correctement répondu\n");

  		if(argument->interfaces[i]==NULL)

  		{

  			argument->interfaces[i]=malloc(sizeof(struct interface_info));
  			strcpy(argument->interfaces[i]->adresse, adresse);

  		}

  		if(packet[1]==0x01)

  			argument->interfaces[i]->status=1;

  		else

  			argument->interfaces[i]->status=0;		

  	}

  
  	else if ((((unsigned char)packet[0])>>5) == 0x05)
  	  {

  	    printf("L'interface a correctement répondu\n");

  	    if(argument->interfaces[i]==NULL)
  		{
  			argument->interfaces[i]=malloc(sizeof(struct interface_info));
  			strcpy(argument->interfaces[i]->adresse, adresse);
  		}
  
  	    uint16_t tmp = (unsigned char)packet[0] & 0x1F; //Récupération du pourcentage
  	    tmp = tmp << 8;
  	    tmp += (unsigned char)packet[1];

  	    argument->interfaces[i]->commande = (int)((tmp*100)/8192);

  	  }

  	else
  	{	// L'interface n a pas correctement répondu

  		
  		pthread_mutex_unlock(&(argument->requete_mutex)); // Libération de la section critique

  		printf("L'interface n'a pas correctement répondu\n");

  		return -1;

  	}

  	pthread_mutex_unlock(&(argument->requete_mutex)); // Libération de la section critique

  	return 0;
  }

  void* reponseConnexion(void* arg_sock_interf)
  {	
  	Arg_Thread *argument=(Arg_Thread*)(arg_sock_interf);
  	int sock=argument->socket;

  	printf("Connecte\n"); // Affiche le fait que qqn soit connecté

  	FILE* sockdial_stream = fdopen(sock, "a+");
  	if (sockdial_stream == NULL)
  	  {
  	    fprintf(stderr,"Erreur d'ouverture sockdial_stream\n");
  	    pthread_exit(NULL);
  	  }

  	char buff_rec[BUFF_SIZE]; // Le buffer de message à la reception

  	fgets(buff_rec, BUFF_SIZE, sockdial_stream);

  	//Distingue la requête HTTP...
  	if(strstr(buff_rec, "GET")!=NULL && strstr(buff_rec, "HTTP")!=NULL)
  	{

  	  vider_interfaces(argument);	
  	  httpReponse(sockdial_stream, argument);

  	}
  	else //.. d'une requête interface
  	{
  		struct sockaddr_storage tmp_addr;
  		socklen_t addr_len=sizeof(tmp_addr);
  		if(getpeername(sock, (struct sockaddr*)&tmp_addr, &addr_len)==0)
  		{
  			char adresse[20];

  			sprintf(adresse, "%s", inet_ntoa(((struct sockaddr_in*)&tmp_addr)->sin_addr));			
  			interfaceReponse(buff_rec, argument, adresse);	

  		}
  	}

    	printf("Fin de la connexion\n");

  	fclose(sockdial_stream);

  	pthread_exit(NULL);
  }
  
  

  int lanceThread(void(* fonction) (void *), void* arg, int size)
  {
  	pthread_t thr_id;

  	printf("%d\n",size);	

  	if(pthread_create(&thr_id, NULL, (void*)fonction, arg )!=0) { fprintf(stderr, "Le thread n'a pas pu être créé.\n"); return -1; }
  	
  	pthread_detach(thr_id);
  
  	return 0;
  }