Function applyDelete

packages/platform/browser/src/IndexedDbQueryBuilder.ts:751–854

(query: IndexedDbQuery.Delete<any, never>)

  : never

const applyDelete = (query: IndexedDbQuery.Delete<any, never>) =>
  Effect.callback<any, IndexedDbQueryError>((resume) => {
    const database = query.delete.from.database
    const IDBKeyRange = query.delete.from.IDBKeyRange
    const transaction = getOrCreateTransaction(database.current, [query.delete.from.table.tableName], "readwrite", {
      durability: query.delete.from.table.durability
    })
    const objectStore = transaction.objectStore(query.delete.from.table.tableName)
    const store = query.delete.index === undefined ? objectStore : objectStore.index(query.delete.index)
    const predicate = query.predicate

    let keyRange: globalThis.IDBKeyRange | undefined = undefined

    if (query.only !== undefined) {
      keyRange = IDBKeyRange.only(query.only)
    } else if (
      query.lowerBound !== undefined &&
      query.upperBound !== undefined
    ) {
      keyRange = IDBKeyRange.bound(
        query.lowerBound,
        query.upperBound,
        query.excludeLowerBound,
        query.excludeUpperBound
      )
    } else if (query.lowerBound !== undefined) {
      keyRange = IDBKeyRange.lowerBound(
        query.lowerBound,
        query.excludeLowerBound
      )
    } else if (query.upperBound !== undefined) {
      keyRange = IDBKeyRange.upperBound(
        query.upperBound,
        query.excludeUpperBound
      )
    }

    let request: globalThis.IDBRequest

    if (query.delete.index !== undefined || query.limitValue !== undefined || predicate) {
      const cursorRequest = store.openCursor(keyRange)
      let count = 0

      cursorRequest.onerror = () => {
        resume(
          Effect.fail(
            new IndexedDbQueryError({
              reason: "TransactionError",
              cause: cursorRequest.error
            })
          )
        )
      }

      cursorRequest.onsuccess = () => {
        const cursor = cursorRequest.result
        if (cursor === null) {
          return resume(Effect.void)