dedupe SyncProgress

packages/store-sync/src/stash/common.ts → packages/store-sync/src/SyncProgress.ts

@@ -1,7 +1,13 @@
 import { defineTable } from "@latticexyz/store/internal";
-import { SyncStep } from "../SyncStep";
 import { getSchemaPrimitives, getValueSchema } from "@latticexyz/protocol-parser/internal";
 
+export enum SyncStep {
+  INITIALIZE = "initialize",
+  SNAPSHOT = "snapshot",
+  RPC = "rpc",
+  LIVE = "live",
+}
+
 export const SyncProgress = defineTable({
   namespaceLabel: "syncToStash",
   label: "SyncProgress",

packages/store-sync/src/index.ts

@@ -1,7 +1,7 @@
 export * from "./common";
 export * from "./configToTables";
 export * from "./createStoreSync";
-export * from "./SyncStep";
+export * from "./SyncProgress";
 export * from "./isTableRegistrationLog";
 export * from "./logToTable";
 export * from "./tablesWithRecordsToLogs";

packages/store-sync/src/recs/createSyncAdapter.ts

@@ -48,6 +48,9 @@ export function createSyncAdapter<const config extends StoreConfig>({
           latestBlockNumber,
           lastBlockNumberProcessed,
           message,
+          __staticData: undefined,
+          __encodedLengths: undefined,
+          __dynamicData: undefined,
         });
 
         // when we switch to live, trigger update for all entities in all components

packages/store-sync/src/recs/defineInternalComponents.ts

@@ -1,19 +1,13 @@
-import { World, defineComponent, Type, Component, Schema, Metadata } from "@latticexyz/recs";
+import { World } from "@latticexyz/recs";
+import { tablesToComponents } from "./tablesToComponents";
+import { SyncProgress } from "../SyncProgress";
 
-export type InternalComponents = ReturnType<typeof defineInternalComponents>;
+export type InternalComponents = tablesToComponents<{
+  SyncProgress: typeof SyncProgress;
+}>;
 
-export function defineInternalComponents(world: World) {
-  return {
-    SyncProgress: defineComponent(
-      world,
-      {
-        step: Type.String,
-        message: Type.String,
-        percentage: Type.Number,
-        latestBlockNumber: Type.BigInt,
-        lastBlockNumberProcessed: Type.BigInt,
-      },
-      { metadata: { componentName: "SyncProgress" } },
-    ),
-  } as const satisfies Record<string, Component<Schema, Metadata>>;
+export function defineInternalComponents(world: World): InternalComponents {
+  return tablesToComponents(world, {
+    SyncProgress,
+  });
 }

packages/store-sync/src/recs/syncToRecs.ts

@@ -52,6 +52,9 @@ export async function syncToRecs<const config extends StoreConfig, const extraTa
         latestBlockNumber,
         lastBlockNumberProcessed,
         message,
+        __staticData: undefined,
+        __encodedLengths: undefined,
+        __dynamicData: undefined,
       });
 
       // when we switch to live, trigger update for all entities in all components

packages/store-sync/src/stash/createSyncAdapter.ts

@@ -1,9 +1,8 @@
 import { getRecord, setRecord, registerTable, Stash } from "@latticexyz/stash/internal";
 import { createStorageAdapter } from "./createStorageAdapter";
-import { SyncStep } from "../SyncStep";
 import { SyncAdapter } from "../common";
 import { createStoreSync } from "../createStoreSync";
-import { SyncProgress } from "./common";
+import { SyncProgress, SyncStep } from "../SyncProgress";
 
 export type CreateSyncAdapterOptions = { stash: Stash };