#include "etherShield.h"
#include <LCD4Bit_mod.h> 
#include <OneWire.h>
#include <stdlib.h>


//create object to control an LCD.  
//number of lines in display=1
LCD4Bit_mod lcd = LCD4Bit_mod(2); 

// DS18S20 Temperature chip i/o
#define TEMP_PIN 13
OneWire ds(TEMP_PIN); 

// please modify the following lines. mac and ip have to be unique
// in your local area network. You can not have the same numbers in
// two devices:
static uint8_t mymac[6] = {0x54,0x55,0x58,0x10,0x00,0x24}; 
static uint8_t myip[4] = {192,168,123,15};
static uint16_t my_port = 1200;     // client port

// client_ip - modify it when you have multiple client on the network
// for server to distinguish each ethershield client. This is getting sent to the server as a parameter.
static char client_ip[] = "192.168.123.15";

// server settings - modify the service ip to your own server
static uint8_t dest_ip[4]={192,168,123,188};
static uint8_t dest_mac[6];

enum CLIENT_STATE
{  
   IDLE, ARP_SENT, ARP_REPLY, SYNC_SENT
 };
 
static CLIENT_STATE client_state;

static uint8_t client_data_ready;

static uint8_t syn_ack_timeout = 0;


#define BUFFER_SIZE 500
static uint8_t buf[BUFFER_SIZE+1];

EtherShield es=EtherShield();

// prepare the webpage by writing the data to the tcp send buffer
uint16_t print_webpage(uint8_t *buf);
int8_t analyse_cmd(char *str);

void client_process(void);
void lcdPrint(int lcdLine, int lcdCol, char *str, boolean ClrToEOL);

void setup(){

   Serial.begin(38400);
 
   lcd.init();
   lcd.clear();
   lcdPrint(1,0,"Web Client",true);
   
   /*initialize enc28j60*/
   es.ES_enc28j60Init(mymac);
   es.ES_enc28j60clkout(2); // change clkout from 6.25MHz to 12.5MHz
   delay(10);
   //*Magjack leds configuration, see enc28j60 datasheet, page 11 */
   // LEDA=greed LEDB=yellow
   //
   // 0x880 is PHLCON LEDB=on, LEDA=on
   // enc28j60PhyWrite(PHLCON,0b0000 1000 1000 00 00);
   es.ES_enc28j60PhyWrite(PHLCON,0x880);
   delay(500);
   //
   // 0x990 is PHLCON LEDB=off, LEDA=off
   // enc28j60PhyWrite(PHLCON,0b0000 1001 1001 00 00);
   es.ES_enc28j60PhyWrite(PHLCON,0x990);
   delay(500);
   //
   // 0x880 is PHLCON LEDB=on, LEDA=on
   // enc28j60PhyWrite(PHLCON,0b0000 1000 1000 00 00);
   es.ES_enc28j60PhyWrite(PHLCON,0x880);
   delay(500);
   //
   // 0x990 is PHLCON LEDB=off, LEDA=off
   // enc28j60PhyWrite(PHLCON,0b0000 1001 1001 00 00);
   es.ES_enc28j60PhyWrite(PHLCON,0x990);
   delay(500);
   //
   // 0x476 is PHLCON LEDA=links status, LEDB=receive/transmit
   // enc28j60PhyWrite(PHLCON,0b0000 0100 0111 01 10);
   es.ES_enc28j60PhyWrite(PHLCON,0x476);
   delay(100);
        
   //init the ethernet/ip layer:
   es.ES_init_ip_arp_udp_tcp(mymac,myip,80);
  
   // intialize varible;
   syn_ack_timeout =0;
   client_data_ready = 0;
   client_state = IDLE;
   lcdPrint(2,0,"Started Ethernet",true);
}


void loop(){
        
        if(client_data_ready==0){
          Serial.print("Countdown to temperature reading ");
          lcdPrint(2,0,"Update in",true);
          for (int i=10;i>0;i--){
            // convert int var "value" into a 10-base string, store it in vString.
            char vString[10];
            itoa(i, vString, 10);
            lcdPrint(2,10, vString,false);
            Serial.print(vString);
            Serial.print(" ");
            delay(500);
          }
          Serial.print("\n");
          
          Serial.println("Getting temperature reading");
          lcdPrint(2,0,"Sensor Data",true);
          


          client_data_ready = 1;
         }
         Serial.println("");
         
         Serial.println("Sending data to website");
	 client_process();

         Serial.println("Sleeping");
         delay(1000);
}

uint16_t gen_client_request(uint8_t *buf )
{
	uint16_t plen;
	byte i;
        lcdPrint(2,0,"Client Request",true);
	plen= es.ES_fill_tcp_data_p(buf,0, PSTR ( "GET /ethernet_log/save.php?pwd=secret&client=" ) );
        for(i=0; client_ip[i]!='\0'; i++){
            buf[TCP_DATA_P+plen]=client_ip[i];
            plen++;
        }
        plen= es.ES_fill_tcp_data_p(buf,plen, PSTR ( "&status=temperature-" ) );
 //       for(i=0; sensorData[i]!='\0'; i++){        
 //               buf[TCP_DATA_P+plen]=sensorData[i];
 //               plen++;
 //       }	
	plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( " HTTP/1.0\r\n" ));
	plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Host: 192.168.123.188\r\n" ));
	plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "User-Agent: AVR ethernet\r\n" ));
        plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Accept: text/html\r\n" ));
	plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Keep-Alive: 300\r\n" ));
	plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Connection: keep-alive\r\n\r\n" ));

	return plen;
}

//*****************************************************************************************
//
// Function : client_process
// Description : send temparature to web server, this option is disabled by default.
// YOU MUST install webserver and server script before enable this option,
// I recommented Apache webserver and PHP script.
// More detail about Apache and PHP installation please visit http://www.avrportal.com/
//
//*****************************************************************************************
void client_process ( void )
{
    uint16_t plen;
	uint8_t i;
    if (client_data_ready == 0)  return;     // nothing to send
	if(client_state == IDLE){   // initialize ARP
           lcdPrint(2,0,"IDLE",true);
           es.ES_make_arp_request(buf, dest_ip); 
	   client_state = ARP_SENT;
	   return;
	}
		
	if(client_state == ARP_SENT){
        lcdPrint(2,0,"ARP_SENT",true);
        plen = es.ES_enc28j60PacketReceive(BUFFER_SIZE, buf);

		// destination ip address was found on network
        if ( plen!=0 )
        {
            if ( es.ES_arp_packet_is_myreply_arp ( buf ) ){
                client_state = ARP_REPLY;
                lcdPrint(2,0,"ARP_REPLY",true);
         	syn_ack_timeout=0;
                return;
            }
		
		}
	        delay(10);
		syn_ack_timeout++;
		
		
		if(syn_ack_timeout== 100) {  //timeout, server ip not found
                        lcdPrint(2,0,"Server not Found",true);
			client_state = IDLE;
			client_data_ready =0;
			syn_ack_timeout=0;
			return;
		}	
    }

 // send SYN packet to initial connection
	if(client_state == ARP_REPLY){
                lcdPrint(2,0,"Saving MAC",true);
		// save dest mac
		for(i=0; i<6; i++){
			dest_mac[i] = buf[ETH_SRC_MAC+i];
		}
	
        es.ES_tcp_client_send_packet (
                       buf,
                       80,
                       1200,
                       TCP_FLAG_SYN_V,                 // flag
                       1,                                              // (bool)maximum segment size
                       1,                                              // (bool)clear sequence ack number
                       0,                                              // 0=use old seq, seqack : 1=new seq,seqack no data : new seq,seqack with data
                       0,                                              // tcp data length
		      dest_mac,
		      dest_ip
                       );
		
		client_state = SYNC_SENT;
                lcdPrint(2,0,"SYNC_SENT",true);
	}
  // get new packet
  if(client_state == SYNC_SENT){
    plen = es.ES_enc28j60PacketReceive(BUFFER_SIZE, buf);

       // no new packet incoming
    if ( plen == 0 )
    {
        lcdPrint(2,0,"No packets",true);
//                client_state = IDLE;

        return;
    }

       // check ip packet send to avr or not?
       // accept ip packet only
    if ( es.ES_eth_type_is_ip_and_my_ip(buf,plen)==0){
                lcdPrint(2,0,"Not my Packet",true);
		return;
    }

       // check SYNACK flag, after AVR send SYN server response by send SYNACK to AVR
    if ( buf [ TCP_FLAGS_P ] == ( TCP_FLAG_SYN_V | TCP_FLAG_ACK_V ) )
    {

               // send ACK to answer SYNACK

               es.ES_tcp_client_send_packet (
                       buf,
                       80,
                       1200,
                       TCP_FLAG_ACK_V,                 // flag
                       0,                                              // (bool)maximum segment size
                       0,                                              // (bool)clear sequence ack number
                       1,                                              // 0=use old seq, seqack : 1=new seq,seqack no data : new seq,seqack with data
                       0,                                              // tcp data length
						dest_mac,
						dest_ip
                       );
               // setup http request to server
               plen = gen_client_request( buf );
               // send http request packet
               // send packet with PSHACK
               es.ES_tcp_client_send_packet (
                                       buf,
                                       80,                                             // destination port
                                       1200,                                   // source port
                                       TCP_FLAG_ACK_V | TCP_FLAG_PUSH_V,                        // flag
                                       0,                                              // (bool)maximum segment size
                                       0,                                              // (bool)clear sequence ack number
                                       0,                                              // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
                                       plen,                           // tcp data length
                                       dest_mac,
									   dest_ip
									   );
               lcdPrint(2,0,"Sent Update",true);

               return;
       }
       // after AVR send http request to server, server response by send data with PSHACK to AVR
       // AVR answer by send ACK and FINACK to server
       if ( buf [ TCP_FLAGS_P ] == (TCP_FLAG_ACK_V|TCP_FLAG_PUSH_V) )
       {
               plen = es.ES_tcp_get_dlength( (uint8_t*)&buf );

               // send ACK to answer PSHACK from server
               es.ES_tcp_client_send_packet (
                                       buf,
                                       80,                                             // destination port
                                       1200,                                   // source port
                                       TCP_FLAG_ACK_V,                  // flag
                                       0,                                              // (bool)maximum segment size
                                       0,                                              // (bool)clear sequence ack number
                                       plen,                                           // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
                                       0,                              // tcp data length
				      dest_mac,
				      dest_ip
               );;
               // send finack to disconnect from web server

               es.ES_tcp_client_send_packet (
                                       buf,
                                       80,                                             // destination port
                                       1200,                                   // source port
                                       TCP_FLAG_FIN_V|TCP_FLAG_ACK_V,                  // flag
                                       0,                                              // (bool)maximum segment size
                                       0,                                              // (bool)clear sequence ack number
                                       0,                                           // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
                                       0,
										dest_mac,
										dest_ip
				);

               return;
               
       }
       // answer FINACK from web server by send ACK to web server
       if ( buf [ TCP_FLAGS_P ] == (TCP_FLAG_ACK_V|TCP_FLAG_FIN_V) )
       {
               // send ACK with seqack = 1
               es.ES_tcp_client_send_packet(

                                       buf,
                                       80,                                             // destination port
                                       1200,                                   // source port
                                       TCP_FLAG_ACK_V,                 // flag
                                       0,                                              // (bool)maximum segment size
                                       0,                                              // (bool)clear sequence ack number
                                       1,                                              // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
                                       0,
									   dest_mac,
									   dest_ip
				);
			client_state = IDLE;		// return to IDLE state
			client_data_ready =0;		// client data sent
		}
  }       
}

void lcdPrint(int lcdLine, int lcdCol, char *str, boolean ClrToEOL)
{
  if (ClrToEOL = true) {
    lcd.cursorTo(lcdLine, lcdCol);
    lcd.printIn("                ");
  }
  lcd.cursorTo(lcdLine, lcdCol);
  lcd.printIn(str);
}


void GetTemp(char *temp_str)
{
      int tHighByte, tLowByte, TReading, SignBit, Tc_100, Whole, Fract;
    byte ti;
    byte present = 0;
    byte tdata[12];
    byte taddr[8];

//          Serial.print("Search for addresses of DS18B20");
//          if ( !ds.search(taddr)) {
//            Serial.print("No more addresses.\n");
//            ds.reset_search();
//            return;
//          }

//          if ( OneWire::crc8( taddr, 7) != taddr[7]) {
//            Serial.print("CRC is not valid!\n");
//            return;
//          }

//          if ( taddr[0] != 0x28) {
//            Serial.print("Device is not a DS18S20 family device.\n");
//            return;
//          }

//          ds.reset();
//          ds.select(taddr);
//          ds.write(0x44,1);         // start conversion, with parasite power on at the end

//          delay(1000);     // maybe 750ms is enough, maybe not
          // we might do a ds.depower() here, but the reset will take care of it.

//          present = ds.reset();
//          ds.select(taddr);    
//          ds.write(0xBE);         // Read Scratchpad

//          for ( ti = 0; ti < 9; ti++) {           // we need 9 bytes
//            tdata[ti] = ds.read();
//          }
//          tLowByte = tdata[0];
//          tHighByte = tdata[1];
//          TReading = (tHighByte << 8) + tLowByte;
//          SignBit = TReading & 0x8000;  // test most sig bit
//          if (SignBit) // negative
//          {
//            TReading = (TReading ^ 0xffff) + 1; // 2's comp
//          }
//          Tc_100 = (6 * TReading) + TReading / 4;    // multiply by (100 * 0.0625) or 6.25

//          Whole = Tc_100 / 100;  // separate off the whole and fractional portions
//          Fract = Tc_100 % 100;


//          if (SignBit) // If its negative
//          {
//             Serial.print("-");
//          }
//          Serial.print(Whole);
//          Serial.print(".");
//          if (Fract < 10)
//          {
//             Serial.print("0");
//          }
//          Serial.print(Fract);

}