From 9190fb2ba337ccd802dfa80562912fe3992e68b3 Mon Sep 17 00:00:00 2001
From: Davit Vardanyan <78792753+davvard@users.noreply.github.com>
Date: Mon, 28 Aug 2023 16:18:12 +0400
Subject: [PATCH] Fix: Deserialize

---
 contrib/usearch                               |  2 +-
 .../MergeTree/MergeTreeIndexUSearch.cpp       | 21 +++++++++----------
 2 files changed, 11 insertions(+), 12 deletions(-)

diff --git a/contrib/usearch b/contrib/usearch
index 387b78b28b1..c6329e9bfb8 160000
--- a/contrib/usearch
+++ b/contrib/usearch
@@ -1 +1 @@
-Subproject commit 387b78b28b17b8954024ffc81e97cbcfa10d1f30
+Subproject commit c6329e9bfb893a92c28d825cc7982580f65bbfae
diff --git a/src/Storages/MergeTree/MergeTreeIndexUSearch.cpp b/src/Storages/MergeTree/MergeTreeIndexUSearch.cpp
index 731aa2309e3..5f07b3be914 100644
--- a/src/Storages/MergeTree/MergeTreeIndexUSearch.cpp
+++ b/src/Storages/MergeTree/MergeTreeIndexUSearch.cpp
@@ -35,7 +35,7 @@ USearchIndexWithSerialization<Metric>::USearchIndexWithSerialization(size_t dime
 }
 
 template <unum::usearch::metric_kind_t Metric>
-void USearchIndexWithSerialization<Metric>::serialize([[maybe_unused]] WriteBuffer & ostr) const
+void USearchIndexWithSerialization<Metric>::serialize(WriteBuffer & ostr) const
 {
     auto callback = [&ostr](void * from, size_t n)
     {
@@ -43,21 +43,20 @@ void USearchIndexWithSerialization<Metric>::serialize([[maybe_unused]] WriteBuff
         return true;
     };
 
-    Base::stream(callback);
+    Base::save_to_stream(callback);
 }
 
 template <unum::usearch::metric_kind_t Metric>
-void USearchIndexWithSerialization<Metric>::deserialize([[maybe_unused]] ReadBuffer & istr)
+void USearchIndexWithSerialization<Metric>::deserialize(ReadBuffer & istr)
 {
-    BufferBase::Position & pos = istr.position();
-    unum::usearch::memory_mapped_file_t memory_map(pos, istr.buffer().size() - istr.count());
-    Base::view(std::move(memory_map));
-    pos += Base::stream_length();
+    auto callback = [&istr](void * from, size_t n)
+    {
+        istr.readStrict(reinterpret_cast<char *>(from), n);
+        return true;
+    };
+
+    Base::load_from_stream(callback);
 
-    auto copy = Base::copy();
-    if (!copy)
-        throw Exception(ErrorCodes::LOGICAL_ERROR, "Could not copy usearch index");
-    Base::swap(copy.index);
 }
 
 template <unum::usearch::metric_kind_t Metric>