|
|
|
@ -1,372 +1,295 @@ |
|
|
|
|
|
|
|
import logger from '@/lib/logger' |
|
|
|
import { |
|
|
|
import { |
|
|
|
batchFetchPublicationSectionEvents, |
|
|
|
batchFetchPublicationSectionEvents, |
|
|
|
buildPublicationSectionRelayUrls, |
|
|
|
buildPublicationSectionRelayUrls, |
|
|
|
|
|
|
|
parsePublicationATagCoordinate, |
|
|
|
publicationRefKey, |
|
|
|
publicationRefKey, |
|
|
|
resolvePublicationEventIdToHex, |
|
|
|
resolvePublicationEventIdToHex, |
|
|
|
type PublicationSectionRef |
|
|
|
type PublicationSectionRef |
|
|
|
} from '@/lib/publication-section-fetch' |
|
|
|
} from '@/lib/publication-section-fetch' |
|
|
|
import { generateBech32IdFromATag } from '@/lib/tag' |
|
|
|
import { eventService, queryService } from '@/services/client.service' |
|
|
|
import { isReplaceableEvent } from '@/lib/event' |
|
|
|
|
|
|
|
import client from '@/services/client.service' |
|
|
|
|
|
|
|
import { eventService } from '@/services/client.service' |
|
|
|
|
|
|
|
import logger from '@/lib/logger' |
|
|
|
|
|
|
|
import indexedDb from '@/services/indexed-db.service' |
|
|
|
import indexedDb from '@/services/indexed-db.service' |
|
|
|
import type { Event } from 'nostr-tools' |
|
|
|
import type { Event } from 'nostr-tools' |
|
|
|
import { useCallback, useEffect, useMemo, useRef, useState } from 'react' |
|
|
|
import { useCallback, useEffect, useMemo, useRef, useState } from 'react' |
|
|
|
|
|
|
|
|
|
|
|
const PUB_SEC_LOG = '[PublicationSection]' |
|
|
|
type LoadStatus = 'idle' | 'loading' | 'loaded' | 'error' |
|
|
|
const SINGLE_REF_FALLBACK_TIMEOUT_MS = 7000 |
|
|
|
|
|
|
|
function pubLog(message: string, data?: Record<string, unknown>) { |
|
|
|
|
|
|
|
if (!import.meta.env.DEV) return |
|
|
|
|
|
|
|
if (data) logger.info(`${PUB_SEC_LOG} ${message}`, data) |
|
|
|
|
|
|
|
else logger.info(`${PUB_SEC_LOG} ${message}`) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
export type SectionLoadStatus = 'idle' | 'loading' | 'loaded' | 'error' |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
export type PublicationSectionRow = { |
|
|
|
type Row = PublicationSectionRef & { |
|
|
|
ref: PublicationSectionRef |
|
|
|
key: string |
|
|
|
status: SectionLoadStatus |
|
|
|
|
|
|
|
event?: Event |
|
|
|
event?: Event |
|
|
|
|
|
|
|
status: LoadStatus |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
function refKey(ref: PublicationSectionRef): string { |
|
|
|
type CachedState = { |
|
|
|
return publicationRefKey(ref) |
|
|
|
loaded: Map<string, Event> |
|
|
|
|
|
|
|
failed: Set<string> |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
async function hydrateRefsFromIndexedDb(refs: PublicationSectionRef[]): Promise<Map<string, Event>> { |
|
|
|
const indexCache = new Map<string, CachedState>() |
|
|
|
const out = new Map<string, Event>() |
|
|
|
const SINGLE_REF_TIMEOUT_MS = 6_000 |
|
|
|
for (const ref of refs) { |
|
|
|
|
|
|
|
const key = refKey(ref) |
|
|
|
|
|
|
|
if (!key) continue |
|
|
|
|
|
|
|
try { |
|
|
|
|
|
|
|
if (ref.type === 'a' && ref.coordinate) { |
|
|
|
|
|
|
|
const ev = await indexedDb.getPublicationEvent(ref.coordinate) |
|
|
|
|
|
|
|
if (ev) out.set(key, ev) |
|
|
|
|
|
|
|
} else if (ref.type === 'e' && ref.eventId) { |
|
|
|
|
|
|
|
const hex = resolvePublicationEventIdToHex(ref.eventId) |
|
|
|
|
|
|
|
if (!hex) continue |
|
|
|
|
|
|
|
let ev = await indexedDb.getEventFromPublicationStore(hex) |
|
|
|
|
|
|
|
if (!ev && ref.kind != null && ref.pubkey && isReplaceableEvent(ref.kind)) { |
|
|
|
|
|
|
|
const rep = await indexedDb.getReplaceableEvent(ref.pubkey, ref.kind) |
|
|
|
|
|
|
|
if (rep && rep.id === hex) ev = rep |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if (ev) out.set(key, ev) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} catch { |
|
|
|
|
|
|
|
/* ignore per-ref */ |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return out |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async function fetchSingleRefFallback(ref: PublicationSectionRef): Promise<Event | undefined> { |
|
|
|
function withTimeout<T>(p: Promise<T>, ms: number): Promise<T> { |
|
|
|
const withTimeout = <T,>(p: Promise<T>, ms: number): Promise<T | undefined> => |
|
|
|
return new Promise<T>((resolve, reject) => { |
|
|
|
new Promise((resolve) => { |
|
|
|
const timer = window.setTimeout(() => reject(new Error('timeout')), ms) |
|
|
|
const t = setTimeout(() => resolve(undefined), ms) |
|
|
|
p.then( |
|
|
|
p.then((v) => resolve(v)).catch(() => resolve(undefined)).finally(() => clearTimeout(t)) |
|
|
|
(v) => { |
|
|
|
}) |
|
|
|
clearTimeout(timer) |
|
|
|
try { |
|
|
|
resolve(v) |
|
|
|
if (ref.type === 'a' && ref.coordinate) { |
|
|
|
}, |
|
|
|
const bech32 = generateBech32IdFromATag(['a', ref.coordinate, ref.relay || '', '']) |
|
|
|
(err) => { |
|
|
|
if (bech32) return await withTimeout(eventService.fetchEvent(bech32), SINGLE_REF_FALLBACK_TIMEOUT_MS) |
|
|
|
clearTimeout(timer) |
|
|
|
} |
|
|
|
reject(err) |
|
|
|
if (ref.type === 'e' && ref.eventId) { |
|
|
|
|
|
|
|
return await withTimeout(eventService.fetchEvent(ref.eventId), SINGLE_REF_FALLBACK_TIMEOUT_MS) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} catch { |
|
|
|
|
|
|
|
/* ignore */ |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
return undefined |
|
|
|
) |
|
|
|
|
|
|
|
}) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
function signatureOfRefs(refs: PublicationSectionRef[]): string { |
|
|
|
* Lazy publication sections: debounced batched REQ (chunked `ids` + grouped `authors`/`kinds`/`#d`), |
|
|
|
return refs.map((r) => publicationRefKey(r)).join('|') |
|
|
|
* IndexedDB first, capped relay list. Call {@link requestKeys} from IntersectionObserver. |
|
|
|
|
|
|
|
*/ |
|
|
|
|
|
|
|
export function usePublicationSectionLoader(indexEvent: Event, referencesData: PublicationSectionRef[]) { |
|
|
|
|
|
|
|
const orderedKeys = useMemo(() => { |
|
|
|
|
|
|
|
const keys: string[] = [] |
|
|
|
|
|
|
|
for (const r of referencesData) { |
|
|
|
|
|
|
|
const k = refKey(r) |
|
|
|
|
|
|
|
if (k) keys.push(k) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
return keys |
|
|
|
|
|
|
|
}, [referencesData]) |
|
|
|
|
|
|
|
const orderedKeysSignature = useMemo(() => orderedKeys.join('|'), [orderedKeys]) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const [rows, setRows] = useState<Map<string, PublicationSectionRow>>(() => new Map()) |
|
|
|
export function usePublicationSectionLoader(indexEvent: Event, refs: PublicationSectionRef[]) { |
|
|
|
const rowsRef = useRef(rows) |
|
|
|
const indexId = indexEvent.id |
|
|
|
rowsRef.current = rows |
|
|
|
const refsSignature = useMemo(() => signatureOfRefs(refs), [refs]) |
|
|
|
|
|
|
|
const [relayUrls, setRelayUrls] = useState<string[]>([]) |
|
|
|
|
|
|
|
const [rows, setRows] = useState<Row[]>([]) |
|
|
|
|
|
|
|
const inflightKeysRef = useRef<Set<string>>(new Set()) |
|
|
|
|
|
|
|
const autoLoadedSignatureRef = useRef<string | null>(null) |
|
|
|
|
|
|
|
|
|
|
|
useEffect(() => { |
|
|
|
useEffect(() => { |
|
|
|
// Preserve per-key load state across rerenders to avoid reinitializing rows to idle
|
|
|
|
const cached = indexCache.get(indexId) ?? { loaded: new Map(), failed: new Set() } |
|
|
|
// when parent components recreate reference objects.
|
|
|
|
const next: Row[] = [] |
|
|
|
setRows((prev) => { |
|
|
|
for (const ref of refs) { |
|
|
|
const next = new Map<string, PublicationSectionRow>() |
|
|
|
const key = publicationRefKey(ref) |
|
|
|
for (const ref of referencesData) { |
|
|
|
if (!key) continue |
|
|
|
const k = refKey(ref) |
|
|
|
const cachedEvent = cached.loaded.get(key) |
|
|
|
if (!k) continue |
|
|
|
if (cachedEvent) { |
|
|
|
const existing = prev.get(k) |
|
|
|
next.push({ ...ref, key, event: cachedEvent, status: 'loaded' }) |
|
|
|
if (existing) { |
|
|
|
continue |
|
|
|
next.set(k, { ...existing, ref }) |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
next.set(k, { ref, status: 'idle' }) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (cached.failed.has(key)) { |
|
|
|
|
|
|
|
next.push({ ...ref, key, status: 'error' }) |
|
|
|
|
|
|
|
continue |
|
|
|
} |
|
|
|
} |
|
|
|
return next |
|
|
|
next.push({ ...ref, key, status: 'idle' }) |
|
|
|
}) |
|
|
|
} |
|
|
|
}, [orderedKeysSignature, referencesData]) |
|
|
|
setRows(next) |
|
|
|
|
|
|
|
}, [indexId, refsSignature, refs]) |
|
|
|
const relayUrlsRef = useRef<string[]>([]) |
|
|
|
|
|
|
|
const searchableRelayUrlsRef = useRef<string[]>([]) |
|
|
|
|
|
|
|
const [relayReady, setRelayReady] = useState(false) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
useEffect(() => { |
|
|
|
useEffect(() => { |
|
|
|
let cancelled = false |
|
|
|
let cancelled = false |
|
|
|
void (async () => { |
|
|
|
;(async () => { |
|
|
|
const [urls, searchableUrls] = await Promise.all([ |
|
|
|
const primary = await buildPublicationSectionRelayUrls(indexEvent, refs, 22, false) |
|
|
|
buildPublicationSectionRelayUrls(indexEvent, referencesData, 22, false), |
|
|
|
if (cancelled) return |
|
|
|
buildPublicationSectionRelayUrls(indexEvent, referencesData, 40, true) |
|
|
|
if (primary.length > 0) { |
|
|
|
]) |
|
|
|
setRelayUrls(primary) |
|
|
|
|
|
|
|
return |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
const fallback = await buildPublicationSectionRelayUrls(indexEvent, refs, 30, true) |
|
|
|
if (cancelled) return |
|
|
|
if (cancelled) return |
|
|
|
relayUrlsRef.current = urls |
|
|
|
setRelayUrls(fallback) |
|
|
|
searchableRelayUrlsRef.current = searchableUrls |
|
|
|
})().catch((err) => { |
|
|
|
setRelayReady(true) |
|
|
|
if (import.meta.env.DEV) { |
|
|
|
})() |
|
|
|
logger.warn('[PublicationSection] relay_build_failed', { |
|
|
|
|
|
|
|
indexId, |
|
|
|
|
|
|
|
message: err instanceof Error ? err.message : String(err) |
|
|
|
|
|
|
|
}) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if (!cancelled) setRelayUrls([]) |
|
|
|
|
|
|
|
}) |
|
|
|
return () => { |
|
|
|
return () => { |
|
|
|
cancelled = true |
|
|
|
cancelled = true |
|
|
|
} |
|
|
|
} |
|
|
|
}, [indexEvent.id, orderedKeysSignature]) |
|
|
|
}, [indexId, refsSignature, indexEvent, refs]) |
|
|
|
|
|
|
|
|
|
|
|
const pendingRef = useRef(new Set<string>()) |
|
|
|
|
|
|
|
const debounceTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null) |
|
|
|
|
|
|
|
const flushInFlightRef = useRef(false) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const runFlush = useCallback(async () => { |
|
|
|
const applyLoadedAndFailed = useCallback( |
|
|
|
if (flushInFlightRef.current) return |
|
|
|
(loaded: Map<string, Event>, failedKeys: string[]) => { |
|
|
|
const keys = [...pendingRef.current] |
|
|
|
const cached = indexCache.get(indexId) ?? { loaded: new Map(), failed: new Set() } |
|
|
|
pendingRef.current.clear() |
|
|
|
for (const [k, ev] of loaded) { |
|
|
|
if (keys.length === 0) return |
|
|
|
cached.loaded.set(k, ev) |
|
|
|
|
|
|
|
cached.failed.delete(k) |
|
|
|
flushInFlightRef.current = true |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
|
|
|
const snapshot = rowsRef.current |
|
|
|
|
|
|
|
const refsToLoad: PublicationSectionRef[] = [] |
|
|
|
|
|
|
|
for (const k of keys) { |
|
|
|
|
|
|
|
const row = snapshot.get(k) |
|
|
|
|
|
|
|
if (!row) continue |
|
|
|
|
|
|
|
// Auto-queue should only process idle rows.
|
|
|
|
|
|
|
|
// - loaded rows are done
|
|
|
|
|
|
|
|
// - loading rows are already in-flight
|
|
|
|
|
|
|
|
// - error rows require explicit retry via retry button
|
|
|
|
|
|
|
|
if (row.status !== 'idle') continue |
|
|
|
|
|
|
|
refsToLoad.push(row.ref) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
for (const k of failedKeys) { |
|
|
|
|
|
|
|
if (!loaded.has(k)) cached.failed.add(k) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
indexCache.set(indexId, cached) |
|
|
|
|
|
|
|
|
|
|
|
if (refsToLoad.length === 0) return |
|
|
|
setRows((prev) => |
|
|
|
|
|
|
|
prev.map((row) => { |
|
|
|
pubLog('flush_start', { |
|
|
|
const ev = loaded.get(row.key) |
|
|
|
keys: refsToLoad.map((r) => refKey(r)), |
|
|
|
if (ev) return { ...row, event: ev, status: 'loaded' as const } |
|
|
|
relayCount: relayUrlsRef.current.length |
|
|
|
if (failedKeys.includes(row.key)) return { ...row, status: 'error' as const } |
|
|
|
|
|
|
|
if (inflightKeysRef.current.has(row.key)) return { ...row, status: 'loading' as const } |
|
|
|
|
|
|
|
return row |
|
|
|
}) |
|
|
|
}) |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
}, |
|
|
|
|
|
|
|
[indexId] |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
setRows((prev) => { |
|
|
|
const runFetch = useCallback( |
|
|
|
const next = new Map(prev) |
|
|
|
async (keys: string[]) => { |
|
|
|
for (const ref of refsToLoad) { |
|
|
|
const selectedRows = rows.filter((r) => keys.includes(r.key)) |
|
|
|
const k = refKey(ref) |
|
|
|
if (selectedRows.length === 0) return |
|
|
|
const row = next.get(k) |
|
|
|
|
|
|
|
if (row) next.set(k, { ...row, status: 'loading' }) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return next |
|
|
|
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const urls = relayUrlsRef.current |
|
|
|
const byDb = new Map<string, Event>() |
|
|
|
const resolved = new Map<string, Event>() |
|
|
|
const stillNeed: Row[] = [] |
|
|
|
|
|
|
|
|
|
|
|
// Always hydrate from IDB — do not gate on relay URLs (they resolve async after first IO batch).
|
|
|
|
await Promise.all( |
|
|
|
const fromDb = await hydrateRefsFromIndexedDb(refsToLoad) |
|
|
|
selectedRows.map(async (row) => { |
|
|
|
for (const [k, ev] of fromDb) { |
|
|
|
try { |
|
|
|
resolved.set(k, ev) |
|
|
|
let ev: Event | undefined |
|
|
|
client.addEventToCache(ev) |
|
|
|
if (row.type === 'e' && row.eventId) { |
|
|
|
|
|
|
|
const hex = resolvePublicationEventIdToHex(row.eventId) |
|
|
|
|
|
|
|
if (hex) ev = await indexedDb.getEventFromPublicationStore(hex) |
|
|
|
|
|
|
|
} else if (row.coordinate) { |
|
|
|
|
|
|
|
ev = await indexedDb.getPublicationEvent(row.coordinate) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if (ev) byDb.set(row.key, ev) |
|
|
|
|
|
|
|
else stillNeed.push(row) |
|
|
|
|
|
|
|
} catch { |
|
|
|
|
|
|
|
stillNeed.push(row) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
let stillNeed = refsToLoad.filter((r) => !resolved.has(refKey(r))) |
|
|
|
|
|
|
|
pubLog('after_idb', { |
|
|
|
|
|
|
|
fromDb: fromDb.size, |
|
|
|
|
|
|
|
stillNeed: stillNeed.map((r) => ({ key: refKey(r), type: r.type })) |
|
|
|
|
|
|
|
}) |
|
|
|
}) |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
// No relay list yet: apply DB hits only, re-queue the rest (do not mark error).
|
|
|
|
if (import.meta.env.DEV) { |
|
|
|
if (urls.length === 0 && stillNeed.length > 0) { |
|
|
|
logger.info('[PublicationSection] after_idb', { |
|
|
|
for (const r of stillNeed) pendingRef.current.add(refKey(r)) |
|
|
|
fromDb: byDb.size, |
|
|
|
pubLog('defer_net_until_relays', { reQueued: stillNeed.length }) |
|
|
|
stillNeed: stillNeed.map((r) => r.key) |
|
|
|
setRows((prev) => { |
|
|
|
|
|
|
|
const next = new Map(prev) |
|
|
|
|
|
|
|
for (const ref of refsToLoad) { |
|
|
|
|
|
|
|
const k = refKey(ref) |
|
|
|
|
|
|
|
const row = next.get(k) |
|
|
|
|
|
|
|
if (!row) continue |
|
|
|
|
|
|
|
const ev = resolved.get(k) |
|
|
|
|
|
|
|
if (ev) next.set(k, { ...row, event: ev, status: 'loaded' }) |
|
|
|
|
|
|
|
else next.set(k, { ...row, status: 'idle', event: undefined }) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return next |
|
|
|
|
|
|
|
}) |
|
|
|
}) |
|
|
|
return |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (urls.length > 0 && stillNeed.length > 0) { |
|
|
|
let fromNet = new Map<string, Event>() |
|
|
|
const fromNet = await batchFetchPublicationSectionEvents(stillNeed, urls) |
|
|
|
if (stillNeed.length > 0 && relayUrls.length > 0) { |
|
|
|
pubLog('after_batch_fetch', { fromNet: fromNet.size }) |
|
|
|
fromNet = await batchFetchPublicationSectionEvents(stillNeed, relayUrls) |
|
|
|
for (const [k, ev] of fromNet) { |
|
|
|
if (import.meta.env.DEV) { |
|
|
|
resolved.set(k, ev) |
|
|
|
logger.info('[PublicationSection] after_batch_fetch', { fromNet: fromNet.size }) |
|
|
|
client.addEventToCache(ev) |
|
|
|
|
|
|
|
if (isReplaceableEvent(ev.kind)) void indexedDb.putReplaceableEvent(ev) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
stillNeed = refsToLoad.filter((r) => !resolved.has(refKey(r))) |
|
|
|
const merged = new Map<string, Event>([...byDb, ...fromNet]) |
|
|
|
if (stillNeed.length > 0) { |
|
|
|
const unresolved = stillNeed.filter((r) => !merged.has(r.key)) |
|
|
|
const searchableUrls = searchableRelayUrlsRef.current |
|
|
|
const bySingle = new Map<string, Event>() |
|
|
|
const hasAdditionalSearchable = searchableUrls.some((u) => !urls.includes(u)) |
|
|
|
|
|
|
|
if (hasAdditionalSearchable) { |
|
|
|
await Promise.all( |
|
|
|
const fromSearchFallback = await batchFetchPublicationSectionEvents(stillNeed, searchableUrls) |
|
|
|
unresolved.map(async (row) => { |
|
|
|
pubLog('after_searchable_fallback', { |
|
|
|
try { |
|
|
|
fromSearchFallback: fromSearchFallback.size, |
|
|
|
if (row.type === 'e' && row.eventId) { |
|
|
|
stillNeedBefore: stillNeed.length, |
|
|
|
const ev = await withTimeout( |
|
|
|
relayCount: searchableUrls.length |
|
|
|
eventService.fetchEvent(row.eventId), |
|
|
|
}) |
|
|
|
SINGLE_REF_TIMEOUT_MS |
|
|
|
for (const [k, ev] of fromSearchFallback) { |
|
|
|
) |
|
|
|
resolved.set(k, ev) |
|
|
|
if (ev) bySingle.set(row.key, ev) |
|
|
|
client.addEventToCache(ev) |
|
|
|
return |
|
|
|
if (isReplaceableEvent(ev.kind)) void indexedDb.putReplaceableEvent(ev) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (row.coordinate) { |
|
|
|
|
|
|
|
const parsed = parsePublicationATagCoordinate(row.coordinate) |
|
|
|
|
|
|
|
if (!parsed) return |
|
|
|
|
|
|
|
const relaysToTry = row.relay ? [row.relay] : relayUrls |
|
|
|
|
|
|
|
const ev = await withTimeout( |
|
|
|
|
|
|
|
queryService |
|
|
|
|
|
|
|
.fetchEvents( |
|
|
|
|
|
|
|
relaysToTry, |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
authors: [parsed.pubkey], |
|
|
|
|
|
|
|
kinds: [parsed.kind], |
|
|
|
|
|
|
|
'#d': [parsed.identifier], |
|
|
|
|
|
|
|
limit: 1 |
|
|
|
|
|
|
|
}, |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
globalTimeout: 6_000, |
|
|
|
|
|
|
|
eoseTimeout: 1_500 |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
.then((arr) => arr[0]), |
|
|
|
|
|
|
|
SINGLE_REF_TIMEOUT_MS |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
if (ev) bySingle.set(row.key, ev) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} catch { |
|
|
|
const missing = refsToLoad.filter((r) => !resolved.has(refKey(r))) |
|
|
|
// unresolved single-ref fallback
|
|
|
|
pubLog('before_fallback', { |
|
|
|
|
|
|
|
missing: missing.map((r) => refKey(r)), |
|
|
|
|
|
|
|
relayUrlsEmpty: urls.length === 0 |
|
|
|
|
|
|
|
}) |
|
|
|
|
|
|
|
await Promise.all( |
|
|
|
|
|
|
|
missing.map(async (ref) => { |
|
|
|
|
|
|
|
const k = refKey(ref) |
|
|
|
|
|
|
|
const ev = await fetchSingleRefFallback(ref) |
|
|
|
|
|
|
|
if (ev) { |
|
|
|
|
|
|
|
resolved.set(k, ev) |
|
|
|
|
|
|
|
client.addEventToCache(ev) |
|
|
|
|
|
|
|
if (isReplaceableEvent(ev.kind)) void indexedDb.putReplaceableEvent(ev) |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
}) |
|
|
|
}) |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
const failed = refsToLoad.filter((r) => !resolved.has(refKey(r))) |
|
|
|
for (const [k, ev] of bySingle) merged.set(k, ev) |
|
|
|
pubLog('flush_done', { |
|
|
|
|
|
|
|
loaded: refsToLoad.length - failed.length, |
|
|
|
|
|
|
|
failed: failed.map((r) => ({ |
|
|
|
|
|
|
|
key: refKey(r), |
|
|
|
|
|
|
|
type: r.type, |
|
|
|
|
|
|
|
coordinate: r.coordinate, |
|
|
|
|
|
|
|
eventId: r.eventId |
|
|
|
|
|
|
|
})) |
|
|
|
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
setRows((prev) => { |
|
|
|
const failed = selectedRows |
|
|
|
const next = new Map(prev) |
|
|
|
.map((r) => r.key) |
|
|
|
for (const ref of refsToLoad) { |
|
|
|
.filter((k) => !merged.has(k)) |
|
|
|
const k = refKey(ref) |
|
|
|
|
|
|
|
const row = next.get(k) |
|
|
|
|
|
|
|
if (!row) continue |
|
|
|
|
|
|
|
const ev = resolved.get(k) |
|
|
|
|
|
|
|
if (ev) { |
|
|
|
|
|
|
|
next.set(k, { ...row, event: ev, status: 'loaded' }) |
|
|
|
|
|
|
|
} else { |
|
|
|
|
|
|
|
next.set(k, { ...row, status: 'error', event: undefined }) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
return next |
|
|
|
|
|
|
|
}) |
|
|
|
|
|
|
|
} finally { |
|
|
|
|
|
|
|
flushInFlightRef.current = false |
|
|
|
|
|
|
|
// While a batch was in flight, debounced runFlush() calls may have returned early
|
|
|
|
|
|
|
|
// (flush lock). Drain any keys that accumulated so scroll-triggered sections still load.
|
|
|
|
|
|
|
|
// IMPORTANT: if relay URLs are not ready yet, do NOT spin in a tight retry loop.
|
|
|
|
|
|
|
|
// The relayReady effect will trigger requestKeys() once relays are available.
|
|
|
|
|
|
|
|
if (pendingRef.current.size > 0 && relayUrlsRef.current.length > 0) { |
|
|
|
|
|
|
|
if (debounceTimerRef.current) clearTimeout(debounceTimerRef.current) |
|
|
|
|
|
|
|
debounceTimerRef.current = setTimeout(() => { |
|
|
|
|
|
|
|
debounceTimerRef.current = null |
|
|
|
|
|
|
|
void runFlush() |
|
|
|
|
|
|
|
}, 0) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
}, []) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const requestKeys = useCallback( |
|
|
|
applyLoadedAndFailed(merged, failed) |
|
|
|
(keys: string[]) => { |
|
|
|
|
|
|
|
for (const k of keys) { |
|
|
|
|
|
|
|
if (k) pendingRef.current.add(k) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
if (debounceTimerRef.current) clearTimeout(debounceTimerRef.current) |
|
|
|
|
|
|
|
debounceTimerRef.current = setTimeout(() => { |
|
|
|
|
|
|
|
debounceTimerRef.current = null |
|
|
|
|
|
|
|
void runFlush() |
|
|
|
|
|
|
|
}, 56) |
|
|
|
|
|
|
|
}, |
|
|
|
}, |
|
|
|
[runFlush] |
|
|
|
[applyLoadedAndFailed, relayUrls, rows] |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
useEffect(() => { |
|
|
|
const requestKeys = useCallback( |
|
|
|
if (!relayReady || orderedKeys.length === 0) return |
|
|
|
(keys: string[]) => { |
|
|
|
// Full list: scroll-IO may have fired before relays were ready; those keys were re-queued idle.
|
|
|
|
const unique = [...new Set(keys.filter(Boolean))] |
|
|
|
requestKeys(orderedKeys) |
|
|
|
if (unique.length === 0) return |
|
|
|
}, [relayReady, orderedKeysSignature, requestKeys]) |
|
|
|
const eligible = rows.filter((r) => unique.includes(r.key) && r.status !== 'loaded' && r.status !== 'loading') |
|
|
|
|
|
|
|
if (eligible.length === 0) return |
|
|
|
|
|
|
|
|
|
|
|
const failedKeys = useMemo( |
|
|
|
const keysToLoad = eligible.map((r) => r.key) |
|
|
|
() => [...rows.entries()].filter(([, v]) => v.status === 'error').map(([k]) => k), |
|
|
|
for (const k of keysToLoad) inflightKeysRef.current.add(k) |
|
|
|
[rows] |
|
|
|
setRows((prev) => prev.map((r) => (keysToLoad.includes(r.key) ? { ...r, status: 'loading' } : r))) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void runFetch(keysToLoad).finally(() => { |
|
|
|
|
|
|
|
for (const k of keysToLoad) inflightKeysRef.current.delete(k) |
|
|
|
|
|
|
|
}) |
|
|
|
|
|
|
|
}, |
|
|
|
|
|
|
|
[rows, runFetch] |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
const retryKeys = useCallback( |
|
|
|
const retryKeys = useCallback( |
|
|
|
(keys: string[]) => { |
|
|
|
(keys: string[]) => { |
|
|
|
setRows((prev) => { |
|
|
|
const unique = [...new Set(keys.filter(Boolean))] |
|
|
|
const next = new Map(prev) |
|
|
|
if (unique.length === 0) return |
|
|
|
for (const k of keys) { |
|
|
|
const cached = indexCache.get(indexId) |
|
|
|
const row = next.get(k) |
|
|
|
if (cached) { |
|
|
|
if (row) next.set(k, { ...row, status: 'idle', event: undefined }) |
|
|
|
for (const key of unique) cached.failed.delete(key) |
|
|
|
} |
|
|
|
} |
|
|
|
return next |
|
|
|
setRows((prev) => |
|
|
|
}) |
|
|
|
prev.map((r) => (unique.includes(r.key) && r.status !== 'loaded' ? { ...r, status: 'idle' } : r)) |
|
|
|
requestKeys(keys) |
|
|
|
) |
|
|
|
|
|
|
|
requestKeys(unique) |
|
|
|
}, |
|
|
|
}, |
|
|
|
[requestKeys] |
|
|
|
[indexId, requestKeys] |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
const referencesWithEvents = useMemo(() => { |
|
|
|
useEffect(() => { |
|
|
|
return orderedKeys.map((k) => { |
|
|
|
if (relayUrls.length === 0) return |
|
|
|
const row = rows.get(k) |
|
|
|
const sig = `${indexId}:${refsSignature}` |
|
|
|
const ref = row?.ref ?? referencesData.find((r) => refKey(r) === k)! |
|
|
|
if (autoLoadedSignatureRef.current === sig) return |
|
|
|
return { |
|
|
|
autoLoadedSignatureRef.current = sig |
|
|
|
type: ref.type, |
|
|
|
const idleKeys = rows.filter((r) => r.status === 'idle').map((r) => r.key) |
|
|
|
coordinate: ref.coordinate, |
|
|
|
if (idleKeys.length > 0) { |
|
|
|
eventId: ref.eventId, |
|
|
|
if (import.meta.env.DEV) { |
|
|
|
kind: ref.kind, |
|
|
|
logger.info('[PublicationSection] flush_start', { keys: idleKeys, relayCount: relayUrls.length }) |
|
|
|
pubkey: ref.pubkey, |
|
|
|
} |
|
|
|
identifier: ref.identifier, |
|
|
|
requestKeys(idleKeys) |
|
|
|
relay: ref.relay, |
|
|
|
} |
|
|
|
event: row?.event, |
|
|
|
}, [indexId, refsSignature, relayUrls, rows, requestKeys]) |
|
|
|
loadStatus: row?.status ?? 'idle' |
|
|
|
|
|
|
|
} |
|
|
|
const referencesWithEvents = useMemo( |
|
|
|
}) |
|
|
|
() => |
|
|
|
}, [orderedKeys, rows, referencesData]) |
|
|
|
rows.map((row) => ({ |
|
|
|
|
|
|
|
...row, |
|
|
|
|
|
|
|
loadStatus: row.status |
|
|
|
|
|
|
|
})), |
|
|
|
|
|
|
|
[rows] |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const failedKeys = useMemo( |
|
|
|
|
|
|
|
() => |
|
|
|
|
|
|
|
rows |
|
|
|
|
|
|
|
.filter((r) => r.status === 'error') |
|
|
|
|
|
|
|
.map((r) => r.key), |
|
|
|
|
|
|
|
[rows] |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
|
return { |
|
|
|
return { |
|
|
|
orderedKeys, |
|
|
|
|
|
|
|
rows, |
|
|
|
|
|
|
|
relayReady, |
|
|
|
|
|
|
|
requestKeys, |
|
|
|
requestKeys, |
|
|
|
retryKeys, |
|
|
|
retryKeys, |
|
|
|
failedKeys, |
|
|
|
failedKeys, |
|
|
|
|
