delivery.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"
#include "../message_stringifier.h"
#include <string>
 
#if !defined(NDEBUG) && !defined(ROTOR_DEBUG_DELIVERY)
#define ROTOR_DO_DELIVERY_DEBUG 1
#endif
 
namespace rotor::plugin {
 
struct ROTOR_API local_delivery_t {
 
    static void delivery(message_ptr_t &message, const subscription_t::joint_handlers_t &local_recipients) noexcept;
};
 
struct ROTOR_API inspected_local_delivery_t {
 
    static void delivery(message_ptr_t &message, const subscription_t::joint_handlers_t &local_recipients,
                         const message_stringifier_t *stringifier) noexcept;
 
    static void discard(message_ptr_t &message, const message_stringifier_t *stringifier) noexcept;
};
 
#if !defined(ROTOR_DO_DELIVERY_DEBUG)
using default_local_delivery_t = local_delivery_t;
#else
using default_local_delivery_t = inspected_local_delivery_t;
#endif
 
struct ROTOR_API delivery_plugin_base_t : public plugin_base_t {
    using plugin_base_t::plugin_base_t;
 
    virtual size_t process() noexcept = 0;
    void activate(actor_base_t *actor) noexcept override;
 
  protected:
    messages_queue_t *queue = nullptr;
 
    address_t *address = nullptr;
 
    subscription_t *subscription_map;
 
    const message_stringifier_t *stringifier;
};
 
template <typename LocalDelivery = local_delivery_t> struct delivery_plugin_t : public delivery_plugin_base_t {
    using delivery_plugin_base_t::delivery_plugin_base_t;
 
    static const std::type_index class_identity;
 
    const std::type_index &identity() const noexcept override { return class_identity; }
 
    inline size_t process() noexcept override;
};
 
template <typename LocalDelivery>
const std::type_index delivery_plugin_t<LocalDelivery>::class_identity = typeid(local_delivery_t);
 
} // namespace rotor::plugin