agent/runners/lua/impl.hpp

Go to the documentation of this file.

// Copyright (c) 2021 MIT Digital Currency Initiative,
//                    Federal Reserve Bank of Boston
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef OPENCBDC_TX_SRC_PARSEC_AGENT_RUNNER_H_
#define OPENCBDC_TX_SRC_PARSEC_AGENT_RUNNER_H_
 
#include "parsec/agent/runners/interface.hpp"
#include "parsec/util.hpp"
 
#include <lua.hpp>
#include <memory>
 
namespace cbdc::parsec::agent::runner {
    class lua_runner : public interface {
      public:
        lua_runner(std::shared_ptr<logging::log> logger,
                   const cbdc::parsec::config& cfg,
                   runtime_locking_shard::value_type function,
                   parameter_type param,
                   bool is_readonly_run,
                   run_callback_type result_callback,
                   try_lock_callback_type try_lock_callback,
                   std::shared_ptr<secp256k1_context> secp,
                   std::shared_ptr<thread_pool> t_pool,
                   ticket_number_type ticket_number);
 
        [[nodiscard]] auto run() -> bool override;
 
        static constexpr auto initial_lock_type = broker::lock_type::read;
 
      private:
        std::shared_ptr<lua_State> m_state;
 
        void contract_epilogue(int n_results);
 
        auto get_stack_string(int index) -> std::optional<buffer>;
 
        auto get_stack_integer(int index) -> std::optional<int64_t>;
 
        void schedule_contract();
 
        void
        handle_try_lock(const broker::interface::try_lock_return_type& res);
 
        static auto check_sig(lua_State* L) -> int;
    };
}
 
#endif