Bump welshman/net

This commit is contained in:
Jon Staab 2024-06-20 12:12:48 -07:00
parent c9db37c92a
commit e212297396
4 changed files with 18 additions and 4 deletions

BIN
package-lock.json generated

Binary file not shown.

View File

@ -58,7 +58,7 @@
"@welshman/content": "^0.0.5", "@welshman/content": "^0.0.5",
"@welshman/feeds": "^0.0.12", "@welshman/feeds": "^0.0.12",
"@welshman/lib": "^0.0.10", "@welshman/lib": "^0.0.10",
"@welshman/net": "^0.0.13", "@welshman/net": "^0.0.14",
"@welshman/util": "^0.0.15", "@welshman/util": "^0.0.15",
"bowser": "^2.11.0", "bowser": "^2.11.0",
"classnames": "^2.5.1", "classnames": "^2.5.1",

View File

@ -12,8 +12,9 @@
import PersonBadgeSmall from "src/app/shared/PersonBadgeSmall.svelte" import PersonBadgeSmall from "src/app/shared/PersonBadgeSmall.svelte"
import {readFeed, readList, displayFeed, mapListToFeed, getSingletonValues} from "src/domain" import {readFeed, readList, displayFeed, mapListToFeed, getSingletonValues} from "src/domain"
import { import {
repository, hints,
pubkey, pubkey,
repository,
addFeedFavorite, addFeedFavorite,
removeFeedFavorite, removeFeedFavorite,
userFeedFavorites, userFeedFavorites,
@ -26,6 +27,7 @@
const expandDefinition = boolCtrl() const expandDefinition = boolCtrl()
const event = repository.getEvent(address) const event = repository.getEvent(address)
const deleted = repository.isDeleted(event) const deleted = repository.isDeleted(event)
const naddr = Address.from(address, hints.Event(event).getUrls()).toNaddr()
const feed = address.startsWith(NAMED_BOOKMARKS) const feed = address.startsWith(NAMED_BOOKMARKS)
? mapListToFeed(readList(event)) ? mapListToFeed(readList(event))
: readFeed(event) : readFeed(event)
@ -88,7 +90,7 @@
on:click={toggleFavorite}> on:click={toggleFavorite}>
<i class="fa fa-bookmark" class:text-accent={isFavorite} /> <i class="fa fa-bookmark" class:text-accent={isFavorite} />
</div> </div>
<CopyValueSimple label="Feed address" value={toNostrURI(Address.from(address).toNaddr())} /> <CopyValueSimple label="Feed address" value={toNostrURI(naddr)} />
</div> </div>
</div> </div>
{#if $expandDefinition.enabled} {#if $expandDefinition.enabled}

View File

@ -1537,6 +1537,7 @@ export const onAuth = async (url, challenge) => {
export type MySubscribeRequest = SubscribeRequest & { export type MySubscribeRequest = SubscribeRequest & {
onEvent?: (event: TrustedEvent) => void onEvent?: (event: TrustedEvent) => void
onEose?: (url: string) => void
onComplete?: () => void onComplete?: () => void
skipCache?: boolean skipCache?: boolean
forcePlatform?: boolean forcePlatform?: boolean
@ -1581,6 +1582,10 @@ export const subscribe = ({forcePlatform = true, ...request}: MySubscribeRequest
projections.push(await ensureUnwrapped(event)) projections.push(await ensureUnwrapped(event))
}) })
if (request.onEose) {
sub.emitter.on("eose", request.onEose)
}
if (request.onComplete) { if (request.onComplete) {
sub.emitter.on("complete", request.onComplete) sub.emitter.on("complete", request.onComplete)
} }
@ -1619,7 +1624,14 @@ export const subscribePersistent = (request: MySubscribeRequest) => {
export const LOAD_OPTS = {timeout: 3000, closeOnEose: true} export const LOAD_OPTS = {timeout: 3000, closeOnEose: true}
export const load = (request: MySubscribeRequest) => subscribe({...request, ...LOAD_OPTS}).result export const load = (request: MySubscribeRequest) =>
new Promise(resolve => {
const events = []
const sub = subscribe({...request, ...LOAD_OPTS})
sub.emitter.on("event", (url: string, event: TrustedEvent) => events.push(event))
sub.emitter.on("complete", (url: string) => resolve(events))
})
export const loadOne = (request: MySubscribeRequest) => export const loadOne = (request: MySubscribeRequest) =>
new Promise<TrustedEvent | null>(resolve => { new Promise<TrustedEvent | null>(resolve => {