fix: entity sync

.github/workflows/ci.yaml

@@ -20,7 +20,7 @@ jobs:
               run: git submodule update --init --recursive
 
             - run: curl -L https://install.dojoengine.org | bash
-            - run: /home/runner/.config/.dojo/bin/dojoup -v v1.0.0-alpha.3
+            - run: /home/runner/.config/.dojo/bin/dojoup -v v1.0.0-alpha.5
             - run: |
                   cd examples/dojo-starter
                   /home/runner/.config/.dojo/bin/sozo build

examples/react/react-app/src/App.tsx

@@ -17,19 +17,7 @@ function App() {
         account,
     } = useDojo();
 
-    useQuerySync(toriiClient, contractComponents as any, [
-        {
-            Keys: {
-                keys: [BigInt(account?.account.address).toString()],
-                models: [
-                    "dojo_starter-Position",
-                    "dojo_starter-Moves",
-                    "dojo_starter-DirectionsAvailable",
-                ],
-                pattern_matching: "FixedLen",
-            },
-        },
-    ]);
+    useQuerySync(toriiClient, contractComponents as any, []);
 
     const [clipboardStatus, setClipboardStatus] = useState({
         message: "",

examples/react/react-app/src/dojo/createSystemCalls.ts

@@ -82,28 +82,28 @@ export function createSystemCalls(
         ]) as Entity;
 
         // Update the state before the transaction
-        const positionId = uuid();
-        Position.addOverride(positionId, {
-            entity: entityId,
-            value: {
-                player: BigInt(entityId),
-                vec: updatePositionWithDirection(
-                    direction,
-                    getComponentValue(Position, entityId) as any
-                ).vec,
-            },
-        });
+        // const positionId = uuid();
+        // Position.addOverride(positionId, {
+        //     entity: entityId,
+        //     value: {
+        //         player: BigInt(entityId),
+        //         vec: updatePositionWithDirection(
+        //             direction,
+        //             getComponentValue(Position, entityId) as any
+        //         ).vec,
+        //     },
+        // });
 
-        // Update the state before the transaction
-        const movesId = uuid();
-        Moves.addOverride(movesId, {
-            entity: entityId,
-            value: {
-                player: BigInt(entityId),
-                remaining:
-                    (getComponentValue(Moves, entityId)?.remaining || 0) - 1,
-            },
-        });
+        // // Update the state before the transaction
+        // const movesId = uuid();
+        // Moves.addOverride(movesId, {
+        //     entity: entityId,
+        //     value: {
+        //         player: BigInt(entityId),
+        //         remaining:
+        //             (getComponentValue(Moves, entityId)?.remaining || 0) - 1,
+        //     },
+        // });
 
         try {
             await client.actions.move({
@@ -127,11 +127,11 @@ export function createSystemCalls(
             });
         } catch (e) {
             console.log(e);
-            Position.removeOverride(positionId);
-            Moves.removeOverride(movesId);
+            // Position.removeOverride(positionId);
+            // Moves.removeOverride(movesId);
         } finally {
-            Position.removeOverride(positionId);
-            Moves.removeOverride(movesId);
+            // Position.removeOverride(positionId);
+            // Moves.removeOverride(movesId);
         }
     };
 

examples/react/react-app/src/dojo/generated/setup.ts

@@ -72,6 +72,5 @@ export async function setup({ ...config }: DojoConfig) {
         dojoProvider,
         burnerManager,
         toriiClient,
-        // sync,
     };
 }

packages/react/src/useQuerySync.ts

@@ -1,7 +1,7 @@
 import { Component, Metadata, Schema } from "@dojoengine/recs";
 import { useCallback, useEffect } from "react";
 import {
-    Client,
+    ToriiClient,
     EntityKeysClause,
     Subscription,
 } from "@dojoengine/torii-client";
@@ -28,7 +28,7 @@ import { getSyncEntities } from "@dojoengine/state";
  * ]);
  */
 export function useQuerySync<S extends Schema>(
-    toriiClient: Client,
+    toriiClient: ToriiClient,
     components: Component<S, Metadata, undefined>[],
     entityKeyClause: EntityKeysClause[]
 ) {

packages/state/src/recs/index.ts

@@ -8,7 +8,7 @@ import {
 } from "@dojoengine/recs";
 import {
     Clause,
-    Client,
+    ToriiClient,
     EntityKeysClause,
     PatternMatching,
 } from "@dojoengine/torii-client";
@@ -40,7 +40,7 @@ import { convertValues } from "../utils";
  * the batch size of each request.
  */
 export const getSyncEntities = async <S extends Schema>(
-    client: Client,
+    client: ToriiClient,
     components: Component<S, Metadata, undefined>[],
     entityKeyClause: EntityKeysClause[],
     limit: number = 100
@@ -62,7 +62,7 @@ export const getSyncEntities = async <S extends Schema>(
  * This function performs paginated queries to fetch all entities and their components.
  */
 export const getEntities = async <S extends Schema>(
-    client: Client,
+    client: ToriiClient,
     components: Component<S, Metadata, undefined>[],
     limit: number = 100
 ) => {
@@ -109,7 +109,7 @@ export const getEntities = async <S extends Schema>(
  * to control the batch size of each request.
  */
 export const getEntitiesQuery = async <S extends Schema>(
-    client: Client,
+    client: ToriiClient,
     components: Component<S, Metadata, undefined>[],
     entityKeyClause: EntityKeysClause,
     patternMatching: PatternMatching = "FixedLen",
@@ -137,7 +137,7 @@ export const getEntitiesQuery = async <S extends Schema>(
         const fetchedEntities = await client.getEntities({
             limit,
             offset: cursor,
-            clause,
+            clause: clause || undefined,
         });
 
         setEntities(fetchedEntities, components);
@@ -163,14 +163,14 @@ export const getEntitiesQuery = async <S extends Schema>(
  * sync.cancel(); // cancel the subscription
  */
 export const syncEntities = async <S extends Schema>(
-    client: Client,
+    client: ToriiClient,
     components: Component<S, Metadata, undefined>[],
     entityKeyClause: EntityKeysClause[]
 ) => {
     return await client.onEntityUpdated(
         entityKeyClause,
-        (fetchedEntities: any) => {
-            setEntities(fetchedEntities, components);
+        (fetchedEntities: any, data: any) => {
+            setEntities({ [fetchedEntities]: data }, components);
         }
     );
 };
@@ -184,7 +184,6 @@ export const setEntities = async <S extends Schema>(
     entities: any,
     components: Component<S, Metadata, undefined>[]
 ) => {
-    console.log(entities, components);
     for (let key in entities) {
         if (entities.hasOwnProperty(key)) {
             for (let componentName in entities[key]) {

packages/state/src/utils/index.ts

@@ -18,6 +18,11 @@ export function convertValues(schema: Schema, values: any) {
             return acc;
         }
 
+        // if (value.type === "struct") {
+        //     acc[key] = convertValues(schemaType, value.value);
+        //     return acc;
+        // }
+
         switch (schemaType) {
             case RecsType.StringArray:
                 if (value.type === "array" && value.value[0].type === "enum") {
@@ -63,11 +68,22 @@ export function convertValues(schema: Schema, values: any) {
                 break;
 
             default:
-                if (
-                    typeof schemaType === "object" &&
-                    typeof value === "object"
+                if (typeof schemaType === "object" && value.type === "struct") {
+                    if (value.value instanceof Map) {
+                        const structValues = Object.fromEntries(value.value);
+                        acc[key] = convertValues(schemaType, structValues);
+                    } else {
+                        acc[key] = convertValues(schemaType, value.value);
+                    }
+                } else if (
+                    Array.isArray(schemaType) &&
+                    value.type === "array"
                 ) {
-                    acc[key] = convertValues(schemaType, value.value);
+                    acc[key] = value.value.map((item: any) =>
+                        convertValues(schemaType[0], item)
+                    );
+                } else {
+                    acc[key] = value.value;
                 }
                 break;
         }