bigdataparser.h

Go to the documentation of this file.

/*
 * Copyright (C) 2021-2025 QuasarApp.
 * Distributed under the lgplv3 software license, see the accompanying
 * Everyone is permitted to copy and distribute verbatim copies
 * of this license document, but changing it is not allowed.
*/
 
 
#ifndef BIGDATAPARSER_H
#define BIGDATAPARSER_H
 
#include <iparser.h>
 
 
namespace QH {
 
namespace PKG {
class BigDataHeader;
class BigDataPart;
class BigDataRequest;
class BigDataWraper;
}
 
class AbstractNode;
class AbstractNodeInfo;
 
struct PoolData {
    QSharedPointer<PKG::BigDataHeader> header;
    QVector<QSharedPointer<PKG::BigDataPart>> chaindata;
    int lastUpdate = time(0);
};

class BigDataParser: public iParser
{
public:
    BigDataParser(AbstractNode* parentNode);
 
    ParserResult parsePackage(const QSharedPointer<PKG::AbstractData> &pkg,
                              const Header &pkgHeader,
                              AbstractNodeInfo *sender) override;
    int version() const override;
    QString parserId() const override;
 
protected:

    bool newPackage(const QSharedPointer<PKG::BigDataHeader> &header,
                    AbstractNodeInfo * sender,
                    const Header & pkgHeader);

    bool processPart(const QSharedPointer<PKG::BigDataPart>& part,
                     AbstractNodeInfo *sender,
                     const QH::Header &pkgHeader);

    bool processRequest(const QSharedPointer<PKG::BigDataRequest>& request,
                        QH::AbstractNodeInfo *sender,
                        const QH::Header &pkgHeader);

    bool processBigDataWraper(const QSharedPointer<PKG::BigDataWraper> &request,
                              AbstractNodeInfo *sender,
                              const Header &pkgHeader);
 
 
private:

     bool sendBigDataPackage(const PKG::AbstractData *data,
                             const QH::AbstractNodeInfo *sender,
                             const Header *pkgHeader);
 
    void insertNewBigData(const QSharedPointer<PKG::BigDataHeader> &header);
    void checkOutDatedPacakges(unsigned int currentProcessedId);
 
    QHash<int, PoolData> _pool;
 
};
}
#endif // BIGDATAPARSER_H