bug-fixes

src/services/client-events.service.ts

@@ -245,6 +245,21 @@ export class EventService {
     return undefined
   }
 
+  /**
+   * IndexedDB publication store only (no session wait, no relay). Used to paint note stats before REQ.
+   */
+  async peekPublicationStoreEvent(hexId: string): Promise<NEvent | undefined> {
+    const id = hexId.trim().toLowerCase()
+    if (!/^[0-9a-f]{64}$/.test(id)) return undefined
+    const fromDb = await indexedDb.getEventFromPublicationStore(id)
+    if (fromDb && !shouldDropEventOnIngest(fromDb, { explicitNoteLookupHexId: id })) {
+      const ev = fromDb as NEvent
+      this.addEventToCache(ev, { explicitNoteLookupHexId: id })
+      return ev
+    }
+    return undefined
+  }
+
   /**
    * When a matching event is added to the session cache, invoke `callback` (and when already cached).
    * Supports hex / note1 / nevent1 and **naddr1** (replaceable coordinate: kind + pubkey + `d`).

src/services/note-stats.service.ts

@@ -187,6 +187,14 @@ class NoteStatsService {
     const eventId = this.statsKey(event.id)
     const foreground = opts?.foreground === true
 
+    /** Session LRU already has many reactions/replies/zaps — paint counts before relay batch runs. */
+    if (event.kind !== ExtendedKind.RSS_THREAD_ROOT) {
+      const preFromSession = eventService.getSessionEventsForNoteStatsTarget(event)
+      if (preFromSession.length > 0) {
+        this.updateNoteStatsByEvents(preFromSession, event.pubkey, { statsRootEvent: event })
+      }
+    }
+
     const rememberRoot = () => {
       if (event.kind === ExtendedKind.RSS_THREAD_ROOT) {
         this.pendingSyntheticRootById.set(eventId, event)
@@ -267,6 +275,14 @@ class NoteStatsService {
     }
     const hexIds = [...hexIdsSet]
 
+    for (const r of hexReplies) {
+      if (r.kind === ExtendedKind.RSS_THREAD_ROOT) continue
+      const pre = eventService.getSessionEventsForNoteStatsTarget(r)
+      if (pre.length > 0) {
+        this.updateNoteStatsByEvents(pre, r.pubkey)
+      }
+    }
+
     const markHexTargetsLoaded = () => {
       for (const id of hexIds) {
         this.touchStatsLoadedMarker(id)
@@ -458,7 +474,16 @@ class NoteStatsService {
       this.pendingSyntheticRootById.delete(eventId)
       const callerRoot = this.pendingStatsRootEventById.get(eventId)
       this.pendingStatsRootEventById.delete(eventId)
-      resolvedEvent = synthetic ?? callerRoot ?? (await eventService.fetchEvent(eventId))
+      resolvedEvent = synthetic ?? callerRoot
+      if (!resolvedEvent && this.hexNoteStatsIdRe.test(eventId)) {
+        resolvedEvent = eventService.peekSessionCachedEvent(eventId)
+      }
+      if (!resolvedEvent && this.hexNoteStatsIdRe.test(eventId)) {
+        resolvedEvent = await eventService.peekPublicationStoreEvent(eventId)
+      }
+      if (!resolvedEvent) {
+        resolvedEvent = await eventService.fetchEvent(eventId)
+      }
       if (!resolvedEvent) {
         markStatsLoaded(eventId)
         return