Bump welshman

src/app/commands.ts

@@ -22,7 +22,7 @@ import {
 } from "@welshman/util"
 import type {TrustedEvent, EventTemplate, List} from "@welshman/util"
 import type {SubscribeRequestWithHandlers, Subscription} from "@welshman/net"
-import {PublishStatus, AuthStatus, ConnectionStatus} from "@welshman/net"
+import {PublishStatus, AuthStatus, SocketStatus} from "@welshman/net"
 import {Nip59, makeSecret, stamp, Nip46Broker} from "@welshman/signer"
 import type {Nip46Handler} from "@welshman/signer"
 import {
@@ -268,8 +268,7 @@ export const setInboxRelayPolicy = (url: string, enabled: boolean) => {
 export const checkRelayAccess = async (url: string, claim = "") => {
   const connection = ctx.net.pool.get(url)
 
-  await connection.auth.attemptIfRequested()
-  await connection.auth.waitIfPending()
+  await connection.auth.attempt()
 
   const thunk = publishThunk({
     event: createEvent(AUTH_JOIN, {tags: [["claim", claim]]}),
@@ -298,11 +297,10 @@ export const checkRelayProfile = async (url: string) => {
 
 export const checkRelayConnection = async (url: string) => {
   const connection = ctx.net.pool.get(url)
-  const okStatuses = [ConnectionStatus.Ok, ConnectionStatus.Slow]
 
-  await connection.ensureConnected()
+  await connection.socket.open()
 
-  if (!okStatuses.includes(connection.meta.getStatus())) {
+  if (connection.socket.status !== SocketStatus.Open) {
     return `Failed to connect`
   }
 }
@@ -311,8 +309,7 @@ export const checkRelayAuth = async (url: string) => {
   const connection = ctx.net.pool.get(url)
   const okStatuses = [AuthStatus.None, AuthStatus.Ok]
 
-  await connection.auth.attemptIfRequested()
-  await connection.auth.waitIfPending()
+  await connection.auth.attempt()
 
   if (!okStatuses.includes(connection.auth.status)) {
     return `Failed to authenticate: "${connection.auth.message}"`

src/app/components/ProfileDetail.svelte

@@ -1,47 +0,0 @@
-<script lang="ts">
-  import {onMount} from "svelte"
-  import {sortBy, flatten} from "@welshman/lib"
-  import {feedFromFilter} from "@welshman/feeds"
-  import {NOTE, getAncestorTags} from "@welshman/util"
-  import {deriveEvents} from "@welshman/store"
-  import {repository, feedLoader} from "@welshman/app"
-  import {createScroller} from "@lib/html"
-  import Spinner from "@lib/components/Spinner.svelte"
-  import NoteItem from "@app/components/NoteItem.svelte"
-
-  export let url
-  export let pubkey
-
-  const filter = {kinds: [NOTE], authors: [pubkey]}
-  const events = deriveEvents(repository, {filters: [filter]})
-  const loader = feedLoader.getLoader(feedFromFilter(filter), {})
-
-  let element: Element
-
-  onMount(() => {
-    const scroller = createScroller({
-      element,
-      onScroll: async () => {
-        const $loader = await loader
-
-        $loader(5)
-      },
-    })
-
-    return () => scroller.stop()
-  })
-</script>
-
-<div class="flex max-w-full flex-col gap-4 p-4" bind:this={element}>
-  <div class="flex flex-col gap-2">
-    {#each sortBy(e => -e.created_at, $events) as event (event.id)}
-      {#if flatten(Object.values(getAncestorTags(event.tags))).length === 0}
-        <NoteItem {url} {event} />
-      {/if}
-    {:else}
-      <p class="flex center my-12">
-        <Spinner loading />
-      </p>
-    {/each}
-  </div>
-</div>

src/app/components/ProfileFeed.svelte

@@ -1,10 +1,11 @@
 <script lang="ts">
   import {onMount} from "svelte"
   import {sortBy, flatten} from "@welshman/lib"
+  import {deriveEvents} from "@welshman/store"
   import {feedFromFilter} from "@welshman/feeds"
   import {NOTE, getAncestorTags} from "@welshman/util"
   import type {TrustedEvent} from "@welshman/util"
-  import {feedLoader} from "@welshman/app"
+  import {repository, createFeedController} from "@welshman/app"
   import {createScroller} from "@lib/html"
   import Spinner from "@lib/components/Spinner.svelte"
   import NoteItem from "@app/components/NoteItem.svelte"
@@ -13,25 +14,17 @@
   export let pubkey
 
   const filter = {kinds: [NOTE], authors: [pubkey]}
-  const loader = feedLoader.getLoader(feedFromFilter(filter), {
-    onEvent: (e: TrustedEvent) => {
-      events = sortBy(e => -e.created_at, [...events, e])
-    },
-  })
+  const events = deriveEvents(repository, {filters: [filter]})
 
   let element: Element
-  let events: TrustedEvent[] = []
 
   onMount(() => {
+    const ctrl = createFeedController({feed: feedFromFilter(filter)})
     const scroller = createScroller({
       element,
       delay: 300,
       threshold: 3000,
-      onScroll: async () => {
-        const $loader = await loader
-
-        $loader(5)
-      },
+      onScroll: () => ctrl.load(5)
     })
 
     return () => scroller.stop()
@@ -40,7 +33,7 @@
 
 <div class="col-4" bind:this={element}>
   <div class="flex flex-col gap-2">
-    {#each events as event (event.id)}
+    {#each sortBy(e => -e.created_at, $events) as event (event.id)}
       {#if flatten(Object.values(getAncestorTags(event.tags))).length === 0}
         <NoteItem {url} {event} />
       {/if}

src/app/components/RelayItem.svelte

@@ -9,7 +9,7 @@
 
   const relay = deriveRelay(url)
 
-  $: connections = $relay?.stats?.connect_count || 0
+  $: connections = $relay?.stats?.open_count || 0
 </script>
 
 <div class="card2 card2-sm bg-alt column gap-2">

src/routes/chat/+layout.svelte

@@ -23,7 +23,7 @@
 
   onMount(() => {
     const filter = {kinds: [WRAP], "#p": [$pubkey!]}
-    const relays = ctx.app.router.InboxRelays().getUrls()
+    const relays = ctx.app.router.UserInbox().getUrls()
     const sub = subscribe({filters: [{...filter, since: ago(WEEK)}], relays})
 
     pullConservatively({filters: [filter], relays})

src/routes/chat/+page.svelte

@@ -23,7 +23,7 @@
 
     pullConservatively({
       filters: [filter],
-      relays: ctx.app.router.InboxRelays().getUrls(),
+      relays: ctx.app.router.UserInbox().getUrls(),
     })
 
     return () => sub.close()

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

@@ -6,7 +6,7 @@
   import type {Filter} from "@welshman/util"
   import {feedsFromFilters, makeIntersectionFeed, makeRelayFeed} from "@welshman/feeds"
   import {nthEq} from "@welshman/lib"
-  import {feedLoader, userMutes} from "@welshman/app"
+  import {createFeedController, userMutes} from "@welshman/app"
   import {createScroller} from "@lib/html"
   import Icon from "@lib/components/Icon.svelte"
   import Button from "@lib/components/Button.svelte"
@@ -24,11 +24,6 @@
   const mutedPubkeys = getPubkeyTagValues(getListTags($userMutes))
   const filters: Filter[] = [{kinds: [THREAD]}, {kinds: [COMMENT], "#K": [String(THREAD)]}]
   const feed = makeIntersectionFeed(makeRelayFeed(url), feedsFromFilters(filters))
-  const loader = feedLoader.getLoader(feed, {
-    onExhausted: () => {
-      loading = false
-    },
-  })
 
   const openMenu = () => pushDrawer(MenuSpace, {url})
 
@@ -39,6 +34,13 @@
   let element: Element
 
   onMount(() => {
+    const ctrl = createFeedController({
+      feed: feedsFromFilters(filters),
+      onExhausted: () => {
+        loading = false
+      },
+    })
+
     const unsub = subscribePersistent({
       filters: filters.map(assoc('since', ago(30))),
       relays: [url],
@@ -48,13 +50,7 @@
       element,
       delay: 300,
       threshold: 3000,
-      onScroll: async () => {
-        const $loader = await loader
-
-        await $loader(5)
-
-        limit += 5
-      },
+      onScroll: () => ctrl.load(5),
     })
 
     return () => {