Skip to content

Commit 70f75f8

Browse files
feat: update for better clause
1 parent 0530d74 commit 70f75f8

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

packages/state/src/recs/index.ts

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -43,10 +43,11 @@ import { convertValues } from "../utils";
4343
export const getSyncEntities = async <S extends Schema>(
4444
client: ToriiClient,
4545
components: Component<S, Metadata, undefined>[],
46+
clause: Clause | undefined,
4647
entityKeyClause: EntityKeysClause[],
4748
limit: number = 100
4849
) => {
49-
await getEntities(client, components, limit);
50+
await getEntities(client, clause, components, limit);
5051
return await syncEntities(client, components, entityKeyClause);
5152
};
5253

@@ -103,21 +104,22 @@ export const getSyncEvents = async <S extends Schema>(
103104
*/
104105
export const getEntities = async <S extends Schema>(
105106
client: ToriiClient,
107+
clause: Clause | undefined,
106108
components: Component<S, Metadata, undefined>[],
107109
limit: number = 100
108110
) => {
109-
let cursor = 0;
111+
let offset = 0;
110112
let continueFetching = true;
111113

112114
while (continueFetching) {
113-
const entities = await client.getAllEntities(limit, cursor);
115+
const entities = await client.getEntities({ limit, offset, clause });
114116

115117
setEntities(entities, components);
116118

117119
if (Object.keys(entities).length < limit) {
118120
continueFetching = false;
119121
} else {
120-
cursor += limit;
122+
offset += limit;
121123
}
122124
}
123125
};

0 commit comments

Comments
 (0)