GWSOptimisticExporter.h

#pragma once

#include <set>

#include <Poco/AtomicCounter.h>
#include <Poco/Mutex.h>

#include "core/Exporter.h"
#include "gwmessage/GWMessage.h"
#include "server/GWSConnector.h"
#include "server/GWSListener.h"
#include "util/Loggable.h"

namespace BeeeOn {

class GWSOptimisticExporter :
        public Exporter,
        public GWSListener,
        Loggable {
public:
        typedef Poco::SharedPtr<GWSOptimisticExporter> Ptr;

        GWSOptimisticExporter();

        void setConnector(GWSConnector::Ptr connector);
        void setExportNonConfirmed(int count);

        bool ship(const SensorData &data) override;

        void onOther(const GWMessage::Ptr message) override;

        void onConnected(const GWSListener::Address &) override;

        void onDisconnected(const GWSListener::Address &) override;

private:
        size_t m_exportNonConfirmed;
        GWSConnector::Ptr m_connector;
        Poco::AtomicCounter m_connected;
        std::set<GlobalID> m_exported;
        Poco::FastMutex m_lock;
};

}