forked from coracle/flotilla
Remove unnecessary snapshots, format
This commit is contained in:
+31
-23
@@ -101,22 +101,26 @@ export const makeFeed = ({
|
|||||||
}
|
}
|
||||||
|
|
||||||
const unsubscribers = [
|
const unsubscribers = [
|
||||||
on(repository, "update", batch(16, (updates: RepositoryUpdate[]) => {
|
on(
|
||||||
const {added, removed} = mergeRepositoryUpdates(updates)
|
repository,
|
||||||
|
"update",
|
||||||
|
batch(150, (updates: RepositoryUpdate[]) => {
|
||||||
|
const {added, removed} = mergeRepositoryUpdates(updates)
|
||||||
|
|
||||||
if (removed.size > 0) {
|
if (removed.size > 0) {
|
||||||
buffer = buffer.filter(e => !removed.has(e.id))
|
buffer = buffer.filter(e => !removed.has(e.id))
|
||||||
events.update($events => $events.filter(e => !removed.has(e.id)))
|
events.update($events => $events.filter(e => !removed.has(e.id)))
|
||||||
}
|
}
|
||||||
|
|
||||||
const matching = added.filter(
|
const matching = added.filter(
|
||||||
event => matchFilters(filters, event) && tracker.getRelays(event.id).has(url),
|
event => matchFilters(filters, event) && tracker.getRelays(event.id).has(url),
|
||||||
)
|
)
|
||||||
|
|
||||||
if (matching.length > 0) {
|
if (matching.length > 0) {
|
||||||
insertEvents(matching)
|
insertEvents(matching)
|
||||||
}
|
}
|
||||||
})),
|
}),
|
||||||
|
),
|
||||||
on(tracker, "add", (id: string, trackerUrl: string) => {
|
on(tracker, "add", (id: string, trackerUrl: string) => {
|
||||||
if (trackerUrl === url) {
|
if (trackerUrl === url) {
|
||||||
const event = repository.getEvent(id)
|
const event = repository.getEvent(id)
|
||||||
@@ -252,19 +256,23 @@ export const makeCalendarFeed = ({
|
|||||||
}
|
}
|
||||||
|
|
||||||
const unsubscribers = [
|
const unsubscribers = [
|
||||||
on(repository, "update", batch(16, (updates: RepositoryUpdate[]) => {
|
on(
|
||||||
const {added, removed} = mergeRepositoryUpdates(updates)
|
repository,
|
||||||
|
"update",
|
||||||
|
batch(150, (updates: RepositoryUpdate[]) => {
|
||||||
|
const {added, removed} = mergeRepositoryUpdates(updates)
|
||||||
|
|
||||||
if (removed.size > 0) {
|
if (removed.size > 0) {
|
||||||
events.update($events => $events.filter(e => !removed.has(e.id)))
|
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) {
|
if (matching.length > 0) {
|
||||||
insertEvents(matching)
|
insertEvents(matching)
|
||||||
}
|
}
|
||||||
})),
|
}),
|
||||||
|
),
|
||||||
on(tracker, "add", (id: string, trackerUrl: string) => {
|
on(tracker, "add", (id: string, trackerUrl: string) => {
|
||||||
if (trackerUrl === url) {
|
if (trackerUrl === url) {
|
||||||
const event = repository.getEvent(id)
|
const event = repository.getEvent(id)
|
||||||
|
|||||||
@@ -967,8 +967,9 @@ export const deriveSpaceActionItems = (url: string) =>
|
|||||||
|
|
||||||
pendingJoins.push(
|
pendingJoins.push(
|
||||||
...removeUndefined(
|
...removeUndefined(
|
||||||
Array.from(groupBy(e => e.pubkey, roomJoins).values())
|
Array.from(groupBy(e => e.pubkey, roomJoins).values()).map(events =>
|
||||||
.map(events => first(sortEventsDesc(events))),
|
first(sortEventsDesc(events)),
|
||||||
|
),
|
||||||
).filter(({pubkey, created_at}) => {
|
).filter(({pubkey, created_at}) => {
|
||||||
if (roomMembers.has(pubkey)) return false
|
if (roomMembers.has(pubkey)) return false
|
||||||
if (
|
if (
|
||||||
|
|||||||
@@ -211,7 +211,8 @@ const loadCriticalRelays = async () => {
|
|||||||
relaysByUrl.set(indexBy(r => r.url, await table.getAll()))
|
relaysByUrl.set(indexBy(r => r.url, await table.getAll()))
|
||||||
}
|
}
|
||||||
|
|
||||||
const syncRelays = () => onRelay(batch(FLUSH_INTERVAL, idleWrite(db.table<RelayProfile>("relays").bulkPut)))
|
const syncRelays = () =>
|
||||||
|
onRelay(batch(FLUSH_INTERVAL, idleWrite(db.table<RelayProfile>("relays").bulkPut)))
|
||||||
|
|
||||||
const initRelayStats = async () => {
|
const initRelayStats = async () => {
|
||||||
const table = db.table<RelayStats>("relayStats")
|
const table = db.table<RelayStats>("relayStats")
|
||||||
|
|||||||
@@ -481,7 +481,7 @@
|
|||||||
{:else if type === "date"}
|
{:else if type === "date"}
|
||||||
<Divider>{value}</Divider>
|
<Divider>{value}</Divider>
|
||||||
{:else}
|
{:else}
|
||||||
{@const event = $state.snapshot(value as TrustedEvent)}
|
{@const event = value as TrustedEvent}
|
||||||
{#if event.kind === ROOM_ADD_MEMBER}
|
{#if event.kind === ROOM_ADD_MEMBER}
|
||||||
<RoomItemAddMember {url} {event} />
|
<RoomItemAddMember {url} {event} />
|
||||||
{:else}
|
{:else}
|
||||||
|
|||||||
@@ -318,7 +318,7 @@
|
|||||||
{:else if type === "date"}
|
{:else if type === "date"}
|
||||||
<Divider>{value}</Divider>
|
<Divider>{value}</Divider>
|
||||||
{:else}
|
{:else}
|
||||||
{@const event = $state.snapshot(value as TrustedEvent)}
|
{@const event = value as TrustedEvent}
|
||||||
{#if event.kind === RELAY_ADD_MEMBER}
|
{#if event.kind === RELAY_ADD_MEMBER}
|
||||||
<RoomItemAddMember {url} {event} />
|
<RoomItemAddMember {url} {event} />
|
||||||
{:else}
|
{:else}
|
||||||
|
|||||||
Reference in New Issue
Block a user