#include <stdio.h>
#include <string.h>		//used by string
#include <unistd.h>		//Used for UART
#include <fcntl.h>		//Used for UART
#include <termios.h>		//Used for UART
#include <mysql/mysql.h>	//used by mysql
#include <stdlib.h>		//used by mysql
int uart0_filestream=1;
MYSQL *conn;				// the connection
MYSQL_RES *res;				// the results
MYSQL_ROW row;						// the results row (line by line)
unsigned char rx_buffer[1024];		// Read up to 255 characters from the port if they are there 
unsigned char tmp_buffer[1024];		// rx_buffer duomenis suraso tvarkingai 
int rx_length,ctpaketas;
int pirmas=0; 	
void setupUART();
void LocalWork();
int ReadUART();
void paketas();
const char *server="localhost";
const char *user="ziogas";
const char *password="ziogas";
const char *database="ziogas";
MYSQL mysql;
int main() {
	setupUART();
	printf("Pradzia\n");
    ctpaketas=0;
	mysql_init(&mysql);
    conn=mysql_real_connect(&mysql, server, user, password, database, 0, 0, 0);
    for (;;) {
        LocalWork();
    }
	close(uart0_filestream);
	mysql_free_result(res);
    mysql_close(conn);
	return 0;
}
void LocalWork() {
        int rxb=ReadUART();
        if (rxb!=-1) {
            char qstr[255];
            for (int i=0; i<rxb; i++){
                if (rx_buffer[i]==0x0D) {paketas();ctpaketas=0;}
                tmp_buffer[ctpaketas++]=rx_buffer[i];
            }
        }// else {printf("Nėra duomenų. Baitų skaičius=255 arba -1\n");
}
void paketas() {
    char tmp[32];
    int cttmp=0;
    int ilgis=0;
    char qstr[512]="insert into ziogas.Duomenys (VK, GD1, GD2, GV, KP, K0, TS) values (";
    for (int i=2; i<ctpaketas; i++){//pirmi du paketo baitao 0A ir 0D - 'newline' is Arduino - nereiksmingi
        tmp[cttmp]=tmp_buffer[i];
        if (tmp_buffer[i]==0x20) {
            tmp[cttmp]='\0';
            strcat(qstr, tmp);
            strcat(qstr, ",");
            ilgis=ilgis+cttmp+1;cttmp=0;		      
        } else {
            cttmp++;
        }        
    }
    tmp[cttmp]='\0';//paskutinos
    strcat(qstr, tmp);
    strcat(qstr, ");");
    ilgis=ilgis+cttmp+2;
    printf("%s\r", qstr);
    if (pirmas!=0) {
        if (mysql_real_query(&mysql, qstr, ilgis+67)==0) {//Return Values: Zero for success. Nonzero if an error occurred. 
		      //printf("Row inserted into the database successfully\n");
	       } else {
		      printf("Row insertion failed\n");
	    }        
    } else {pirmas=1;}
}
void setupUART(){
	uart0_filestream = open("/dev/ttyUSB0", O_RDWR | O_NOCTTY | O_NDELAY);		//Open in non blocking read/write mode
    if (uart0_filestream == -1){
        close(uart0_filestream);
		printf("Error - Unable to open UART.  Ensure it is not in use by another application\n");//ERROR - CAN'T OPEN SERIAL PORT
	}
	struct termios options;
	tcgetattr(uart0_filestream, &options);
	options.c_cflag = B115200 | CS8 | CLOCAL | CREAD;		//<Set baud rate
	options.c_iflag = IGNPAR;
	options.c_oflag = 0;
	options.c_lflag = 0;
	tcflush(uart0_filestream, TCIFLUSH);
	tcsetattr(uart0_filestream, TCSANOW, &options);
}
int ReadUART() {
	int i;
	if (uart0_filestream!=-1){
		int rx_length = read(uart0_filestream, (void*)rx_buffer, 512);//Filestream, buffer to store in, number of bytes to read (max)
		if (rx_length<0){//An error occured (will occur if there are no bytes)}
    		return rx_length;
    	  } else if (rx_length==0){
    		usleep(2000000);
            close(uart0_filestream);
            setupUART();
    	  } else {//printf("Priimta %i baitu\n",rx_length);
    		rx_buffer[rx_length]='\0';
    		return rx_length;
    	}
      } else {
    	usleep(2000000);
        setupUART();
        return -1;
    }
}