skypod / src / client / util / signals.ts

import {ReadonlySignal, useSignal, useSignalEffect} from '@preact/signals'
import {liveQuery} from 'dexie'

export function useLiveQuery<T>(querier: () => Promise<T>): ReadonlySignal<T | undefined> {
  const signal = useSignal<T>()
  const observable = liveQuery(querier)

  useSignalEffect(() => {
    const subscription = observable.subscribe((value) => {
      signal.value = value
      console.debug('subscription updating')
    })

    return () => {
      subscription.unsubscribe()
      console.debug('subscription closing')
    }
  })

  return signal
}