1 files changed, 39 insertions, 45 deletions

diff --git a/src/CursorManager.cpp b/src/CursorManager.cpp
index d96909b..0d71b1c 100644
--- a/src/CursorManager.cpp
+++ b/src/CursorManager.cpp
@@ -3,46 +3,38 @@
 #include "ObjectManager.h"
 #include "TupleCodec.h"
 
-namespace nt
-{
-    CursorManager::CursorManager(IStorageBackend& backend,
-                                 LifecycleManager* lifecycles,
+namespace nt {
+    CursorManager::CursorManager(IStorageBackend& backend, LifecycleManager* lifecycles,
                                  ObjectManager* objects)
-        : backend_(backend)
-        , lifecycles_(lifecycles)
-        , objects_(objects)
-    {}
+        : backend_(backend), lifecycles_(lifecycles), objects_(objects) {
+    }
 
     // Finds the /system/snapshots/<H> entry that owns a handle's relation, or
     // nullptr when the relation lives outside the snapshot namespace (tests use
     // synthetic paths like {"relations", "villager"}).
-    static ObjectManager::registry* find_parent_snapshot(
-        ObjectManager& objects,
-        HandlerManager::handle* handle)
-    {
-        if (handle == nullptr || handle->object == nullptr
-            || handle->object->head == nullptr)
+    static ObjectManager::registry* find_parent_snapshot(ObjectManager& objects,
+                                                         HandlerManager::handle* handle) {
+        if (handle == nullptr || handle->object == nullptr || handle->object->head == nullptr)
             return nullptr;
 
         const auto& p = handle->object->head->path;
-        if (p.size() != 5) return nullptr;
+        if (p.size() != 5)
+            return nullptr;
         if (p[0] != "system" || p[1] != "snapshots" || p[3] != "relations")
             return nullptr;
 
-        return objects.Find({ p[0], p[1], p[2] });
+        return objects.Find({p[0], p[1], p[2]});
     }
 
-    void CursorManager::LoadPage(cursor* c)
-    {
-        auto entries = Merkle<Hash32>::Page(backend_, c->merkle_root,
-                                             c->fetch_offset, PAGE_SIZE);
+    void CursorManager::LoadPage(cursor* c) {
+        auto entries = Merkle<Hash32>::Page(backend_, c->merkle_root, c->fetch_offset, PAGE_SIZE);
         c->page.clear();
         c->page_position = 0;
 
-        for (const auto& entry : entries)
-        {
+        for (const auto& entry : entries) {
             auto bytes = backend_.Get(bin_to_hex(entry.payload));
-            if (!bytes) continue;
+            if (!bytes)
+                continue;
             c->page.emplace_back(TupleCodec::Deserialize(*bytes));
         }
 
@@ -52,23 +44,23 @@ namespace nt
     }
 
     CursorManager::cursor* CursorManager::Open(HandlerManager::handle* handle,
-                                                const std::string& merkle_root)
-    {
+                                               const std::string& merkle_root) {
         if (handle == nullptr || handle->object == nullptr)
             return nullptr;
 
         const auto label = handle->object->head->type->label;
 
         auto pin_snapshot = [&](cursor* c) {
-            if (lifecycles_ == nullptr || objects_ == nullptr) return;
+            if (lifecycles_ == nullptr || objects_ == nullptr)
+                return;
             auto* snap = find_parent_snapshot(*objects_, handle);
-            if (snap == nullptr) return;
+            if (snap == nullptr)
+                return;
             lifecycles_->Pin(snap);
             c->pinned_snapshot = snap;
         };
 
-        if (label == EPHEMERAL_RELATION)
-        {
+        if (label == EPHEMERAL_RELATION) {
             // Cursor is created exhausted — the JOIN operator writes args and
             // resets the state before the first probe. The generator is copied
             // off the registry-owned ephemeral_object_type so Next() never has
@@ -78,8 +70,8 @@ namespace nt
 
             auto* c = new cursor();
             c->is_ephemeral = true;
-            c->generator    = etype->generator;
-            c->exhausted    = true;
+            c->generator = etype->generator;
+            c->exhausted = true;
             pin_snapshot(c);
             return c;
         }
@@ -91,8 +83,7 @@ namespace nt
         c->merkle_root = merkle_root;
         pin_snapshot(c);
 
-        if (merkle_root.empty())
-        {
+        if (merkle_root.empty()) {
             // Empty relation: valid but immediately exhausted.
             c->exhausted = true;
             return c;
@@ -102,36 +93,39 @@ namespace nt
         return c;
     }
 
-    Tuple* CursorManager::Next(cursor* c)
-    {
-        if (c == nullptr) return nullptr;
+    Tuple* CursorManager::Next(cursor* c) {
+        if (c == nullptr)
+            return nullptr;
 
         if (c->page_position < c->page.size())
             return &c->page[c->page_position++];
 
-        if (c->exhausted) return nullptr;
+        if (c->exhausted)
+            return nullptr;
 
-        if (c->is_ephemeral)
-        {
+        if (c->is_ephemeral) {
             c->page = c->generator(c->args, c->fetch_offset, PAGE_SIZE);
             c->page_position = 0;
             c->fetch_offset += c->page.size();
             if (c->page.size() < PAGE_SIZE)
                 c->exhausted = true;
-            if (c->page.empty()) return nullptr;
+            if (c->page.empty())
+                return nullptr;
             return &c->page[c->page_position++];
         }
 
         LoadPage(c);
-        if (c->page.empty()) return nullptr;
+        if (c->page.empty())
+            return nullptr;
         return &c->page[c->page_position++];
     }
 
-    void CursorManager::Close(cursor* c)
-    {
-        if (c == nullptr) { return; }
+    void CursorManager::Close(cursor* c) {
+        if (c == nullptr) {
+            return;
+        }
         if (lifecycles_ != nullptr && c->pinned_snapshot != nullptr)
             lifecycles_->Unpin(c->pinned_snapshot);
         delete c;
     }
-}
+} // namespace nt