15f5d55075
Reviewed-on: https://gitea.coracle.social/coracle/flotilla/pulls/398 Co-authored-by: Coracle-Bot <npub1klq6260@nostr.local>
40 lines
1.5 KiB
TypeScript
40 lines
1.5 KiB
TypeScript
import type {Page} from "@playwright/test"
|
|
import type {TrustedEvent} from "@welshman/util"
|
|
|
|
// Must match the database name and the `events` table in src/app/storage.ts, which are scoped to
|
|
// one identity.
|
|
const databaseName = (pubkey: string) => `flotilla-9gl-${pubkey}`
|
|
|
|
/**
|
|
* What this user's client has written to disk so far. Events reach indexeddb in three-second
|
|
* batches with nothing in the ui to say when one has landed, so a spec about what survives a
|
|
* restart waits on this before it reloads.
|
|
*/
|
|
export const readCachedEvents = (page: Page, pubkey: string): Promise<TrustedEvent[]> =>
|
|
page.evaluate(async name => {
|
|
const open = await new Promise<IDBDatabase>((resolve, reject) => {
|
|
const request = indexedDB.open(name)
|
|
|
|
request.onsuccess = () => resolve(request.result)
|
|
request.onerror = () => reject(request.error)
|
|
})
|
|
|
|
// An unversioned open creates the database when it is missing, so a client that has not written
|
|
// anything yet has no store to read.
|
|
if (!open.objectStoreNames.contains("events")) {
|
|
open.close()
|
|
|
|
return []
|
|
}
|
|
|
|
const items = await new Promise<{event: TrustedEvent}[]>((resolve, reject) => {
|
|
const request = open.transaction("events", "readonly").objectStore("events").getAll()
|
|
|
|
request.onsuccess = () => resolve(request.result)
|
|
request.onerror = () => reject(request.error)
|
|
})
|
|
|
|
open.close()
|
|
|
|
return items.map(item => item.event)
|
|
}, databaseName(pubkey))
|