diff --git a/src/app/core/requests.ts b/src/app/core/requests.ts index 3dedea09..dfab9bca 100644 --- a/src/app/core/requests.ts +++ b/src/app/core/requests.ts @@ -101,22 +101,26 @@ export const makeFeed = ({ } const unsubscribers = [ - on(repository, "update", batch(16, (updates: RepositoryUpdate[]) => { - const {added, removed} = mergeRepositoryUpdates(updates) + on( + repository, + "update", + batch(150, (updates: RepositoryUpdate[]) => { + const {added, removed} = mergeRepositoryUpdates(updates) - if (removed.size > 0) { - buffer = buffer.filter(e => !removed.has(e.id)) - events.update($events => $events.filter(e => !removed.has(e.id))) - } + if (removed.size > 0) { + buffer = buffer.filter(e => !removed.has(e.id)) + events.update($events => $events.filter(e => !removed.has(e.id))) + } - const matching = added.filter( - event => matchFilters(filters, event) && tracker.getRelays(event.id).has(url), - ) + const matching = added.filter( + event => matchFilters(filters, event) && tracker.getRelays(event.id).has(url), + ) - if (matching.length > 0) { - insertEvents(matching) - } - })), + if (matching.length > 0) { + insertEvents(matching) + } + }), + ), on(tracker, "add", (id: string, trackerUrl: string) => { if (trackerUrl === url) { const event = repository.getEvent(id) @@ -252,19 +256,23 @@ export const makeCalendarFeed = ({ } const unsubscribers = [ - on(repository, "update", batch(16, (updates: RepositoryUpdate[]) => { - const {added, removed} = mergeRepositoryUpdates(updates) + on( + repository, + "update", + batch(150, (updates: RepositoryUpdate[]) => { + const {added, removed} = mergeRepositoryUpdates(updates) - if (removed.size > 0) { - events.update($events => $events.filter(e => !removed.has(e.id))) - } + if (removed.size > 0) { + events.update($events => $events.filter(e => !removed.has(e.id))) + } - const matching = added.filter(event => matchFilters(filters, event)) + const matching = added.filter(event => matchFilters(filters, event)) - if (matching.length > 0) { - insertEvents(matching) - } - })), + if (matching.length > 0) { + insertEvents(matching) + } + }), + ), on(tracker, "add", (id: string, trackerUrl: string) => { if (trackerUrl === url) { const event = repository.getEvent(id) diff --git a/src/app/core/state.ts b/src/app/core/state.ts index 0cd790c8..56e1e871 100644 --- a/src/app/core/state.ts +++ b/src/app/core/state.ts @@ -967,8 +967,9 @@ export const deriveSpaceActionItems = (url: string) => pendingJoins.push( ...removeUndefined( - Array.from(groupBy(e => e.pubkey, roomJoins).values()) - .map(events => first(sortEventsDesc(events))), + Array.from(groupBy(e => e.pubkey, roomJoins).values()).map(events => + first(sortEventsDesc(events)), + ), ).filter(({pubkey, created_at}) => { if (roomMembers.has(pubkey)) return false if ( diff --git a/src/app/util/storage.ts b/src/app/util/storage.ts index 5a7b6dc2..1b65bc25 100644 --- a/src/app/util/storage.ts +++ b/src/app/util/storage.ts @@ -211,7 +211,8 @@ const loadCriticalRelays = async () => { relaysByUrl.set(indexBy(r => r.url, await table.getAll())) } -const syncRelays = () => onRelay(batch(FLUSH_INTERVAL, idleWrite(db.table("relays").bulkPut))) +const syncRelays = () => + onRelay(batch(FLUSH_INTERVAL, idleWrite(db.table("relays").bulkPut))) const initRelayStats = async () => { const table = db.table("relayStats") diff --git a/src/routes/spaces/[relay]/[h]/+page.svelte b/src/routes/spaces/[relay]/[h]/+page.svelte index a3648ef4..2626f214 100644 --- a/src/routes/spaces/[relay]/[h]/+page.svelte +++ b/src/routes/spaces/[relay]/[h]/+page.svelte @@ -481,7 +481,7 @@ {:else if type === "date"} {value} {:else} - {@const event = $state.snapshot(value as TrustedEvent)} + {@const event = value as TrustedEvent} {#if event.kind === ROOM_ADD_MEMBER} {:else} diff --git a/src/routes/spaces/[relay]/chat/+page.svelte b/src/routes/spaces/[relay]/chat/+page.svelte index 8290a535..00d1ee56 100644 --- a/src/routes/spaces/[relay]/chat/+page.svelte +++ b/src/routes/spaces/[relay]/chat/+page.svelte @@ -318,7 +318,7 @@ {:else if type === "date"} {value} {:else} - {@const event = $state.snapshot(value as TrustedEvent)} + {@const event = value as TrustedEvent} {#if event.kind === RELAY_ADD_MEMBER} {:else}