Function createWrappedSyncConfig

packages/db-sqlite-persistence-core/src/persisted.ts:2201–2536

(
  sourceSyncConfig: SyncConfig<T, TKey>,
  runtime: PersistedCollectionRuntime<T, TKey>,
)

}

function createWrappedSyncConfig<
  T extends object,
  TKey extends string | number,
>(
  sourceSyncConfig: SyncConfig<T, TKey>,
  runtime: PersistedCollectionRuntime<T, TKey>,
): SyncConfig<T, TKey> {
  return {
    ...sourceSyncConfig,
    sync: (params) => {
      const transactionStack: Array<OpenSyncTransaction<T, TKey>> = []
      const getOpenTransaction = () =>
        transactionStack[transactionStack.length - 1]
      let fullStartPromise: Promise<void> | null = null
      const cancelledLoadKeys = new Set<string>()
      const loadSubscriptionIds = new WeakMap<object, string>()
      let nextLoadSubscriptionId = 0
      const getLoadKey = (options: LoadSubsetOptions) => {
        const subscription = options.subscription as object | undefined
        if (subscription && typeof subscription === `object`) {
          const existingId = loadSubscriptionIds.get(subscription)
          if (existingId) {
            return `sub:${existingId}`
          }
          nextLoadSubscriptionId++
          const nextId = String(nextLoadSubscriptionId)
          loadSubscriptionIds.set(subscription, nextId)
          return `sub:${nextId}`
        }

        return `opts:${stableSerialize(normalizeSubsetOptionsForKey(options))}`
      }
      runtime.setSyncControls({
        begin: params.begin,
        write: params.write as SyncControlFns<T, TKey>[`write`],
        commit: params.commit,
        truncate: params.truncate,
        metadata: params.metadata ?? null,
      })
      runtime.setCollection(
        params.collection as Collection<T, TKey, PersistedCollectionUtils>,
      )

      const wrappedParams = {
        ...params,
        markReady: () => {
          void (fullStartPromise ?? runtime.ensureStarted())
            .then(() => {
              params.markReady()
            })
            .catch((error) => {
              console.warn(
                `Failed persisted sync startup before markReady:`,
                error,
              )
              params.markReady()
            })
        },