offchain_persistent_storage.hpp

Go to the documentation of this file.

#ifndef KAGOME_OFFCHAIN_OFFCHAINPERSISTENTSTORAGEIMPL
#define KAGOME_OFFCHAIN_OFFCHAINPERSISTENTSTORAGEIMPL

#include "offchain/offchain_persistent_storage.hpp"

#include "log/logger.hpp"
#include "storage/buffer_map_types.hpp"

namespace kagome::offchain {

  class OffchainPersistentStorageImpl final : public OffchainPersistentStorage {
   public:
    explicit OffchainPersistentStorageImpl(
        std::shared_ptr<storage::BufferStorage> storage);

    outcome::result<void> set(const common::BufferView &key,
                              common::Buffer value) override;

    outcome::result<void> clear(const common::BufferView &key) override;

    outcome::result<bool> compare_and_set(
        const common::BufferView &key,
        const std::optional<common::BufferView> &expected,
        common::Buffer value) override;

    outcome::result<common::Buffer> get(const common::BufferView &key) override;

   private:
    std::shared_ptr<storage::BufferStorage> storage_;

    std::mutex mutex_;
    log::Logger log_;
  };

}  // namespace kagome::offchain

#endif  // KAGOME_OFFCHAIN_OFFCHAINPERSISTENTSTORAGEIMPL