subscription_service_addon.cpp

Go to the documentation of this file.

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

#include <opc/ua/server/addons/address_space.h>
#include <opc/ua/server/addons/asio_addon.h>
#include <opc/ua/server/addons/services_registry.h>
#include <opc/ua/server/address_space.h>
#include <opc/ua/server/subscription_service.h>

#include <iostream>

namespace
{

class SubscriptionAddon:
  public Common::Addon,
  public OpcUa::Server::SubscriptionService
{
public:
  void Initialize(Common::AddonsManager & manager, const Common::AddonParameters & parameters)
  {
    Logger = manager.GetLogger();
    ApplyAddonParameters(parameters);
    Services = manager.GetAddon<OpcUa::Server::ServicesRegistry>(OpcUa::Server::ServicesRegistryAddonId);
    OpcUa::Server::AddressSpace::SharedPtr addressSpace = manager.GetAddon<OpcUa::Server::AddressSpace>(OpcUa::Server::AddressSpaceRegistryAddonId);
    OpcUa::Server::AsioAddon::SharedPtr asio = manager.GetAddon<OpcUa::Server::AsioAddon>(OpcUa::Server::AsioAddonId);
    Subscriptions = OpcUa::Server::CreateSubscriptionService(addressSpace, asio->GetIoService(), Logger);
    Services->RegisterSubscriptionServices(Subscriptions);
  }

  void Stop()
  {
    Services->UnregisterSubscriptionServices();
    Subscriptions.reset();
    Services.reset();
  }

public:
  void TriggerEvent(OpcUa::NodeId node, OpcUa::Event event)
  {
    Subscriptions->TriggerEvent(node, event);
  }

public:
  OpcUa::SubscriptionData CreateSubscription(const OpcUa::CreateSubscriptionRequest & request, std::function<void (OpcUa::PublishResult)> callback)
  {
    return Subscriptions->CreateSubscription(request, callback);
  }

  OpcUa::ModifySubscriptionResponse ModifySubscription(const OpcUa::ModifySubscriptionParameters & parameters)
  {
    return Subscriptions->ModifySubscription(parameters);
  }

  std::vector<OpcUa::StatusCode> DeleteSubscriptions(const std::vector<uint32_t> & subscriptions)
  {
    return Subscriptions->DeleteSubscriptions(subscriptions);
  }

  void Publish(const OpcUa::PublishRequest & request)
  {
    Subscriptions->Publish(request);
  }

  OpcUa::RepublishResponse Republish(const OpcUa::RepublishParameters & request)
  {
    return Subscriptions->Republish(request);
  }

  std::vector<OpcUa::MonitoredItemCreateResult> CreateMonitoredItems(const OpcUa::MonitoredItemsParameters & parameters)
  {
    return Subscriptions->CreateMonitoredItems(parameters);
  }

  std::vector<OpcUa::StatusCode> DeleteMonitoredItems(const OpcUa::DeleteMonitoredItemsParameters & parameters)
  {
    return Subscriptions->DeleteMonitoredItems(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")
          {
            std::cout << "SubscriptionService | Debug mode enabled." << std::endl;
          }
      }
    */
  }

private:
  SubscriptionService::SharedPtr Subscriptions;
  OpcUa::Server::ServicesRegistry::SharedPtr Services;
  Common::Logger::SharedPtr Logger;
};

}

namespace OpcUa
{
namespace Server
{
Common::Addon::UniquePtr SubscriptionServiceAddonFactory::CreateAddon()
{
  return Common::Addon::UniquePtr(new SubscriptionAddon());
}
}
}