Function loadStoreFromStorage

src/persisters/persister-partykit-server/index.ts:64–87

(
  storage: Storage,
  storagePrefix = EMPTY_STRING,
)

): Promise<boolean> => !!(await storage.get<1>(storagePrefix + HAS_STORE));

export const loadStoreFromStorage = async (
  storage: Storage,
  storagePrefix = EMPTY_STRING,
): Promise<Content> => {
  const tables: Tables = {};
  const values: Values = {};
  mapForEach(
    await storage.list<string | number | boolean>(),
    (key, cellOrValue) =>
      ifNotUndefined(deconstruct(storagePrefix, key), ([type, ids]) => {
        if (type == T) {
          const [tableId, rowId, cellId] = jsonParse('[' + ids + ']');
          objEnsure(
            objEnsure(tables, tableId, objNew<Row>),
            rowId,
            objNew<Cell>,
          )[cellId] = cellOrValue;
        } else if (type == V) {
          values[ids] = cellOrValue;
        }
      }),
  );
  return [tables, values];
};

export const broadcastChanges = async (
  server: TinyBasePartyKitServer,