endpoints_services_addon.cpp

Go to the documentation of this file.

#include "endpoints_parameters.h"

#include <opc/ua/server/addons/endpoints_services.h>

#include <opc/common/addons_core/addon_manager.h>
#include <opc/ua/server/addons/services_registry.h>
#include <opc/ua/services/endpoints.h>

using namespace OpcUa;
using namespace OpcUa::Server;


namespace
{

class EndpointsAddon : public Common::Addon, public EndpointsRegistry
{
public:
  virtual void Initialize(Common::AddonsManager & addons, const Common::AddonParameters & params) override
  {
    Logger = addons.GetLogger();
    ApplyAddonParameters(params);

    Endpoints = OpcUa::Server::CreateEndpointsRegistry();
    InternalServer = addons.GetAddon<ServicesRegistry>(ServicesRegistryAddonId);
    InternalServer->RegisterEndpointsServices(Endpoints);

    const std::vector<OpcUa::Server::ApplicationData> & data = OpcUa::ParseEndpointsParameters(params.Groups, Logger);

    for (const OpcUa::Server::ApplicationData & application : data)
      {
        Endpoints->AddApplications(std::vector<OpcUa::ApplicationDescription>(1, application.Application));
        Endpoints->AddEndpoints(application.Endpoints);
      }
  }

  virtual void Stop() override
  {
    InternalServer->UnregisterEndpointsServices();
    InternalServer.reset();
    Endpoints.reset();
  }

  virtual void AddEndpoints(const std::vector<EndpointDescription> & endpoints) override
  {
    Endpoints->AddEndpoints(endpoints);
  }

  virtual void AddApplications(const std::vector<OpcUa::ApplicationDescription> & applications) override
  {
    Endpoints->AddApplications(applications);
  }


  virtual std::vector<ApplicationDescription> FindServers(const FindServersParameters & params) const override
  {
    return Endpoints->FindServers(params);
  }

  virtual std::vector<EndpointDescription> GetEndpoints(const GetEndpointsParameters & filter) const override
  {
    return Endpoints->GetEndpoints(filter);
  }

  virtual void RegisterServer(const ServerParameters & parameters) override
  {
    Endpoints->RegisterServer(parameters);
  }

private:
  void ApplyAddonParameters(const Common::AddonParameters & addons)
  {
    /*
    for (const Common::Parameter parameter : addons.Parameters)
      {
        if (parameter.Name == "debug" && !parameter.Value.empty() && parameter.Value != "0")
          {
            Debug = true;
          }
      }
     */
  }

private:
  EndpointsRegistry::SharedPtr Endpoints;
  ServicesRegistry::SharedPtr InternalServer;
  Common::Logger::SharedPtr Logger;
};

} // namespace


namespace OpcUa
{
namespace Server
{
Common::Addon::UniquePtr EndpointsRegistryAddonFactory::CreateAddon()
{
  return Common::Addon::UniquePtr(new ::EndpointsAddon());
}
}
}