core_provider_call.h

#pragma once
 
#include <neograph/api.h>
#include <neograph/graph/provider_call_broker.h>
 
#include <cstdint>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
#include <utility>
#include <vector>
 
namespace neograph::program {
 
class ProgramMonetaryAccount;
 
struct ProgramCoreProviderCallReplaySource {
    std::string run_id;
    std::string program_version_id;
    std::vector<std::pair<std::string, std::string>> threads;
    std::uint64_t max_attempt = 0;
    bool may_resend = false;
};
 
struct ProgramCoreProviderCallDiagnostic {
    std::string code;
    std::string message;
    json        witness;
};
 
struct ProgramCoreProviderCallContext {
    std::string_view owner_scope;
    std::string_view program_version_id;
    std::string_view run_id;
    std::string_view operation_id;
    std::uint64_t attempt = 0;
    std::shared_ptr<ProgramMonetaryAccount> monetary_account;
    std::shared_ptr<UsageAccumulator> journaled_usage;
    std::optional<ProgramCoreProviderCallReplaySource> replay_source;
    std::function<void(ProgramCoreProviderCallDiagnostic)> diagnostic;
};
 
struct ProgramCoreProviderCallBinding {
    std::string owner_scope;
    std::string program_version_id;
    std::string run_id;
    std::string operation_id;
    std::uint64_t attempt = 0;
    std::shared_ptr<graph::ProviderCallBroker> broker;
};
 
using ProgramCoreProviderCallResolver = std::function<
    std::optional<ProgramCoreProviderCallBinding>(
        const ProgramCoreProviderCallContext&)>;
 
NEOGRAPH_PROGRAM_API ProgramCoreProviderCallBinding bind_priced_provider_call(
    const ProgramCoreProviderCallContext& context);
 
}  // namespace neograph::program