rocksdb_cursor.cpp

Go to the documentation of this file.

#include "storage/rocksdb/rocksdb_cursor.hpp"

#include "rocksdb_util.hpp"

namespace kagome::storage {

  RocksDBCursor::RocksDBCursor(std::shared_ptr<rocksdb::Iterator> it)
      : i_{std::move(it)} {}

  outcome::result<bool> RocksDBCursor::seekFirst() {
    i_->SeekToFirst();
    return isValid();
  }

  outcome::result<bool> RocksDBCursor::seek(const BufferView &key) {
    i_->Seek(make_slice(key));
    return isValid();
  }

  outcome::result<bool> RocksDBCursor::seekLast() {
    i_->SeekToLast();
    return isValid();
  }

  bool RocksDBCursor::isValid() const {
    return i_->Valid();
  }

  outcome::result<void> RocksDBCursor::next() {
    i_->Next();
    return outcome::success();
  }

  std::optional<Buffer> RocksDBCursor::key() const {
    return isValid() ? std::make_optional(make_buffer(i_->key()))
                     : std::nullopt;
  }

  std::optional<Buffer> RocksDBCursor::value() const {
    return isValid() ? std::make_optional(make_buffer(i_->value()))
                     : std::nullopt;
  }
}  // namespace kagome::storage