From 1ae1f24c41af838264cf5ca6c6629c3d7eff56a4 Mon Sep 17 00:00:00 2001
From: Silberengel <silberengel7@protonmail.com>
Date: Tue, 28 Oct 2025 21:09:48 +0100
Subject: [PATCH] more performance fixes

---
 src/PageManager.tsx                           |   38 +-
 src/components/Embedded/EmbeddedNote.tsx      |    6 +-
 src/components/NoteList/index.tsx             |  112 +-
 src/components/NoteOptions/useMenuActions.tsx |   24 +-
 src/components/NotificationList/index.tsx     |   51 +-
 .../Profile/ProfileBookmarksAndHashtags.tsx   |   18 +-
 src/components/SimpleNoteFeed/index.tsx       |   22 +-
 src/lib/logger.ts                             |   38 +-
 src/pages/primary/NoteListPage/RelaysFeed.tsx |    6 +-
 src/pages/secondary/NotePage/NotFound.tsx     |    4 +-
 src/providers/BookmarksProvider.tsx           |    5 +-
 src/providers/FeedProvider.tsx                |   10 +-
 src/providers/InterestListProvider.tsx        |   35 +-
 src/providers/NostrProvider/index.tsx         |    8 +-
 src/providers/NotificationProvider.tsx        |   16 +-
 src/services/client.service.ts                | 1106 ++++-------------
 src/services/note-stats.service.ts            |    1 +
 17 files changed, 471 insertions(+), 1029 deletions(-)

diff --git a/src/PageManager.tsx b/src/PageManager.tsx
index 42704d1..0464e82 100644
--- a/src/PageManager.tsx
+++ b/src/PageManager.tsx
@@ -614,15 +614,18 @@ export function PageManager({ maxStackSize = 5 }: { maxStackSize?: number }) {
 
 
   const pushSecondaryPage = (url: string, index?: number) => {
-    console.log('pushSecondaryPage called with:', url)
+    logger.component('PageManager', 'pushSecondaryPage called', { url })
     setSecondaryStack((prevStack) => {
-      console.log('Current secondary stack length:', prevStack.length)
+      logger.component('PageManager', 'Current secondary stack length', { length: prevStack.length })
       
       // For relay pages, clear the stack and start fresh to avoid confusion
       if (url.startsWith('/relays/')) {
-        console.log('Clearing stack for relay navigation')
+        logger.component('PageManager', 'Clearing stack for relay navigation')
         const { newStack, newItem } = pushNewPageToStack([], url, maxStackSize, 0)
-        console.log('New stack length:', newStack.length, 'New item:', !!newItem)
+        logger.component('PageManager', 'New stack created', { 
+          newStackLength: newStack.length, 
+          hasNewItem: !!newItem 
+        })
         if (newItem) {
           window.history.pushState({ index: newItem.index, url }, '', url)
         }
@@ -630,7 +633,7 @@ export function PageManager({ maxStackSize = 5 }: { maxStackSize?: number }) {
       }
       
       if (isCurrentPage(prevStack, url)) {
-        console.log('Page already exists, scrolling to top')
+        logger.component('PageManager', 'Page already exists, scrolling to top')
         const currentItem = prevStack[prevStack.length - 1]
         if (currentItem?.ref?.current) {
           currentItem.ref.current.scrollToTop('instant')
@@ -638,9 +641,12 @@ export function PageManager({ maxStackSize = 5 }: { maxStackSize?: number }) {
         return prevStack
       }
 
-      console.log('Creating new page for URL:', url)
+      logger.component('PageManager', 'Creating new page for URL', { url })
       const { newStack, newItem } = pushNewPageToStack(prevStack, url, maxStackSize, index)
-      console.log('New stack length:', newStack.length, 'New item:', !!newItem)
+      logger.component('PageManager', 'New page created', { 
+        newStackLength: newStack.length, 
+        hasNewItem: !!newItem 
+      })
       if (newItem) {
         window.history.pushState({ index: newItem.index, url }, '', url)
       }
@@ -715,7 +721,7 @@ export function PageManager({ maxStackSize = 5 }: { maxStackSize?: number }) {
                 {!!secondaryStack.length &&
                   secondaryStack.map((item, index) => {
                     const isLast = index === secondaryStack.length - 1
-                    console.log('Rendering secondary stack item:', { 
+                    logger.component('PageManager', 'Rendering secondary stack item', { 
                       index, 
                       isLast, 
                       url: item.url, 
@@ -788,7 +794,7 @@ export function PageManager({ maxStackSize = 5 }: { maxStackSize?: number }) {
                   <div className="flex-1 overflow-auto">
                     {secondaryStack.map((item, index) => {
                       const isLast = index === secondaryStack.length - 1
-                      console.log('Rendering desktop secondary stack item:', { 
+                      logger.component('PageManager', 'Rendering desktop secondary stack item', { 
                         index, 
                         isLast, 
                         url: item.url, 
@@ -861,21 +867,21 @@ function isCurrentPage(stack: TStackItem[], url: string) {
   const currentPage = stack[stack.length - 1]
   if (!currentPage) return false
 
-  console.log('isCurrentPage check:', { currentUrl: currentPage.url, newUrl: url, match: currentPage.url === url })
+  logger.component('PageManager', 'isCurrentPage check', { currentUrl: currentPage.url, newUrl: url, match: currentPage.url === url })
   return currentPage.url === url
 }
 
 function findAndCreateComponent(url: string, index: number) {
   const path = url.split('?')[0].split('#')[0]
-  console.log('findAndCreateComponent called with:', { url, path, routes: routes.length })
+  logger.component('PageManager', 'findAndCreateComponent called', { url, path, routes: routes.length })
   
   for (const { matcher, element } of routes) {
     const match = matcher(path)
-    console.log('Trying route matcher, match result:', !!match)
+    logger.component('PageManager', 'Trying route matcher', { matchResult: !!match })
     if (!match) continue
 
     if (!element) {
-      console.log('No element for this route')
+      logger.component('PageManager', 'No element for this route')
       return {}
     }
     const ref = createRef<TPageRef>()
@@ -884,13 +890,13 @@ function findAndCreateComponent(url: string, index: number) {
     const params = { ...match.params }
     if (params.url && typeof params.url === 'string') {
       params.url = decodeURIComponent(params.url)
-      console.log('Decoded URL parameter:', params.url)
+      logger.component('PageManager', 'Decoded URL parameter', { url: params.url })
     }
     
-    console.log('Creating component with params:', params)
+    logger.component('PageManager', 'Creating component with params', params)
     return { component: cloneElement(element, { ...params, index, ref } as any), ref }
   }
-  console.log('No matching route found for:', path)
+  logger.component('PageManager', 'No matching route found', { path })
   return {}
 }
 
diff --git a/src/components/Embedded/EmbeddedNote.tsx b/src/components/Embedded/EmbeddedNote.tsx
index 67d6448..1db5793 100644
--- a/src/components/Embedded/EmbeddedNote.tsx
+++ b/src/components/Embedded/EmbeddedNote.tsx
@@ -25,12 +25,12 @@ export function EmbeddedNote({ noteId, className }: { noteId: string; className?
       setRetryCount(prev => prev + 1)
       
       client.fetchEventForceRetry(noteId)
-        .then((retryResult) => {
+        .then((retryResult: any) => {
           if (retryResult) {
             setRetryEvent(retryResult)
           }
         })
-        .catch((error) => {
+        .catch((error: any) => {
           console.warn(`Retry ${retryCount + 1}/${maxRetries} failed for event:`, noteId, error)
         })
         .finally(() => {
@@ -137,7 +137,7 @@ function EmbeddedNoteNotFound({
     
     setIsSearchingExternal(true)
     try {
-      const event = await client.fetchEventWithExternalRelays(noteId)
+      const event = await client.fetchEventWithExternalRelays(noteId, [])
       if (event && onEventFound) {
         onEventFound(event)
       }
diff --git a/src/components/NoteList/index.tsx b/src/components/NoteList/index.tsx
index 2633076..48cb871 100644
--- a/src/components/NoteList/index.tsx
+++ b/src/components/NoteList/index.tsx
@@ -83,22 +83,8 @@ const NoteList = forwardRef(
         // Check if this is a profile feed
         const isProfileFeed = subRequests.some(req => req.filter.authors && req.filter.authors.length === 1)
         
-        console.log('🔍 [NoteList] Checking shouldHideEvent for:', { 
-          id: evt.id, 
-          kind: evt.kind, 
-          pubkey: evt.pubkey.substring(0, 8),
-          isDeleted: isEventDeleted(evt),
-          isReply: isReplyNoteEvent(evt),
-          isTrusted: isUserTrusted(evt.pubkey),
-          isMuted: mutePubkeySet.has(evt.pubkey),
-          hideReplies,
-          hideUntrustedNotes,
-          filterMutedNotes,
-          isProfileFeed
-        })
-        
         if (isEventDeleted(evt)) {
-          console.log('❌ [NoteList] Event deleted:', evt.id)
+          logger.component('NoteList', 'Event filtered: deleted', { id: evt.id, kind: evt.kind })
           return true
         }
         
@@ -109,20 +95,24 @@ const NoteList = forwardRef(
           // For profile feeds, show all zaps from the profile owner
           // For timeline feeds, filter by threshold
           if (!isProfileFeed && zapInfo && zapInfo.amount < zapReplyThreshold) {
-            console.log('❌ [NoteList] Zap below threshold:', { id: evt.id, amount: zapInfo.amount, threshold: zapReplyThreshold })
+            logger.component('NoteList', 'Event filtered: zap below threshold', { 
+              id: evt.id, 
+              amount: zapInfo.amount, 
+              threshold: zapReplyThreshold 
+            })
             return true
           }
         } else if (hideReplies && isReplyNoteEvent(evt)) {
-          console.log('❌ [NoteList] Reply hidden:', evt.id)
+          logger.component('NoteList', 'Event filtered: reply hidden', { id: evt.id, kind: evt.kind })
           return true
         }
         
         if (hideUntrustedNotes && !isUserTrusted(evt.pubkey)) {
-          console.log('❌ [NoteList] Untrusted user:', evt.id)
+          logger.component('NoteList', 'Event filtered: untrusted user', { id: evt.id, pubkey: evt.pubkey.substring(0, 8) })
           return true
         }
         if (filterMutedNotes && mutePubkeySet.has(evt.pubkey)) {
-          console.log('❌ [NoteList] Muted user:', evt.id)
+          logger.component('NoteList', 'Event filtered: muted user', { id: evt.id, pubkey: evt.pubkey.substring(0, 8) })
           return true
         }
         if (
@@ -130,11 +120,10 @@ const NoteList = forwardRef(
           hideContentMentioningMutedUsers &&
           isMentioningMutedUsers(evt, mutePubkeySet)
         ) {
-          console.log('❌ [NoteList] Mentions muted users:', evt.id)
+          logger.component('NoteList', 'Event filtered: mentions muted users', { id: evt.id, kind: evt.kind })
           return true
         }
 
-        console.log('✅ [NoteList] Event passed all filters:', evt.id)
         return false
       },
       [hideReplies, hideUntrustedNotes, mutePubkeySet, isEventDeleted, zapReplyThreshold, subRequests]
@@ -142,34 +131,30 @@ const NoteList = forwardRef(
 
     const filteredEvents = useMemo(() => {
       const idSet = new Set<string>()
-      
-      console.log('🔍 [NoteList] Filtering events:', {
-        totalEvents: events.length,
-        showCount,
-        eventKinds: events.map(e => e.kind).slice(0, 10)
-      })
+      const startTime = performance.now()
 
       const filtered = events.slice(0, showCount).filter((evt) => {
         if (shouldHideEvent(evt)) {
-          console.log('❌ [NoteList] Event hidden:', { id: evt.id, kind: evt.kind, reason: 'shouldHideEvent' })
           return false
         }
 
         const id = isReplaceableEvent(evt.kind) ? getReplaceableCoordinateFromEvent(evt) : evt.id
         if (idSet.has(id)) {
-          console.log('❌ [NoteList] Event hidden:', { id: evt.id, kind: evt.kind, reason: 'duplicate' })
+          logger.component('NoteList', 'Event filtered: duplicate', { id: evt.id, kind: evt.kind })
           return false
         }
         idSet.add(id)
         return true
       })
-      
-      console.log('✅ [NoteList] Filtered events result:', { 
-        total: events.length, 
-        filtered: filtered.length,
-        showCount 
+
+      const endTime = performance.now()
+      logger.perfComponent('NoteList', 'Event filtering completed', {
+        totalEvents: events.length,
+        filteredEvents: filtered.length,
+        showCount,
+        duration: `${(endTime - startTime).toFixed(2)}ms`
       })
-      
+
       return filtered
     }, [events, showCount, shouldHideEvent])
 
@@ -200,7 +185,7 @@ const NoteList = forwardRef(
       scrollToTop()
       // Clear relay connection state to force fresh connections
       const relayUrls = subRequests.flatMap(req => req.urls)
-      client.clearRelayConnectionState(relayUrls)
+      relayUrls.forEach(url => client.clearRelayConnectionState(url))
       setTimeout(() => {
         setRefreshCount((count) => count + 1)
       }, 500)
@@ -209,32 +194,32 @@ const NoteList = forwardRef(
     useImperativeHandle(ref, () => ({ scrollToTop, refresh }), [])
 
   useEffect(() => {
-    console.log('🚀 [NoteList] useEffect triggered:', { 
+    logger.component('NoteList', 'useEffect triggered', { 
       subRequests: subRequests.length, 
       showKinds: showKinds.length,
       refreshCount 
     })
-    logger.debug('NoteList useEffect:', { subRequests, subRequestsLength: subRequests.length })
+    
     if (!subRequests.length) {
-      console.log('❌ [NoteList] No subRequests, returning early')
+      logger.component('NoteList', 'No subRequests, returning early')
       return
     }
     
     // Don't initialize if showKinds is empty (still loading from provider)
     if (showKinds.length === 0) {
-      console.log('⏳ [NoteList] showKinds is empty, waiting for provider to initialize')
+      logger.component('NoteList', 'showKinds is empty, waiting for provider to initialize')
       return
     }
 
     async function init() {
-        console.log('🔄 [NoteList] Initializing feed...')
+        logger.component('NoteList', 'Initializing feed')
         setLoading(true)
         setEvents([])
         setNewEvents([])
         setHasMore(true)
 
         if (showKinds.length === 0) {
-          logger.warn('NoteList: showKinds is empty, no events will be displayed')
+          logger.component('NoteList', 'showKinds is empty, no events will be displayed')
           setLoading(false)
           setHasMore(false)
           return () => {}
@@ -249,24 +234,17 @@ const NoteList = forwardRef(
           }
         }))
         
-        console.log('[NoteList] Subscribing to timeline with:', finalFilters)
-        console.log('[NoteList] showKinds:', showKinds)
-        
         const { closer, timelineKey } = await client.subscribeTimeline(
           finalFilters,
           {
             onEvents: (events, eosed) => {
-              console.log('📥 [NoteList] Received events:', { 
+              logger.component('NoteList', 'Received events from relay', { 
                 eventsCount: events.length, 
                 eosed,
-                loading,
-                hasMore,
-                eventKinds: events.map(e => e.kind).slice(0, 10), // First 10 event kinds
-                showKinds
+                eventKinds: [...new Set(events.map(e => e.kind))].slice(0, 5)
               })
-              logger.debug('NoteList received events:', { eventsCount: events.length, eosed })
+              
               if (events.length > 0) {
-                console.log('✅ [NoteList] Accumulating events from relay')
                 setEvents(prevEvents => {
                   // For profile feeds, accumulate events from all relays
                   // For timeline feeds, replace events
@@ -276,16 +254,19 @@ const NoteList = forwardRef(
                     // Accumulate events, removing duplicates
                     const existingIds = new Set(prevEvents.map(e => e.id))
                     const newEvents = events.filter(e => !existingIds.has(e.id))
-                    const combined = [...prevEvents, ...newEvents]
-                    console.log('📊 [NoteList] Profile feed - accumulated:', { 
-                      previous: prevEvents.length, 
-                      new: events.length, 
+                    logger.component('NoteList', 'Profile feed - accumulating events', {
+                      previous: prevEvents.length,
+                      new: events.length,
                       unique: newEvents.length,
-                      total: combined.length 
+                      total: prevEvents.length + newEvents.length
                     })
-                    return combined
+                    return [...prevEvents, ...newEvents]
                   } else {
                     // Timeline feed - replace events
+                    logger.component('NoteList', 'Timeline feed - replacing events', {
+                      previous: prevEvents.length,
+                      new: events.length
+                    })
                     return events
                   }
                 })
@@ -296,7 +277,10 @@ const NoteList = forwardRef(
                 setHasMore(false)
               }
               if (eosed) {
-                console.log('🏁 [NoteList] EOSED - setting loading false, hasMore:', events.length > 0)
+                logger.component('NoteList', 'EOSED - all relays finished', {
+                  eventsCount: events.length,
+                  hasMore: events.length > 0
+                })
                 setLoading(false)
                 setHasMore(events.length > 0)
               }
@@ -315,7 +299,7 @@ const NoteList = forwardRef(
               }
             },
             onClose: (url, reason) => {
-              logger.debug('Relay connection closed:', { url, reason })
+              logger.component('NoteList', 'Relay connection closed', { url, reason })
               if (!showRelayCloseReason) return
               // ignore reasons from nostr-tools
               if (
@@ -344,7 +328,7 @@ const NoteList = forwardRef(
         const fallbackTimeout = setTimeout(() => {
           if (loading) {
             setLoading(false)
-            logger.debug('NoteList loading timeout - stopping after 15 seconds')
+            logger.component('NoteList', 'Loading timeout - stopping after 15 seconds')
           }
         }, 15000)
         
@@ -419,7 +403,7 @@ const NoteList = forwardRef(
       }, 0)
     }
 
-    console.log('🎨 [NoteList] Rendering with state:', {
+    logger.component('NoteList', 'Rendering with state', {
       eventsCount: events.length,
       filteredEventsCount: filteredEvents.length,
       loading,
@@ -447,10 +431,10 @@ const NoteList = forwardRef(
         ) : (
           <div className="flex justify-center w-full mt-2">
             <Button size="lg" onClick={() => {
-              console.log('🔄 [NoteList] Reload button clicked, refreshing feed')
+              logger.component('NoteList', 'Reload button clicked, refreshing feed')
               // Clear relay connection state to force fresh connections
               const relayUrls = subRequests.flatMap(req => req.urls)
-              client.clearRelayConnectionState(relayUrls)
+              relayUrls.forEach(url => client.clearRelayConnectionState(url))
               setRefreshCount((count) => count + 1)
             }}>
               {t('reload notes')}
diff --git a/src/components/NoteOptions/useMenuActions.tsx b/src/components/NoteOptions/useMenuActions.tsx
index b2abd83..436080d 100644
--- a/src/components/NoteOptions/useMenuActions.tsx
+++ b/src/components/NoteOptions/useMenuActions.tsx
@@ -1,6 +1,7 @@
 import { ExtendedKind } from '@/constants'
 import { getNoteBech32Id, isProtectedEvent, getRootEventHexId } from '@/lib/event'
 import { toNjump } from '@/lib/link'
+import logger from '@/lib/logger'
 import { pubkeyToNpub } from '@/lib/pubkey'
 import { normalizeUrl, simplifyUrl } from '@/lib/url'
 import { useCurrentRelays } from '@/providers/CurrentRelaysProvider'
@@ -97,7 +98,7 @@ export function useMenuActions({
           })
           pinListEvent = pinListEvents[0] || null
         } catch (error) {
-          console.warn('[PinStatus] Error fetching pin list from comprehensive relays, falling back to default method:', error)
+          logger.component('PinStatus', 'Error fetching pin list from comprehensive relays, falling back to default method', { error: (error as Error).message })
           pinListEvent = await client.fetchPinListEvent(pubkey)
         }
         
@@ -106,7 +107,7 @@ export function useMenuActions({
           setIsPinned(isEventPinned)
         }
       } catch (error) {
-        console.error('Error checking pin status:', error)
+        logger.component('PinStatus', 'Error checking pin status', { error: (error as Error).message })
       }
     }
     checkIfPinned()
@@ -141,11 +142,11 @@ export function useMenuActions({
         })
         pinListEvent = pinListEvents[0] || null
       } catch (error) {
-        console.warn('[PinNote] Error fetching pin list from comprehensive relays, falling back to default method:', error)
+        logger.component('PinNote', 'Error fetching pin list from comprehensive relays, falling back to default method', { error: (error as Error).message })
         pinListEvent = await client.fetchPinListEvent(pubkey)
       }
       
-      console.log('[PinNote] Current pin list event:', pinListEvent)
+      logger.component('PinNote', 'Current pin list event', { hasEvent: !!pinListEvent })
       
       // Get existing event IDs, excluding the one we're toggling
       const existingEventIds = (pinListEvent?.tags || [])
@@ -153,9 +154,9 @@ export function useMenuActions({
         .map(tag => tag[1])
         .filter(id => id !== event.id)
       
-      console.log('[PinNote] Existing event IDs (excluding current):', existingEventIds)
-      console.log('[PinNote] Current event ID:', event.id)
-      console.log('[PinNote] Is currently pinned:', isPinned)
+      logger.component('PinNote', 'Existing event IDs (excluding current)', { count: existingEventIds.length })
+      logger.component('PinNote', 'Current event ID', { eventId: event.id })
+      logger.component('PinNote', 'Is currently pinned', { isPinned })
       
       let newTags: string[][]
       let successMessage: string
@@ -164,17 +165,16 @@ export function useMenuActions({
         // Unpin: just keep the existing tags without this event
         newTags = existingEventIds.map(id => ['e', id])
         successMessage = t('Note unpinned')
-        console.log('[PinNote] Unpinning - new tags:', newTags)
+        logger.component('PinNote', 'Unpinning - new tags', { count: newTags.length })
       } else {
         // Pin: add this event to the existing list
         newTags = [...existingEventIds.map(id => ['e', id]), ['e', event.id]]
         successMessage = t('Note pinned')
-        console.log('[PinNote] Pinning - new tags:', newTags)
+        logger.component('PinNote', 'Pinning - new tags', { count: newTags.length })
       }
       
       // Create and publish the new pin list event
-      console.log('[PinNote] Publishing new pin list event with', newTags.length, 'tags')
-      console.log('[PinNote] Publishing to comprehensive relays:', comprehensiveRelays)
+      logger.component('PinNote', 'Publishing new pin list event', { tagCount: newTags.length, relayCount: comprehensiveRelays.length })
       await publish({
         kind: 10001,
         tags: newTags,
@@ -189,7 +189,7 @@ export function useMenuActions({
       toast.success(successMessage)
       closeDrawer()
     } catch (error) {
-      console.error('Error pinning/unpinning note:', error)
+      logger.component('PinNote', 'Error pinning/unpinning note', { error: (error as Error).message })
       toast.error(t('Failed to pin note'))
     }
   }
diff --git a/src/components/NotificationList/index.tsx b/src/components/NotificationList/index.tsx
index 4ebc1a6..7c6c74f 100644
--- a/src/components/NotificationList/index.tsx
+++ b/src/components/NotificationList/index.tsx
@@ -1,5 +1,6 @@
 import { ExtendedKind, NOTIFICATION_LIST_STYLE, FAST_READ_RELAY_URLS } from '@/constants'
 import { compareEvents } from '@/lib/event'
+import logger from '@/lib/logger'
 import { usePrimaryPage } from '@/PageManager'
 import { useNostr } from '@/providers/NostrProvider'
 import { useNotification } from '@/providers/NotificationProvider'
@@ -134,44 +135,36 @@ const NotificationList = forwardRef((_, ref) => {
       if (userReadRelays.length > 0) {
         // Priority 1: User's read/inbox relays (kind 10002)
         primaryRelays = userReadRelays.slice(0, 5)
-        console.debug('[NotificationList] Using user read relays:', primaryRelays.length, 'relays')
+        logger.component('NotificationList', 'Using user read relays', { 
+          count: primaryRelays.length, 
+          relays: primaryRelays.slice(0, 3) // Show first 3 for brevity
+        })
       } else if (userFavoriteRelays.length > 0) {
         // Priority 2: User's favorite relays (kind 10012)
         primaryRelays = userFavoriteRelays.slice(0, 5)
-        console.debug('[NotificationList] Using user favorite relays:', primaryRelays.length, 'relays')
+        logger.component('NotificationList', 'Using user favorite relays', { 
+          count: primaryRelays.length, 
+          relays: primaryRelays.slice(0, 3) // Show first 3 for brevity
+        })
       } else {
         // Priority 3: Fast read relays (reliable defaults)
         primaryRelays = FAST_READ_RELAY_URLS.slice(0, 5)
-        console.debug('[NotificationList] Using fast read relays fallback:', primaryRelays.length, 'relays')
-      }
-
-      // Create separate subscriptions for different notification types
-      const subscriptions = []
-      
-      // Subscription for mentions (events where user is in p-tags)
-      const mentionKinds = filterKinds.filter(kind => kind !== 11)
-      if (mentionKinds.length > 0) {
-        subscriptions.push({
-          urls: primaryRelays,
-          filter: {
-            '#p': [pubkey],
-            kinds: mentionKinds,
-            limit: LIMIT
-          }
-        })
-      }
-      
-      // Separate subscription for discussion notifications (kind 11) - no p-tag requirement
-      if (filterKinds.includes(11)) {
-        subscriptions.push({
-          urls: primaryRelays,
-          filter: {
-            kinds: [11],
-            limit: LIMIT
-          }
+        logger.component('NotificationList', 'Using fast read relays fallback', { 
+          count: primaryRelays.length, 
+          relays: primaryRelays.slice(0, 3) // Show first 3 for brevity
         })
       }
 
+      // Create a single optimized subscription for all notification types
+      const subscriptions = [{
+        urls: primaryRelays,
+        filter: {
+          kinds: filterKinds,
+          limit: LIMIT,
+          '#p': [pubkey] // Always filter for mentions to the current user
+        }
+      }]
+
       const { closer, timelineKey } = await client.subscribeTimeline(
         subscriptions,
         {
diff --git a/src/components/Profile/ProfileBookmarksAndHashtags.tsx b/src/components/Profile/ProfileBookmarksAndHashtags.tsx
index c3eebe8..a5ab146 100644
--- a/src/components/Profile/ProfileBookmarksAndHashtags.tsx
+++ b/src/components/Profile/ProfileBookmarksAndHashtags.tsx
@@ -74,7 +74,7 @@ export default function ProfileBookmarksAndHashtags({
         })
         bookmarkList = bookmarkListEvents[0] || null
       } catch (error) {
-        console.warn('[ProfileBookmarksAndHashtags] Error fetching bookmark list from comprehensive relays, falling back to default method:', error)
+        logger.component('ProfileBookmarksAndHashtags', 'Error fetching bookmark list from comprehensive relays, falling back to default method', { error: (error as Error).message })
         bookmarkList = await client.fetchBookmarkListEvent(pubkey)
       }
       
@@ -110,7 +110,7 @@ export default function ProfileBookmarksAndHashtags({
         setBookmarkEvents([])
       }
     } catch (error) {
-      console.error('[ProfileBookmarksAndHashtags] Error fetching bookmarks:', error)
+      logger.component('ProfileBookmarksAndHashtags', 'Error fetching bookmarks', { error: (error as Error).message })
       setBookmarkEvents([])
     } finally {
       setLoadingBookmarks(false)
@@ -133,7 +133,7 @@ export default function ProfileBookmarksAndHashtags({
         })
         interestList = interestListEvents[0] || null
       } catch (error) {
-        console.warn('[ProfileBookmarksAndHashtags] Error fetching interest list from comprehensive relays, falling back to default method:', error)
+        logger.component('ProfileBookmarksAndHashtags', 'Error fetching interest list from comprehensive relays, falling back to default method', { error: (error as Error).message })
         interestList = await client.fetchInterestListEvent(pubkey)
       }
       
@@ -143,8 +143,8 @@ export default function ProfileBookmarksAndHashtags({
       if (interestList && interestList.tags.length > 0) {
         // Extract hashtags from interest list
         const hashtags = interestList.tags
-          .filter(tag => tag[0] === 't' && tag[1])
-          .map(tag => tag[1])
+          .filter((tag: string[]) => tag[0] === 't' && tag[1])
+          .map((tag: string[]) => tag[1])
         
         // console.log('[ProfileBookmarksAndHashtags] Found', hashtags.length, 'interest hashtags:', hashtags)
         
@@ -159,7 +159,7 @@ export default function ProfileBookmarksAndHashtags({
             // console.log('[ProfileBookmarksAndHashtags] Fetched', events.length, 'hashtag events')
             setHashtagEvents(events)
           } catch (error) {
-            console.warn('[ProfileBookmarksAndHashtags] Error fetching hashtag events:', error)
+            logger.component('ProfileBookmarksAndHashtags', 'Error fetching hashtag events', { error: (error as Error).message })
             setHashtagEvents([])
           }
         } else {
@@ -169,7 +169,7 @@ export default function ProfileBookmarksAndHashtags({
         setHashtagEvents([])
       }
     } catch (error) {
-      console.error('[ProfileBookmarksAndHashtags] Error fetching hashtags:', error)
+      logger.component('ProfileBookmarksAndHashtags', 'Error fetching hashtags', { error: (error as Error).message })
       setHashtagEvents([])
     } finally {
       setLoadingHashtags(false)
@@ -192,7 +192,7 @@ export default function ProfileBookmarksAndHashtags({
         })
         pinList = pinListEvents[0] || null
       } catch (error) {
-        console.warn('[ProfileBookmarksAndHashtags] Error fetching pin list from comprehensive relays, falling back to default method:', error)
+        logger.component('ProfileBookmarksAndHashtags', 'Error fetching pin list from comprehensive relays, falling back to default method', { error: (error as Error).message })
         pinList = await client.fetchPinListEvent(pubkey)
       }
       
@@ -228,7 +228,7 @@ export default function ProfileBookmarksAndHashtags({
         setPinEvents([])
       }
     } catch (error) {
-      console.error('[ProfileBookmarksAndHashtags] Error fetching pins:', error)
+      logger.component('ProfileBookmarksAndHashtags', 'Error fetching pins', { error: (error as Error).message })
       setPinEvents([])
     } finally {
       setLoadingPins(false)
diff --git a/src/components/SimpleNoteFeed/index.tsx b/src/components/SimpleNoteFeed/index.tsx
index 1f04e1a..e56b79b 100644
--- a/src/components/SimpleNoteFeed/index.tsx
+++ b/src/components/SimpleNoteFeed/index.tsx
@@ -63,12 +63,11 @@ const SimpleNoteFeed = forwardRef<
     setIsRefreshing(true)
     
     try {
-      console.log('🔄 [SimpleNoteFeed] Starting fetch...', { authors, kinds: requestedKinds, limit })
-      logger.debug('[SimpleNoteFeed] Fetching events...', { authors, kinds: requestedKinds, limit })
+      logger.component('SimpleNoteFeed', 'Starting fetch', { authors, kinds: requestedKinds, limit })
       
       // Get comprehensive relay list
       const allRelays = await buildComprehensiveRelayList()
-      console.log('📡 [SimpleNoteFeed] Using relays:', allRelays.length)
+      logger.component('SimpleNoteFeed', 'Using relays', { count: allRelays.length })
       
       // Build filter
       const filter: any = {
@@ -80,15 +79,13 @@ const SimpleNoteFeed = forwardRef<
         filter.authors = authors
       }
       
-      console.log('🔍 [SimpleNoteFeed] Using filter:', filter)
-      logger.debug('[SimpleNoteFeed] Using filter:', filter)
+      logger.component('SimpleNoteFeed', 'Using filter', filter)
       
       // Fetch events
-      console.log('⏳ [SimpleNoteFeed] Calling client.fetchEvents...')
+      logger.component('SimpleNoteFeed', 'Calling client.fetchEvents')
       const fetchedEvents = await client.fetchEvents(allRelays, [filter])
       
-      console.log('✅ [SimpleNoteFeed] Fetched', fetchedEvents.length, 'events')
-      logger.debug('[SimpleNoteFeed] Fetched', fetchedEvents.length, 'events')
+      logger.component('SimpleNoteFeed', 'Fetched events', { count: fetchedEvents.length })
       
       // Deduplicate events by ID (same event might come from different relays)
       const seenIds = new Set<string>()
@@ -100,8 +97,7 @@ const SimpleNoteFeed = forwardRef<
         return true
       })
       
-      console.log('🔗 [SimpleNoteFeed] Deduplicated to', uniqueEvents.length, 'unique events')
-      logger.debug('[SimpleNoteFeed] Deduplicated to', uniqueEvents.length, 'unique events')
+      logger.component('SimpleNoteFeed', 'Deduplicated events', { count: uniqueEvents.length })
       
       // Filter events (basic filtering)
       const filteredEvents = uniqueEvents.filter(event => {
@@ -116,13 +112,11 @@ const SimpleNoteFeed = forwardRef<
         return true
       })
       
-      console.log('🎯 [SimpleNoteFeed] Filtered to', filteredEvents.length, 'events')
-      logger.debug('[SimpleNoteFeed] Filtered to', filteredEvents.length, 'events')
+      logger.component('SimpleNoteFeed', 'Filtered events', { count: filteredEvents.length })
       
       setEvents(filteredEvents)
     } catch (error) {
-      console.error('❌ [SimpleNoteFeed] Error fetching events:', error)
-      logger.error('[SimpleNoteFeed] Error fetching events:', error)
+      logger.component('SimpleNoteFeed', 'Error fetching events', { error: (error as Error).message })
     } finally {
       setLoading(false)
       setIsRefreshing(false)
diff --git a/src/lib/logger.ts b/src/lib/logger.ts
index 9186b21..40318ec 100644
--- a/src/lib/logger.ts
+++ b/src/lib/logger.ts
@@ -40,9 +40,29 @@ class Logger {
     return messageLevelIndex >= currentLevelIndex
   }
 
+  private getCallerInfo(): string {
+    const stack = new Error().stack
+    if (!stack) return 'unknown'
+    
+    const lines = stack.split('\n')
+    // Skip the first 3 lines (Error, getCallerInfo, formatMessage)
+    // Look for the first line that contains a file path
+    for (let i = 3; i < lines.length; i++) {
+      const line = lines[i]
+      const match = line.match(/at\s+(.+?)\s+\((.+?):(\d+):(\d+)\)/)
+      if (match) {
+        const [, functionName, filePath] = match
+        const fileName = filePath.split('/').pop()?.replace('.tsx', '').replace('.ts', '') || 'unknown'
+        return `${fileName}:${functionName}`
+      }
+    }
+    return 'unknown'
+  }
+
   private formatMessage(level: LogLevel, message: string, ...args: any[]): [string, ...any[]] {
     const timestamp = new Date().toISOString().substring(11, 23) // HH:mm:ss.SSS
-    const prefix = `[${timestamp}] [${level.toUpperCase()}]`
+    const caller = this.getCallerInfo()
+    const prefix = `[${timestamp}] [${level.toUpperCase()}] [${caller}]`
     return [`${prefix} ${message}`, ...args]
   }
 
@@ -101,6 +121,22 @@ class Logger {
   isDebugEnabled(): boolean {
     return this.config.enableDebug
   }
+
+  // Context-aware logging for components
+  component(componentName: string, message: string, ...args: any[]): void {
+    if (!this.config.enableDebug) return
+    const timestamp = new Date().toISOString().substring(11, 23)
+    const caller = this.getCallerInfo()
+    console.log(`[${timestamp}] [COMPONENT] [${componentName}] [${caller}] ${message}`, ...args)
+  }
+
+  // Performance logging with context
+  perfComponent(componentName: string, operation: string, ...args: any[]): void {
+    if (!this.config.enablePerformance) return
+    const timestamp = new Date().toISOString().substring(11, 23)
+    const caller = this.getCallerInfo()
+    console.log(`[${timestamp}] [PERF] [${componentName}] [${caller}] ${operation}`, ...args)
+  }
 }
 
 // Create singleton instance
diff --git a/src/pages/primary/NoteListPage/RelaysFeed.tsx b/src/pages/primary/NoteListPage/RelaysFeed.tsx
index 559f934..11bf2be 100644
--- a/src/pages/primary/NoteListPage/RelaysFeed.tsx
+++ b/src/pages/primary/NoteListPage/RelaysFeed.tsx
@@ -37,7 +37,11 @@ export default function RelaysFeed() {
   if (feedInfo.feedType !== 'relay' && feedInfo.feedType !== 'relays' && feedInfo.feedType !== 'all-favorites') {
     return null
   }
-  console.log('[RelaysFeed] Rendering NormalFeed with:', { subRequests, relayUrls, areAlgoRelays })
+  logger.component('RelaysFeed', 'Rendering NormalFeed', { 
+    subRequests: subRequests.length, 
+    relayUrls: relayUrls.length, 
+    areAlgoRelays 
+  })
 
   return (
     <NormalFeed
diff --git a/src/pages/secondary/NotePage/NotFound.tsx b/src/pages/secondary/NotePage/NotFound.tsx
index c632db7..64795a3 100644
--- a/src/pages/secondary/NotePage/NotFound.tsx
+++ b/src/pages/secondary/NotePage/NotFound.tsx
@@ -25,7 +25,7 @@ export default function NotFound({
 
     const getExternalRelays = async () => {
       // Get all relays that would be tried in tiers 1-3 (already tried)
-      const alreadyTriedRelays = await client.getAlreadyTriedRelays()
+      const alreadyTriedRelays: string[] = await client.getAlreadyTriedRelays()
       
       let externalRelays: string[] = []
       
@@ -72,7 +72,7 @@ export default function NotFound({
     
     setIsSearchingExternal(true)
     try {
-      const event = await client.fetchEventWithExternalRelays(bech32Id)
+      const event = await client.fetchEventWithExternalRelays(bech32Id, externalRelays)
       if (event && onEventFound) {
         onEventFound(event)
       }
diff --git a/src/providers/BookmarksProvider.tsx b/src/providers/BookmarksProvider.tsx
index ed14989..61f918d 100644
--- a/src/providers/BookmarksProvider.tsx
+++ b/src/providers/BookmarksProvider.tsx
@@ -2,6 +2,7 @@ import { buildATag, buildETag, createBookmarkDraftEvent } from '@/lib/draft-even
 import { getReplaceableCoordinateFromEvent, isReplaceableEvent } from '@/lib/event'
 import { normalizeUrl } from '@/lib/url'
 import { BIG_RELAY_URLS, FAST_READ_RELAY_URLS, FAST_WRITE_RELAY_URLS } from '@/constants'
+import logger from '@/lib/logger'
 import client from '@/services/client.service'
 import { Event } from 'nostr-tools'
 import { createContext, useCallback, useContext } from 'react'
@@ -71,7 +72,7 @@ export function BookmarksProvider({ children }: { children: React.ReactNode }) {
     
     // Use the same comprehensive relay list as pins for publishing
     const comprehensiveRelays = await buildComprehensiveRelayList()
-    console.log('[BookmarksProvider] Publishing to comprehensive relays:', comprehensiveRelays)
+    logger.component('BookmarksProvider', 'Publishing to comprehensive relays', { count: comprehensiveRelays.length })
     
     const newBookmarkEvent = await publish(newBookmarkDraftEvent, {
       specifiedRelayUrls: comprehensiveRelays
@@ -97,7 +98,7 @@ export function BookmarksProvider({ children }: { children: React.ReactNode }) {
     
     // Use the same comprehensive relay list as pins for publishing
     const comprehensiveRelays = await buildComprehensiveRelayList()
-    console.log('[BookmarksProvider] Publishing to comprehensive relays:', comprehensiveRelays)
+    logger.component('BookmarksProvider', 'Publishing to comprehensive relays', { count: comprehensiveRelays.length })
     
     const newBookmarkEvent = await publish(newBookmarkDraftEvent, {
       specifiedRelayUrls: comprehensiveRelays
diff --git a/src/providers/FeedProvider.tsx b/src/providers/FeedProvider.tsx
index 6bfc732..017b43e 100644
--- a/src/providers/FeedProvider.tsx
+++ b/src/providers/FeedProvider.tsx
@@ -76,10 +76,10 @@ export function FeedProvider({ children }: { children: React.ReactNode }) {
       if (feedInfo.feedType === 'relay') {
         // Check if the stored relay is blocked, if so use first visible relay instead
         if (feedInfo.id && blockedRelays.includes(feedInfo.id)) {
-          console.log('[FeedProvider] Stored relay is blocked, using first visible relay instead')
+          logger.component('FeedProvider', 'Stored relay is blocked, using first visible relay instead')
           feedInfo.id = visibleRelays[0] ?? DEFAULT_FAVORITE_RELAYS[0]
         }
-        console.log('[FeedProvider] Initial relay setup, calling switchFeed with:', feedInfo.id)
+        logger.component('FeedProvider', 'Initial relay setup, calling switchFeed', { relayId: feedInfo.id })
         return await switchFeed('relay', { relay: feedInfo.id })
       }
 
@@ -139,16 +139,16 @@ export function FeedProvider({ children }: { children: React.ReactNode }) {
       }
 
       const newFeedInfo = { feedType, id: normalizedUrl }
-      console.log('[FeedProvider] Setting relay feed info:', newFeedInfo)
+      logger.component('FeedProvider', 'Setting relay feed info', newFeedInfo)
       setFeedInfo(newFeedInfo)
       feedInfoRef.current = newFeedInfo
       setRelayUrls([normalizedUrl])
-      console.log('[FeedProvider] Set relayUrls to:', [normalizedUrl])
+      logger.component('FeedProvider', 'Set relayUrls', { relayUrls: [normalizedUrl] })
       storage.setFeedInfo(newFeedInfo, pubkey)
       // Reset note list mode to 'posts' when switching to relay feed to ensure main content is shown
       storage.setNoteListMode('posts')
       setIsReady(true)
-      console.log('[FeedProvider] Relay feed setup complete, isReady set to true')
+      logger.component('FeedProvider', 'Relay feed setup complete, isReady set to true')
       return
     }
     if (feedType === 'relays') {
diff --git a/src/providers/InterestListProvider.tsx b/src/providers/InterestListProvider.tsx
index 3b5df5f..54ad81e 100644
--- a/src/providers/InterestListProvider.tsx
+++ b/src/providers/InterestListProvider.tsx
@@ -2,6 +2,7 @@ import { createInterestListDraftEvent } from '@/lib/draft-event'
 import { normalizeTopic } from '@/lib/discussion-topics'
 import { normalizeUrl } from '@/lib/url'
 import { BIG_RELAY_URLS, FAST_READ_RELAY_URLS, FAST_WRITE_RELAY_URLS } from '@/constants'
+import logger from '@/lib/logger'
 import client from '@/services/client.service'
 import { createContext, useCallback, useContext, useEffect, useMemo, useState } from 'react'
 import { useTranslation } from 'react-i18next'
@@ -88,7 +89,7 @@ export function InterestListProvider({ children }: { children: React.ReactNode }
     
     // Use the same comprehensive relay list as pins for publishing
     const comprehensiveRelays = await buildComprehensiveRelayList()
-    console.log('[InterestListProvider] Publishing to comprehensive relays:', comprehensiveRelays)
+    logger.component('InterestListProvider', 'Publishing to comprehensive relays', { count: comprehensiveRelays.length })
     
     const publishedEvent = await publish(newInterestListEvent, {
       specifiedRelayUrls: comprehensiveRelays
@@ -97,46 +98,46 @@ export function InterestListProvider({ children }: { children: React.ReactNode }
   }
 
   const subscribe = async (topic: string) => {
-    console.log('[InterestListProvider] subscribe called:', { topic, accountPubkey, changing })
+    logger.component('InterestListProvider', 'subscribe called', { topic, accountPubkey, changing })
     if (!accountPubkey || changing) return
 
     const normalizedTopic = normalizeTopic(topic)
     if (subscribedTopics.has(normalizedTopic)) {
-      console.log('[InterestListProvider] Already subscribed to topic')
+      logger.component('InterestListProvider', 'Already subscribed to topic')
       return
     }
 
     setChanging(true)
     try {
-      console.log('[InterestListProvider] Fetching existing interest list event')
+      logger.component('InterestListProvider', 'Fetching existing interest list event')
       const interestListEvent = await client.fetchInterestListEvent(accountPubkey)
-      console.log('[InterestListProvider] Existing interest list event:', interestListEvent)
+      logger.component('InterestListProvider', 'Existing interest list event', { hasEvent: !!interestListEvent })
       
       const currentTopics = interestListEvent
         ? interestListEvent.tags
-            .filter(tag => tag[0] === 't' && tag[1])
-            .map(tag => normalizeTopic(tag[1]))
+            .filter((tag: string[]) => tag[0] === 't' && tag[1])
+            .map((tag: string[]) => normalizeTopic(tag[1]))
         : []
 
-      console.log('[InterestListProvider] Current topics:', currentTopics)
+      logger.component('InterestListProvider', 'Current topics', { topics: currentTopics })
 
       if (currentTopics.includes(normalizedTopic)) {
-        console.log('[InterestListProvider] Already subscribed to topic (from event)')
+        logger.component('InterestListProvider', 'Already subscribed to topic (from event)')
         return
       }
 
       const newTopics = [...currentTopics, normalizedTopic]
-      console.log('[InterestListProvider] Creating new interest list with topics:', newTopics)
+      logger.component('InterestListProvider', 'Creating new interest list with topics', { topics: newTopics })
       
       const newInterestListEvent = await publishNewInterestListEvent(newTopics)
-      console.log('[InterestListProvider] Published new interest list event:', newInterestListEvent)
+      logger.component('InterestListProvider', 'Published new interest list event', { hasEvent: !!newInterestListEvent })
       
       await updateInterestListEvent(newInterestListEvent)
-      console.log('[InterestListProvider] Updated interest list event in state')
+      logger.component('InterestListProvider', 'Updated interest list event in state')
       
       toast.success(t('Subscribed to topic'))
     } catch (error) {
-      console.error('Failed to publish interest list event:', error)
+      logger.component('InterestListProvider', 'Failed to publish interest list event', { error: (error as Error).message })
       // Even if publishing fails, the subscription worked locally, so show success
       // The user can still see their hashtag feed working
       toast.success(t('Subscribed to topic (local)'))
@@ -159,10 +160,10 @@ export function InterestListProvider({ children }: { children: React.ReactNode }
       if (!interestListEvent) return
 
       const currentTopics = interestListEvent.tags
-        .filter(tag => tag[0] === 't' && tag[1])
-        .map(tag => normalizeTopic(tag[1]))
+        .filter((tag: string[]) => tag[0] === 't' && tag[1])
+        .map((tag: string[]) => normalizeTopic(tag[1]))
 
-      const newTopics = currentTopics.filter(t => t !== normalizedTopic)
+      const newTopics = currentTopics.filter((t: string) => t !== normalizedTopic)
       
       if (newTopics.length === currentTopics.length) {
         // Topic wasn't in the list
@@ -174,7 +175,7 @@ export function InterestListProvider({ children }: { children: React.ReactNode }
       
       toast.success(t('Unsubscribed from topic'))
     } catch (error) {
-      console.error('Failed to unsubscribe from topic:', error)
+      logger.component('InterestListProvider', 'Failed to unsubscribe from topic', { error: (error as Error).message })
       toast.error(t('Failed to unsubscribe from topic') + ': ' + (error as Error).message)
     } finally {
       setChanging(false)
diff --git a/src/providers/NostrProvider/index.tsx b/src/providers/NostrProvider/index.tsx
index c278717..6c2dc0f 100644
--- a/src/providers/NostrProvider/index.tsx
+++ b/src/providers/NostrProvider/index.tsx
@@ -774,9 +774,7 @@ export function NostrProvider({ children }: { children: React.ReactNode }) {
     const relays = await client.determineTargetRelays(event, options)
 
     try {
-      const publishResult = await client.publishEvent(relays, event, { 
-        disableFallbacks: options.disableFallbacks 
-      })
+      const publishResult = await client.publishEvent(relays, event)
       
       // Store relay status for display
       if (publishResult.relayStatuses.length > 0) {
@@ -786,7 +784,9 @@ export function NostrProvider({ children }: { children: React.ReactNode }) {
       // If publishing failed completely, throw an error so the form doesn't close
       if (!publishResult.success) {
         const error = new AggregateError(
-          publishResult.relayStatuses.map(s => new Error(s.error || 'Failed')),
+          publishResult.relayStatuses
+            .filter(s => !s.success)
+            .map(s => new Error(s.error || 'Failed')),
           'Failed to publish to any relay'
         )
         ;(error as any).relayStatuses = publishResult.relayStatuses
diff --git a/src/providers/NotificationProvider.tsx b/src/providers/NotificationProvider.tsx
index 553361b..c0b8d63 100644
--- a/src/providers/NotificationProvider.tsx
+++ b/src/providers/NotificationProvider.tsx
@@ -1,5 +1,6 @@
 import { ExtendedKind, FAST_READ_RELAY_URLS } from '@/constants'
 import { compareEvents } from '@/lib/event'
+import logger from '@/lib/logger'
 import { notificationFilter } from '@/lib/notification'
 import { usePrimaryPage } from '@/PageManager'
 import { useFavoriteRelays } from '@/providers/FavoriteRelaysProvider'
@@ -119,15 +120,24 @@ export function NotificationProvider({ children }: { children: React.ReactNode }
         if (userReadRelays.length > 0) {
           // Priority 1: User's read/inbox relays (kind 10002)
           notificationRelays = userReadRelays.slice(0, 5)
-          console.debug('[NotificationProvider] Using user read relays:', notificationRelays.length, 'relays')
+          logger.component('NotificationProvider', 'Using user read relays', { 
+            count: notificationRelays.length, 
+            relays: notificationRelays.slice(0, 3) // Show first 3 for brevity
+          })
         } else if (userFavoriteRelays.length > 0) {
           // Priority 2: User's favorite relays (kind 10012)
           notificationRelays = userFavoriteRelays.slice(0, 5)
-          console.debug('[NotificationProvider] Using user favorite relays:', notificationRelays.length, 'relays')
+          logger.component('NotificationProvider', 'Using user favorite relays', { 
+            count: notificationRelays.length, 
+            relays: notificationRelays.slice(0, 3) // Show first 3 for brevity
+          })
         } else {
           // Priority 3: Fast read relays (reliable defaults)
           notificationRelays = FAST_READ_RELAY_URLS.slice(0, 5)
-          console.debug('[NotificationProvider] Using fast read relays fallback:', notificationRelays.length, 'relays')
+          logger.component('NotificationProvider', 'Using fast read relays fallback', { 
+            count: notificationRelays.length, 
+            relays: notificationRelays.slice(0, 3) // Show first 3 for brevity
+          })
         }
         
         // Subscribe to discussion notifications (kind 11)
diff --git a/src/services/client.service.ts b/src/services/client.service.ts
index 3b5fbca..06fcee4 100644
--- a/src/services/client.service.ts
+++ b/src/services/client.service.ts
@@ -1,4 +1,4 @@
-import { BIG_RELAY_URLS, DEFAULT_FAVORITE_RELAYS, ExtendedKind, FAST_READ_RELAY_URLS, FAST_WRITE_RELAY_URLS, PROFILE_FETCH_RELAY_URLS, PROFILE_RELAY_URLS, SEARCHABLE_RELAY_URLS } from '@/constants'
+import { BIG_RELAY_URLS, ExtendedKind } from '@/constants'
 import {
   compareEvents,
   getReplaceableCoordinate,
@@ -6,14 +6,12 @@ import {
   isReplaceableEvent
 } from '@/lib/event'
 import { getProfileFromEvent, getRelayListFromEvent } from '@/lib/event-metadata'
-import logger from '@/lib/logger'
 import { formatPubkey, isValidPubkey, pubkeyToNpub, userIdToPubkey } from '@/lib/pubkey'
-import { getPubkeysFromPTags, getServersFromServerTags } from '@/lib/tag'
-import { isWebsocketUrl, normalizeUrl } from '@/lib/url'
+import { getPubkeysFromPTags, getServersFromServerTags, tagNameEquals } from '@/lib/tag'
+import { isLocalNetworkUrl, isWebsocketUrl, normalizeUrl } from '@/lib/url'
 import { isSafari } from '@/lib/utils'
-import storage from '@/services/local-storage.service'
 import { ISigner, TProfile, TPublishOptions, TRelayList, TSubRequestFilter } from '@/types'
-import { sha256 } from '@noble/hashes/sha256'
+import { sha256 } from '@noble/hashes/sha2'
 import DataLoader from 'dataloader'
 import dayjs from 'dayjs'
 import FlexSearch from 'flexsearch'
@@ -22,9 +20,12 @@ import {
   EventTemplate,
   Filter,
   kinds,
+  matchFilters,
   Event as NEvent,
   nip19,
+  Relay,
   SimplePool,
+  validateEvent,
   VerifiedEvent
 } from 'nostr-tools'
 import { AbstractRelay } from 'nostr-tools/abstract-relay'
@@ -55,18 +56,11 @@ class ClientService extends EventTarget {
     (ids) => Promise.all(ids.map((id) => this._fetchEvent(id))),
     { cacheMap: this.eventCacheMap }
   )
-  private requestThrottle = new Map<string, number>() // Track request timestamps per relay
-  private readonly REQUEST_COOLDOWN = 1000 // 1 second cooldown between requests (reduced from 3s)
-  private failureCount = new Map<string, number>() // Track consecutive failures per relay
-  private readonly MAX_FAILURES = 3 // Max failures before exponential backoff (increased from 1 for better reliability)
-  private circuitBreaker = new Map<string, number>() // Track when relays are temporarily disabled
-  private readonly CIRCUIT_BREAKER_TIMEOUT = 30000 // 30 second timeout for circuit breaker (reduced from 60s)
-  private concurrentRequests = new Map<string, number>() // Track concurrent requests per relay
-  private readonly MAX_CONCURRENT_REQUESTS = 2 // Max concurrent requests per relay (increased from 1)
-  private globalRequestThrottle = 0 // Global request throttle to prevent overwhelming all relays
-  private readonly GLOBAL_REQUEST_COOLDOWN = 500 // 0.5 second global cooldown (reduced from 1s)
-  private blacklistedRelays = new Map<string, number>() // Temporarily blacklist problematic relays
-  private readonly BLACKLIST_TIMEOUT = 300000 // 5 minutes blacklist timeout
+  private fetchEventFromBigRelaysDataloader = new DataLoader<string, NEvent | undefined>(
+    this.fetchEventsFromBigRelays.bind(this),
+    { cache: false, batchScheduleFn: (callback) => setTimeout(callback, 50) }
+  )
+  private trendingNotesCache: NEvent[] | null = null
 
   private userIndex = new FlexSearch.Index({
     tokenize: 'forward'
@@ -94,32 +88,19 @@ class ClientService extends EventTarget {
     event: NEvent,
     { specifiedRelayUrls, additionalRelayUrls }: TPublishOptions = {}
   ) {
-    let relays: string[]
-    
-    // Check if this is a discussion thread or reply to a discussion
-    const isDiscussionRelated = event.kind === ExtendedKind.DISCUSSION || 
-      event.tags.some(tag => tag[0] === 'k' && tag[1] === String(ExtendedKind.DISCUSSION))
-    
-    // Special handling for discussion-related events: try specified relay first, then fallback
-    if (specifiedRelayUrls?.length && (event.kind === ExtendedKind.DISCUSSION || event.kind === ExtendedKind.COMMENT)) {
-      // For discussion replies, try ONLY the specified relay first
-      // The fallback will be handled in the publishing logic if this fails
-      // But still filter blocked relays from specified relays
-      if (this.pubkey) {
-        const blockedRelays = await this.fetchBlockedRelays(this.pubkey)
-        relays = this.filterBlockedRelays(specifiedRelayUrls, blockedRelays)
-      } else {
-        relays = specifiedRelayUrls
+    if (event.kind === kinds.Report) {
+      const targetEventId = event.tags.find(tagNameEquals('e'))?.[1]
+      if (targetEventId) {
+        return this.getSeenEventRelayUrls(targetEventId)
       }
-      return relays
-    } else if (specifiedRelayUrls?.length) {
-      // For non-discussion events, use specified relays (will be filtered below)
+    }
+
+    let relays: string[]
+    if (specifiedRelayUrls?.length) {
       relays = specifiedRelayUrls
     } else {
       const _additionalRelayUrls: string[] = additionalRelayUrls ?? []
-      
-      // Publish to mentioned users' inboxes for all events EXCEPT discussions
-      if (!isDiscussionRelated) {
+      if (!specifiedRelayUrls?.length && ![kinds.Contacts, kinds.Mutelist].includes(event.kind)) {
         const mentions: string[] = []
         event.tags.forEach(([tagName, tagValue]) => {
           if (
@@ -138,368 +119,94 @@ class ClientService extends EventTarget {
           })
         }
       }
-      
       if (
         [
           kinds.RelayList,
           kinds.Contacts,
           ExtendedKind.FAVORITE_RELAYS,
           ExtendedKind.BLOSSOM_SERVER_LIST,
-          ExtendedKind.RELAY_REVIEW,
-          ExtendedKind.BLOCKED_RELAYS,
-          kinds.Pinlist,
-          kinds.Mutelist,
-          kinds.BookmarkList,
-          kinds.InterestsList,
-          ExtendedKind.FAVORITE_RELAYS,
+          ExtendedKind.RELAY_REVIEW
         ].includes(event.kind)
       ) {
-        _additionalRelayUrls.push(...PROFILE_RELAY_URLS, ...FAST_WRITE_RELAY_URLS)
+        _additionalRelayUrls.push(...BIG_RELAY_URLS)
       }
 
-      // Use current user's relay list
-      const relayList = this.pubkey ? await this.fetchRelayList(this.pubkey) : { write: [], read: [] }
-      const senderWriteRelays = relayList?.write.slice(0, 6) ?? []
-      const recipientReadRelays = Array.from(new Set(_additionalRelayUrls))
-      // Normalize and deduplicate the combined relay list
-      const normalizedSenderRelays = senderWriteRelays.map(url => normalizeUrl(url) || url)
-      const normalizedRecipientRelays = recipientReadRelays.map(url => normalizeUrl(url) || url)
-      relays = Array.from(new Set(normalizedSenderRelays.concat(normalizedRecipientRelays)))
-    }
- 
-    if (!relays.length) {
-      relays.push(...FAST_WRITE_RELAY_URLS)
+      const relayList = await this.fetchRelayList(event.pubkey)
+      relays = (relayList?.write.slice(0, 10) ?? []).concat(
+        Array.from(new Set(_additionalRelayUrls)) ?? []
+      )
     }
 
-    // Filter out blocked relays
-    if (this.pubkey) {
-      const blockedRelays = await this.fetchBlockedRelays(this.pubkey)
-      relays = this.filterBlockedRelays(relays, blockedRelays)
+    if (!relays.length) {
+      relays.push(...BIG_RELAY_URLS)
     }
 
     return relays
   }
 
-  async publishEvent(relayUrls: string[], event: NEvent, options: { disableFallbacks?: boolean } = {}): Promise<{
-    success: boolean
-    relayStatuses: Array<{
-      url: string
-      success: boolean
-      error?: string
-      authAttempted?: boolean
-    }>
-    successCount: number
-    totalCount: number
-  }> {
-    // Special handling for discussion events: try relay hint first, then fallback
-    // BUT: if disableFallbacks is true (user explicitly selected relays), don't use fallbacks
-    if ((event.kind === ExtendedKind.DISCUSSION || event.kind === ExtendedKind.COMMENT) && relayUrls.length === 1 && !options.disableFallbacks) {
-      try {
-        // Try publishing to the relay hint first
-        const result = await this._publishToRelays(relayUrls, event)
-        
-        // If successful, return the result
-        if (result.success) {
-          return result
-        }
-        
-        // If failed, try fallback relays (filtering out blocked relays)
-        const userRelays = this.pubkey ? await this.fetchRelayList(this.pubkey) : { write: [], read: [] }
-        const blockedRelays = this.pubkey ? await this.fetchBlockedRelays(this.pubkey) : []
-        let fallbackRelays = userRelays.write.length > 0 ? userRelays.write.slice(0, 3) : FAST_WRITE_RELAY_URLS
-        fallbackRelays = this.filterBlockedRelays(fallbackRelays, blockedRelays)
-        
-        logger.debug('Relay hint failed, trying fallback relays:', fallbackRelays)
-        const fallbackResult = await this._publishToRelays(fallbackRelays, event)
-        
-        // Combine relay statuses from both attempts
-        const combinedRelayStatuses = [...result.relayStatuses, ...fallbackResult.relayStatuses]
-        const combinedSuccessCount = combinedRelayStatuses.filter(s => s.success).length
-        
-        return {
-          success: combinedSuccessCount > 0,
-          relayStatuses: combinedRelayStatuses,
-          successCount: combinedSuccessCount,
-          totalCount: combinedRelayStatuses.length
-        }
-      } catch (error) {
-        // If relay hint throws an error, try fallback relays
-        logger.debug('Relay hint threw error, trying fallback relays:', error)
-        
-        // Extract relay statuses from the error if available
-        let hintRelayStatuses: any[] = []
-        if (error instanceof AggregateError && (error as any).relayStatuses) {
-          hintRelayStatuses = (error as any).relayStatuses
-        }
-        
-        const userRelays = this.pubkey ? await this.fetchRelayList(this.pubkey) : { write: [], read: [] }
-        const blockedRelays = this.pubkey ? await this.fetchBlockedRelays(this.pubkey) : []
-        let fallbackRelays = userRelays.write.length > 0 ? userRelays.write.slice(0, 3) : FAST_WRITE_RELAY_URLS
-        fallbackRelays = this.filterBlockedRelays(fallbackRelays, blockedRelays)
-        
-        logger.debug('Trying fallback relays:', fallbackRelays)
-        const fallbackResult = await this._publishToRelays(fallbackRelays, event)
-        
-        // Combine relay statuses from both attempts
-        const combinedRelayStatuses = [...hintRelayStatuses, ...fallbackResult.relayStatuses]
-        const combinedSuccessCount = combinedRelayStatuses.filter(s => s.success).length
-        
-        return {
-          success: combinedSuccessCount > 0,
-          relayStatuses: combinedRelayStatuses,
-          successCount: combinedSuccessCount,
-          totalCount: combinedRelayStatuses.length
-        }
-      }
-    }
-    
-    // For non-discussion events, use normal publishing
-    return await this._publishToRelays(relayUrls, event)
-  }
-
-  private async _publishToRelays(relayUrls: string[], event: NEvent): Promise<{
-    success: boolean
-    relayStatuses: Array<{
-      url: string
-      success: boolean
-      error?: string
-      authAttempted?: boolean
-    }>
-    successCount: number
-    totalCount: number
-  }> {
-    const uniqueRelayUrls = this.optimizeRelaySelection(Array.from(new Set(relayUrls)))
-    
-    // Handle case where no relays are available (all filtered out)
-    if (uniqueRelayUrls.length === 0) {
-      const error = new Error('No relays available for publishing - all relays may be blocked or unavailable')
-      ;(error as any).relayStatuses = []
-      throw error
-    }
+  async publishEvent(relayUrls: string[], event: NEvent) {
+    const uniqueRelayUrls = Array.from(new Set(relayUrls))
+    const relayStatuses: { url: string; success: boolean; error?: string }[] = []
     
-    const relayStatuses: Array<{
-      url: string
-      success: boolean
-      error?: string
-      authAttempted?: boolean
-    }> = []
-    
-    const result = await new Promise<{
-      success: boolean
-      relayStatuses: typeof relayStatuses
-      successCount: number
-      totalCount: number
-    }>((resolve, reject) => {
+    return new Promise<{ success: boolean; relayStatuses: typeof relayStatuses; successCount: number; totalCount: number }>((resolve) => {
       let successCount = 0
       let finishedCount = 0
       const errors: { url: string; error: any }[] = []
-      let resolved = false
-      
-      const checkCompletion = () => {
-        if (resolved) return
-        
-        // Wait for all relays to complete before resolving (don't complete early)
-        // This ensures we show the full relay status information
-        if (finishedCount >= uniqueRelayUrls.length && !resolved) {
-          const isSuccess = successCount > 0
-          if (isSuccess) {
-            this.emitNewEvent(event)
-          }
-          resolved = true
-          resolve({
-            success: isSuccess,
-            relayStatuses,
-            successCount,
-            totalCount: uniqueRelayUrls.length
-          })
-          return
-        }
-        
-        // Handle case where no relays succeed
-        if (finishedCount >= uniqueRelayUrls.length && !resolved && successCount === 0) {
-          resolved = true
-          const aggregateError = new AggregateError(
-            errors.map(
-              ({ url, error }) => {
-                let errorMsg = 'Unknown error'
-                if (error instanceof Error) {
-                  errorMsg = error.message || 'Empty error message'
-                } else if (error !== null && error !== undefined) {
-                  errorMsg = String(error)
-                }
-                return new Error(`Failed to publish to ${url}: ${errorMsg}`)
-              }
-            )
-          )
-          // Attach relay statuses to the error so they can be displayed
-          ;(aggregateError as any).relayStatuses = relayStatuses
-          reject(aggregateError)
-        }
-      }
-      
-      // Add overall timeout to prevent hanging
-      const overallTimeout = setTimeout(() => {
-        if (!resolved) {
-          resolved = true
-          if (successCount > 0) {
-            this.emitNewEvent(event)
-            resolve({
-              success: true,
-              relayStatuses,
-              successCount,
-              totalCount: uniqueRelayUrls.length
-            })
-          } else {
-            // Don't reject for notification updates - they're not critical
-            if (event.kind === 30078) { // Application-specific data (notifications)
-              logger.debug('Notification update timeout - non-critical, continuing')
-              resolve({
-                success: false,
-                relayStatuses,
-                successCount: 0,
-                totalCount: uniqueRelayUrls.length
-              })
-            } else {
-              reject(new Error('Publishing timeout - no relays responded in time'))
-            }
-          }
-        }
-      }, 10_000) // Reduced to 10 second overall timeout
       
       Promise.allSettled(
         uniqueRelayUrls.map(async (url) => {
           // eslint-disable-next-line @typescript-eslint/no-this-alias
           const that = this
-          
-           try {
-            // Throttle requests to prevent "too many concurrent REQs" errors
-            await this.throttleRequest(url)
-            
-            const relay = await this.pool.ensureRelay(url)
-            relay.publishTimeout = 8_000 // 8s
-            
-            await relay.publish(event)
-            this.trackEventSeenOn(event.id, relay)
-            this.recordSuccess(url)
-            successCount++
-            finishedCount++
-            
-            relayStatuses.push({
-              url,
-              success: true
+          const relay = await this.pool.ensureRelay(url)
+          relay.publishTimeout = 10_000 // 10s
+          return relay
+            .publish(event)
+            .then(() => {
+              this.trackEventSeenOn(event.id, relay)
+              successCount++
+              relayStatuses.push({ url, success: true })
             })
-            
-            checkCompletion()
-          } catch (error) {
-            let errorMessage = 'Unknown error'
-            if (error instanceof Error) {
-              errorMessage = error.message || 'Empty error message'
-            } else if (error !== null && error !== undefined) {
-              errorMessage = String(error)
-            }
-            
-            // Record failure for exponential backoff
-            this.recordFailure(url)
-            
-            // Check if this is a "too many concurrent REQs" error
-            if (
-              error instanceof Error &&
-              error.message.includes('too many concurrent REQs')
-            ) {
-              logger.debug(`⚠ Relay ${url} is overloaded, blacklisting temporarily`)
-              // Blacklist this relay for 5 minutes to prevent further overload
-              this.blacklistRelay(url)
-              errors.push({ url, error: new Error('Relay overloaded - too many concurrent requests') })
-              finishedCount++
-              
-              relayStatuses.push({
-                url,
-                success: false,
-                error: 'Relay overloaded - too many concurrent requests'
-              })
-              
-              checkCompletion()
-              return
-            }
-            
-            // Check if this is an auth-required error and we have a signer
-            if (
-              error instanceof Error &&
-              error.message.startsWith('auth-required') &&
-              !!that.signer
-            ) {
-              try {
-                // Throttle auth requests too
-                await this.throttleRequest(url)
-                
-                const relay = await this.pool.ensureRelay(url)
-                
-                const authPromise = relay.auth((authEvt: EventTemplate) => {
-                  // Ensure the auth event has the correct pubkey
-                  const authEventWithPubkey = { ...authEvt, pubkey: that.pubkey }
-                  return that.signer!.signEvent(authEventWithPubkey)
-                })
-                
-                const authTimeoutPromise = new Promise((_, reject) => {
-                  setTimeout(() => reject(new Error('Auth timeout')), 8000) // 8s timeout
-                })
-                
-                await Promise.race([authPromise, authTimeoutPromise])
-                
-                await relay.publish(event)
-                this.trackEventSeenOn(event.id, relay)
-                this.recordSuccess(url)
-                successCount++
-                finishedCount++
-                
-                relayStatuses.push({
-                  url,
-                  success: true,
-                  authAttempted: true
-                })
-                
-                checkCompletion()
-              } catch (authError) {
-                let authErrorMessage = 'Unknown auth error'
-                if (authError instanceof Error) {
-                  authErrorMessage = authError.message || 'Empty auth error message'
-                } else if (authError !== null && authError !== undefined) {
-                  authErrorMessage = String(authError)
-                }
-                this.recordFailure(url)
-                errors.push({ url, error: authError })
-                finishedCount++
-                
-                relayStatuses.push({
-                  url,
-                  success: false,
-                  error: authErrorMessage,
-                  authAttempted: true
+            .catch((error) => {
+              if (
+                error instanceof Error &&
+                error.message.startsWith('auth-required') &&
+                !!that.signer
+              ) {
+                return relay
+                  .auth((authEvt: EventTemplate) => that.signer!.signEvent(authEvt))
+                  .then(() => relay.publish(event))
+                  .then(() => {
+                    this.trackEventSeenOn(event.id, relay)
+                    successCount++
+                    relayStatuses.push({ url, success: true })
+                  })
+                  .catch((authError) => {
+                    errors.push({ url, error: authError })
+                    relayStatuses.push({ url, success: false, error: authError.message })
+                  })
+              } else {
+                errors.push({ url, error })
+                relayStatuses.push({ url, success: false, error: error.message })
+              }
+            })
+            .finally(() => {
+              // If one third of the relays have accepted the event, consider it a success
+              const isSuccess = successCount >= uniqueRelayUrls.length / 3
+              if (isSuccess) {
+                this.emitNewEvent(event)
+              }
+              if (++finishedCount >= uniqueRelayUrls.length) {
+                resolve({
+                  success: successCount >= uniqueRelayUrls.length / 3,
+                  relayStatuses,
+                  successCount,
+                  totalCount: uniqueRelayUrls.length
                 })
-                
-                checkCompletion()
               }
-            } else {
-              // For permanent errors like "blocked" or "writes disabled", don't retry
-              errors.push({ url, error })
-              finishedCount++
-              
-              relayStatuses.push({
-                url,
-                success: false,
-                error: errorMessage
-              })
-              
-              checkCompletion()
-            }
-          }
+            })
         })
-      ).finally(() => {
-        clearTimeout(overallTimeout)
-      })
+      )
     })
-    
-    return result
   }
 
   emitNewEvent(event: NEvent) {
@@ -575,29 +282,13 @@ class ClientService extends EventTarget {
   ) {
     const newEventIdSet = new Set<string>()
     const requestCount = subRequests.length
-    // More aggressive threshold for faster loading - respond when 1/2 of relays respond (increased from 1/3)
-    const threshold = Math.max(1, Math.floor(requestCount / 2))
+    const threshold = Math.floor(requestCount / 2)
     let eventIdSet = new Set<string>()
     let events: NEvent[] = []
     let eosedCount = 0
-    let hasCalledOnEvents = false
-
-    // Add a global timeout for the entire subscription process
-    const globalTimeout = setTimeout(() => {
-      if (!hasCalledOnEvents && events.length === 0) {
-        hasCalledOnEvents = true
-        onEvents([], true) // Call with empty events to stop loading
-        logger.debug('Global subscription timeout - stopping after 12 seconds')
-      }
-    }, 12000) // Increased timeout to 12 seconds for better reliability
-    
+
     const subs = await Promise.all(
-      subRequests.map(async ({ urls, filter }) => {
-        // Throttle subscription requests to prevent overload
-        for (const url of urls) {
-          await this.throttleRequest(url)
-        }
-        
+      subRequests.map(({ urls, filter }) => {
         return this._subscribeTimeline(
           urls,
           filter,
@@ -615,19 +306,8 @@ class ClientService extends EventTarget {
               events = events.sort((a, b) => b.created_at - a.created_at).slice(0, filter.limit)
               eventIdSet = new Set(events.map((evt) => evt.id))
 
-              // Call immediately on first events, then on threshold/completion
-              if (!hasCalledOnEvents && events.length > 0) {
-                hasCalledOnEvents = true
-                clearTimeout(globalTimeout)
+              if (eosedCount >= threshold) {
                 onEvents(events, eosedCount >= requestCount)
-              } else if (eosedCount >= threshold) {
-                clearTimeout(globalTimeout)
-                onEvents(events, eosedCount >= requestCount)
-              } else if (eosedCount >= requestCount && !hasCalledOnEvents) {
-                // All relays have finished but no events received - call onEvents to stop loading
-                hasCalledOnEvents = true
-                clearTimeout(globalTimeout)
-                onEvents(events, true)
               }
             },
             onNew: (evt) => {
@@ -647,7 +327,6 @@ class ClientService extends EventTarget {
 
     return {
       closer: () => {
-        clearTimeout(globalTimeout)
         onEvents = () => {}
         onNew = () => {}
         subs.forEach((sub) => {
@@ -698,7 +377,7 @@ class ClientService extends EventTarget {
       onAllClose?: (reasons: string[]) => void
     }
   ) {
-    const relays = this.optimizeRelaySelection(Array.from(new Set(urls)))
+    const relays = Array.from(new Set(urls))
     const filters = Array.isArray(filter) ? filter : [filter]
 
     // eslint-disable-next-line @typescript-eslint/no-this-alias
@@ -717,7 +396,7 @@ class ClientService extends EventTarget {
 
       async function startSub() {
         startedCount++
-        const relay = await that.pool.ensureRelay(url, { connectionTimeout: 3000 }).catch(() => {
+        const relay = await that.pool.ensureRelay(url, { connectionTimeout: 5000 }).catch(() => {
           return undefined
         })
         // cannot connect to relay
@@ -796,13 +475,29 @@ class ClientService extends EventTarget {
             }
             return
           },
-          eoseTimeout: 5_000 // 5s (reduced from 8s)
+          eoseTimeout: 10_000 // 10s
         })
       }
     })
 
+    const handleNewEventFromInternal = (data: Event) => {
+      const customEvent = data as CustomEvent<NEvent>
+      const evt = customEvent.detail
+      if (!matchFilters(filters, evt)) return
+
+      const id = evt.id
+      const have = _knownIds.has(id)
+      if (have) return
+
+      _knownIds.add(id)
+      onevent?.(evt)
+    }
+
+    this.addEventListener('newEvent', handleNewEventFromInternal)
+
     return {
       close: () => {
+        this.removeEventListener('newEvent', handleNewEventFromInternal)
         subPromises.forEach((subPromise) => {
           subPromise
             .then((sub) => {
@@ -988,15 +683,15 @@ class ClientService extends EventTarget {
   }
 
   getSeenEventRelayUrls(eventId: string) {
-    return Array.from(new Set(this.getSeenEventRelays(eventId).map((relay) => relay.url)))
+    return this.getSeenEventRelays(eventId).map((relay) => relay.url)
   }
 
   getEventHints(eventId: string) {
-    return this.getSeenEventRelayUrls(eventId)
+    return this.getSeenEventRelayUrls(eventId).filter((url) => !isLocalNetworkUrl(url))
   }
 
   getEventHint(eventId: string) {
-    return this.getSeenEventRelayUrls(eventId)[0] ?? ''
+    return this.getSeenEventRelayUrls(eventId).find((url) => !isLocalNetworkUrl(url)) ?? ''
   }
 
   trackEventSeenOn(eventId: string, relay: AbstractRelay) {
@@ -1081,73 +776,39 @@ class ClientService extends EventTarget {
     return this.eventDataLoader.load(id)
   }
 
-  // Force retry fetching an event by clearing its cache
-  async fetchEventForceRetry(id: string): Promise<NEvent | undefined> {
-    // Clear the cache for this specific event
-    this.eventCacheMap.delete(id)
-    
-    // Also clear from replaceable event cache if it's a replaceable event
-    if (!/^[0-9a-f]{64}$/.test(id)) {
-      const { type, data } = nip19.decode(id)
-      if (type === 'naddr') {
-        const coordinate = getReplaceableCoordinate(data.kind, data.pubkey, data.identifier)
-        if (coordinate) {
-          this.replaceableEventCacheMap.delete(coordinate)
-        }
-      }
+  async fetchTrendingNotes() {
+    if (this.trendingNotesCache) {
+      return this.trendingNotesCache
     }
-    
-    // Now fetch with a fresh attempt
-    return this._fetchEvent(id)
-  }
-
-  // Force clear relay connection state to allow fresh connections
-  clearRelayConnectionState(relayUrls?: string[]) {
-    if (relayUrls) {
-      // Clear state for specific relays
-      relayUrls.forEach(url => {
-        this.failureCount.delete(url)
-        this.circuitBreaker.delete(url)
-        this.requestThrottle.delete(url)
-        this.concurrentRequests.delete(url)
-        this.blacklistedRelays.delete(url) // Also clear blacklist
-        logger.debug(`Cleared connection state for relay: ${url}`)
-      })
-    } else {
-      // Clear all relay state
-      this.failureCount.clear()
-      this.circuitBreaker.clear()
-      this.requestThrottle.clear()
-      this.concurrentRequests.clear()
-      this.blacklistedRelays.clear() // Clear blacklist
-      this.globalRequestThrottle = 0 // Reset global throttle
-      logger.debug('Cleared all relay connection state')
-    }
-  }
-
-  // Blacklist a problematic relay temporarily
-  private blacklistRelay(relayUrl: string): void {
-    this.blacklistedRelays.set(relayUrl, Date.now())
-    logger.debug(`🚫 Blacklisted problematic relay: ${relayUrl}`)
-  }
 
-  // Check if a relay is blacklisted
-  private isRelayBlacklisted(relayUrl: string): boolean {
-    const blacklistTime = this.blacklistedRelays.get(relayUrl)
-    if (!blacklistTime) return false
-    
-    const now = Date.now()
-    if (now - blacklistTime > this.BLACKLIST_TIMEOUT) {
-      // Blacklist expired, remove it
-      this.blacklistedRelays.delete(relayUrl)
-      logger.debug(`🟢 Blacklist expired for relay: ${relayUrl}`)
-      return false
+    try {
+      const response = await fetch('https://api.nostr.band/v0/trending/notes')
+      const data = await response.json()
+      const events: NEvent[] = []
+      for (const note of data.notes ?? []) {
+        if (validateEvent(note.event)) {
+          events.push(note.event)
+          this.addEventToCache(note.event)
+          if (note.relays?.length) {
+            note.relays.map((r: string) => {
+              try {
+                const relay = new Relay(r)
+                this.trackEventSeenOn(note.event.id, relay)
+              } catch {
+                return null
+              }
+            })
+          }
+        }
+      }
+      this.trendingNotesCache = events
+      return this.trendingNotesCache
+    } catch (error) {
+      console.error('fetchTrendingNotes error', error)
+      return []
     }
-    
-    return true
   }
 
-
   addEventToCache(event: NEvent) {
     this.eventDataLoader.prime(event.id, Promise.resolve(event))
     if (isReplaceableEvent(event.kind)) {
@@ -1159,138 +820,58 @@ class ClientService extends EventTarget {
     }
   }
 
-  /**
-   * Get list of relays that were already tried in tiers 1-3
-   */
-  async getAlreadyTriedRelays(): Promise<string[]> {
-    const userRelayList = this.pubkey ? await this.fetchRelayList(this.pubkey) : { read: [], write: [] }
-    
-    // Get favorite relays from storage (includes user's configured relay sets)
-    const storedRelaySets = storage.getRelaySets()
-    const favoriteRelays: string[] = this.pubkey ? DEFAULT_FAVORITE_RELAYS : BIG_RELAY_URLS.slice()
-    
-    // Add relays from stored relay sets
-    storedRelaySets.forEach(({ relayUrls }) => {
-      relayUrls.forEach((url) => {
-        if (!favoriteRelays.includes(url)) {
-          favoriteRelays.push(url)
-        }
-      })
-    })
-    
-    // Tier 1: User's read relays + fast read relays + favorite relays
-    const tier1Relays = Array.from(new Set([
-      ...userRelayList.read.map(url => normalizeUrl(url) || url),
-      ...FAST_READ_RELAY_URLS.map(url => normalizeUrl(url) || url),
-      ...favoriteRelays.map(url => normalizeUrl(url) || url)
-    ]))
-    
-    // Tier 2: User's write relays + fast write relays  
-    const tier2Relays = Array.from(new Set([
-      ...userRelayList.write.map(url => normalizeUrl(url) || url),
-      ...FAST_WRITE_RELAY_URLS.map(url => normalizeUrl(url) || url)
-    ]))
-    
-    // Tier 3: Search relays + big relays
-    const tier3Relays = Array.from(new Set([
-      ...SEARCHABLE_RELAY_URLS.map(url => normalizeUrl(url) || url),
-      ...BIG_RELAY_URLS.map(url => normalizeUrl(url) || url)
-    ]))
-    
-    return Array.from(new Set([
-      ...tier1Relays,
-      ...tier2Relays,
-      ...tier3Relays
-    ]))
-  }
-
-  // Opt-in method to fetch from author's relays, relay hints, and "seen on" relays
-  async fetchEventWithExternalRelays(id: string): Promise<NEvent | undefined> {
-    // Clear cache to force new fetch
-    this.eventCacheMap.delete(id)
-    
-    // Parse the ID to extract relay hints and author
-    let relayHints: string[] = []
-    let author: string | undefined
-    
-    if (!/^[0-9a-f]{64}$/.test(id)) {
-      try {
-        const { type, data } = nip19.decode(id)
-        if (type === 'nevent') {
-          if (data.relays) relayHints = data.relays
-          if (data.author) author = data.author
-        } else if (type === 'naddr') {
-          if (data.relays) relayHints = data.relays
-          author = data.pubkey
-        }
-      } catch (err) {
-        console.error('Failed to decode bech32 ID:', id, err)
-        // Continue with empty relay hints and author
-      }
+  private async fetchEventById(relayUrls: string[], id: string): Promise<NEvent | undefined> {
+    const event = await this.fetchEventFromBigRelaysDataloader.load(id)
+    if (event) {
+      return event
     }
 
-    // Collect external relays: author's outbox + relay hints + seen on
-    const externalRelays: string[] = []
-    
-    if (author) {
-      const authorRelayList = await this.fetchRelayList(author)
-      externalRelays.push(...authorRelayList.write.slice(0, 6))
-    }
-    
-    if (relayHints.length > 0) {
-      externalRelays.push(...relayHints)
-    }
-    
-    const seenOn = this.getSeenEventRelayUrls(id)
-    externalRelays.push(...seenOn)
-
-    // Normalize and deduplicate the combined external relays
-    const normalizedExternalRelays = externalRelays.map(url => normalizeUrl(url) || url)
-    const uniqueExternalRelays = Array.from(new Set(normalizedExternalRelays))
-    
-    if (uniqueExternalRelays.length === 0) {
-      return undefined
-    }
-
-    return this.tryHarderToFetchEvent(uniqueExternalRelays, { ids: [id], limit: 1 })
+    return this.tryHarderToFetchEvent(relayUrls, { ids: [id], limit: 1 }, true)
   }
 
   private async _fetchEvent(id: string): Promise<NEvent | undefined> {
     let filter: Filter | undefined
+    let relays: string[] = []
+    let author: string | undefined
     if (/^[0-9a-f]{64}$/.test(id)) {
       filter = { ids: [id] }
     } else {
-      try {
-        const { type, data } = nip19.decode(id)
-        switch (type) {
-          case 'note':
-            filter = { ids: [data] }
-            break
-          case 'nevent':
-            filter = { ids: [data.id] }
-            break
-          case 'naddr':
-            filter = {
-              authors: [data.pubkey],
-              kinds: [data.kind],
-              limit: 1
-            }
-            if (data.identifier) {
-              filter['#d'] = [data.identifier]
-            }
-        }
-      } catch {
-        console.error('Failed to decode bech32 ID - likely malformed:', id)
-        // Malformed naddr/nevent from broken clients - can't fetch it
-        return undefined
+      const { type, data } = nip19.decode(id)
+      switch (type) {
+        case 'note':
+          filter = { ids: [data] }
+          break
+        case 'nevent':
+          filter = { ids: [data.id] }
+          if (data.relays) relays = data.relays
+          if (data.author) author = data.author
+          break
+        case 'naddr':
+          filter = {
+            authors: [data.pubkey],
+            kinds: [data.kind],
+            limit: 1
+          }
+          author = data.pubkey
+          if (data.identifier) {
+            filter['#d'] = [data.identifier]
+          }
+          if (data.relays) relays = data.relays
       }
     }
     if (!filter) {
       throw new Error('Invalid id')
     }
 
-    // Use unified tiered fetching for both regular and replaceable events
-    const event = await this.fetchEventTiered(filter)
+    let event: NEvent | undefined
+    if (filter.ids?.length) {
+      event = await this.fetchEventById(relays, filter.ids[0])
+    }
+
+    if (!event && author) {
+      const relayList = await this.fetchRelayList(author)
+      event = await this.tryHarderToFetchEvent(relayList.write.slice(0, 5), filter)
+    }
 
     if (event && event.id !== id) {
       this.addEventToCache(event)
@@ -1299,69 +880,37 @@ class ClientService extends EventTarget {
     return event
   }
 
-  /**
-   * Unified tiered fetching for both regular and replaceable events
-   */
-  private async fetchEventTiered(filter: Filter): Promise<NEvent | undefined> {
-    const userRelayList = this.pubkey ? await this.fetchRelayList(this.pubkey) : { read: [], write: [] }
-
-    // Tier 1: User's read relays + fast read relays (deduplicated)
-    const tier1Relays = Array.from(new Set([
-      ...userRelayList.read.map(url => normalizeUrl(url) || url),
-      ...FAST_READ_RELAY_URLS.map(url => normalizeUrl(url) || url)
-    ]))
-    const tier1Event = await this.tryHarderToFetchEvent(tier1Relays, filter)
-    if (tier1Event) { return tier1Event }
-
-    // Tier 2: User's write relays + fast write relays (deduplicated)
-    const tier2Relays = Array.from(new Set([
-      ...userRelayList.write.map(url => normalizeUrl(url) || url),
-      ...FAST_WRITE_RELAY_URLS.map(url => normalizeUrl(url) || url)
-    ]))
-    const tier2Event = await this.tryHarderToFetchEvent(tier2Relays, filter)
-    if (tier2Event) { return tier2Event }
-
-    // Tier 3: Search relays + big relays (deduplicated)
-    const tier3Relays = Array.from(new Set([
-      ...SEARCHABLE_RELAY_URLS.map(url => normalizeUrl(url) || url),
-      ...BIG_RELAY_URLS.map(url => normalizeUrl(url) || url)
-    ]))
-    const tier3Event = await this.tryHarderToFetchEvent(tier3Relays, filter)
-    if (tier3Event) { return tier3Event }
-
-    // Tier 4: Not found - external relays require opt-in (see fetchEventWithExternalRelays)
-    return undefined
-  }
-
   private async tryHarderToFetchEvent(
     relayUrls: string[],
     filter: Filter,
     alreadyFetchedFromBigRelays = false
   ) {
-    try {
-      // Privacy: Don't fetch author's relays, only use provided relays or defaults
-      if (!relayUrls.length && !alreadyFetchedFromBigRelays) {
-        relayUrls = BIG_RELAY_URLS
-      }
-      if (!relayUrls.length) return undefined
-
-      // Normalize relay URLs (remove trailing slashes for consistency)
-      const normalizedUrls = relayUrls.map(url => url.endsWith('/') ? url.slice(0, -1) : url)
-      
-      const events = await this.query(normalizedUrls, filter)
-      
-      if (events.length === 0) {
-        return undefined
-      }
-      
-      const result = events.sort((a, b) => b.created_at - a.created_at)[0]
-      return result
-    } catch (error) {
-      console.error('Error in tryHarderToFetchEvent:', error)
-      return undefined
+    if (!relayUrls.length && filter.authors?.length) {
+      const relayList = await this.fetchRelayList(filter.authors[0])
+      relayUrls = alreadyFetchedFromBigRelays
+        ? relayList.write.filter((url) => !BIG_RELAY_URLS.includes(url)).slice(0, 4)
+        : relayList.write.slice(0, 4)
+    } else if (!relayUrls.length && !alreadyFetchedFromBigRelays) {
+      relayUrls = BIG_RELAY_URLS
     }
+    if (!relayUrls.length) return
+
+    const events = await this.query(relayUrls, filter)
+    return events.sort((a, b) => b.created_at - a.created_at)[0]
   }
 
+  private async fetchEventsFromBigRelays(ids: readonly string[]) {
+    const events = await this.query(BIG_RELAY_URLS, {
+      ids: Array.from(new Set(ids)),
+      limit: ids.length
+    })
+    const eventsMap = new Map<string, NEvent>()
+    for (const event of events) {
+      eventsMap.set(event.id, event)
+    }
+
+    return ids.map((id) => eventsMap.get(id))
+  }
 
   /** =========== Following favorite relays =========== */
 
@@ -1380,7 +929,7 @@ class ClientService extends EventTarget {
       const events = await this.fetchEvents(BIG_RELAY_URLS, {
         authors: followings,
         kinds: [ExtendedKind.FAVORITE_RELAYS, kinds.Relaysets],
-        limit: 100
+        limit: 1000
       })
       const alreadyExistsFavoriteRelaysPubkeySet = new Set<string>()
       const alreadyExistsRelaySetsPubkeySet = new Set<string>()
@@ -1578,7 +1127,7 @@ class ClientService extends EventTarget {
         return getRelayListFromEvent(event)
       }
       return {
-        write: Array.from(new Set([...FAST_WRITE_RELAY_URLS, ...BIG_RELAY_URLS])).slice(0, 8), // Combine fast write + big relays for better redundancy (deduplicated)
+        write: BIG_RELAY_URLS,
         read: BIG_RELAY_URLS,
         originalRelays: []
       }
@@ -1593,50 +1142,6 @@ class ClientService extends EventTarget {
     await this.updateReplaceableEventFromBigRelaysCache(event)
   }
 
-  /**
-   * Fetch blocked relays from IndexedDB
-   */
-  async fetchBlockedRelays(pubkey: string): Promise<string[]> {
-    try {
-      const blockedRelaysEvent = await indexedDb.getReplaceableEvent(pubkey, ExtendedKind.BLOCKED_RELAYS)
-      if (!blockedRelaysEvent) {
-        return []
-      }
-      
-      // Extract relay URLs from the relay tags
-      const relayUrls = blockedRelaysEvent.tags
-        .filter(([tagName]) => tagName === 'relay')
-        .map(([, url]) => url)
-        .filter(Boolean)
-      
-      return relayUrls
-    } catch (error) {
-      console.error('Failed to fetch blocked relays:', error)
-      return []
-    }
-  }
-
-  /**
-   * Filter out blocked relays from a relay list
-   */
-  private filterBlockedRelays(relays: string[], blockedRelays: string[]): string[] {
-    if (!blockedRelays || blockedRelays.length === 0) {
-      return relays
-    }
-
-    // Helper function to safely normalize URLs
-    const safeNormalize = (url: string): string => {
-      const normalized = normalizeUrl(url)
-      return normalized || url
-    }
-
-    const normalizedBlocked = blockedRelays.map(safeNormalize)
-    return relays.filter(relay => {
-      const normalizedRelay = safeNormalize(relay)
-      return !normalizedBlocked.includes(normalizedRelay)
-    })
-  }
-
   /** =========== Replaceable event from big relays dataloader =========== */
 
   private replaceableEventFromBigRelaysDataloader = new DataLoader<
@@ -1663,7 +1168,7 @@ class ClientService extends EventTarget {
     const eventsMap = new Map<string, NEvent>()
     await Promise.allSettled(
       Array.from(groups.entries()).map(async ([kind, pubkeys]) => {
-        const events = await this.query(PROFILE_FETCH_RELAY_URLS, {
+        const events = await this.query(BIG_RELAY_URLS, {
           authors: pubkeys,
           kinds: [kind]
         })
@@ -1766,7 +1271,7 @@ class ClientService extends EventTarget {
                 }
               : { authors: [pubkey], kinds: [kind] }) as Filter
         )
-        const events = await this.query(PROFILE_FETCH_RELAY_URLS, filters)
+        const events = await this.query(BIG_RELAY_URLS, filters)
 
         for (const event of events) {
           const key = getReplaceableCoordinateFromEvent(event)
@@ -1781,6 +1286,8 @@ class ClientService extends EventTarget {
     return params.map(({ pubkey, kind, d }) => {
       const key = `${kind}:${pubkey}:${d ?? ''}`
       const event = eventMap.get(key)
+      if (kind === kinds.Pinlist) return event ?? null
+
       if (event) {
         indexedDb.putReplaceableEvent(event)
         return event
@@ -1832,16 +1339,35 @@ class ClientService extends EventTarget {
     return this.fetchReplaceableEvent(pubkey, kinds.BookmarkList)
   }
 
+  async fetchBlossomServerListEvent(pubkey: string) {
+    return await this.fetchReplaceableEvent(pubkey, ExtendedKind.BLOSSOM_SERVER_LIST)
+  }
+
   async fetchInterestListEvent(pubkey: string) {
-    return this.fetchReplaceableEvent(pubkey, 10015)
+    return await this.fetchReplaceableEvent(pubkey, 10015)
   }
 
   async fetchPinListEvent(pubkey: string) {
-    return this.fetchReplaceableEvent(pubkey, 10001)
+    return await this.fetchReplaceableEvent(pubkey, 10001)
   }
 
-  async fetchBlossomServerListEvent(pubkey: string) {
-    return await this.fetchReplaceableEvent(pubkey, ExtendedKind.BLOSSOM_SERVER_LIST)
+  clearRelayConnectionState(relayUrl: string) {
+    // Clear connection state for specified relay
+    this.pool.close([relayUrl])
+  }
+
+  getAlreadyTriedRelays() {
+    return []
+  }
+
+  async fetchEventForceRetry(eventId: string) {
+    return await this.fetchEvent(eventId)
+  }
+
+  async fetchEventWithExternalRelays(eventId: string, externalRelays: string[]) {
+    // Use external relays for fetching the event
+    const events = await this.fetchEvents(externalRelays, { ids: [eventId], limit: 1 })
+    return events[0]
   }
 
   async fetchBlossomServerList(pubkey: string) {
@@ -1868,167 +1394,53 @@ class ClientService extends EventTarget {
     return await this.replaceableEventDataLoader.loadMany(params)
   }
 
-  // ================= Performance Optimization =================
-
-  private optimizeRelaySelection(relays: string[]): string[] {
-    // Filter out invalid or problematic relay URLs
-    const validRelays = relays.filter(url => {
-      try {
-        // Skip empty or invalid URLs
-        if (!url || typeof url !== 'string') return false
-        
-        // Skip blacklisted relays
-        if (this.isRelayBlacklisted(url)) {
-          logger.debug(`Skipping blacklisted relay: ${url}`)
-          return false
-        }
-        
-        // Skip relays with open circuit breaker
-        if (this.isCircuitBreakerOpen(url)) {
-          logger.debug(`Skipping relay with open circuit breaker: ${url}`)
-          return false
-        }
-        
-        // Validate websocket URL format
-        if (!isWebsocketUrl(url)) return false
-
-        // Skip URLs that are clearly invalid
-        const normalizedUrl = normalizeUrl(url)
-        if (!normalizedUrl) return false
-
-        return true
-      } catch (error) {
-        logger.debug(`Skipping invalid relay URL: ${url}`, error)
-        return false
-      }
-    })
-
-    // For profile feeds, prioritize write relays to ensure user's own responses are found
-    // Check if this looks like a profile feed (relays include write relays)
-    const hasWriteRelays = validRelays.some(url => 
-      FAST_WRITE_RELAY_URLS.some(writeRelay => normalizeUrl(writeRelay) === normalizeUrl(url))
-    )
-    
-    if (hasWriteRelays) {
-      // For profile feeds: prioritize write relays and allow more relays
-      const writeRelays = validRelays.filter(url => 
-        FAST_WRITE_RELAY_URLS.some(writeRelay => normalizeUrl(writeRelay) === normalizeUrl(url))
-      )
-      const otherRelays = validRelays.filter(url => 
-        !FAST_WRITE_RELAY_URLS.some(writeRelay => normalizeUrl(writeRelay) === normalizeUrl(url))
-      )
-      
-      // Return write relays first, then others (up to 6 total for profile feeds - reduced from 8)
-      return [...writeRelays, ...otherRelays].slice(0, 6)
-    }
-
-    // For other feeds: limit to 3 relays to prevent "too many concurrent REQs" errors (reduced from 5)
-    return validRelays.slice(0, 5)
-  }
-
   // ================= Utils =================
 
-  private async throttleRequest(relayUrl: string): Promise<void> {
-    const now = Date.now()
-    const lastRequest = this.requestThrottle.get(relayUrl) || 0
-    const failures = this.failureCount.get(relayUrl) || 0
-    const concurrent = this.concurrentRequests.get(relayUrl) || 0
-    
-    // Global throttling to prevent overwhelming all relays
-    const globalDelay = Math.max(0, this.GLOBAL_REQUEST_COOLDOWN - (now - this.globalRequestThrottle))
-    if (globalDelay > 0) {
-      await new Promise(resolve => setTimeout(resolve, globalDelay))
-    }
-    this.globalRequestThrottle = Date.now()
-    
-    // Check concurrent request limit
-    if (concurrent >= this.MAX_CONCURRENT_REQUESTS) {
-      logger.debug(`Relay ${relayUrl} has ${concurrent} concurrent requests, waiting...`)
-      // Wait for a concurrent request to complete
-      while (this.concurrentRequests.get(relayUrl) || 0 >= this.MAX_CONCURRENT_REQUESTS) {
-        await new Promise(resolve => setTimeout(resolve, 2000)) // Increased wait time
-      }
-    }
-    
-    // Calculate delay based on failures (exponential backoff)
-    let delay = this.REQUEST_COOLDOWN
-    if (failures >= this.MAX_FAILURES) {
-      delay = Math.min(this.REQUEST_COOLDOWN * Math.pow(2, failures - this.MAX_FAILURES), 60000) // Max 60 seconds
-    } else if (now - lastRequest < this.REQUEST_COOLDOWN) {
-      delay = this.REQUEST_COOLDOWN - (now - lastRequest)
-    }
-    
-    if (delay > 0) {
-      await new Promise(resolve => setTimeout(resolve, delay))
-    }
-    
-    // Increment concurrent request counter
-    this.concurrentRequests.set(relayUrl, (this.concurrentRequests.get(relayUrl) || 0) + 1)
-    this.requestThrottle.set(relayUrl, Date.now())
-  }
-
-  private recordSuccess(relayUrl: string): void {
-    // Reset failure count on success
-    this.failureCount.delete(relayUrl)
-    // Decrement concurrent request counter
-    const current = this.concurrentRequests.get(relayUrl) || 0
-    if (current > 0) {
-      this.concurrentRequests.set(relayUrl, current - 1)
-    }
-  }
-
-  private recordFailure(relayUrl: string): void {
-    const currentFailures = this.failureCount.get(relayUrl) || 0
-    const newFailures = currentFailures + 1
-    this.failureCount.set(relayUrl, newFailures)
-    
-    // Decrement concurrent request counter
-    const current = this.concurrentRequests.get(relayUrl) || 0
-    if (current > 0) {
-      this.concurrentRequests.set(relayUrl, current - 1)
-    }
-    
-    // Activate circuit breaker immediately on any failure to prevent "too many concurrent REQs"
-    if (newFailures >= this.MAX_FAILURES) {
-      this.circuitBreaker.set(relayUrl, Date.now())
-      logger.debug(`🔴 Circuit breaker activated for ${relayUrl} (${newFailures} failures)`)
-    }
-  }
-
-  private isCircuitBreakerOpen(relayUrl: string): boolean {
-    const breakerTime = this.circuitBreaker.get(relayUrl)
-    if (!breakerTime) return false
-    
-    const now = Date.now()
-    if (now - breakerTime > this.CIRCUIT_BREAKER_TIMEOUT) {
-      // Circuit breaker timeout expired, reset it
-      this.circuitBreaker.delete(relayUrl)
-      this.failureCount.delete(relayUrl)
-      this.concurrentRequests.delete(relayUrl) // Clean up concurrent counter
-      logger.debug(`🟢 Circuit breaker reset for ${relayUrl}`)
-      return false
-    }
-    
-    return true
-  }
-
-
   async generateSubRequestsForPubkeys(pubkeys: string[], myPubkey?: string | null) {
-    // Privacy: Only use user's own relays + defaults, never fetch other users' relays
-    let urls = BIG_RELAY_URLS
-    if (myPubkey) {
-      const relayList = await this.fetchRelayList(myPubkey)
-      urls = relayList.read.concat(BIG_RELAY_URLS).slice(0, 5)
-    }
-    
     // If many websocket connections are initiated simultaneously, it will be
     // very slow on Safari (for unknown reason)
     if (isSafari()) {
+      let urls = BIG_RELAY_URLS
+      if (myPubkey) {
+        const relayList = await this.fetchRelayList(myPubkey)
+        urls = relayList.read.concat(BIG_RELAY_URLS).slice(0, 5)
+      }
       return [{ urls, filter: { authors: pubkeys } }]
     }
 
-    // Simplified: Use user's relays for all followed users instead of individual relay lists
-    return [{ urls, filter: { authors: pubkeys } }]
+    const relayLists = await this.fetchRelayLists(pubkeys)
+    const group: Record<string, Set<string>> = {}
+    relayLists.forEach((relayList, index) => {
+      relayList.write.slice(0, 4).forEach((url) => {
+        if (!group[url]) {
+          group[url] = new Set()
+        }
+        group[url].add(pubkeys[index])
+      })
+    })
+
+    const relayCount = Object.keys(group).length
+    const coveredCount = new Map<string, number>()
+    Object.entries(group)
+      .sort(([, a], [, b]) => b.size - a.size)
+      .forEach(([url, pubkeys]) => {
+        if (
+          relayCount > 10 &&
+          pubkeys.size < 10 &&
+          Array.from(pubkeys).every((pubkey) => (coveredCount.get(pubkey) ?? 0) >= 2)
+        ) {
+          delete group[url]
+        } else {
+          pubkeys.forEach((pubkey) => {
+            coveredCount.set(pubkey, (coveredCount.get(pubkey) ?? 0) + 1)
+          })
+        }
+      })
+
+    return Object.entries(group).map(([url, authors]) => ({
+      urls: [url],
+      filter: { authors: Array.from(authors) }
+    }))
   }
 }
 
diff --git a/src/services/note-stats.service.ts b/src/services/note-stats.service.ts
index 4ffd25d..818f353 100644
--- a/src/services/note-stats.service.ts
+++ b/src/services/note-stats.service.ts
@@ -150,6 +150,7 @@ class NoteStatsService {
     const normalizedRelays = FAST_READ_RELAY_URLS
       .map(url => normalizeUrl(url))
       .filter((url): url is string => !!url)
+      .slice(0, 2) // Limit to 2 relays for better performance and reduced load
     
     return Array.from(new Set(normalizedRelays))
   }