FitpDeviceManager.h

#pragma once

#include <Poco/Mutex.h>
#include <Poco/SharedPtr.h>
#include <Poco/Timer.h>
#include <Poco/Timestamp.h>

#include <fitp/fitp.h>

#include "core/DeviceManager.h"
#include "core/GatewayInfo.h"
#include "fitp/FitpDevice.h"
#include "model/DeviceID.h"

namespace BeeeOn {

class FitpDeviceManager : public DeviceManager {
public:
        typedef Poco::SharedPtr<FitpDeviceManager> Ptr;
        typedef uint32_t EDID;

        FitpDeviceManager();
        ~FitpDeviceManager();

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

        void loadDeviceList();

        void setConfigPath(const std::string &configPath);

        void setNoiseMin(int min);

        void setNoiseMax(int max);

        void setBitrate(int bitrate);


        void setBand(int band);

        void setChannel(int channel);

        void setPower(int power);

        void setTxRetries(int retries);

        void setGatewayInfo(Poco::SharedPtr<GatewayInfo> info);

        void initFitp();

        static DeviceID buildID(EDID edid);

        static EDID deriveEDID(const DeviceID &id);

        EDID parseEDID(const std::vector<uint8_t> &id);

        void processDataMsg(const std::vector<uint8_t> &data);

        void processJoinMsg(const std::vector<uint8_t> &data);

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

        void doListenCommand(const GatewayListenCommand::Ptr cmd);

        void doDeviceAcceptCommand(const DeviceAcceptCommand::Ptr cmd);

        void doUnpairCommand(const DeviceUnpairCommand::Ptr cmd);

        void dispatchNewDevice(FitpDevice::Ptr device);

private:
        void stopListen(Poco::Timer &timer);
        int channelCnt();

private:
        std::map<DeviceID, FitpDevice::Ptr> m_devices;
        std::string m_configFile;
        PHY_init_t m_phyParams;
        LINK_init_t m_linkParams;
        bool m_listening;
        Poco::TimerCallback<FitpDeviceManager> m_listenCallback;
        Poco::Timer m_listenTimer;
        Poco::FastMutex m_lock;
        Poco::SharedPtr<GatewayInfo> m_gatewayInfo;
};

}