RecoverableJournalQueuingStrategy.h

#pragma once

#include "exporters/JournalQueuingStrategy.h"

namespace BeeeOn {

class RecoverableJournalQueuingStrategy : public JournalQueuingStrategy {
public:
        RecoverableJournalQueuingStrategy();

        void setDisableTmpDataRecovery(bool disable);

        void setDisableBrokenRecovery(bool disable);

        void setDisableLostRecovery(bool disable);

        void setup() override;

protected:
        void collectRecoverable(std::list<Poco::File> &files) const;

        size_t recoverEntries(
                Poco::File file,
                std::vector<SensorData> &data) const;

        std::string recoverBrokenBuffer(Poco::File file) const;

        std::string recoverBuffer(Poco::File tmpFile) const;

        void recoverTmpData(Poco::Timestamp &newest);

        void recoverBroken(
                const std::string &broken,
                Poco::Timestamp &newest);

        void recoverLost(
                std::list<Poco::File> &recoverable,
                const Poco::Timestamp &indexModified,
                const Poco::Timestamp &newest);

private:
        bool m_disableTmpDataRecovery;
        bool m_disableBrokenRecovery;
        bool m_disableLostRecovery;
};

}