attempt rest

Author: elebras1

examples/src/main/java/com/github/elebras1/flecs/examples/RestExplorerExample.java

@@ -8,10 +8,9 @@ public class RestExplorerExample {
 
     public static void main(String[] args) throws InterruptedException {
         try (Flecs world = new Flecs()) {
-            flecs_h.ecs_log_set_level(0);
+            flecs_h.ecs_log_set_level(1);
             System.out.println("=== Flecs REST Explorer Example ===");
             FlecsServer server = world.restServer((short) 27750);
-
             System.out.println("Open https://flecs.dev/explorer?remote=true");
 
             int numberEntities = 1000;
@@ -51,9 +50,14 @@ public static void main(String[] args) throws InterruptedException {
 
             System.out.println("Loop running...");
 
-            while (world.progress(0.016f)) {
+            float deltaTime = 0.016f;
+            while (world.progress(deltaTime)) {
+                world.processHttp(server, deltaTime);
+
                 Thread.sleep(16);
             }
+
+            world.restServerStop(server);
         }
     }
 }

src/main/java/com/github/elebras1/flecs/Flecs.java

@@ -750,24 +750,50 @@ public void httpServerStop(FlecsServer server) {
         }
     }
 
+    public void processHttp(FlecsServer server, float deltaTime) {
+        this.checkClosed();
+        if (server != null && !server.getServerSegment().equals(MemorySegment.NULL)) {
+            flecs_h.ecs_http_server_dequeue(server.getServerSegment(), deltaTime);
+        }
+    }
+
     public FlecsServer restServer(short port) {
         this.checkClosed();
-        try (Arena tempArena = Arena.ofConfined()) {
-            flecs_h.FlecsRestImport(this.nativeWorld);
-            MemorySegment desc = ecs_http_server_desc_t.allocate(tempArena);
-            ecs_http_server_desc_t.port(desc, port);
-            MemorySegment server = flecs_h.ecs_rest_server_init(this.nativeWorld, desc);
-            if (server.equals(MemorySegment.NULL)) {
-                throw new IllegalStateException("Failed to start REST server on port " + port);
-            }
+        flecs_h.FlecsDocImport(this.nativeWorld);
+        flecs_h.FlecsStatsImport(this.nativeWorld);
+        flecs_h.FlecsMetricsImport(this.nativeWorld);
+        flecs_h.FlecsWorldMonitorImport(this.nativeWorld);
+        flecs_h.FlecsSystemMonitorImport(this.nativeWorld);
+        flecs_h.FlecsPipelineMonitorImport(this.nativeWorld);
+        flecs_h.FlecsAlertsImport(this.nativeWorld);
+        flecs_h.FlecsRestImport(this.nativeWorld);
 
-            return new FlecsServer(server);
+        flecs_h.ecs_set_entity_range(this.nativeWorld, 0, 0);
+
+        MemorySegment desc = ecs_http_server_desc_t.allocate(this.arena);
+        desc.fill((byte) 0);
+        ecs_http_server_desc_t.port(desc, port);
+
+        MemorySegment server = flecs_h.ecs_rest_server_init(this.nativeWorld, desc);
+        if (server == null || server.equals(MemorySegment.NULL)) {
+            throw new IllegalStateException("Failed to initialize REST server");
         }
+
+        int result = flecs_h.ecs_http_server_start(server);
+        if (result != 0) {
+            flecs_h.ecs_http_server_fini(server);
+            throw new IllegalStateException("Failed to start REST server on port " + port);
+        }
+
+        System.out.println("REST server started on http://localhost:" + port);
+
+        return new FlecsServer(server);
     }
 
     public void restServerStop(FlecsServer server) {
         this.checkClosed();
         if (server != null && !server.getServerSegment().equals(MemorySegment.NULL)) {
+            flecs_h.ecs_http_server_stop(server.getServerSegment());
             flecs_h.ecs_rest_server_fini(server.getServerSegment());
         }
     }