Function onMessage

packages/browser-db-sqlite-persistence/src/opfs-database.ts:146–162

(event: Event)

  }

  const onMessage = (event: Event): void => {
    const messageEvent = event as MessageEvent<BrowserOPFSWorkerResponse>
    const response = messageEvent.data

    const pendingRequest = pendingRequests.get(response.requestId)
    if (!pendingRequest) {
      return
    }
    pendingRequests.delete(response.requestId)

    if (response.ok) {
      pendingRequest.resolve(response.rows ?? [])
      return
    }

    pendingRequest.reject(createWorkerError(response.code, response.error))
  }

  const onError = (): void => {
    rejectAllPendingRequests(