#include "rmappluginpythonwrapper.h"
#include <math.h>
#include <QApplication>

rmappluginPythonWrapper::rmappluginPythonWrapper(lppmonplugin *parent) :
    genericPySysdriver(parent)
{
    timer = new QTimer;
    timer->setSingleShot(true);
    connect(timer, SIGNAL(timeout()), this, SLOT(sendTC()));
    connect(this, SIGNAL(activateTCLoopSig()), this, SLOT(sendTCLoop()));
}

QList<QVariant> rmappluginPythonWrapper::ReadSPW(unsigned int size) // size is not used
{
    QList<QVariant> result;
    TMPacketToRead *ccsdsPacket;

    if (!ccsdsPacketStore->isEmpty())
    {
        ccsdsPacket = ccsdsPacketStore->takeFirst();
        for(unsigned int i = 0;i<ccsdsPacket->size;i++)
        {
            result.append((QVariant)ccsdsPacket->Value[i]);
        }
        delete(ccsdsPacket);
    }
    emit nbPacketHasChanged(ccsdsPacketStore->size());
    return result;
}

void rmappluginPythonWrapper::WriteSPW(QList<int> dataList)
{
    char targetLogicalAddress;
    char userApplication;
    unsigned int count;
    char *Value;

    unsigned char data[dataList.count()];

    for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char
    {
        data[i] = (unsigned char)dataList.at(i);
    }
    // read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters
    targetLogicalAddress = data[0];
    userApplication = data[3];

    count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON
    Value = (char*) &data[4];

    emit WriteSPWSig(Value, count, targetLogicalAddress, userApplication);
}

void rmappluginPythonWrapper::WriteSPWDelay(QList<int> dataList, unsigned int delay)
{
    char targetLogicalAddress;
    char userApplication;
    unsigned int count;
    char *Value;
    TCPacketToSend *packet;

    unsigned char data[dataList.count()];

    for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char
    {
        data[i] = (unsigned char)dataList.at(i);
    }
    // read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters
    targetLogicalAddress = data[0];
    userApplication = data[3];

    count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON
    Value = (char*) &data[4];

    packet = new TCPacketToSend(Value, count, targetLogicalAddress, userApplication, delay);
    TCPacketStore.append(packet);

    emit(activateTCLoopSig());

}

void rmappluginPythonWrapper::processPacketStoreLater(unsigned int delay)
{
    emit sendMessage(
                "*** process packet store in " + QString::number(delay) + " ms"
                );
    QTimer::singleShot(delay, this, SLOT(sendProcessPacketStoreNowSig()));
}

void rmappluginPythonWrapper::sendTCLoop()
{
    unsigned int delay;

    if (!timer->isActive())
    {
        if (!TCPacketStore.isEmpty())
        {
            delay = TCPacketStore.at(0)->delay;
            timer->setInterval(delay);
            timer->start();
        }
    }
}

void rmappluginPythonWrapper::sendTC()
{
    TCPacketToSend *packet;
    unsigned int delay;

    packet = TCPacketStore.takeFirst();
    // the signal is connected with the option Qt::DirectConnection, thus it is processed immediately
    emit(WriteSPWSig(packet->Value, packet->count,packet->targetLogicalAddress, packet->userApplication));
    delete(packet);
    if (!TCPacketStore.isEmpty())
    {
        delay = TCPacketStore.at(0)->delay;
        timer->setInterval(delay);
        timer->start();
    }
}

void rmappluginPythonWrapper::processPacketStore()
{
    emit ccsdsPacketIsAvailable(ccsdsPacketStore->at(0)->size);
}

void rmappluginPythonWrapper::setTargetAddressValue(unsigned int address)
{
    unsigned char newAddress;
    newAddress = (unsigned char) address;
    emit updateTargetAddress(newAddress);
}

void rmappluginPythonWrapper::setSourceAddressValue(unsigned int address)
{
    unsigned char newAddress;
    newAddress = (unsigned char) address;
    emit updateSourceAddress(newAddress);
}

void rmappluginPythonWrapper::ProcessPendingEvents()
{
    QCoreApplication::processEvents();
}