lifetime.h

#pragma once
 
//
// Copyright (c) 2019-2023 Ivan Baidakou (basiliscos) (the dot dmol at gmail dot com)
//
// Distributed under the MIT Software License
//
 
#include "plugin_base.h"
 
namespace rotor::plugin {

struct ROTOR_API lifetime_plugin_t : public plugin_base_t {
    using plugin_base_t::plugin_base_t;

    static const std::type_index class_identity;
 
    const std::type_index &identity() const noexcept override;
 
    void activate(actor_base_t *actor) noexcept override;
    void deactivate() noexcept override;

    void initate_subscription(const subscription_info_ptr_t &info) noexcept;

    void unsubscribe(const handler_ptr_t &h, const address_ptr_t &addr) noexcept;

    void unsubscribe(const subscription_info_ptr_t &info) noexcept;

    virtual void on_subscription(message::subscription_t &) noexcept;

    virtual void on_unsubscription(message::unsubscription_t &) noexcept;

    virtual void on_unsubscription_external(message::unsubscription_external_t &) noexcept;
 
    bool handle_unsubscription(const subscription_point_t &point, bool external) noexcept override;
 
    bool handle_shutdown(message::shutdown_request_t *message) noexcept override;

    template <typename T> auto &access() noexcept;
 
  private:
    void unsubscribe() noexcept;

    subscription_container_t points;
 
    bool ready_to_shutdown() noexcept;
};
 
} // namespace rotor::plugin