registry.hpp

Go to the documentation of this file.

#pragma once
 
#include <optional>
#include <string>
#include <filesystem>
 
#include "native.h"
#include <asio.hpp>
#include <absl/container/flat_hash_map.h>
#include <spdlog/spdlog.h>
 
#include "utils.hpp"
#include "file.hpp"
#include "pt.hpp"
#include "evm.hpp"
 
namespace dcn::registry
{
    class Registry
    {
        public:
            Registry() = delete;
            Registry(asio::io_context & io_context);
 
            Registry(const Registry&) = delete;
            Registry& operator=(const Registry&) = delete;
            
            ~Registry() = default;
 
            asio::awaitable<bool> addParticle(evm::Address address, ParticleRecord particle);
            asio::awaitable<std::optional<Particle>> getNewestParticle(const std::string& name) const;
            asio::awaitable<std::optional<Particle>> getParticle(const std::string& name, const evm::Address & address) const;
 
 
            asio::awaitable<bool> addFeature(evm::Address address, FeatureRecord feature);
            
            asio::awaitable<std::optional<Feature>> getNewestFeature(const std::string& name) const;
 
            asio::awaitable<std::optional<Feature>> getFeature(const std::string& name, const evm::Address & address) const;
 
            asio::awaitable<bool> addTransformation(evm::Address address, TransformationRecord transformation);
 
            asio::awaitable<std::optional<Transformation>> getNewestTransformation(const std::string& name) const;
 
            asio::awaitable<std::optional<Transformation>> getTransformation(const std::string& name, const evm::Address & address) const;
 
            asio::awaitable<bool> addCondition(evm::Address address, ConditionRecord condition);
 
            asio::awaitable<std::optional<Condition>> getNewestCondition(const std::string& name) const;
 
            asio::awaitable<std::optional<Condition>> getCondition(const std::string& name, const evm::Address & address) const;
 
            asio::awaitable<absl::flat_hash_set<std::string>> getOwnedParticles(const evm::Address & address) const;
            asio::awaitable<absl::flat_hash_set<std::string>> getOwnedFeatures(const evm::Address & address) const;
            asio::awaitable<absl::flat_hash_set<std::string>> getOwnedTransformations(const evm::Address & address) const;
            asio::awaitable<absl::flat_hash_set<std::string>> getOwnedConditions(const evm::Address & address) const;
 
        protected:
 
            asio::awaitable<bool> containsParticleBucket(const std::string& name) const;
 
            asio::awaitable<bool> containsFeatureBucket(const std::string& name) const;
 
            asio::awaitable<bool> containsTransformationBucket(const std::string& name) const;
 
            asio::awaitable<bool> containsConditionBucket(const std::string& name) const;
 
 
            asio::awaitable<bool> isParticleBucketEmpty(const std::string& name) const;
 
            asio::awaitable<bool> isFeatureBucketEmpty(const std::string& name) const;
 
            asio::awaitable<bool> isTransformationBucketEmpty(const std::string& name) const;
 
            asio::awaitable<bool> isConditionBucketEmpty(const std::string& name) const;
        
        private:
            asio::strand<asio::io_context::executor_type> _strand;
 
            absl::flat_hash_map<std::string, evm::Address> _newest_particle;
            absl::flat_hash_map<std::string, evm::Address> _newest_feature;
            absl::flat_hash_map<std::string, evm::Address> _newest_transformation;
            absl::flat_hash_map<std::string, evm::Address> _newest_condition;
 
            absl::flat_hash_map<std::string, absl::flat_hash_map<evm::Address, ParticleRecord>> _particles;
            absl::flat_hash_map<std::string, absl::flat_hash_map<evm::Address, FeatureRecord>> _features;
            absl::flat_hash_map<std::string, absl::flat_hash_map<evm::Address, TransformationRecord>> _transformations;
            absl::flat_hash_map<std::string, absl::flat_hash_map<evm::Address, ConditionRecord>> _conditions;
 
 
            absl::flat_hash_map<evm::Address, absl::flat_hash_set<std::string>> _owned_particles;
            absl::flat_hash_map<evm::Address, absl::flat_hash_set<std::string>> _owned_features;
            absl::flat_hash_map<evm::Address, absl::flat_hash_set<std::string>> _owned_transformations;
            absl::flat_hash_map<evm::Address, absl::flat_hash_set<std::string>> _owned_conditions;
    };
}