avm_execute.hpp

Go to the documentation of this file.

#pragma once
#include "barretenberg/avm/avm_commands.hpp"
#include "barretenberg/cdb/cdb_ipc_client.hpp"
#include "barretenberg/common/named_union.hpp"
#include "barretenberg/vm2/simulation/lib/cancellation_token.hpp"
#include "barretenberg/wsdb/wsdb_ipc_client_generated.hpp"
 
#include <atomic>
 
namespace bb::avm {
 
// NOLINTNEXTLINE(cppcoreguidelines-avoid-non-const-global-variables)
extern std::atomic<avm2::simulation::CancellationToken*> g_active_cancellation_token;
 
struct AvmRequest {
    cdb::CdbIpcContractDB& cdb_client;
    wsdb::WsdbIpcClient& wsdb_client;
};
 
struct AvmErrorResponse {
    static constexpr const char MSGPACK_SCHEMA_NAME[] = "AvmErrorResponse";
    std::string message;
    SERIALIZATION_FIELDS(message);
    bool operator==(const AvmErrorResponse&) const = default;
};
 
using AvmCommand = NamedUnion<AvmSimulate, AvmSimulateWithHints, AvmShutdown>;
 
using AvmCommandResponse =
    NamedUnion<AvmErrorResponse, AvmSimulate::Response, AvmSimulateWithHints::Response, AvmShutdown::Response>;
 
inline AvmCommandResponse execute(AvmRequest& request, AvmCommand&& command)
{
    return std::move(command).visit([&request](auto&& cmd) -> AvmCommandResponse {
        using CmdType = std::decay_t<decltype(cmd)>;
        return std::forward<CmdType>(cmd).execute(request);
    });
}
 
AvmCommandResponse avm_dispatch(AvmRequest& request, AvmCommand&& command);
 
} // namespace bb::avm