#include <STDIO.H>

/* PIP NEWFILE.C=MYFILE.C[Z] to remove high bit garbage */

char str1[255]; /* general purpose global string */
char str2[255]; /* yes pointers are better, but possibly */
char str3[255]; /* this is safer with stack overrun errors */
char strfilt[20];
int  intfilt;

char bargraph;

main()
{
     intfilt = 0;

     bargraph = 0x01; /* demo for the 8 leds */
     incbar();
     printf("ESP8266 Test Program\n");
     resetESP();
     listen1sec();
     incbar();
/*     AT();  */
/*     listen1sec();  */
/*     incbar(); */
     CWMODE();
     listen1sec();
     incbar();
/*     CWLAP();
     listen1sec();
     listen1sec();
     listen1sec();
     incbar(); */
     CWJAP();
     listen1sec();
     listen1sec();
     listen1sec();
     incbar();
     CIPMUX();
     listen1sec();
/*     listen1sec(); */
     incbar();
/* now either call google, or xively or some other site */
/*    XivelyPut();  */
/*     XivelyGet(); */
/*     Google();  */
       telnet();
/*       ftp(); */
}

listen1sec()
{
     int i;
     for (i=0;i<30000;i++) {
          port4term();
     }
}

resetESP()
{
     outp(0x7E,255);
     outp(0x7E,0);
     outp(0x7E,255); /* toggle the esp reset pin */
}

port4term()
{
     char c;
     int n;
     n = ac4in();
     if (n != -1) {
          c = n;
          if (((c>31) && (c<128)) || (c==10) || (c==13)) {
               printf("%c",c);
          }
     }
}

incbar()
{
     bargraph = (((bargraph+1) *2 ) -1);
     outp(0x7f,bargraph);
}


int ac0in() /* returns integer, not char, and -1 is no char */
{
     int n;
     char b,c;
     n = -1;
     b = inp(0x80);
     b = b & 0x01;
     if (b == 1) {
          c = inp(0x81);
          n = c;
     }
   return n;
}


int ac1in() /* returns integer, not char, and -1 is no char */
{
     int n;
     char b,c;
     n = -1;
     b = inp(0x82);
     b = b & 0x01;
     if (b == 1) {
          c = inp(0x83);
          n = c;
     }
   return n;
}

int ac4in() /* returns integer, not char, and -1 is no char */
{
     int n;
     char b,c;
     n = -1;
     b = inp(0x90);
     b = b & 0x01;
     if (b == 1) {
          c = inp(0x91);
          n = c;
     }
   return n;
}


ac4out(c)  /* output c to port 4 esp8266 port */
    char c;
{
    char d;
    do {
          d = inp(0x90);
          d = d & 0x2; /* mask bit 1 */
    } while (d != 2);
     outp(0x91,c); /* ok to output now */
}

printf4() /* output str1 to port4 */
{
     int i;
     /* printf("Send: "); */
     for(i=0;i<strlen(str1);i++) {
          /* printf("%c",str1[i]); */
          ac4out(str1[i]);
     }
}

AT()
{
     strcpy(str1,"AT\r\n");
     printf4();
}

CWMODE()
{
     strcpy(str1,"AT+CWMODE=3\r\n");
     printf4();
}

CWLAP()
{
     strcpy(str1,"AT+CWLAP\r\n");
     printf4();
}

CWJAP()
{
     strcpy(str1,"AT+CWJAP=\"Hogwarts Great Hall Wifi\",\"\"\r\n");
     printf4();
}

CIPMUX()
{
     strcpy(str1,"AT+CIPMUX=1\r\n");
     printf4();
}
ATE0()
{
        strcpy(str1,"ATE0\R\N"); /* turn off echo */
        printf4();
}

ATE1()
{
        strcpy(str1,"ATE1\R\N"); /* turn on echo */
        printf4();
}


CIPCLOSE()
{
     strcpy(str1,"AT+CIPCLOSE=0\r\n");
     printf4();
}

Google()
{
     strcpy(str1,"AT+CIPSTART=0,\"TCP\",\"www.google.com\",80\r\n");
     printf4();
     listen1sec();
     listen1sec();
     strcpy(str1,"GET / HTTP/1.1\r\n");
     strcat(str1,"Host: www.google.com:80\r\n\r\n");
     commandSend();
     listen1sec();
     listen1sec();
     listen1sec();
     CIPCLOSE();
     listen1sec();
}



XivelyPut()
{
     char xivelyData[40];
     char xivelyKey[80];
     char xivelyFeedID[20];
     char xivelyUserAgent[20];
     strcpy(xivelyData,"SensorName,150");
     strcpy(xivelyKey,"shsCNFtxuGELLZx8ehqglXAgDo9lkyBam5Zj22p3g3urH2FM");
     strcpy(xivelyFeedID,"970253233");
     strcpy(xivelyUserAgent,"Arduino1");

     strcpy(str1,"AT+CIPSTART=0,\"TCP\",\"api.xively.com\",80\r\n");
     printf4();
     listen1sec();
     strcpy(str1,"PUT /v2/feeds/");
     strcat(str1,xivelyFeedID);
     strcat(str1,".csv HTTP/1.1\r\n");
     strcat(str1,"Host: api.xively.com\r\n");
     strcat(str1,"X-ApiKey: ");
     strcat(str1,xivelyKey);
     strcat(str1,"\r\n");
     strcat(str1,"User-Agent: ");
     strcat(str1,xivelyUserAgent);
     strcat(str1,"\r\n");
     strcat(str1,"Content-Length: ");
     inttostring(strlen(xivelyData)); /* length in str2 */
     strcat(str1,str2);
     strcat(str1,"\r\n");
     strcat(str1,"Content-Type: text/csv\r\n");
     strcat(str1,"Connection: close\r\n\r\n");
     strcat(str1,xivelyData); /* the actual data */
     strcat(str1,"\r\n\r\n");
     commandSend();
     listen1sec();
     listen1sec();
}

XivelyGet()
{
     char xivelyKey[80];
     char xivelyFeedID[20];
     char xivelyUserAgent[20];
     char xivelySensor[20];
     strcpy(xivelyKey,"shsCNFtxuGELLZx8ehqglXAgDo9lkyBam5Zj22p3g3urH2FM");
     strcpy(xivelyFeedID,"970253233");
     strcpy(xivelyUserAgent,"Arduino1");
     strcpy(xivelySensor,"SensorName");

     strcpy(str1,"AT+CIPSTART=0,\"TCP\",\"api.xively.com\",80\r\n");
     printf4();
     listen1sec();
     strcpy(str1,"GET /v2/feeds/");
     strcat(str1,xivelyFeedID);
     strcat(str1,"/datastreams/");
     strcat(str1,xivelySensor);
     strcat(str1,".csv HTTP/1.1\r\n");
     strcat(str1,"Host: api.xively.com\r\n");
     strcat(str1,"X-ApiKey: ");
     strcat(str1,xivelyKey);
     strcat(str1,"\r\n");
     strcat(str1,"User-Agent: ");
     strcat(str1,xivelyUserAgent);
     strcat(str1,"\r\n");
     strcat(str1,"Content-Type: text/csv\r\n");
     strcat(str1,"Connection: close\r\n\r\n");
     strcat(str1,"\r\n\r\n");
     commandSend();
     listen1sec();
     listen1sec();
     listen1sec();
}


telnet()
{
     int i;
/*
http://mewbies.com/acute_terminal_fun_telnet_public_servers_watch_star_wars_play_games_etc.htm
*/
     char c;
     int x;
     int n;
     char e;
     printf("Turn off command echo\r\n");
     ATE0();
     listen1sec();
     strcpy(str1,"AT+CIPSTART=0,\"TCP\",\"telehack.com\",23\r\n");
/* strcpy(str1,"AT+CIPSTART=0,\"TCP\",\"towel.blinkenlights.nl\",23\r\n"); */
     printf4();
     printf("^C to quit telnet session\r\n");
     e = 0;
     while (e == 0) {
          x = ac0in(); /* scan serial port 0 */
          if (x != -1) {
               str1[0] = x;
               str1[1] = '\0';
               commandSend();
          }
          if ( x == 3) { e = 1; }
          x = ac1in(); /* scan physical keyboard */
          if (x != -1) {
               str1[0] = x;
               str1[1] = '\0';
               commandSend();
          }
          if ( x == 3) { e = 1; }
          n = ac4in();
          if (n != -1) {
                         c = n;
                         n = filter(c);
                         if (n != -1) {
                              printf("%c",n);
                         }
          }
     }
     printf("^C end session\r\n");
     printf("Turn on command echo\r\n");
     ATE1();
     CIPCLOSE();
     listen1sec();
}

commandSend() /* pass str1, uses str2 and str3 */
{
     strcpy(str3,"AT+CIPSEND=0,"); /* 0 is the channel number */
     inttostring(strlen(str1));  /* get length of  str1 */
     strcat(str3,str2); /* keep building string */
     strcat(str3,"\r\n"); /* add crlf */
     strcat(str3,str1); /* put cipsend at the start */
     strcpy(str1,str3); /* copy over to str1 */
     printf4(); /* send to esp module */

}


inttostring(num) /* pass integer n, returns str2 */
int num;
{
     int i,rem, len, n;
     n = num;
     len = 0;
     while ( n != 0 ) {
          len++;
          n /= 10;
     }
     for (i=0; i< len; i++) {
          rem = num % 10;
          num = num / 10;
          str2[len - (i+1)] = rem + '0';
     }
     str2[len] = '\0';
     /* printf("%s",str2);  */
}


ftp()
{
     int i;
     char c;
     int x;
     int n;
     char e;
     printf("^C to quit ftp after close\r\n");
     strcpy(str1,"AT+CIPSTART=0,\"TCP\",\"ftp.update.uu.se\",21\r\n");
     printf4();
     /* don't call listen1sec here, all needs to be filtered */
     e = 0;
     while (e == 0) {
          x = ac0in(); /* scan serial port 0 */
          if (x != -1) {
               str1[0] = x;
               str1[1] = '\0';
               commandSend();
          }
          if ( x == 3) { e = 1; }
          x = ac1in(); /* scan physical keyboard */
          if (x != -1) {
               str1[0] = x;
               str1[1] = '\0';
               commandSend();
          }
          if ( x == 3) { e = 1; }
          n = ac4in();
          if (n != -1) {
                 c = n;
                 printf("%c",c);
/*                 n = filter(c);
                 if (n != -1) {
                    printf("%c",n);
                 }  */
          }
     }
     printf("^C end session\r\n");
     CIPCLOSE();
     listen1sec();
}

int filter(c) /* +IPD,0,500: and let next 500 through */
char c; /* and uses global var intfilt and strfilt[20] */
{
     int returnval;
     returnval = -1;
     int i;
     int units;
     int a;
     int x;
     units = 1;
     if (intfilt >0 ) {
          intfilt = intfilt - 1;
          returnval = c; /* pass through */
     }
     if (intfilt == 0) {
          if(strfilt[0] != '+') {
               strfilt[0] = 0;
          }
          if (c == '+') {
               strfilt[0] = '+';
               strfilt[1] = 0;
          }
          if ((strfilt[0] == '+') && (c != '+')) {
               i = strlen(strfilt);
               strfilt[i] = c;
               strfilt[i+1] = 0;
          }
          if (strlen(strfilt) >18) {
               strfilt[0] = 0;
          }
          if (c==':') {
               x = strlen(strfilt) - 2;
               while ((x>0) && (strfilt[x] != ',')) {
                    intfilt = intfilt + ((strfilt[x]-48) * units);
                    units = units * 10;
                    x = x - 1;
               }
               strfilt[0] = 0;
          }
     }
     return returnval;
}