20#ifndef ORES_ORE_API_MESSAGING_ORE_IMPORT_ENGINE_PROTOCOL_HPP
21#define ORES_ORE_API_MESSAGING_ORE_IMPORT_ENGINE_PROTOCOL_HPP
26#include "ores.ore.api/messaging/ore_import_protocol.hpp"
28namespace ores::ore::messaging {
42 static constexpr std::string_view nats_subject =
"ore.v1.ore.import.execute";
46 std::string correlation_id;
59 std::string correlation_id;
60 std::vector<ore_import_item_error> item_errors;
61 std::vector<std::string> saved_currency_iso_codes;
62 std::vector<std::string> saved_portfolio_ids;
63 std::vector<std::string> saved_book_ids;
64 std::vector<std::string> saved_trade_ids;
75 static constexpr std::string_view nats_subject =
"ore.v1.ore.import.rollback";
77 std::string correlation_id;
79 std::vector<std::string> saved_currency_iso_codes;
80 std::vector<std::string> saved_portfolio_ids;
81 std::vector<std::string> saved_book_ids;
82 std::vector<std::string> saved_trade_ids;
Workflow step command: execute the full ORE import.
Definition ore_import_engine_protocol.hpp:41
std::string bearer_token
Caller's JWT — used for delegated NATS calls.
Definition ore_import_engine_protocol.hpp:47
std::string import_choices_json
JSON-serialised import_choices.
Definition ore_import_engine_protocol.hpp:45
std::string request_id
UUID; storage key root for the tarball.
Definition ore_import_engine_protocol.hpp:44
Internal result stored as workflow_step.response_json for step 0.
Definition ore_import_engine_protocol.hpp:56
Workflow compensation command: roll back a completed ORE import.
Definition ore_import_engine_protocol.hpp:74
std::string bearer_token
Caller's JWT — used for delegated NATS calls.
Definition ore_import_engine_protocol.hpp:78