A libery to connect to telegesis zigbee module. Bassed on implemtation of XBEE

Fork of xbee_lib by Tristan Hughes

telegesis.cpp

Committer:
gert_lauritsen
Date:
2013-10-18
Revision:
14:dcf2390f89e2
Parent:
12:debf76f0c0bf
Child:
15:8d4990362a80

File content as of revision 14:dcf2390f89e2:

#include "telegesis.h"
#define CR 0x0D
#define LF 0x0A


zigbee::zigbee(PinName tx, PinName rx): _zbee(tx, rx) {
    _tx = tx;
    _rx = rx;
    _pos=0; 
      _zbee.baud(19200);
      _zbee.attach(this, &zigbee::SeePacket, Serial::RxIrq);
}

zigbee::~zigbee()
{
}

bool zigbee::wait4OK() {
    Timer t;
    t.reset();
  t.start();
    readPacket();
    while ((strstr(_responseFrameString,"OK")==0) & (t.read_ms() < 500))    readPacket();
    return (strstr(_responseFrameString,"OK")>0);
}

int zigbee::GetSerial()
{ 
        
    /** comes with something like this
  Telegesis ETRX357-LRS
  R305C
  000D6F0000D5F06A
  OK
*/   
    _zbee.printf("ATI\r");
      readPacket(); readPacket(); //commando
      readPacket();
    sscanf(_responseFrameString,"Telegesis %s",HWType);
      readPacket(); readPacket();
      LocalID=hextoint(_responseFrameString);
      wait_ms(5);
    return 1;
}

int zigbee::SetKey(char* key)
{
    return 1;
}



void zigbee::RecieveData(char *data_buf, int numchar)
{
    int count=0;
    if(numchar == 0) {
        numchar = sizeof(data_buf);
    }
    
    while(numchar!=count) {
        if(_zbee.readable()) {
            *data_buf = _zbee.getc();
            data_buf+=1;
            count++;
        }

    }
}

int zigbee::Reset()
{
    _zbee.printf("ATZ\r");
    wait4OK();
    return 1;
}

int zigbee::ATI()
{
    GetSerial();
    return 1;
}


int zigbee::PingOut()
{ //just return a OK (sends it ID out out the pan)
    _zbee.printf("AT+ANNCE\r");
    wait4OK();
    return 1;
}


int zigbee::PanScan()
{//
    _zbee.printf("AT+PANSCAN\r");
    return 1;
}


int zigbee::Establish_Network()
{//
    _zbee.printf("AT+EN\r");
    return 1;
}


int zigbee::JoinNetwork()
{
    _zbee.printf("AT+JN\r");
    return 1;
}

int zigbee::ScanNetwork()
{
    _zbee.printf("AT+SN\r");
    return 1;
}

int zigbee::NetworkInfo()
{
//Return something like this "+N=COO,12,-11,29F0,55C0E0DCE605C522"
    _zbee.printf("AT+N\r");
    return 1;
}

int zigbee::UniCast(char *adr,char *payload)  //Ascii mode with null terminated string
{
    _zbee.printf("AT+UCAST:%s=%s\r",adr,payload);
//    _zbee.scanf ("UCAST:%X,%X=%s ",&EUI64,&framesize,Zdata);
    return 1;
}

int zigbee::UniCastb(char *adr,char *payload, char payloadSize) //sends data in binary format
{
    _zbee.printf("AT+UCASTB:%X,%s\r",adr,payloadSize);
    //_zbee.scanf ("%*s");
    return 1;
}

//-----------------------Handle incoming data------------------------------

unsigned long zigbee::hextolong(const char *hex)
{
    //return 32 bit
    unsigned long result = 0;
    while (*hex) { //så længe det ikke er null
        if (*hex >= '0' && *hex <= '9')
            result += (*hex - '0');
        else if (*hex >= 'A' && *hex <= 'F')
            result += (*hex - 'A' +10);
        else if (*hex >= 'a' && *hex <= 'f')
            result += (*hex - 'a'+ 10);

        if (*++hex) //if the neext isn't a null
            result <<= 4;
    }
    return result;
}


unsigned int zigbee::hextoint(const char *hex)
{
    //return 16 bit
    unsigned int result = 0;
    while (*hex) { //så længe det ikke er null
        if (*hex >= '0' && *hex <= '9')
            result += (*hex - '0');
        else if (*hex >= 'A' && *hex <= 'F')
            result += (*hex - 'A' +10);
        else if (*hex >= 'a' && *hex <= 'f')
            result += (*hex - 'a'+ 10);

        if (*++hex) //if the neext isn't a null
            result <<= 4;
    }
    return result;
}
//---------------------------------------------------------------
void zigbee::readPacket() {
    //read and waits for the packet
    Timer t;
    t.reset();
  t.start();
    while ((GotFrame==0) & (t.read_ms() < 500)){}
    t.stop();   
    GotFrame=0; 
}   


void zigbee::SeePacket() {
 char *p;   
    b = _zbee.getc();
    if ((b!=CR) & (b!=LF)) _responseFrameData[_pos]=b;
    _pos=(_pos+1) % MAX_FRAME_DATA_SIZE;
    if (b==CR) {
         memcpy(&_responseFrameString,&_responseFrameData,_pos);
         GotFrame=1;
         _responseFrameString[_pos]=0; //Nul terminate
         _pos=0;
         if (strstr(_responseFrameString,"+UCAST:")) { //returns on that we have sendt something
            //Do something 
         } else
         if (strstr(_responseFrameString,"UCAST:")) {//checke for incoming UCAST data
             //if (sscanf (_responseFrameString,"UCAST:%X,%X=%s ",&EUI64,&framesize,Zdata)>0)
             p=strstr(_responseFrameString,"="); 
             if (p) {
               p++;
               strcpy(Zdata,p);
               Zdat=1;
             }   
         }
         if (strstr(_responseFrameString,"LeftPAN:")) PanOnline=0;  //Local node has left the Pan

         if (strstr(_responseFrameString,"NEWNODE:")) { //NEWNODE: <NodeID>,<EUI64>,<Parent NodeID>
             //new node on the pan
         }

         if ((strstr(_responseFrameString,"OK")>0) & (strstr(_responseFrameString,"TOKDUMP")==0) ) {  
                //if (ScriptState) ConnectScript();
                //Ok=1; Cmd=0; LineNo=0; 
         }
         if (strstr(_responseFrameString,"+N=")) {  
          sscanf (_responseFrameString,"+N=%s,%d,%d,%4X,",Devicetype,&channel,&NodeID,&EPID);
         }   
         if (strstr(_responseFrameString,"ACK")) { //
            PacketAck=1;
            p=strstr(_responseFrameString,":"); p++; //P indholder nu SEQ nummer
            SeqNumber=hextoint(p);
         }
         if (strstr(_responseFrameString,"NAK")) {
            PacketAck=0; 
            p=strstr(_responseFrameString,":"); p++; //P indholder nu SEQ nummer
            SeqNumber=hextoint(p);
         }
         if (strstr(_responseFrameString,"SEQ")) { //
            PacketAck=1;
            p=strstr(_responseFrameString,":"); p++; //P indholder nu SEQ nummer
            SeqNumber=hextoint(p);
         }      
    }   
}