// C program to illustrate
// non I/O blocking calls

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <fcntl.h> // library for fcntl function
#include <errno.h>
#include "logging.h"

#include <string.h>

#include <time.h>

#define MSGSIZE 6
#define UPDATE_INTERVAL 17



int main(int argc, char **argv) {
	int fdPipe[2];			// File descriptor för pipe
	
	pipe(fdPipe);			// Skapar en pipe
	
	pid_t cpid = fork();	// Skapar en till process
	if (fcntl(fdPipe[0], F_SETFL, O_NONBLOCK) < 0)
        exit(2);
	
	switch(cpid) {
		
		// Fel
		case -1: exit(3);
		
		// Child process
		case 0:								
		dup2(fdPipe[1], STDOUT_FILENO);		// Skriva till stdout, skrivs till pipe istället
		close(fdPipe[1]);					// Stäng änden som inte används
		mqtt_sub();
		break;
		
		// Parent process
		default:
		dup2(fdPipe[0], STDIN_FILENO);
		close(fdPipe[0]);
		parent_init();

	}
	return 0;
}
int parent_init(){

    int nrOfEntries = 0;
    LogEntry sensorLog[200];

    char updates[3000] = "\0";

    time_t omega;
    time_t alpha = time(NULL);
    time_t seconds = UPDATE_INTERVAL; // Hur många sekunder mellan varje thingspeak update

    omega = alpha + seconds;    // Detta är början

    printf("start time is : %s", ctime(&alpha));

// För resten av programmet, läs och logga data och uppdatera thingspeak varje UPDATE_INTERVAL
    char stdinput[MSGSIZE];
	int nread;
	while (1) {
		while (fgets(stdinput, 10, stdin) != NULL) {


            // text read
            // by default return no. of bytes
            // which read call read at that time
            fprintf(stdout,"MSG = %s", stdinput);
		
		// sensorLogging(sensorLog, &nrOfEntries);
        /* while (alpha < omega){                          // Loggar data under UPDATE_INTERVAL
          
          alpha = time(NULL);
        }
        fprintf(stdout,"En minut har passerat!\n");
        sortLog(sensorLog, &nrOfEntries);               // Slå ihop sensorvärden som har skett samma sekund
        buildUpdates(sensorLog, nrOfEntries);           // Skapar strängar av datum,tid och effekt i CSV format
        buildURI(sensorLog, nrOfEntries, updates);			// Bygger strängen av all sensordata som ska skickas till thingspeak
        if(nrOfEntries > 0){
          curling(updates);
        }
        nrOfEntries = 0;          // Börjar om, obs structen har kvar sina värden tills de skrivs över
        omega = alpha + seconds;  // Detta är den nya början*/
    }
	}

}

void sensorLogging(LogEntry *sensorLog, int *entries){


  int nread;
  char line[MSGSIZE];

			while( fgets(line, MSGSIZE,stdin) != NULL){
				fprintf(stdout,"%s",line);
			}

            // text read
            // by default return no. of bytes
            // which read call read at that time
            //fprintf(stdout,"MSG = %s, COUNT: %d\n", buf, *entries);
            //loggingParent(sensorLog, buf, entries);
}