VirtualDeviceManager.h

#pragma once

#include <queue>
#include <string>

#include <Poco/SharedPtr.h>
#include <Poco/Timestamp.h>
#include <Poco/Util/IniFileConfiguration.h>

#include "core/DeviceManager.h"
#include "core/PollingKeeper.h"
#include "vdev/VirtualDevice.h"

namespace BeeeOn {

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

        void setDevicePoller(DevicePoller::Ptr poller);

        void run() override;
        void stop() override;

        void setConfigFile(const std::string &path);

        void installVirtualDevices();

        void registerDevice(const VirtualDevice::Ptr virtualDevice);

        void dispatchNewDevice(VirtualDevice::Ptr device);

        VirtualDevice::Ptr parseDevice(
                Poco::AutoPtr<Poco::Util::AbstractConfiguration> cfg);

        VirtualModule::Ptr parseModule(
                Poco::AutoPtr<Poco::Util::AbstractConfiguration> cfg,
                const ModuleID &moduleID);

        void scheduleAllEntries();

        void logDeviceParsed(VirtualDevice::Ptr device);

        void handleRemoteStatus(
                const DevicePrefix &prefix,
                const std::set<DeviceID> &devices,
                const DeviceStatusHandler::DeviceValues &values) override;

protected:
        void handleGeneric(const Command::Ptr cmd, Result::Ptr result) override;

        void doListenCommand(const GatewayListenCommand::Ptr);

        void doDeviceAcceptCommand(const DeviceAcceptCommand::Ptr cmd);

        void doSetValueCommand(const DeviceSetValueCommand::Ptr cmd);

        void doUnpairCommand(const DeviceUnpairCommand::Ptr cmd);

private:
        std::map<DeviceID, VirtualDevice::Ptr> m_virtualDevicesMap;
        std::string m_configFile;
        PollingKeeper m_pollingKeeper;
        bool m_requestDeviceList;
        Poco::FastMutex m_lock;
};

}