Function summarizeBatch

test/unit/persisters/powersync.test.ts:38–51

(
  powerSync: PowerSyncDatabase,
)

};

const summarizeBatch = async (
  powerSync: PowerSyncDatabase,
): Promise<[CrudSummary[], (() => Promise<void>)?]> => {
  const batch = await powerSync.getCrudBatch();
  return [
    batch?.crud.map(({op, table, id, opData}) => ({
      op,
      table,
      id,
      opData,
    })) ?? [],
    batch?.complete,
  ];
};

const completeNextBatch = async (powerSync: PowerSyncDatabase) =>
  (await summarizeBatch(powerSync))[1]?.();