#ifndef SPWPACKETRECEIVER_H
#define SPWPACKETRECEIVER_H

#include <QSemaphore>
#include <QTcpSocket>

#define READ_WRITE_MAX_COUNTS 4096                      // in words
#define RMAP_MAX_DATA_LENGTH 4*READ_WRITE_MAX_COUNTS    // in bytes, shall be lower than the limit size of SPW packet of the GRESB bridge
#define RMAP_READ_REPLY_HEADER_LENGTH 12                // in bytes => ECSS
#define RMAP_READ_COMMAND_HEADER_LENGTH 16              // in bytes => ECSS
#define RMAP_DATA_CRC_LENGTH 1                          // in bytes => ECSS
#define RMAP_MAX_PACKET_LENGTH RMAP_READ_REPLY_HEADER_LENGTH + RMAP_MAX_DATA_LENGTH + RMAP_DATA_CRC_LENGTH
#define CCSDS_MAX_PACKET_LENGTH 4412                    // in bytes, specified in the LFR Software Requirements Specification

class spwpacketreceiver : public QObject
{
     Q_OBJECT
public:
    explicit spwpacketreceiver(QObject *parent = 0);
    ~spwpacketreceiver();
    int fetchRMAPPacket();
    void acquireRMAPSemaphore();
    void acquireCCSDSSemaphore();
    bool isRMAPPacketSemaphoreAvailable();

    unsigned char* ccsdsPacket;
    char* rmapPacket;
    char* spwPacket;
    unsigned int rmapPacketSize;
    unsigned int ccsdsPacketSize;
    QSemaphore* rmapPacketSEMAPHORE;
    QSemaphore* ccsdsPacketSEMAPHORE;
    QTcpSocket* gresbReceptionSocket;

public slots:
    int receiveSPWPacket(unsigned char requestID = 0); // request ID by default is 0 for CCSDS
    void processCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size);

signals:
    void ccsdsPacketAvailable(unsigned char* ccsdsPacket, unsigned int size);
    void sendMessage(QString message);
};

#endif // SPWPACKETRECEIVER_H