src/layouts/Main.tsx

@@ -109,7 +109,6 @@ export const MainLayout = () => {
 
       if (pubkey && !hasSubscribed.current) {
         // Call `subscribeForSigits` only if it hasn't been called before
-        // #193 disabled websocket subscribtion, until #194 is done
         subscribeForSigits(pubkey)
 
         // Mark `subscribeForSigits` as called

src/utils/nostr.ts

@@ -859,16 +859,9 @@ export const subscribeForSigits = async (pubkey: string) => {
     '#p': [pubkey]
   }
 
-  // Process the received event synchronously
+  relayController.subscribeForEvents(filter, relaySet.read, (event) => {
-  const events = await relayController.fetchEvents(filter, relaySet.read)
+    processReceivedEvent(event) // Process the received event
-  for (const e of events) {
+  })
-    await processReceivedEvent(e)
-  }
-
-  // Async processing of the events has a race condition
-  // relayController.subscribeForEvents(filter, relaySet.read, (event) => {
-  //   processReceivedEvent(event)
-  // })
 }
 
 const processReceivedEvent = async (event: Event, difficulty: number = 5) => {
@@ -914,7 +907,7 @@ const processReceivedEvent = async (event: Event, difficulty: number = 5) => {
 
   if (!meta) return
 
-  await updateUsersAppData(meta)
+  updateUsersAppData(meta)
 }
 
 /**