Function mockSyncCollectionOptionsNoInitialState

packages/db/tests/utils.ts:318–396

(config: MockSyncCollectionConfigNoInitialState<T>)

}

export function mockSyncCollectionOptionsNoInitialState<
  T extends object = Record<string, unknown>,
>(config: MockSyncCollectionConfigNoInitialState<T>) {
  let begin: () => void
  let write: Parameters<SyncConfig<T>[`sync`]>[0][`write`]
  let commit: () => void
  let markReady: () => void
  let truncate: () => 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!(),
    markReady: () => markReady!(),
    truncate: () => truncate!(),
    resolveSync: () => {
      syncPendingResolve!()
    },
    rejectSync: (error: Error) => {
      syncPendingReject!(error)
    },
  }

  const options: CollectionConfig<T, string | number, never> & {
    utils: typeof utils
  } = {
    sync: {
      sync: (params: Parameters<SyncConfig<T>[`sync`]>[0]) => {
        begin = params.begin
        write = params.write
        commit = params.commit
        markReady = params.markReady
        truncate = params.truncate
      },
    },
    startSync: false,
    onInsert: async (_params: MutationFnParams<T>) => {
      // TODO