Flush Benefit removals immediately (Joystream#375)

Author: traumschule

src/mappings/content/commentsAndReactions.ts

@@ -218,6 +218,7 @@ async function processVideoReaction(
       --previousReactionTypeCounter.count
       // remove reaction
       videoReactionRepository.remove(existingReaction)
+      await overlay.updateDatabase()
       return
     }
     // otherwise...
@@ -370,6 +371,7 @@ export async function processReactCommentMessage(
     --comment.reactionsCount
     // remove reaction
     commentReactionRepository.remove(existingReaction)
+    await overlay.updateDatabase()
   } else {
     // new reaction
     const id = commentReactionEntityId({ memberId, commentId, reactionId })

src/mappings/content/utils.ts

@@ -169,6 +169,7 @@ export async function deleteChannel(overlay: EntityManagerOverlay, channelId: bi
 
   overlay.getRepository(BannedMember).remove(...bannedMembers)
   overlay.getRepository(Channel).remove(channelId.toString())
+  await overlay.updateDatabase()
   // delete channel related notifications
 }
 
@@ -204,6 +205,7 @@ export async function deleteVideo(overlay: EntityManagerOverlay, videoId: bigint
   }
   subtitlesRepository.remove(...subtitles)
   videoRepository.remove(video)
+  await overlay.updateDatabase()
 }
 
 export async function processNft(

src/mappings/token/utils.ts

@@ -244,12 +244,13 @@ export async function processTokenMetadata(
     token.description = metadata.description
   }
 
-  // remove all current bnefits
+  // remove all current benefits
   const existingBenefit = await overlay
     .getRepository(Benefit)
     .getManyByRelation('tokenId', token.id)
   if (existingBenefit !== undefined) {
     overlay.getRepository(Benefit).remove(...existingBenefit)
+    await overlay.updateDatabase()
   }
 
   if (isSet(metadata.benefits)) {
@@ -302,6 +303,7 @@ export async function processTokenMetadata(
       }
       if (oldTrailer) {
         trailerVideoRepository.remove(oldTrailer)
+        await overlay.updateDatabase()
       }
 
       const id = overlay.getRepository(TrailerVideo).getNewEntityId()
@@ -316,6 +318,7 @@ export async function processTokenMetadata(
     const oldTrailer = await trailerVideoRepository.getOneByRelation('tokenId', token.id)
     if (oldTrailer) {
       trailerVideoRepository.remove(oldTrailer)
+      await overlay.updateDatabase()
     }
   }
 }