NotificationSubscriber.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//

#pragma once

#include "Arp/System/Core/event.hxx"
#include "Arp/System/Commons/Diagnostics/Logging/Loggable.hxx"
#include "Arp/System/Commons/Threading/Mutex.hpp"
#include "Arp/System/Nm/INotificationReceiving.hpp"
#include "Arp/System/Nm/INotificationSubscriber.hpp"

namespace Arp { namespace System { namespace Nm
{


class NotificationSubscriber
    : public INotificationSubscriber
    , Arp::System::Commons::Diagnostics::Logging::Loggable<NotificationSubscriber>
{
public:
    NotificationSubscriber() = default;

    ARP_DEPRECATED("Use NotificationSubscriber(notificationName) instead. notificationReceiving is ignored.")
    NotificationSubscriber(
        const String& notificationName, INotificationReceiving& notificationReceiving);

    explicit NotificationSubscriber(const String& notificationName);

    NotificationSubscriber(NotificationSubscriber&& other);
    ~NotificationSubscriber() override;

    NotificationSubscriber& operator=(NotificationSubscriber&& other);

    NotificationSubscriber(const NotificationSubscriber&) = delete;
    NotificationSubscriber& operator=(const NotificationSubscriber&) = delete;

    Arp::event<const Notification&> OnNotification;

    void Dispose() noexcept;

    void Notify(const Notification& notification) override;

    const String GetNotificationName() const;

    const NotificationNameIdType GetNotificationNameId() const;

private: // methods
    void Initialize();
    bool IsInitialized() const;
    void TranferSubscriptionFrom(NotificationSubscriber& other);

private: // fields

    // NotificationReceiving is not used any more. It will be removed in future versions.
    INotificationReceiving* NotificationReceiving = nullptr;

    String NotificationName;
    NotificationNameIdType NotificationNameId;

    // Mutex is not used any more. It will be removed in future versions.
    Arp::System::Commons::Threading::Mutex Mutex;
};

}}} // namespace Arp::System::Nm