#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(struct interface_info* interfaces[20])
{
	for(int i=0; i<20; i++)
	{
		if(interfaces[i]!=NULL)
		{
			free(interfaces[i]);
			interfaces[i]=NULL;
		}
	}
}


int httpReponse(FILE* sockdial_stream, struct interface_info* interfaces[20])
{	
	char message[]={0x00,0x00};

	sendUDPBroadcast(message, 2020);

	struct PageWeb* page; 

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

	createPage(&page, interfaces); // Permet de creer la pageweb (http.c)

	char buffer[BUFF_SIZE];	// Le buffer de message pour l'emission
	// char buff_rec[BUFF_SIZE]; // Le buffer de message à la reception

	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(FILE* sockdial_stream, char packet[BUFF_SIZE], struct interface_info* interfaces[20], char adresse[20])
{
	printf("Interface : %s - Adresse : %s\n", packet, adresse);
	
	char buffer[BUFF_SIZE];	

	int i=0;
	while(interfaces[i]!=NULL && strcmp(adresse,interfaces[i]->adresse)!=0)
	{
		i++;	
	}
	
	if(interfaces[0]!=NULL)
		printf("Il y a %d associations\n", i+1);
	else
		printf("Il n'y aucune association\n");


	if(interfaces[i]!=NULL)
		interfaces[i]->status=-1;


	if(strlen(packet)>=2 && packet[0]=='A' && (packet[1]=='A' || packet[1]=='B') )
	{		
		//L'interface a correctement répondu, on la rajoute à la liste des interfaces
		printf("L'interface a correctement répondu\n");

		if(interfaces[i]==NULL)
		{
			interfaces[i]=malloc(sizeof(struct interface_info));
			strcpy(interfaces[i]->adresse, adresse);
		}

		if(packet[1]==0x01)
			interfaces[i]->status=1;
		else
			interfaces[i]->status=0;		

	}
	else // L'interface n a pas correctement répondu
		return -1;



	strcpy(buffer, "\x60\x00"); // Demande la commande en mémoire

	fprintf(sockdial_stream, "%s", buffer); // Transmission du message 

	fgets(packet, BUFF_SIZE, sockdial_stream); // Attente de reception du message


	
	if( strlen(packet)>=2 && (packet[0]&0xE0)==0x10 )
		interfaces[i]->commande = (packet[0]&0x01)*256+packet[1];
	else
	{
		interfaces[i]->commande = -1;
		return -1; // Si le message n'est pas reçu correctement
	}

	return 0;
}



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

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

	FILE* sockdial_stream = fdopen(sock, "a+"); 

	char buff_rec[BUFF_SIZE]; // Le buffer de message à la reception
	// char buffer[BUFF_SIZE];	// Le buffer de message pour l'emission

	fgets(buff_rec, BUFF_SIZE, sockdial_stream);
	
	printf("Le message reçu : %s\n", buff_rec);

	//Distingue la requête HTTP...
	if(strstr(buff_rec, "GET")!=NULL && strstr(buff_rec, "HTTP")!=NULL)
	{
		vider_interfaces(argument->interfaces);	
		httpReponse(sockdial_stream, argument->interfaces);
	}
	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(sockdial_stream, buff_rec, argument->interfaces, adresse); 
		}
	}

	printf("Sock : %d // Stream : %p \n", sock, sockdial_stream);

	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;
}