comAdptEnvision.hpp

Go to the documentation of this file.

 
#ifndef CCF_PROTOCOLS_COM_ADPT_ENVISION_HPP_H_
#define CCF_PROTOCOLS_COM_ADPT_ENVISION_HPP_H_
 
#include "ifw/core/protocol/open62541/open62541.hpp"
 
#include <ifw/ccf/protocols/rtms/comAdptRtms.hpp>
 
 
namespace ifw::ccf::protocols::envision {
 
    constexpr auto DEV_PROP_OPCUA_OBJECT     = "OpcUaObject";
    constexpr auto DEV_PROP_OPCUA_NS         = "OpcUaNs";

  class ComAdptEnvision: public ifw::ccf::protocols::rtms::ComAdptRtms {
  public:
 
    ComAdptEnvision();
    virtual ~ComAdptEnvision();

    virtual void InitialiseUser() override;

    virtual void SetDeviceAddressUser(const std::string& address) override;

    virtual void CheckConnectionUser(bool& connected) override;

    virtual void CheckStatusUser(ifw::ccf::HwStatus& status,
                                 std::string& message) override;

    virtual void ConnectUser() override;

    virtual void DisconnectUser() override;

    virtual void ReceiveUser(ifw::ccf::common::DataFrame& frame,
                             bool& frame_received,
                             const double timeout,
                             bool& timed_out) override;

    virtual void ReadUser(const std::string& name,
                          ifw::core::utils::param::Parameter& par) override;

    virtual void ScanUser(std::vector<ifw::core::utils::param::Parameter>& pars) override;

    virtual void StartUser() override;

    virtual void StopUser() override;

    virtual void WriteUser(const ifw::core::utils::param::Parameter& par) override;

    virtual void HandleParPreWriteUser(ifw::core::utils::param::Parameter& par) override;

    virtual void HandleParPostWriteUser(ifw::core::utils::param::Parameter& par) override;

    virtual void HandleParPostReadUser(ifw::core::utils::param::Parameter& par) override;

    virtual void HandleSetupUser() override;
 
  protected:
 
  private:
 
    void CheckErrTryReconnect(const std::string& action,
                              const std::string& err);
 
    void WriteOpcUa(const ifw::core::utils::param::Parameter& par);
 
    ifw::fnd::datatype::DataType GetNodeType(const std::string& low_level_name);
 
    void CoreParToPairVariant(const ifw::core::utils::param::Parameter& par,
                              ifw::core::protocol::base::PairVariant& variant_par,
                              ifw::fnd::datatype::DataType& data_type);
 
    //protocol::opcua::Open62541  m_opcua_client;
    std::unique_ptr<ifw::core::protocol::opcua::Open62541> m_opcua_client;
 
    // Name of object in OPC UA namespace, hosting the nodes for the device.
    std::string m_opcua_object;
 
    // Cache in which node values are updated to get access to the type.
    std::map<std::string, ifw::core::protocol::base::Variant> m_nodes_cache;
    std::map<std::string, ifw::fnd::datatype::DataType> m_node_types_cache;
 
    std::string         m_opcua_ns;
 
    double              m_expo_time;
 
    // Set to true when running (started), false when stopped.
    std::atomic<bool>   m_dev_acq_running{false};
 
    //UA_ServerConfig* m_open62541_config{nullptr};
    UA_Client* m_uaclient{nullptr};
    UA_ClientConfig* m_uaconfig{nullptr};
  };
 
}
 
#endif // CCF_PROTOCOLS_COM_ADPT_ENVISION_HPP_H_