mleku/flotilla
1
1
Fork 0
mirror of https://github.com/coracle-social/flotilla.git synced 2025-12-10 19:07:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Sync messages at the space level

Browse Source
This commit is contained in:
Jon Staab
2025-10-28 15:46:25 -07:00
parent b09d3065ae
commit df42085be6
1 changed files with 2 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/app/core/sync.ts
View File

@@ -39,6 +39,7 @@ import {
relaysByUrl, relaysByUrl,
} from "@welshman/app" } from "@welshman/app"
import { import {
MESSAGE_KINDS,
CONTENT_KINDS, CONTENT_KINDS,
INDEXER_RELAYS, INDEXER_RELAYS,
loadSettings, loadSettings,
@@ -265,7 +266,7 @@ const syncSpace = (url: string) => {
{kinds: [RELAY_MEMBERS]}, {kinds: [RELAY_MEMBERS]},
{kinds: [ROOM_META]}, {kinds: [ROOM_META]},
{kinds: [RELAY_ADD_MEMBER, RELAY_REMOVE_MEMBER]}, {kinds: [RELAY_ADD_MEMBER, RELAY_REMOVE_MEMBER]},
...CONTENT_KINDS.map(kind => ({kinds: [kind]})), ...MESSAGE_KINDS.map(kind => ({kinds: [kind]})),
makeCommentFilter(CONTENT_KINDS), makeCommentFilter(CONTENT_KINDS),
], ],
}) })
@@ -327,18 +328,6 @@ const syncSpaces = () => {
// Chat // Chat
const syncSpaceChat = (url: string) => {
const controller = new AbortController()
pullAndListen({
relays: [url],
signal: controller.signal,
filters: [{kinds: [MESSAGE]}],
})
return () => controller.abort()
}
const syncRoomChat = (url: string, room: string) => { const syncRoomChat = (url: string, room: string) => {
const controller = new AbortController() const controller = new AbortController()
@@ -376,12 +365,6 @@ const syncRooms = () => {
keys.add(id) keys.add(id)
} }
} else {
if (!unsubscribersByKey.has(url)) {
newUnsubscribersByKey.set(url, syncSpaceChat(url))
}
keys.add(url)
} }
} }