Reading legacy Berkeley DB files for migration

751    }
752}
753
754bool BerkeleyROBatch::ReadKey(DataStream&& key, DataStream& value)
755{
756    SerializeData key_data{key.begin(), key.end()};
757    const auto it{m_database.m_records.find(key_data)};
758    if (it == m_database.m_records.end()) {
759        return false;
760    }
761    auto val = it->second;
762    value.clear();
763    value.write(std::span(val));
764    return true;
765}
766
767bool BerkeleyROBatch::HasKey(DataStream&& key)
768{
769    SerializeData key_data{key.begin(), key.end()};
770    return m_database.m_records.contains(key_data);
771}
772
773BerkeleyROCursor::BerkeleyROCursor(const BerkeleyRODatabase& database, std::span<const std::byte> prefix)
774    : m_database(database)
775{
776    std::tie(m_cursor, m_cursor_end) = m_database.m_records.equal_range(BytePrefix{prefix});
777}
778
779DatabaseCursor::Status BerkeleyROCursor::Next(DataStream& ssKey, DataStream& ssValue)
780{
781    if (m_cursor == m_cursor_end) {
782        return DatabaseCursor::Status::DONE;
783    }
784    ssKey.write(std::span(m_cursor->first));
785    ssValue.write(std::span(m_cursor->second));
786    m_cursor++;
787    return DatabaseCursor::Status::MORE;
788}
789
790std::unique_ptr<DatabaseCursor> BerkeleyROBatch::GetNewPrefixCursor(std::span<const std::byte> prefix)
791{
792    return std::make_unique<BerkeleyROCursor>(m_database, prefix);
793}
794
795std::unique_ptr<BerkeleyRODatabase> MakeBerkeleyRODatabase(const fs::path& path, const DatabaseOptions& options, DatabaseStatus& status, bilingual_str& error)
796{
797    fs::path data_file = BDBDataFile(path);
798    try {
799        std::unique_ptr<BerkeleyRODatabase> db = std::make_unique<BerkeleyRODatabase>(data_file);
800        status = DatabaseStatus::SUCCESS;
801        return db;
802    } catch (const std::runtime_error& e) {
803        error.original = e.what();
804        status = DatabaseStatus::FAILED_LOAD;
805        return nullptr;
806    }
807}
808} // namespace wallet
809