SonoffDeviceManager.h

#pragma once

#include <map>

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

#include "core/DeviceManager.h"
#include "model/DeviceID.h"
#include "net/MqttClient.h"
#include "sonoff/SonoffDevice.h"

namespace BeeeOn {

class SonoffDeviceManager : public DeviceManager {
public:
        SonoffDeviceManager();

        void run() override;
        void stop() override;
        void setMqttClient(MqttClient::Ptr mqttClient);
        void setMaxLastSeen(const Poco::Timespan &timeout);

protected:
        AsyncWork<>::Ptr startDiscovery(const Poco::Timespan &timeout) override;
        AsyncWork<std::set<DeviceID>>::Ptr startUnpair(
                const DeviceID &id,
                const Poco::Timespan &) override;
        void handleAccept(const DeviceAcceptCommand::Ptr cmd) override;

        void processMQTTMessage(const MqttMessage &message);

        std::pair<DeviceID, std::string> retrieveDeviceInfo(const std::string &message) const;

        void createNewDevice(const std::pair<DeviceID, std::string>& deviceInfo);

private:
        Poco::FastMutex m_devicesMutex;
        std::map<DeviceID, SonoffDevice::Ptr> m_devices;

        MqttClient::Ptr m_mqttClient;
        Poco::Timespan m_maxLastSeen;
};
}