LedgerCacheLoadingState.hpp

#pragma once
 
#include "data/LedgerCacheInterface.hpp"
 
#include <atomic>
#include <functional>
#include <memory>
 
namespace data {

class LedgerCacheLoadingStateInterface {
public:
    virtual ~LedgerCacheLoadingStateInterface() = default;

    virtual void
    allowLoading() = 0;

    [[nodiscard]] virtual bool
    isLoadingAllowed() const = 0;

    virtual void
    waitForLoadingAllowed() const = 0;

    [[nodiscard]] virtual bool
    isCurrentlyLoading() const = 0;

    [[nodiscard]] virtual std::unique_ptr<LedgerCacheLoadingStateInterface>
    clone() const = 0;
};

class LedgerCacheLoadingState : public LedgerCacheLoadingStateInterface {
    std::reference_wrapper<LedgerCacheInterface const> cache_;
    std::shared_ptr<std::atomic_bool> isLoadingAllowed_ = std::make_shared<std::atomic_bool>(false);
 
public:
    explicit LedgerCacheLoadingState(LedgerCacheInterface const& cache);

    void
    allowLoading() override;

    [[nodiscard]] bool
    isLoadingAllowed() const override;

    void
    waitForLoadingAllowed() const override;

    [[nodiscard]] bool
    isCurrentlyLoading() const override;

    [[nodiscard]] std::unique_ptr<LedgerCacheLoadingStateInterface>
    clone() const override;
};
 
}  // namespace data