wsdb_schedule.hpp

Go to the documentation of this file.

#pragma once
#include "barretenberg/wsdb/generated/wsdb_dispatch.hpp" // Responder
#include "barretenberg/wsdb/wsdb_request.hpp"
#include "barretenberg/wsdb/wsdb_scheduler.hpp"
 
#include <cstdint>
#include <exception>
#include <string>
#include <utility>
 
namespace bb::wsdb {
 
namespace detail {
template <typename Resp, typename Fn> std::function<void()> wrap(Responder<Resp> respond, Fn&& logic)
{
    return [respond = std::move(respond), logic = std::forward<Fn>(logic)]() mutable {
        try {
            respond.ok(logic());
        } catch (const std::exception& e) {
            respond.error(e.what());
        }
    };
}
} // namespace detail
 
template <typename Resp, typename Fn>
void schedule_read(WsdbRequest& ctx, uint64_t fork, bool committed, Responder<Resp> respond, Fn&& logic)
{
    ctx.scheduler->submit_read(fork, committed, detail::wrap(std::move(respond), std::forward<Fn>(logic)));
}
 
template <typename Resp, typename Fn>
void schedule_write(WsdbRequest& ctx, uint64_t fork, Responder<Resp> respond, Fn&& logic)
{
    ctx.scheduler->submit_write(fork, detail::wrap(std::move(respond), std::forward<Fn>(logic)));
}
 
} // namespace bb::wsdb