File content as of revision 1:b2a9a6f2c30e:

#include "AferoCommHndlr.h"

Necochan *Necochan::ref = NULL;

Necochan::Necochan()
{
    if(ref==NULL)
    {
        ref = this;
    }
    out = new DigitalOut(PTB8,1);
}

void Necochan::release()
{
    DigitalOut *p = ref->out;
    *p = 1;
}

void Necochan::push()
{
    SERIAL_PRINT_DBG("push meow\n");
    *out = 0;
    timeout.attach(&release,1);
}

static AferoCommHndlr *self = NULL;

AferoCommHndlr::AferoCommHndlr() : flowControlEnabled(false)
{
    necochan = new Necochan();
}

void
AferoCommHndlr::loop()
{
    piafLib->loop();
    todoQ->loop();
}

AferoCommHndlr*
AferoCommHndlr::create(Timer *timer, mbedSPI *spi)
{
     SERIAL_PRINT_DBG("HELLO\n");
     self = new AferoCommHndlr();
     self->timer = timer;
     self->piafLib = iafLib::create((PinName)PINS::ASR_1::SPI::SR,
       AferoCommHndlr::fco_irq_fall,
       AferoCommHndlr::myOnAttributeSet,
       AferoCommHndlr::myOnAttributeSetComplete, spi);
     self->todoQ = ToDoQ::create(AferoCommHndlr::onGetTodo);
     SERIAL_PRINT_DBG("AferoCommHndlr init done\n");
     self->piafLib->setAttribute8(1,1);
     
     return self;
}

void
AferoCommHndlr::myOnAttributeSet(
    const uint8_t requestId,
    const uint16_t attributeId,
    const uint16_t valueLen,
    const uint8_t *value)
{
    self->piafLib->setAttributeComplete(requestId, attributeId, valueLen, value);
}

void
AferoCommHndlr::myOnAttributeSetComplete(
    const uint8_t requestId,
    const uint16_t attributeId,
    const uint16_t valueLen,
    const uint8_t *value)
{
    uint8_t *buf = new uint8_t[valueLen+1];
    memset(buf,'\0',valueLen+1);
    memcpy(buf, value, valueLen);
    SERIAL_PRINT_DBG("attr id:%d value:%s\n",attributeId,buf);
    delete[] buf;
    buf = NULL;
    
    if(attributeId==1024)
    {
        self->necochan->push();
    }
    
    if(attributeId==ATTR_ID_SENSING_INTERVAL)
    {
        
    }
    else if(attributeId==ATTR_ID_SENSE_VAL)
    {
        //self->timeoutUpload.attach(&AferoCommHndlr::updateToAferoCloud,1);
    }
}

void
AferoCommHndlr::fco_irq_fall()
{
    if(self->piafLib)
    {
        self->piafLib->mcuISR();
    }
}

void
AferoCommHndlr::onGetTodo(ToDo *todo)
{
    SERIAL_PRINT_DBG("AferoCommHndlr::onGetTodo()\n");
    char buf[255];
    memset(buf,'\0',sizeof(buf));
    if(todo!=NULL)
    {
        if(self->flowControlEnabled==true)
        {
            
        }
        else
        {    
            todo->toJSON(buf);
            SERIAL_PRINT_DBG("%s\n",buf);
            self->piafLib->setAttribute(ATTR_ID_SENSE_VAL,strlen(buf),buf);
        }
    }
}