How to “fetch” all user stores info. in Cloudflare Durable Object with sql?

[gonza224]

Hi guys,
I’m using Tinybase for my Expo app, I'm using persistence through SQLite and synchronization with Cloudflare Durable Objects. Each authenticated client gets its own MergeableStore and is optionally synced over WebSocket.

What I want to achieve now is query all of the user information stored in the Durable Objects. Basically a “fetch everything” so I can list or aggregate user data. I've created an endpoint on the worker that basically listed the tables created on the durable's sql and got ["stores_tinybase_tables", "stores_tinybase_values"], but everything seems empty. (the synchronization and persistance is working fine, so i dont think it really is).

This is the important info. of my UsersStore.ts

const SYNC_SERVER_URL = process.env.EXPO_PUBLIC_SYNC_SERVER_URL;

if (!SYNC_SERVER_URL) {
    throw new Error(
        "Please set EXPO_PUBLIC_SYNC_SERVER_URL in .env to the URL of the sync server"
    );
}

const STORE_ID_PREFIX = "usersStore_";
const {
    ...
} = UiReact as UiReact.WithSchemas<[typeof USERS_TABLES_SCHEMA, NoValuesSchema]>;

export const getStoreId = (userId: string) => {
    const safeUserId = encodeURIComponent(userId);
    return STORE_ID_PREFIX + safeUserId;
};

function AuthenticatedStore({ user, children }: { user: AuthenticatedUser, children: React.ReactNode }) {
    const storeId = getStoreId(user.id);

    const store = useCreateMergeableStore(() =>
        createMergeableStore().setTablesSchema(USERS_TABLES_SCHEMA)
    );

    const persister = useCreatePersister(
        store as any,
        (storeInstance) =>
            Platform.OS === 'web'
                ? createLocalPersister(storeInstance, storeId)
                : createExpoSqlitePersister(storeInstance, SQLite.openDatabaseSync(`${storeId}.db`)),
        [storeId]
    );
   await persister.load();
   await persister.startAutoSave();
   
   synchronizer = await createWsSynchronizer(
       store,
       new ReconnectingWebSocket(SYNC_SERVER_URL + storeId, [], {
           maxReconnectionDelay: 1000,
           connectionTimeout: 1000,
       })
   );

   await synchronizer.startSync();

    useProvideStore(storeId, store);
    return <>{children}</>;
}


export default function UsersStore({ children }: { children: React.ReactNode }) {
    const { user } = useAuth();
    if (!user) {
        return <AppText>Authenticating...</AppText>;
    }

    return <AuthenticatedStore user={user}>{children}</AuthenticatedStore>;
}

Important info. of my cloudflare worker index.ts

type Schemas = [typeof USERS_TABLES_SCHEMA, NoValuesSchema];

export class SyncDurableObjectSql extends WsServerDurableObject<Schemas> {
  persister: DurableObjectSqlStoragePersister<Schemas> | undefined;
  store: MergeableStore<Schemas>;

  constructor(ctx: DurableObjectState, env: Env) {
    super(ctx, env);
    this.store = createMergeableStore().setTablesSchema(USERS_TABLES_SCHEMA);
    this.persister = this.createPersister();
  }

  createPersister() {
    return createDurableObjectSqlStoragePersister(this.store, this.ctx.storage.sql, {
      mode: "fragmented",
      storagePrefix: "stores_",
    });
  }
}

export default {
  fetch: getWsServerDurableObjectFetch("SyncDurableObjectSql"),
};

[gonza224]

@jamesgpearce Sorry to ping you like this, I noticed there was another discussion around a similar question that hasn’t had a reply yet.
This might be something straightforward, but since it’s my first time using TinyBase with Durable Objects, I wanted to check with you whether what I’m trying to achieve is actually possible before I go too far down the wrong path.