loader.cpp File Reference

#include "loader.hpp"
#include "utils.hpp"
#include <algorithm>
#include <array>
#include <cstdlib>
#include <sstream>
#include <string_view>
#include <type_traits>

Namespaces
namespace	dcn
namespace	dcn::loader

Functions
asio::awaitable< bool >	dcn::loader::ensureTransformationImported (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, JsonImportContext &context)
asio::awaitable< bool >	dcn::loader::ensureConditionImported (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, JsonImportContext &context)
asio::awaitable< bool >	dcn::loader::ensureConnectorImported (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, JsonImportContext &context)
asio::awaitable< bool >	dcn::loader::ensureConnectorDeployedImpl (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path, ConnectorEnsureContext &context)
bool	dcn::loader::ensurePTBuildVersion (const std::filesystem::path &storage_path)
asio::awaitable< std::expected< chain::Address, pt::PTDeployError > >	dcn::loader::deployConnector (evm::EVM &evm, storage::Registry &registry, ConnectorRecord connector, const std::filesystem::path &storage_path, bool register_in_registry=true, bool persist_json=true)
asio::awaitable< std::expected< chain::Address, pt::PTDeployError > >	dcn::loader::deployTransformation (evm::EVM &evm, storage::Registry &registry, TransformationRecord transformation, const std::filesystem::path &storage_path, bool register_in_registry=true, bool persist_json=true)
asio::awaitable< std::expected< chain::Address, pt::PTDeployError > >	dcn::loader::deployCondition (evm::EVM &evm, storage::Registry &registry, ConditionRecord condition, const std::filesystem::path &storage_path, bool register_in_registry=true, bool persist_json=true)
asio::awaitable< bool >	dcn::loader::loadStoredConnectors (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, std::size_t registry_batch_size=1000)
asio::awaitable< bool >	dcn::loader::loadStoredTransformations (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, std::size_t registry_batch_size=5000)
asio::awaitable< bool >	dcn::loader::loadStoredConditions (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, std::size_t registry_batch_size=5000)
asio::awaitable< bool >	dcn::loader::ensureTransformationDeployed (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path)
asio::awaitable< bool >	dcn::loader::ensureConditionDeployed (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path)
asio::awaitable< bool >	dcn::loader::ensureConnectorDeployed (evm::EVM &evm, storage::Registry &registry, const std::string &name, const std::filesystem::path &storage_path)
asio::awaitable< bool >	dcn::loader::importJsonStorageToDatabase (evm::EVM &evm, storage::Registry &registry, const std::filesystem::path &storage_path, LoaderBatchConfig batch_config={})

Variable Documentation

batch_config

LoaderBatchConfig batch_config {}

conditions

absl::flat_hash_map<std::string, ConditionRecord> conditions

connector_deploy_stack

std::vector<std::string> connector_deploy_stack

connector_import_stack

std::vector<std::string> connector_import_stack

connectors

absl::flat_hash_map<std::string, ConnectorRecord> connectors

done

absl::flat_hash_set<std::string> done

imported_conditions

absl::flat_hash_set<std::string> imported_conditions

imported_connectors

absl::flat_hash_set<std::string> imported_connectors

imported_transformations

absl::flat_hash_set<std::string> imported_transformations

importing_conditions

absl::flat_hash_set<std::string> importing_conditions

importing_connectors

absl::flat_hash_set<std::string> importing_connectors

importing_transformations

absl::flat_hash_set<std::string> importing_transformations

pending_conditions

std::vector<std::pair<chain::Address, ConditionRecord> > pending_conditions

pending_connectors

std::vector<std::pair<chain::Address, ConnectorRecord> > pending_connectors

pending_transformations

std::vector<std::pair<chain::Address, TransformationRecord> > pending_transformations

stack_ref

std::vector<std::string>& stack_ref

trace_enabled

bool trace_enabled = false

transformations

absl::flat_hash_map<std::string, TransformationRecord> transformations

visiting

absl::flat_hash_set<std::string> visiting