Merge pull request #2286 from okTurtles/bugfix-enqueue-pubsubevents

Enqueue all pubsub events
okTurtles · Aug 6, 2024 · 21974e5 · 21974e5
2 parents 63ae0a0 + 7e800b0
commit 21974e5
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/shared/domains/chelonia/chelonia.js b/shared/domains/chelonia/chelonia.js
@@ -573,14 +573,14 @@ export default (sbp('sbp/selectors/register', {
                     console.info(`[chelonia] Discarding pub event for ${msg.channelID} because it's not in the current subscriptionSet`)
                     return
                   }
-                  try {
+                  sbp('chelonia/queueInvocation', msg.channelID, () => {
                     (v: Function)(parseEncryptedOrUnencryptedMessage.call(this, {
                       contractID: msg.channelID,
                       serializedData: msg.data
                     }))
-                  } catch (e) {
+                  }).catch(e => {
                     console.error(`[chelonia] Error processing pub event for ${msg.channelID}`, e)
-                  }
+                  })
                 }]
               case NOTIFICATION_TYPE.KV:
                 return [k, (msg) => {
@@ -592,15 +592,15 @@ export default (sbp('sbp/selectors/register', {
                     console.info(`[chelonia] Discarding kv event for ${msg.channelID} because it's not in the current subscriptionSet`)
                     return
                   }
-                  try {
+                  sbp('chelonia/queueInvocation', msg.channelID, () => {
                     (v: Function)([msg.key, parseEncryptedOrUnencryptedMessage.call(this, {
                       contractID: msg.channelID,
                       meta: msg.key,
                       serializedData: JSON.parse(Buffer.from(msg.data).toString())
                     })])
-                  } catch (e) {
+                  }).catch(e => {
                     console.error(`[chelonia] Error processing kv event for ${msg.channelID} and key ${msg.key}`, e)
-                  }
+                  })
                 }]
               default:
                 return [k, v]