aljaz/boris
1
1
Fork 0
mirror of https://github.com/dergigi/boris.git synced 2025-12-28 03:54:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: make controller onEvent non-blocking for queryEvents completion

Browse Source 
Changed onEvent callback from async to synchronous:
- Removed await inside onEvent that was blocking observable
- Decryption now fires in background using .then()/.catch()
- Allows queryEvents to complete (EOSE) and trigger final bookmark build

This matches the working Debug pattern and allows bookmarks to appear in sidebar.
This commit is contained in:
Gigi
2025-10-17 23:12:19 +02:00
parent f95f8f4bf1
commit 7a75982715
1 changed files with 18 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/services/bookmarkController.ts
View File

@@ -268,7 +268,7 @@ class BookmarkController {
relayPool,
{ kinds: [KINDS.ListSimple, KINDS.ListReplaceable, KINDS.List, KINDS.WebBookmark], authors: [account.pubkey] },
{
onEvent: async (evt) => {
onEvent: (evt) => {
const key = getEventKey(evt)
const existing = this.currentEvents.get(key)
@@ -286,29 +286,27 @@ class BookmarkController {
// Schedule bookmark update (non-blocking, coalesced)
this.scheduleBookmarkUpdate(relayPool, maybeAccount, signerCandidate)
// Auto-decrypt if event has encrypted content
// Auto-decrypt if event has encrypted content (fire-and-forget, non-blocking)
if (hasEncryptedContent(evt)) {
console.log('[controller] 🔓 Auto-decrypting event', evt.id.slice(0, 8))
try {
const { publicItemsAll, privateItemsAll } = await collectBookmarksFromEvents(
[evt],
account,
signerCandidate
)
this.decryptedEvents.set(evt.id, {
public: publicItemsAll.length,
private: privateItemsAll.length
// Don't await - let it run in background
collectBookmarksFromEvents([evt], account, signerCandidate)
.then(({ publicItemsAll, privateItemsAll }) => {
this.decryptedEvents.set(evt.id, {
public: publicItemsAll.length,
private: privateItemsAll.length
})
console.log('[controller] ✅ Auto-decrypted:', evt.id.slice(0, 8), {
public: publicItemsAll.length,
private: privateItemsAll.length
})
// Schedule another update after decrypt
this.scheduleBookmarkUpdate(relayPool, maybeAccount, signerCandidate)
})
console.log('[controller] ✅ Auto-decrypted:', evt.id.slice(0, 8), {
public: publicItemsAll.length,
private: privateItemsAll.length
.catch((error) => {
console.error('[controller] ❌ Auto-decrypt failed:', evt.id.slice(0, 8), error)
})
// Schedule another update after decrypt
this.scheduleBookmarkUpdate(relayPool, maybeAccount, signerCandidate)
} catch (error) {
console.error('[controller] ❌ Auto-decrypt failed:', evt.id.slice(0, 8), error)
}
}
}
}