NonBlockingNotificationRegistration3Base.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//

#pragma once

#include "Arp/System/Core/PimplPtr.hxx"
#include "Arp/System/Nm/NonBlockingNotificationRegistration3ArgumentsBufferBase.hpp"
#include "Arp/System/Nm/NonBlockingNotificationSendingAdapter.hpp"

namespace Arp { namespace System { namespace Nm
{

class NonBlockingNotificationRegistration3Base
{
protected:
    explicit NonBlockingNotificationRegistration3Base(
        std::unique_ptr<NonBlockingNotificationSendingAdapter> notificationSending);
    ~NonBlockingNotificationRegistration3Base();

public:
    NonBlockingNotificationRegistration3Base(const NonBlockingNotificationRegistration3Base& other) = delete;
    NonBlockingNotificationRegistration3Base(NonBlockingNotificationRegistration3Base&& other) noexcept;

    NonBlockingNotificationRegistration3Base& operator=(const NonBlockingNotificationRegistration3Base& other) = delete;
    NonBlockingNotificationRegistration3Base& operator=(NonBlockingNotificationRegistration3Base&& other) noexcept;

protected:
    bool HasImpl() const;

    NotificationNameIdType GetNotificationNameIdInternal() const;

    const Future<NotificationIdType>& GetFutureNotificationId() const;
    void ResetFutureNotificationId();

protected:
    void Register(
        const String& notificationName, const String& senderName, Severity severity, PayloadTypeIdType payloadTypeId);
    void Unregister();
    void SendNotificationInternal(const DateTime& timestamp,
                                  std::shared_ptr<NonBlockingNotificationRegistration3ArgumentsBufferBase> argumentsBuffer,
                                  NonBlockingNotificationRegistration3ArgumentsBufferBase::InsertResult argumentsBufferInsertResult,
                                  NonBlockingNotificationSendingAdapter::CreatePayloadFunctor createPayloadFunctor);

    bool IsReadyToSend() const;

public:
    bool IsCompleted() const;

    NotificationIdType GetLastNotificationId() const;

private:
    class Impl;
    using Pimpl = PimplPtr<Impl, false>;
    Pimpl pimpl;
};

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