@@ -81,7 +81,7 @@ export const handleEventToSyncDB = async <
8181 const cid = event . cid ;
8282 const user = event . user ;
8383 if ( user ?. id && cid ) {
84- return await queriesWithChannelGuard ( async ( flushOverride ) =>
84+ return await queriesWithChannelGuard ( ( flushOverride ) =>
8585 upsertReads ( {
8686 cid,
8787 flush : flushOverride ,
@@ -115,7 +115,7 @@ export const handleEventToSyncDB = async <
115115 if ( message && ! message . parent_id ) {
116116 // Update only if it exists, otherwise event could be related
117117 // to a message which is not in database.
118- return await queriesWithChannelGuard ( async ( flushOverride ) =>
118+ return await queriesWithChannelGuard ( ( flushOverride ) =>
119119 updateMessage ( {
120120 flush : flushOverride ,
121121 message,
@@ -128,7 +128,7 @@ export const handleEventToSyncDB = async <
128128 const message = event . message ;
129129 if ( message && event . reaction ) {
130130 // We update the entire message to make sure we also update reaction_groups
131- return await queriesWithChannelGuard ( async ( flushOverride ) =>
131+ return await queriesWithChannelGuard ( ( flushOverride ) =>
132132 updateMessage ( {
133133 flush : flushOverride ,
134134 message,
@@ -143,7 +143,7 @@ export const handleEventToSyncDB = async <
143143 // Here we are relying on the fact message.latest_reactions always includes
144144 // the new reaction. So we first delete all the existing reactions and populate
145145 // the reactions table with message.latest_reactions
146- return await queriesWithChannelGuard ( async ( flushOverride ) =>
146+ return await queriesWithChannelGuard ( ( flushOverride ) =>
147147 updateMessage ( {
148148 flush : flushOverride ,
149149 message,
@@ -202,7 +202,7 @@ export const handleEventToSyncDB = async <
202202 const member = event . member ;
203203 const cid = event . cid ;
204204 if ( member && cid ) {
205- return await queriesWithChannelGuard ( async ( flushOverride ) =>
205+ return await queriesWithChannelGuard ( ( flushOverride ) =>
206206 upsertMembers ( {
207207 cid,
208208 flush : flushOverride ,
@@ -216,7 +216,7 @@ export const handleEventToSyncDB = async <
216216 const member = event . member ;
217217 const cid = event . cid ;
218218 if ( member && cid ) {
219- return await queriesWithChannelGuard ( async ( flushOverride ) =>
219+ return await queriesWithChannelGuard ( ( flushOverride ) =>
220220 deleteMember ( {
221221 cid,
222222 flush : flushOverride ,
0 commit comments