Clean up feeds and listeners

src/routes/+layout.svelte

@@ -3,7 +3,7 @@
   import {onMount} from "svelte"
   import {get} from "svelte/store"
   import {dev} from "$app/environment"
-  import {sleep, take, sortBy, ago, now, HOUR} from "@welshman/lib"
+  import {ctx, uniq, sleep, take, sortBy, ago, now, HOUR, WEEK} from "@welshman/lib"
   import type {TrustedEvent} from "@welshman/util"
   import {
     PROFILE,
@@ -13,6 +13,7 @@
     RELAYS,
     INBOX_RELAYS,
     WRAP,
+    DELETE,
     getPubkeyTagValues,
     getListTags,
   } from "@welshman/util"
@@ -41,8 +42,17 @@
   import {setupTracking} from "@app/tracking"
   import {setupAnalytics} from "@app/analytics"
   import {theme} from "@app/theme"
-  import {INDEXER_RELAYS} from "@app/state"
-  import {loadUserData} from "@app/commands"
+  import {
+    INDEXER_RELAYS,
+    getMembershipUrls,
+    getMembershipRooms,
+    userMembership,
+    MEMBERSHIPS,
+    MESSAGE,
+    COMMENT,
+    THREAD,
+  } from "@app/state"
+  import {loadUserData, subscribePersistent} from "@app/commands"
   import * as state from "@app/state"
 
   // Migration: old nostrtalk instance used different sessions
@@ -130,10 +140,55 @@
         tracker: storageAdapters.fromTracker(tracker, {throttle: 1000}),
       }).then(() => sleep(300))
 
+      let unsubRooms: any
+
+      userMembership.subscribe($membership => {
+        unsubRooms?.()
+
+        const since = ago(30)
+        const rooms = uniq(getMembershipRooms($membership).map(m => m.room))
+        const relays = uniq(getMembershipUrls($membership))
+
+        if (relays.length > 0) {
+          subscribePersistent({
+            relays,
+            filters: [
+              {kinds: [THREAD], since},
+              {kinds: [MESSAGE], "#~": rooms, since},
+              {kinds: [COMMENT], "#K": [THREAD, MESSAGE].map(String), since},
+              {kinds: [DELETE], "#k": [THREAD, COMMENT, MESSAGE].map(String), since},
+              {kinds: [MEMBERSHIPS], "#r": relays, since},
+            ],
+          })
+        }
+      })
+
+      let unsubChats: any
+
+      pubkey.subscribe($pubkey => {
+        unsubChats?.()
+
+        if ($pubkey) {
+          unsubChats = subscribePersistent({
+            filters: [{kinds: [WRAP], "#p": [$pubkey], since: ago(WEEK)}],
+            relays: ctx.app.router.UserInbox().getUrls(),
+          })
+        }
+      })
+
+      // Unwrap gift wraps as they come in
+      repository.on("update", ({added}) => {
+        for (const event of added) {
+          state.ensureUnwrapped(event)
+        }
+      })
+
+      // Load relay info
       for (const url of INDEXER_RELAYS) {
         loadRelay(url)
       }
 
+      // Load user data
       if ($pubkey) {
         loadUserData($pubkey)
       }

src/routes/chat/+layout.svelte

@@ -4,7 +4,7 @@
   import {WEEK, ctx, ago} from "@welshman/lib"
   import {WRAP} from "@welshman/util"
   import type {TrustedEvent} from "@welshman/util"
-  import {pubkey, repository, subscribe} from "@welshman/app"
+  import {pubkey, repository} from "@welshman/app"
   import Icon from "@lib/components/Icon.svelte"
   import Page from "@lib/components/Page.svelte"
   import Button from "@lib/components/Button.svelte"
@@ -35,15 +35,9 @@
   $: chats = $chatSearch.searchOptions(term).filter(c => c.pubkeys.length > 1)
 
   onMount(() => {
-    const sub = subscribe({
-      filters: [{kinds: [WRAP], "#p": [$pubkey!], since: ago(WEEK)}],
-      relays: ctx.app.router.UserInbox().getUrls(),
-    })
-
     repository.on("update", onUpdate)
 
     return () => {
-      sub.close()
       repository.off("update", onUpdate)
     }
   })

src/routes/spaces/[relay]/+layout.svelte

@@ -1,15 +1,13 @@
 <script lang="ts">
   import {onMount} from "svelte"
   import {page} from "$app/stores"
-  import {subscribe} from "@welshman/app"
-  import {DELETE} from "@welshman/util"
   import Page from "@lib/components/Page.svelte"
   import Delay from "@lib/components/Delay.svelte"
   import SecondaryNav from "@lib/components/SecondaryNav.svelte"
   import MenuSpace from "@app/components/MenuSpace.svelte"
   import {pushToast} from "@app/toast"
   import {checkRelayConnection, checkRelayAuth} from "@app/commands"
-  import {decodeRelay, MEMBERSHIPS, THREAD, MESSAGE, COMMENT} from "@app/state"
+  import {decodeRelay} from "@app/state"
 
   $: url = decodeRelay($page.params.relay)
 
@@ -27,16 +25,6 @@
 
   onMount(() => {
     checkConnection()
-
-    const sub = subscribe({
-      filters: [
-        {kinds: [DELETE], "#k": [THREAD, COMMENT, MESSAGE].map(String)},
-        {kinds: [MEMBERSHIPS], "#r": [url]},
-      ],
-      relays: [url],
-    })
-
-    return () => sub.close()
   })
 </script>
 

src/routes/spaces/[relay]/[room]/+page.svelte

@@ -8,9 +8,8 @@
 </script>
 
 <script lang="ts">
-  import {onMount} from "svelte"
   import {page} from "$app/stores"
-  import {sortBy, ago, append} from "@welshman/lib"
+  import {sortBy, append} from "@welshman/lib"
   import type {TrustedEvent, EventContent} from "@welshman/util"
   import {createEvent} from "@welshman/util"
   import {formatTimestampAsDate, publishThunk} from "@welshman/app"
@@ -35,7 +34,7 @@
     COMMENT,
     getMembershipRoomsByUrl,
   } from "@app/state"
-  import {subscribePersistent, addRoomMembership, removeRoomMembership} from "@app/commands"
+  import {addRoomMembership, removeRoomMembership} from "@app/commands"
   import {pushDrawer} from "@app/modal"
   import {popKey} from "@app/implicit"
 
@@ -90,15 +89,6 @@
     elements.reverse()
   }
 
-  onMount(() => {
-    const unsub = subscribePersistent({
-      filters: [{"#~": [room], since: ago(30)}],
-      relays: [url],
-    })
-
-    return () => unsub()
-  })
-
   setTimeout(() => {
     loading = false
   }, 5000)

src/routes/spaces/[relay]/threads/+page.svelte

@@ -1,9 +1,9 @@
 <script lang="ts">
   import {onMount} from "svelte"
   import {page} from "$app/stores"
-  import {ago, assoc} from "@welshman/lib"
+  import {sortBy, uniqBy} from "@welshman/lib"
   import {getListTags, getPubkeyTagValues} from "@welshman/util"
-  import type {Filter} from "@welshman/util"
+  import type {Filter, TrustedEvent} from "@welshman/util"
   import {feedsFromFilters, makeIntersectionFeed, makeRelayFeed} from "@welshman/feeds"
   import {nthEq} from "@welshman/lib"
   import {createFeedController, userMutes} from "@welshman/app"
@@ -15,40 +15,43 @@
   import MenuSpace from "@app/components/MenuSpace.svelte"
   import ThreadItem from "@app/components/ThreadItem.svelte"
   import ThreadCreate from "@app/components/ThreadCreate.svelte"
-  import {THREAD, COMMENT, deriveEventsForUrl, decodeRelay} from "@app/state"
+  import {THREAD, COMMENT, decodeRelay} from "@app/state"
   import {pushModal, pushDrawer} from "@app/modal"
-  import {subscribePersistent} from "@app/commands"
 
   const url = decodeRelay($page.params.relay)
-  const events = deriveEventsForUrl(url, [{kinds: [THREAD]}])
   const mutedPubkeys = getPubkeyTagValues(getListTags($userMutes))
   const filters: Filter[] = [{kinds: [THREAD]}, {kinds: [COMMENT], "#K": [String(THREAD)]}]
-  const feed = makeIntersectionFeed(makeRelayFeed(url), feedsFromFilters(filters))
 
   const openMenu = () => pushDrawer(MenuSpace, {url})
 
   const createThread = () => pushModal(ThreadCreate, {url})
 
-  let limit = 5
   let loading = true
   let element: Element
   let scroller: Scroller
+  let buffer: TrustedEvent[] = []
+  let events: TrustedEvent[] = []
 
   onMount(() => {
     let unmounted = false
 
     const ctrl = createFeedController({
-      feed,
+      useWindowing: true,
+      feed: makeIntersectionFeed(makeRelayFeed(url), feedsFromFilters(filters)),
+      onEvent: (event: TrustedEvent) => {
+        if (
+          event.kind === THREAD &&
+          !event.tags.some(nthEq(0, "e")) &&
+          !mutedPubkeys.includes(event.pubkey)
+        ) {
+          buffer.push(event)
+        }
+      },
       onExhausted: () => {
         loading = false
       },
     })
 
-    const unsub = subscribePersistent({
-      filters: filters.map(assoc("since", ago(30))),
-      relays: [url],
-    })
-
     // Element is frequently not defined. I don't know why
     setTimeout(() => {
       if (!unmounted) {
@@ -56,10 +59,16 @@
           element,
           delay: 300,
           threshold: 3000,
-          onScroll: async () => {
-            limit += 5
+          onScroll: () => {
+            buffer = uniqBy(
+              e => e.id,
+              sortBy(e => -e.created_at, buffer),
+            )
+            events = [...events, ...buffer.splice(0, 5)]
 
-            await ctrl.load(5)
+            if (buffer.length < 50) {
+              ctrl.load(50)
+            }
           },
         })
       }
@@ -67,7 +76,6 @@
 
     return () => {
       unmounted = true
-      unsub()
       scroller?.stop()
     }
   })
@@ -90,16 +98,14 @@
     </div>
   </PageBar>
   <div class="flex flex-grow flex-col gap-2 overflow-auto p-2">
-    {#each $events.slice(0, limit) as event (event.id)}
-      {#if !event.tags.some(nthEq(0, "e")) && !mutedPubkeys.includes(event.pubkey)}
-        <ThreadItem {url} {event} />
-      {/if}
+    {#each events as event (event.id)}
+      <ThreadItem {url} {event} />
     {/each}
     <p class="flex h-10 items-center justify-center py-20">
       <Spinner {loading}>
         {#if loading}
           Looking for threads...
-        {:else if $events.length === 0}
+        {:else if events.length === 0}
           No threads found.
         {/if}
       </Spinner>