Function mockSyncCollectionOptions

packages/db/tests/utils.ts:222–308

(config: MockSyncCollectionConfig<T>)

}

export function mockSyncCollectionOptions<
  T extends object = Record<string, unknown>,
>(config: MockSyncCollectionConfig<T>) {
  let begin: () => void
  let write: Parameters<SyncConfig<T>[`sync`]>[0][`write`]
  let commit: () => void

  let syncPendingPromise: Promise<void> | undefined
  let syncPendingResolve: (() => void) | undefined
  let syncPendingReject: ((error: Error) => void) | undefined

  const awaitSync = async () => {
    if (syncPendingPromise) {
      return syncPendingPromise
    }
    syncPendingPromise = new Promise((resolve, reject) => {
      syncPendingResolve = resolve
      syncPendingReject = reject
    })
    syncPendingPromise.then(() => {
      syncPendingPromise = undefined
      syncPendingResolve = undefined
      syncPendingReject = undefined
    })
    return syncPendingPromise
  }

  const utils = {
    begin: () => begin!(),
    write: ((value) => write!(value)) as typeof write,
    commit: () => commit!(),
    resolveSync: () => {
      syncPendingResolve!()
    },
    rejectSync: (error: Error) => {
      syncPendingReject!(error)
    },
  }

  const sync = config.sync ?? {
    sync: (params: Parameters<SyncConfig<T>[`sync`]>[0]) => {
      begin = params.begin
      write = params.write
      commit = params.commit
      const markReady = params.markReady

      begin()
      config.initialData.forEach((item) => {
        write({
          type: `insert`,
          value: item,
        })
      })
      commit()
      markReady()
    },
  }