/*
   * Test on serial device
   */
  
  ////
  // Include files
  ////
  #include <stdio.h>
  #include <stdlib.h>
  #include <unistd.h>
  #include <termios.h>
  #include <string.h>
  #include <libwebsockets.h>
  #include "serial.h"
  
  
  #define MAX_FRAME_SIZE  1024
  #define WAIT_DELAY      50
  
  

  #define         SERIAL_DEVICE           "/dev/ttyUSB0" //utiliser USB0 pour le shield Xbee branché en USB

  
  /*****************************************************************************/
  /**********************PARTIE WEBSOCKETS + COM SERIE**************************/
  /*****************************************************************************/
  
  //Fonction qui retourne un tableau de char, chaque char correspondant à une donnée d'un capteur
  

  char * getDataFromSensors(char *request,int sizeOfRequest,int sd)

  {

  
  	int i;

  	//la réponse est récupérée sous un type charactère non signé. Il est possible de la stocker dans un charactère signé, mais la valeur affichée par un printf sera différente
  	unsigned char *reponse = NULL;
  	reponse = malloc(4*sizeof(unsigned char));
  	

  
  	//On envoie le GET au FPGA pour récupérer les données
  	for(i = 0; i < sizeOfRequest;i++)
  	{

  		if(write(sd,(void*)&request[i],sizeof(char))!=1)
  		{ 
  			perror("main.write"); exit(-1); 
  		}
  	}
  
  	printf("\nReponse : ");
  

  	//NE PAS OUBLIER DE LIBERER LA MEMOIRE EN DEHORS DE LA FONCTION

  	for(i=0;i < 4;i++)
  	{	//on lit ce que nous envoie l'arduino à la suite de la requete GET
  		if(read(sd,(void*)&reponse[i],sizeof(unsigned char))!=1)

  		{ 
  			perror("main.read"); exit(-1); 
  		}
  	}

  	printf("\nTemperature (C) : %d",reponse[1]);
  	printf("\nPression (hPa) : %d",reponse[0]+845);
  	printf("\nHumidite (pourcents) : %d",reponse[2]);
  	printf("\nLuminosité : %d\n",reponse[3]);

  
  	return reponse;
  }
  
  
  
  static int callback_http(struct libwebsocket_context *this, struct libwebsocket *wsi, enum libwebsocket_callback_reasons reason, void *user,void *in,size_t len)
  {
    return 0;
  }
  
  static int callback_my(struct libwebsocket_context * this, struct libwebsocket *wsi, enum libwebsocket_callback_reasons reason, void *user,void *in,size_t len)
  {
  	static char *requete = NULL;
  	static char *reponse = NULL;

  	//Initialisation com Serie
  	int sd=serialOpen(SERIAL_DEVICE,SERIAL_BOTH);
  	serialConfig(sd,B9600);

  
    switch(reason)
    {

      case LWS_CALLBACK_ESTABLISHED:
        printf("connection established\n");
        requete=NULL;

        // Declenchement d'un prochain envoi au navigateur

        libwebsocket_callback_on_writable(this,wsi);
      break;
  
      case LWS_CALLBACK_RECEIVE:
                    // Ici sont traites les messages envoyes par le navigateur
  		printf("received data: %s\n",(char *)in);
  		requete=malloc(len+LWS_SEND_BUFFER_PRE_PADDING+LWS_SEND_BUFFER_POST_PADDING);
  
  		if(requete==NULL)
  		{ 
  			perror("callback_my.malloc"); exit(EXIT_FAILURE); 
  		}
  

  		memcpy(requete,in,len);

  		          // Declenchement d'un prochain envoi au navigateur

  		libwebsocket_callback_on_writable(this,wsi);
      break;
  
      case LWS_CALLBACK_SERVER_WRITEABLE:

  		// Ici sont envoyes les messages au navigateur
      	//Si la requete a pour valeur GET, on envoie les donnée au site
      		

  		if(requete!= NULL)
  		{

  			if(requete[0] == 'G' && requete[1] == 'E' && requete[2] == 'T')

  			{

  				reponse = getDataFromSensors(requete,3,sd);
  				int length = 4;

  				unsigned char *buf = malloc(LWS_SEND_BUFFER_PRE_PADDING + length + LWS_SEND_BUFFER_POST_PADDING);
  				memcpy (buf + LWS_SEND_BUFFER_PRE_PADDING, reponse, length );

  				libwebsocket_write(wsi, buf + LWS_SEND_BUFFER_PRE_PADDING, length, LWS_WRITE_BINARY); //LWS_WRITE_TEXT

  				free(reponse);

  				free(requete);
  				requete = NULL;
  				reponse = NULL;
  			}
  		}
  
      break;
      default:
        break;
      }

    serialClose(sd);

    return 0;
  }
  
  static struct libwebsocket_protocols protocols[] = {
    {
      "http-only",   // name
      callback_http, // callback
      0,             // data size
      0              // maximum frame size
    },
    {"myprotocol",callback_my,0,MAX_FRAME_SIZE},
    {NULL,NULL,0,0}
  };
  
  
  
  
  /*****************************************************************/
  /**********************MAIN***************************************/
  /*****************************************************************/
  
  int main(void){
  
  
  	char j;
  	int i;
  	unsigned long count = 0;
  
  	//Initialisation WebSockets
  	int port=9000;
  	struct lws_context_creation_info info;
  	memset(&info,0,sizeof info);
  	info.port=port;
  	info.protocols=protocols;
  	info.gid=-1;
  	info.uid=-1;
  	struct libwebsocket_context *context=libwebsocket_create_context(&info);
  

  
  
  	if(context==NULL)
  	{
  		fprintf(stderr, "libwebsocket init failed\n");
  		return -1;
  	}
  	printf("starting server...\n");
  
  
  	//boucle infinie du main
  	while(1)
  	{
  		libwebsocket_service(context,WAIT_DELAY);
  	}
  	libwebsocket_context_destroy(context);

  	return 0;
  
  }
  
  
  //********************************************************************************//