FOL VM with cursor mocked storage

1 files changed, 73 insertions, 2 deletions

diff --git a/src/NT.cpp b/src/NT.cpp
index 4d391a8..66752ef 100644
--- a/src/NT.cpp
+++ b/src/NT.cpp
@@ -1,6 +1,14 @@
 #include "Runtime.h"
 
 #ifdef NT_CONSOLE_APP
+#include "CursorManager.h"
+#include "HandlerManager.h"
+#include "IdentityManager.h"
+#include "LifecycleManager.h"
+#include "ObjectManager.h"
+#include "PermissionsManager.h"
+#include "VM.h"
+
 #include <iostream>
 #endif
 
@@ -21,13 +29,76 @@ int main()
 {
     const nt::NT runtime;
     std::cout << "RNT running: " << (runtime.IsRunning() ? "yes" : "no") << '\n';
-    const int exit_code = runtime.IsRunning() ? 0 : 1;
+
+    // --- Mock: register RelationX in the object registry ---
+    nt::ObjectManager objects;
+
+    auto type = std::make_unique<nt::ObjectManager::object_type>();
+    type->label = RELATION;
+    type->disposable = false;
+    type->methods = { OPEN, CLOSE };
+
+    objects.Register({ "RelationX" }, std::make_unique<nt::ObjectManager::Relation>(), std::move(type));
+
+    // --- Mock: populate the cursor store with three tuples ---
+    nt::CursorManager cursors;
+    cursors.MockInsert({ "RelationX" }, { { "name", "Alice" }, { "age", "30" } });
+    cursors.MockInsert({ "RelationX" }, { { "name", "Bob"   }, { "age", "25" } });
+    cursors.MockInsert({ "RelationX" }, { { "name", "Carol" }, { "age", "35" } });
+
+    // --- Open a handle on RelationX through the full manager pipeline ---
+    nt::PermissionsManager permissions;
+    nt::IdentityManager identities;
+    nt::LifecycleManager lifecycles;
+    nt::HandlerManager handler(objects, permissions, identities, lifecycles);
+
+    int connection = 1;  // dummy connection context
+    nt::HandlerManager::handle* handle = handler.Open({ "RelationX" }, &connection);
+    if (handle == nullptr)
+    {
+        std::cout << "Failed to open handle for RelationX\n";
+        return 1;
+    }
+
+    // --- Open a cursor on the relation ---
+    nt::CursorManager::cursor* cursor = cursors.Open(handle);
+    if (cursor == nullptr)
+    {
+        std::cout << "Failed to open cursor for RelationX\n";
+        handler.Close(handle);
+        return 1;
+    }
+
+    // --- Build a SCAN plan and pull all tuples lazily through the FOL VM ---
+    nt::PlanNode plan;
+    plan.op = nt::PlanNode::Op::SCAN;
+    plan.scan_cursor = cursor;
+
+    nt::VM vm(cursors);
+    std::cout << "Tuples in RelationX:\n";
+    while (nt::Tuple* t = vm.Next(&plan))
+    {
+        std::cout << "  ";
+        const nt::Attribute* attr = t->Next();
+        while (attr != nullptr)
+        {
+            std::cout << attr->name << "=" << attr->value;
+            attr = t->Next();
+            if (attr != nullptr)
+                std::cout << ", ";
+        }
+        std::cout << '\n';
+    }
+
+    // --- Cleanup ---
+    cursors.Close(cursor);
+    handler.Close(handle);
 
 #ifdef NT_WAIT_ON_EXIT
     std::cout << "Press Enter to exit...";
     std::cin.get();
 #endif
 
-    return exit_code;
+    return runtime.IsRunning() ? 0 : 1;
 }
 #endif