wsdb_handlers.cpp File Reference

Per-command handlers consumed by the codegen-emitted server dispatch. More...

#include "barretenberg/wsdb/wsdb_handlers.hpp"
#include "barretenberg/crypto/merkle_tree/indexed_tree/indexed_leaf.hpp"
#include "barretenberg/crypto/merkle_tree/response.hpp"
#include "barretenberg/world_state/world_state.hpp"
#include "barretenberg/wsdb/wsdb_schedule.hpp"
#include "barretenberg/wsdb/wsdb_wire_convert.hpp"
#include <optional>
#include <stdexcept>

Go to the source code of this file.

Namespaces
namespace	bb
	Entry point for Barretenberg command-line interface.
namespace	bb::wsdb

Functions
void	bb::wsdb::handle_get_tree_info (WsdbRequest &ctx, wire::WsdbGetTreeInfo &&cmd, Responder< wire::WsdbGetTreeInfoResponse > respond)
void	bb::wsdb::handle_get_state_reference (WsdbRequest &ctx, wire::WsdbGetStateReference &&cmd, Responder< wire::WsdbGetStateReferenceResponse > respond)
void	bb::wsdb::handle_get_initial_state_reference (WsdbRequest &ctx, wire::WsdbGetInitialStateReference &&, Responder< wire::WsdbGetInitialStateReferenceResponse > respond)
void	bb::wsdb::handle_get_leaf_value (WsdbRequest &ctx, wire::WsdbGetLeafValue &&cmd, Responder< wire::WsdbGetLeafValueResponse > respond)
void	bb::wsdb::handle_get_public_data_leaf_value (WsdbRequest &ctx, wire::WsdbGetPublicDataLeafValue &&cmd, Responder< wire::WsdbGetPublicDataLeafValueResponse > respond)
void	bb::wsdb::handle_get_nullifier_leaf_value (WsdbRequest &ctx, wire::WsdbGetNullifierLeafValue &&cmd, Responder< wire::WsdbGetNullifierLeafValueResponse > respond)
void	bb::wsdb::handle_get_public_data_leaf_preimage (WsdbRequest &ctx, wire::WsdbGetPublicDataLeafPreimage &&cmd, Responder< wire::WsdbGetPublicDataLeafPreimageResponse > respond)
void	bb::wsdb::handle_get_nullifier_leaf_preimage (WsdbRequest &ctx, wire::WsdbGetNullifierLeafPreimage &&cmd, Responder< wire::WsdbGetNullifierLeafPreimageResponse > respond)
void	bb::wsdb::handle_get_sibling_path (WsdbRequest &ctx, wire::WsdbGetSiblingPath &&cmd, Responder< wire::WsdbGetSiblingPathResponse > respond)
void	bb::wsdb::handle_get_block_numbers_for_leaf_indices (WsdbRequest &ctx, wire::WsdbGetBlockNumbersForLeafIndices &&cmd, Responder< wire::WsdbGetBlockNumbersForLeafIndicesResponse > respond)
void	bb::wsdb::handle_find_leaf_indices (WsdbRequest &ctx, wire::WsdbFindLeafIndices &&cmd, Responder< wire::WsdbFindLeafIndicesResponse > respond)
void	bb::wsdb::handle_find_public_data_leaf_indices (WsdbRequest &ctx, wire::WsdbFindPublicDataLeafIndices &&cmd, Responder< wire::WsdbFindPublicDataLeafIndicesResponse > respond)
void	bb::wsdb::handle_find_nullifier_leaf_indices (WsdbRequest &ctx, wire::WsdbFindNullifierLeafIndices &&cmd, Responder< wire::WsdbFindNullifierLeafIndicesResponse > respond)
void	bb::wsdb::handle_find_low_leaf (WsdbRequest &ctx, wire::WsdbFindLowLeaf &&cmd, Responder< wire::WsdbFindLowLeafResponse > respond)
void	bb::wsdb::handle_find_sibling_paths (WsdbRequest &ctx, wire::WsdbFindSiblingPaths &&cmd, Responder< wire::WsdbFindSiblingPathsResponse > respond)
void	bb::wsdb::handle_find_public_data_sibling_paths (WsdbRequest &ctx, wire::WsdbFindPublicDataSiblingPaths &&cmd, Responder< wire::WsdbFindPublicDataSiblingPathsResponse > respond)
void	bb::wsdb::handle_find_nullifier_sibling_paths (WsdbRequest &ctx, wire::WsdbFindNullifierSiblingPaths &&cmd, Responder< wire::WsdbFindNullifierSiblingPathsResponse > respond)
void	bb::wsdb::handle_append_leaves (WsdbRequest &ctx, wire::WsdbAppendLeaves &&cmd, Responder< wire::WsdbAppendLeavesResponse > respond)
void	bb::wsdb::handle_append_public_data_leaves (WsdbRequest &ctx, wire::WsdbAppendPublicDataLeaves &&cmd, Responder< wire::WsdbAppendPublicDataLeavesResponse > respond)
void	bb::wsdb::handle_append_nullifier_leaves (WsdbRequest &ctx, wire::WsdbAppendNullifierLeaves &&cmd, Responder< wire::WsdbAppendNullifierLeavesResponse > respond)
void	bb::wsdb::handle_batch_insert_public_data (WsdbRequest &ctx, wire::WsdbBatchInsertPublicData &&cmd, Responder< wire::WsdbBatchInsertPublicDataResponse > respond)
void	bb::wsdb::handle_batch_insert_nullifier (WsdbRequest &ctx, wire::WsdbBatchInsertNullifier &&cmd, Responder< wire::WsdbBatchInsertNullifierResponse > respond)
void	bb::wsdb::handle_sequential_insert_public_data (WsdbRequest &ctx, wire::WsdbSequentialInsertPublicData &&cmd, Responder< wire::WsdbSequentialInsertPublicDataResponse > respond)
void	bb::wsdb::handle_sequential_insert_nullifier (WsdbRequest &ctx, wire::WsdbSequentialInsertNullifier &&cmd, Responder< wire::WsdbSequentialInsertNullifierResponse > respond)
void	bb::wsdb::handle_update_archive (WsdbRequest &ctx, wire::WsdbUpdateArchive &&cmd, Responder< wire::WsdbUpdateArchiveResponse > respond)
void	bb::wsdb::handle_commit (WsdbRequest &ctx, wire::WsdbCommit &&, Responder< wire::WsdbCommitResponse > respond)
void	bb::wsdb::handle_rollback (WsdbRequest &ctx, wire::WsdbRollback &&, Responder< wire::WsdbRollbackResponse > respond)
void	bb::wsdb::handle_sync_block (WsdbRequest &ctx, wire::WsdbSyncBlock &&cmd, Responder< wire::WsdbSyncBlockResponse > respond)
void	bb::wsdb::handle_create_fork (WsdbRequest &ctx, wire::WsdbCreateFork &&cmd, Responder< wire::WsdbCreateForkResponse > respond)
void	bb::wsdb::handle_delete_fork (WsdbRequest &ctx, wire::WsdbDeleteFork &&cmd, Responder< wire::WsdbDeleteForkResponse > respond)
void	bb::wsdb::handle_finalize_blocks (WsdbRequest &ctx, wire::WsdbFinalizeBlocks &&cmd, Responder< wire::WsdbFinalizeBlocksResponse > respond)
void	bb::wsdb::handle_unwind_blocks (WsdbRequest &ctx, wire::WsdbUnwindBlocks &&cmd, Responder< wire::WsdbUnwindBlocksResponse > respond)
void	bb::wsdb::handle_remove_historical_blocks (WsdbRequest &ctx, wire::WsdbRemoveHistoricalBlocks &&cmd, Responder< wire::WsdbRemoveHistoricalBlocksResponse > respond)
void	bb::wsdb::handle_get_status (WsdbRequest &ctx, wire::WsdbGetStatus &&, Responder< wire::WsdbGetStatusResponse > respond)
void	bb::wsdb::handle_create_checkpoint (WsdbRequest &ctx, wire::WsdbCreateCheckpoint &&cmd, Responder< wire::WsdbCreateCheckpointResponse > respond)
void	bb::wsdb::handle_commit_checkpoint (WsdbRequest &ctx, wire::WsdbCommitCheckpoint &&cmd, Responder< wire::WsdbCommitCheckpointResponse > respond)
void	bb::wsdb::handle_revert_checkpoint (WsdbRequest &ctx, wire::WsdbRevertCheckpoint &&cmd, Responder< wire::WsdbRevertCheckpointResponse > respond)
void	bb::wsdb::handle_commit_all_checkpoints (WsdbRequest &ctx, wire::WsdbCommitAllCheckpoints &&cmd, Responder< wire::WsdbCommitAllCheckpointsResponse > respond)
void	bb::wsdb::handle_revert_all_checkpoints (WsdbRequest &ctx, wire::WsdbRevertAllCheckpoints &&cmd, Responder< wire::WsdbRevertAllCheckpointsResponse > respond)
void	bb::wsdb::handle_copy_stores (WsdbRequest &ctx, wire::WsdbCopyStores &&cmd, Responder< wire::WsdbCopyStoresResponse > respond)

Detailed Description

Per-command handlers consumed by the codegen-emitted server dispatch.

Each handler matches the signature declared by generated/wsdb_dispatch.hpp but as a non-template overload for WsdbRequest so the codegen's make_wsdb_handler<WsdbRequest> instantiation resolves to these definitions via overload resolution (preferred over the unspecialized template).

Handlers are asynchronous: each declares its own ordering by calling schedule_read (concurrent; committed reads bypass ordering) or schedule_write (exclusive on its fork), passing the fork it touches and a lambda that does the work and returns the typed response. The helper runs that lambda on the scheduler (inline when idle, else a pool thread) and turns the return value into respond.ok(...) or a thrown exception into respond.error(...). Wire <-> domain conversion happens inside the lambda via wsdb_wire_convert.hpp.

Definition in file wsdb_handlers.cpp.