feat: subscription

Author: ponderingdemocritus

examples/clients/react/react-sdk/src/App.tsx

@@ -1,6 +1,4 @@
 import { useEffect, useState } from "react";
-import reactLogo from "./assets/react.svg";
-import viteLogo from "/vite.svg";
 import "./App.css";
 import { init } from "@dojoengine/sdk";
 
@@ -54,6 +52,41 @@ const db = await init<Schema>({
 });
 
 function App() {
+    useEffect(() => {
+        let unsubscribe: (() => void) | undefined;
+
+        const subscribe = async () => {
+            const subscription = await db.subscribeEntityQuery(
+                {
+                    dojo_starter: {
+                        Moves: true,
+                    },
+                },
+                (response) => {
+                    if (response.error) {
+                        console.error(
+                            "Error setting up entity sync:",
+                            response.error
+                        );
+                    } else {
+                        console.log(response);
+                    }
+                }
+            );
+
+            unsubscribe = () => subscription.cancel();
+        };
+
+        subscribe();
+
+        return () => {
+            if (unsubscribe) {
+                unsubscribe();
+                console.log("Sync unsubscribed");
+            }
+        };
+    }, []);
+
     useEffect(() => {
         const fetchEntities = async () => {
             try {
@@ -62,7 +95,7 @@ function App() {
                         dojo_starter: {
                             Moves: {
                                 $: {
-                                    where: { can_move: { $eq: true } },
+                                    where: { last_direction: { $eq: "Left" } },
                                 },
                             },
                         },
@@ -76,11 +109,10 @@ function App() {
                             return;
                         }
                         if (resp.data) {
-                            console.log("resp.data:", resp.data.dojo_starter);
                         }
                     }
                 );
-                console.log("Queried entities:", entities);
+                // console.log("Queried entities:", entities);
             } catch (error) {
                 console.error("Error querying entities:", error);
             }

packages/create-dojo/bin/index.js

@@ -8,7 +8,7 @@
     "type": "module",
     "scripts": {
         "build": "tsup --dts-resolve",
-        "test": "vitest run",
+        "test": "vitest run --config ./vitest.config.ts",
         "coverage": "vitest run --coverage",
         "lint": "eslint . --ext .ts,.tsx"
     },
@@ -29,6 +29,7 @@
     },
     "dependencies": {
         "@dojoengine/torii-client": "workspace:*",
+        "vite-plugin-wasm": "^3.3.0",
         "zustand": "^4.5.2"
     }
 }

packages/create-dojo/bin/index.js.map

@@ -43,15 +43,15 @@ describe("convertQueryToClause", () => {
                             model: "world-player",
                             member: "id",
                             operator: "Eq",
-                            value: { Primitive: { Felt252: "1" } },
+                            value: { String: "1" },
                         },
                     },
                     {
                         Member: {
                             model: "world-player",
                             member: "name",
                             operator: "Eq",
-                            value: { Primitive: { Felt252: "Alice" } },
+                            value: { String: "Alice" },
                         },
                     },
                 ],
@@ -100,15 +100,15 @@ describe("convertQueryToClause", () => {
                             model: "world-player",
                             member: "id",
                             operator: "Eq",
-                            value: { Primitive: { Felt252: "1" } },
+                            value: { String: "1" },
                         },
                     },
                     {
                         Member: {
                             model: "world-game",
                             member: "status",
                             operator: "Eq",
-                            value: { Primitive: { Felt252: "active" } },
+                            value: { String: "active" },
                         },
                     },
                 ],

packages/sdk/package.json

@@ -165,7 +165,7 @@ describe("parseEntities", () => {
                 },
         };
 
-        const result = parseEntities(mockEntities, query);
+        const result = parseEntities(mockEntities);
 
         expect(result).toEqual([
             {