wsdb_execute.hpp

Go to the documentation of this file.

#pragma once
#include "barretenberg/common/named_union.hpp"
#include "barretenberg/world_state/world_state.hpp"
#include "barretenberg/wsdb/wsdb_commands.hpp"
 
namespace bb::wsdb {
 
struct WsdbRequest {
    world_state::WorldState& world_state;
};
 
struct WsdbErrorResponse {
    static constexpr const char MSGPACK_SCHEMA_NAME[] = "WsdbErrorResponse";
    std::string message;
    SERIALIZATION_FIELDS(message);
    bool operator==(const WsdbErrorResponse&) const = default;
};
 
using WsdbCommand = NamedUnion<WsdbGetTreeInfo,
                               WsdbGetStateReference,
                               WsdbGetInitialStateReference,
                               WsdbGetLeafValue,
                               WsdbGetLeafPreimage,
                               WsdbGetSiblingPath,
                               WsdbGetBlockNumbersForLeafIndices,
                               WsdbFindLeafIndices,
                               WsdbFindLowLeaf,
                               WsdbFindSiblingPaths,
                               WsdbAppendLeaves,
                               WsdbBatchInsert,
                               WsdbSequentialInsert,
                               WsdbUpdateArchive,
                               WsdbCommit,
                               WsdbRollback,
                               WsdbSyncBlock,
                               WsdbCreateFork,
                               WsdbDeleteFork,
                               WsdbFinalizeBlocks,
                               WsdbUnwindBlocks,
                               WsdbRemoveHistoricalBlocks,
                               WsdbGetStatus,
                               WsdbCreateCheckpoint,
                               WsdbCommitCheckpoint,
                               WsdbRevertCheckpoint,
                               WsdbCommitAllCheckpoints,
                               WsdbRevertAllCheckpoints,
                               WsdbCopyStores,
                               WsdbShutdown>;
 
using WsdbCommandResponse = NamedUnion<WsdbErrorResponse,
                                       WsdbGetTreeInfo::Response,
                                       WsdbGetStateReference::Response,
                                       WsdbGetInitialStateReference::Response,
                                       WsdbGetLeafValue::Response,
                                       WsdbGetLeafPreimage::Response,
                                       WsdbGetSiblingPath::Response,
                                       WsdbGetBlockNumbersForLeafIndices::Response,
                                       WsdbFindLeafIndices::Response,
                                       WsdbFindLowLeaf::Response,
                                       WsdbFindSiblingPaths::Response,
                                       WsdbAppendLeaves::Response,
                                       WsdbBatchInsert::Response,
                                       WsdbSequentialInsert::Response,
                                       WsdbUpdateArchive::Response,
                                       WsdbCommit::Response,
                                       WsdbRollback::Response,
                                       WsdbSyncBlock::Response,
                                       WsdbCreateFork::Response,
                                       WsdbDeleteFork::Response,
                                       WsdbFinalizeBlocks::Response,
                                       WsdbUnwindBlocks::Response,
                                       WsdbRemoveHistoricalBlocks::Response,
                                       WsdbGetStatus::Response,
                                       WsdbCreateCheckpoint::Response,
                                       WsdbCommitCheckpoint::Response,
                                       WsdbRevertCheckpoint::Response,
                                       WsdbCommitAllCheckpoints::Response,
                                       WsdbRevertAllCheckpoints::Response,
                                       WsdbCopyStores::Response,
                                       WsdbShutdown::Response>;
 
inline WsdbCommandResponse execute(WsdbRequest& request, WsdbCommand&& command)
{
    return std::move(command).visit([&request](auto&& cmd) -> WsdbCommandResponse {
        using CmdType = std::decay_t<decltype(cmd)>;
        return std::forward<CmdType>(cmd).execute(request);
    });
}
 
WsdbCommandResponse wsdb(WsdbRequest& request, WsdbCommand&& command);
 
} // namespace bb::wsdb