Function trailBaseCollectionOptions

packages/trailbase-db-collection/src/trailbase.ts:121–431

(
  config: TrailBaseCollectionConfig<TItem, TRecord, TKey>,
)

}

export function trailBaseCollectionOptions<
  TItem extends ShapeOf<TRecord>,
  TRecord extends ShapeOf<TItem> = TItem,
  TKey extends string | number = string | number,
>(
  config: TrailBaseCollectionConfig<TItem, TRecord, TKey>,
): CollectionConfig<TItem, TKey, never, TrailBaseCollectionUtils> & {
  utils: TrailBaseCollectionUtils
} {
  const getKey = config.getKey

  const parse = (record: TRecord) =>
    convert<TRecord, TItem>(config.parse, record)
  const serialUpd = (item: Partial<TItem>) =>
    convertPartial<TItem, TRecord>(config.serialize, item)
  const serialIns = (item: TItem) =>
    convert<TItem, TRecord>(config.serialize, item)

  const seenIds = new Store(new Map<string, number>())

  const internalSyncMode = config.syncMode ?? `eager`
  let fullSyncCompleted = false

  const awaitIds = (
    ids: Array<string>,
    timeout: number = 120 * 1000,
  ): Promise<void> => {
    const completed = (value: Map<string, number>) =>
      ids.every((id) => value.has(id))
    if (completed(seenIds.state)) {
      return Promise.resolve()
    }

    return new Promise<void>((resolve, reject) => {
      const timeoutId = setTimeout(() => {
        sub.unsubscribe()
        reject(new TimeoutWaitingForIdsError(ids.toString()))
      }, timeout)

      const sub = seenIds.subscribe((value) => {
        if (completed(value)) {
          clearTimeout(timeoutId)
          sub.unsubscribe()
          resolve()
        }
      })
    })
  }

  let eventReader: ReadableStreamDefaultReader<Event> | undefined
  const cancelEventReader = () => {
    if (eventReader) {
      eventReader.cancel()
      eventReader.releaseLock()
      eventReader = undefined
    }
  }