/*
 * 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/ttyACM0"

/*****************************************************************************/
/**********************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=serialOpen(SERIAL_DEVICE,SERIAL_BOTH);
	serialConfig(sd,B9600);

	int i;
	char *reponse = NULL;

	//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 : ");

	reponse = malloc(3*sizeof(char));

	for(i=0;i < 3;i++)
	{
		if(read(sd,(void*)&reponse[i],sizeof(char))!=1)
		{ 
			perror("main.read"); exit(-1); 
		}
	}
	printf("\nTemperature : %d",reponse[1]);
	printf("\nPressure : %d",reponse[0]);
	printf("\nHumidity : %d\n",reponse[2]);

	serialClose(sd);

	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;
	static int msize=0;

  switch(reason)
  {
  	char test[2];
    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+LWS_SEND_BUFFER_PRE_PADDING,in,len);
		          // Declenchement d'un prochain envoi au navigateur
		msize=len;
		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
    			printf("entree dans envoie");

		if(requete!= NULL)
		{
			char *test = requete + LWS_SEND_BUFFER_PRE_PADDING;
			printf("entree dans envoir->requete");
			printf("Message : %c%c%c\n",test[0],test[1],test[2]);
			if(test[0] == 'G' && test[1] == 'E' && test[2] == 'T')
			{
				reponse = malloc(3*sizeof(char));
				reponse[0] = 'a';reponse[1] = 'b'; reponse[2] = 'c';
				printf("\nSending : %c%c%c",reponse[0],reponse[1],reponse[2]);
				int length = 3;
				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;
    }
  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);

	//Initialisation com Serie


	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;

}


//********************************************************************************//