hook_runtime.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/hook_outbox.h>
 
#include <atomic>
#include <chrono>
#include <memory>
#include <optional>
#include <string>
 
namespace neograph::graph { class CancelToken; }
 
namespace neograph {
 
class NEOGRAPH_API HookRuntime final {
public:
    explicit HookRuntime(std::shared_ptr<MandatoryHookRunner> runner,
                         std::chrono::milliseconds default_timeout = std::chrono::seconds(30));
 
    [[nodiscard]] static std::shared_ptr<HookRuntime> compose(std::shared_ptr<HookRuntime> outer,
                                                              std::shared_ptr<HookRuntime> inner);
 
    asio::awaitable<void> emit_async(HookPhase phase, std::string type,
                                       std::string owner_scope, std::string run_id, json data,
                                       std::shared_ptr<graph::CancelToken> cancellation = {},
                                       std::optional<std::chrono::system_clock::time_point> parent_deadline = {},
                                       std::optional<std::uint64_t> event_sequence = {});
 
    asio::awaitable<void> emit_once_async(HookPhase phase, std::string type,
                                            std::string owner_scope, std::string run_id,
                                            json data,
                                            std::shared_ptr<graph::CancelToken> cancellation = {},
                                            std::optional<std::chrono::system_clock::time_point> parent_deadline = {});
 
    [[nodiscard]] static bool executing_hook_target() noexcept;
 
private:
    HookRuntime(std::shared_ptr<HookRuntime> outer, std::shared_ptr<HookRuntime> inner);
 
    std::shared_ptr<MandatoryHookRunner> runner_;
    std::chrono::milliseconds default_timeout_;
    std::atomic<std::uint64_t> next_sequence_{0};
    std::shared_ptr<HookRuntime> outer_;
    std::shared_ptr<HookRuntime> inner_;
};
 
} // namespace neograph