A6Services.cpp

#include "Arduino.h"
#include "A6Services.h"
#include <ctype.h>

A6GPRS::A6GPRS(Stream &comm,unsigned cbs,unsigned maxmessagelength){
  comm_buf = new char[cbs];
  commbuffsize = cbs;
  CIPstatus = IP_STATUS_UNKNOWN;
  _comms = &comm;
  connectedToServer = false;
  modemMessageLength = 0;
  modemmessage = new byte[maxmessagelength];
  maxMessageLength = maxmessagelength;
  ParseState = GETMM;
  callState = IDLE;
  nextLineSMS = false;
};
A6GPRS::~A6GPRS(){};

static char *statusnames[] = {"IP INITIAL","IP START","IP CONFIG","IP IND","IP GPRSACT","IP STATUS","TCP/UDP CONNECTING","IP CLOSE","CONNECT OK"};
//const char* const status_names[] PROGMEM = {"IP INITIAL","IP START","IP CONFIG","IP IND","IP GPRSACT","IP STATUS","TCP/UDP CONNECTING","IP CLOSE","CONNECT OK"};

char tempbuf[100];

bool A6GPRS::getIMEI(char imei[])
{
  bool rc;
  RXFlush();
  modemPrint(F("AT+EGMR=2,7\r"));
  rc = GetLineWithPrefix("+EGMR:",imei,20,500);
  waitresp("OK\r\n",500);
  return rc;
}

bool A6GPRS::getCIMI(char cimi[])
{
  bool rc;
  RXFlush();
  modemPrint(F("AT+CIMI\r"));
  waitresp("\r\n",500);
  rc = GetLineWithPrefix(NULL,cimi,20,500);
  waitresp("OK\r\n",500);
  return rc;
}
bool A6GPRS::getRTC(char rtc[])
{
  bool rc;
  RXFlush();
  modemPrint(F("AT+CCLK\r"));
  waitresp("\r\n",500);
  rc = GetLineWithPrefix("+CCLK:",rtc,30,500);
  waitresp("OK\r\n",500);
  return rc;
}
bool A6GPRS::setRTC(char rtc[])
{
  RXFlush();
  modemPrint(F("AT+CCLK=\""));
  modemPrint(rtc);
  modemPrint("\"\r");
  return waitresp("OK\r\n",500);
}

enum A6GPRS::eCIPstatus A6GPRS::getCIPstatus()
{
  enum eCIPstatus es = IP_STATUS_UNKNOWN;
  RXFlush();
  modemPrint(F("AT+CIPSTATUS\r"));
  if (GetLineWithPrefix("+IPSTATUS:",tempbuf,50,1000))
  {
    char *s = tempbuf;  // skip over whitespace
    while (isspace(*s))
      s++;
    int i;
    for (i=0;i<9;i++)
      if (strncmp(s,statusnames[i],strlen(statusnames[i])) == 0)
      {
        es = i;
        break;
      }
  }
  waitresp("OK\r\n",2000);  // trailing stuff
  CIPstatus = es;
  return es;
}

char *A6GPRS::getCIPstatusString(enum eCIPstatus i)
{
  return statusnames[i];
}

char *A6GPRS::getCIPstatusString()
{
  return statusnames[getCIPstatus()];
}

bool A6GPRS::startIP(char apn[],char user[],char pwd[])  // apn, username, password
{
  bool rc = false;
  RXFlush();
  if (CIPstatus != IP_INITIAL)
  {
    modemPrint(F("AT+CIPCLOSE\r"));
    waitresp("OK\r\n",2000);
  }
  RXFlush();
  modemPrint(F("AT+CGATT=1\r"));
  if (waitresp("OK\r\n",10000))
  {
    RXFlush();
    sprintf(tempbuf,"AT+CGDCONT=1,\"IP\",\"%s\"\r",apn);
    modemPrint(tempbuf);
    if (waitresp("OK\r\n",1000))
    {
      RXFlush();
      sprintf(tempbuf,"AT+CGACT=1,1\r");
      modemPrint(tempbuf);
      if (waitresp("OK\r\n",1000))
      {
        RXFlush();
        rc = true;
      }
    }
  }
  RXFlush();
  return rc;
}

bool A6GPRS::startIP(char apn[])  // apn
{
  return startIP(apn,"","");
}

bool A6GPRS::stopIP()
{
  bool rc = false;
  RXFlush();
  modemPrint(F("AT+CIPCLOSE\r"));
  rc = waitresp("OK\r\n",1000);
  return rc;
}

A6GPRS::ePSstate A6GPRS::getPSstate()
{
  ePSstate eps = PS_UNKNOWN;
  RXFlush();
  modemPrint(F("AT+CGATT?\r"));  
  if (GetLineWithPrefix("+CGATT:",tempbuf,50,1000))
  {
    if (*tempbuf == '0')
      eps = DETACHED;
    else if (*tempbuf == '1')
      eps = ATTACHED;
  }
  return eps;
}

bool A6GPRS::setPSstate(A6GPRS::ePSstate eps)
{
  bool rc = false;
  RXFlush();
  switch (eps)
  {
    case DETACHED:
      modemPrint(F("AT+CGATT=0\r"));
      break;
    case ATTACHED:
      modemPrint(F("AT+CGATT=1\r"));
      break;
  }
  return waitresp("OK\r\n",2000);
}

bool A6GPRS::getLocalIP(char ip[])
{
  bool rc = false;
  int count = 5;
  RXFlush();
  ip[0] = 0;
  modemPrint(F("AT+CIFSR\r"));
  // skip empty lines
  while (count-- && !isdigit(ip[0]))
	  GetLineWithPrefix(NULL,ip,20,2000);
  if (count == 0)
	  return rc;
  else
	return waitresp("OK\r\n",2000);
}
bool A6GPRS::connectTCPserver(char*path,int port)
{
  bool rc = false;
  CIPstatus = getCIPstatus();
  if (CIPstatus == IP_CLOSE || CIPstatus == IP_GPRSACT)
  {
    sprintf(tempbuf,"AT+CIPSTART=\"TCP\",\"%s\",%d\r",path,port);
    modemPrint(tempbuf);
    if (waitresp("CONNECT OK",10000))
    {
      debugWrite(">>");
      waitresp("OK\r\n",10000);
	  connectedToServer = true;
      rc = true;
    }
  }
  return rc;
}
bool A6GPRS::sendToServer(char msg[])
{
  bool rc = false;
  getCIPstatus();
  if (CIPstatus == CONNECT_OK)
  {
    modemPrint(F("AT+CIPSEND\r"));
    if (waitresp(">",100))
    {
      modemPrint(msg);
      modemWrite(0x1a);
	  txcount += strlen(msg) + 1;
      waitresp("OK\r\n",1000);
      rc = true;
    }
  }
  return rc;
}

bool A6GPRS::sendToServer(char *msgs[],unsigned num)
{
  bool rc = false;
  getCIPstatus();
  if (CIPstatus == CONNECT_OK)
  {
    modemPrint(F("AT+CIPSEND\r"));
    if (waitresp(">",100))
    {
	  for (int i=0;i<num;i++)
	  {
		modemPrint(msgs[i]);
        txcount += strlen(msgs[i]);
	  }
      modemWrite(0x1a);
	  txcount++;
      waitresp("OK\r\n",1000);
      rc = true;
    }
  }
  return rc;
}

bool A6GPRS::sendToServer(char msg[],int length)
{
  bool rc = false;
  getCIPstatus();
  if (CIPstatus == CONNECT_OK)
  {
    modemPrint(F("AT+CIPSEND="));
    modemPrint(length);
    modemPrint(F("\r"));
    if (waitresp(">",100))
    {
      modemPrint(msg);
	  txcount += length;
      waitresp("OK\r\n",1000);
      rc = true;
    }
  }
  return rc;
}

bool A6GPRS::sendToServer(byte msg[],int length)
{
  bool rc = false;
  char buff[10];
  getCIPstatus();
  if (CIPstatus == CONNECT_OK)
  {
    modemPrint(F("AT+CIPSEND="));
    modemPrint(length);
    modemPrint(F("\r"));
    if (waitresp(">",100))
    {
	  for (int i=0;i<length;i++)
	  {
		sprintf(buff,"%02X,",msg[i]);
		debugWrite(buff);
		modemWrite(msg[i]);
		txcount++;  
	  }
      rc = waitresp("OK\r\n",3000);
    }
  }
  return rc;
}

/*
 *  Serial input is a mixture of modem unsolicited messages e.g. +CGREG: 1, expected
 *  messages such as the precursor to data +CIPRCV:n, and data from the server
 *  We look for complete modem messages & react to +CIPRCV, transfer n bytes
 *  to the registered client parser
 *  wait for cr/lf cr , as terminators 
 */
byte *A6GPRS::Parse(unsigned *length)
{
  byte *mm = 0;
  *length = 0;
  bool alldone = false;
  char c = pop();
  while (!alldone && c != -1)
  {
    switch (ParseState)
    {
      case GETMM:
        modemmessage[modemMessageLength++] = c;
		// first check if we got an unsolicited message
		if (c == 0x0a /*|| c == 0x0d*/)
		{
			*length = modemMessageLength;
			alldone = true;
			modemmessage[modemMessageLength]=0; // end marker
			mm = modemmessage;
			modemMessageLength = 0;
		}
		// then check if there is data coming in from an TCP connection
        else if (modemMessageLength == 8 && strncmp(modemmessage,"+CIPRCV:",8) == 0)
        {
            ParseState = GETLENGTH;
            modemMessageLength = 0;
        }
        else if (modemMessageLength == 11 && strncmp(modemmessage,"+TCPCLOSED:",11) == 0)
        {
            debugWrite(F("Server closed connection\r\n"));
            connectedToServer = false;
			ParseState = GETMM;
			modemMessageLength = 0;
            stopIP();
           // getCIPstatus();
        }
        break;
      case GETLENGTH:
        modemmessage[modemMessageLength++] = c;
        if (c == ',')
        {
          modemmessage[modemMessageLength] = 0;
          clientMsgLength = atoi(modemmessage);
	//	  debugWrite("ClientMsgLength ");
	//	  debugWrite(clientMsgLength);
		  rxcount += clientMsgLength;
          modemMessageLength = 0;
		  if (clientMsgLength > maxMessageLength)
			  debugWrite("Item is too large");
          ParseState = GETDATA;
        }
        break;
      case GETDATA:
        if (clientMsgLength <= maxMessageLength)   // only copy data if there is space
          modemmessage[modemMessageLength++] = c;
        else
          modemMessageLength++;   // else just discard
        if (modemMessageLength == clientMsgLength)
        {
          ParseState = GETMM;
          modemMessageLength = 0;
		  alldone = true;
		  mm = modemmessage;
		  if (clientMsgLength > maxMessageLength)
		  {
			  debugWrite("item too large");
			  onException(BUFFER_OVERFLOW,clientMsgLength);
			  *length = maxMessageLength;
		  }
		  else
			  *length = clientMsgLength;
        }
        break;
    }
	if (!alldone)
		c = pop();
  }
  return mm;
}

bool A6GPRS::dial(char number[])
{
	bool rc = false;
	modemPrint(F("ATD"));
	modemPrint(number);
	modemPrint(F("\r"));
	if (waitresp("OK",1000))
	{
		callState = DIALLING_OUT;
		rc = true;
	}
	return rc;
}
bool A6GPRS::answer()
{
	modemPrint(F("ATA\r"));
	callState = SPEAKING;
	return waitresp("OK",1000);
}
bool A6GPRS::hangup()
{
	modemPrint(F("ATH\r"));
	callState = IDLE;
	return waitresp("OK",1000);
}
bool A6GPRS::callerID(bool enable)
{
	modemPrint(F("AT+CLIP="));
	modemPrint(enable);
	modemPrint(F("\r"));
	return waitresp("OK",1000);	
}
bool A6GPRS::sendDTMF(char c,unsigned t)
{
	modemPrint(F("AT+VTS="));
	modemWrite(c);
	modemPrint(F(","));
	modemPrint(t);
	modemPrint(F("\r"));
	return waitresp("OK",1000);
}

bool A6GPRS::sendDTMF(char c)
{
	return sendDTMF(c,1);
}

bool A6GPRS::sendSMS(char addr[],char text[])
{
	modemPrint(F("AT+CMGS=\""));
	modemPrint(addr);
	modemPrint(F("\"\r"));
	waitresp(">",1000);	
	modemPrint(text);
	modemWrite(0x1a);
	return waitresp("+CMGS:",5000);
}

bool A6GPRS::setSmsTextMode()
{
	modemPrint(F("AT+CMGF=1\r")); // SMS text mode
	return waitresp("OK\r\n",1000);		
}