subscription.hpp

Go to the documentation of this file.

#ifndef IROHA_SUBSCRIPTION_HPP
#define IROHA_SUBSCRIPTION_HPP

#include <memory>

#include "common/common.hpp"
#include "main/subscription_fwd.hpp"
#include "subscription/subscriber_impl.hpp"
#include "subscription/subscription_manager.hpp"

namespace iroha {
  std::shared_ptr<Dispatcher> getDispatcher();
  std::shared_ptr<Subscription> getSubscription();

  template <typename ObjectType, typename EventData>
  struct SubscriberCreator {
    template <EventTypes key, typename F, typename... Args>
    static auto create(SubscriptionEngineHandlers tid,
                       F &&callback,
                       Args &&... args) {
      auto subscriber = BaseSubscriber<ObjectType, EventData>::create(
          getSubscription()->getEngine<EventTypes, EventData>(),
          std::forward<Args>(args)...);
      subscriber->setCallback(
          [f{std::forward<F>(callback)}](auto /*set_id*/,
                                         auto &object,
                                         auto event_key,
                                         EventData args) mutable {
            assert(key == event_key);
            std::forward<F>(f)(object, std::move(args));
          });
      subscriber->subscribe(0, key, tid);
      return subscriber;
    }
  };
}  // namespace iroha

#endif  // IROHA_SUBSCRIPTION_HPP