command_journal.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/api.h>
#include <neograph/program/command.h>
#include <neograph/program/result.h>
 
#include <cstdint>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
 
namespace neograph::program {
 
struct ProgramJavaScriptCommandJournalEntryData {
    std::uint64_t              sequence = 0;
    std::string                bundle_id;
    std::uint64_t              command_ordinal = 0;
    JavaScriptCommand          command = JavaScriptCommand::call_core(
        "journal:default", "journal:default", json::object());
    std::optional<std::string> effect_identity;
    std::optional<json>        terminal_result;
    std::optional<json>        settled_members;
    std::optional<json>        await_started_at;
};
 
class NEOGRAPH_PROGRAM_API ProgramJavaScriptCommandJournalEntry final {
public:
    static constexpr std::uint32_t STORAGE_SCHEMA_VERSION = 3;
 
    explicit ProgramJavaScriptCommandJournalEntry(
        ProgramJavaScriptCommandJournalEntryData data);
    static ProgramJavaScriptCommandJournalEntry parse(std::string_view stored_bytes);
 
    std::uint64_t              sequence() const noexcept;
    const std::string&         bundle_id() const noexcept;
    std::uint64_t              command_ordinal() const noexcept;
    const JavaScriptCommand&   command() const noexcept;
    std::optional<std::string> effect_identity() const;
    std::optional<json>        terminal_result() const;
    std::optional<json>        settled_members() const;
    std::optional<json>        await_started_at() const;
    bool                       pending() const noexcept;
    bool                       completed() const noexcept;
    const std::string&         coordinate_id() const noexcept;
    const std::string&         id() const noexcept;
    std::string                serialize_canonical() const;
 
private:
    struct Impl;
    explicit ProgramJavaScriptCommandJournalEntry(std::shared_ptr<const Impl> impl);
    std::shared_ptr<const Impl> impl_;
};
 
}  // namespace neograph::program