offchain_extension.hpp

Go to the documentation of this file.

#ifndef KAGOME_OFFCHAIN_EXTENSION_HPP
#define KAGOME_OFFCHAIN_EXTENSION_HPP

#include "clock/clock.hpp"
#include "crypto/random_generator.hpp"
#include "log/logger.hpp"
#include "offchain/offchain_storage.hpp"
#include "runtime/types.hpp"

namespace kagome::offchain {
  class OffchainWorker;
  class OffchainWorkerPool;
}  // namespace kagome::offchain

namespace kagome::runtime {
  class MemoryProvider;
}

namespace kagome::host_api {

  struct OffchainExtensionConfig {
    bool is_indexing_enabled = false;
  };

  class OffchainExtension final {
   public:
    OffchainExtension(
        const OffchainExtensionConfig &config,
        std::shared_ptr<const runtime::MemoryProvider> memory_provider,
        std::shared_ptr<offchain::OffchainStorage> offchain_storage,
        std::shared_ptr<offchain::OffchainWorkerPool> ocw_pool);

    runtime::WasmI32 ext_offchain_is_validator_version_1();

    runtime::WasmSpan ext_offchain_submit_transaction_version_1(
        runtime::WasmSpan data);

    runtime::WasmSpan ext_offchain_network_state_version_1();

    runtime::WasmU64 ext_offchain_timestamp_version_1();

    void ext_offchain_sleep_until_version_1(runtime::WasmU64 deadline);

    runtime::WasmPointer ext_offchain_random_seed_version_1();

    void ext_offchain_local_storage_set_version_1(runtime::WasmI32 kind,
                                                  runtime::WasmSpan key,
                                                  runtime::WasmSpan value);

    void ext_offchain_local_storage_clear_version_1(runtime::WasmI32 kind,
                                                    runtime::WasmSpan key);

    runtime::WasmI32 ext_offchain_local_storage_compare_and_set_version_1(
        runtime::WasmI32 kind,
        runtime::WasmSpan key,
        runtime::WasmSpan expected,
        runtime::WasmSpan value);

    runtime::WasmSpan ext_offchain_local_storage_get_version_1(
        runtime::WasmI32 kind, runtime::WasmSpan key);

    runtime::WasmSpan ext_offchain_http_request_start_version_1(
        runtime::WasmSpan method,
        runtime::WasmSpan uri,
        runtime::WasmSpan meta);

    runtime::WasmSpan ext_offchain_http_request_add_header_version_1(
        runtime::WasmI32 request_id,
        runtime::WasmSpan name,
        runtime::WasmSpan value);

    runtime::WasmSpan ext_offchain_http_request_write_body_version_1(
        runtime::WasmI32 request_id,
        runtime::WasmSpan chunk,
        runtime::WasmSpan deadline);

    runtime::WasmSpan ext_offchain_http_response_wait_version_1(
        runtime::WasmSpan ids, runtime::WasmSpan deadline);

    runtime::WasmSpan ext_offchain_http_response_headers_version_1(
        runtime::WasmI32 request_id);

    runtime::WasmSpan ext_offchain_http_response_read_body_version_1(
        runtime::WasmI32 request_id,
        runtime::WasmSpan buffer,
        runtime::WasmSpan deadline);

    void ext_offchain_set_authorized_nodes_version_1(
        runtime::WasmSpan nodes, runtime::WasmI32 authorized_only);

    void ext_offchain_index_set_version_1(runtime::WasmSpan key,
                                          runtime::WasmSpan value);

    void ext_offchain_index_clear_version_1(runtime::WasmSpan key);

   private:
    std::shared_ptr<offchain::OffchainWorker> getWorker();

    const OffchainExtensionConfig &config_;
    std::shared_ptr<const runtime::MemoryProvider> memory_provider_;
    std::shared_ptr<offchain::OffchainStorage> offchain_storage_;
    std::shared_ptr<offchain::OffchainWorkerPool> ocw_pool_;

    log::Logger log_;
  };

}  // namespace kagome::host_api

#endif /* KAGOME_OFFCHAIN_EXTENSION_HPP */