Adds a check for deletion before processing inner posts

This commit is contained in:
Vitor Pamplona
2025-08-06 18:02:26 -04:00
parent fdff92dff9
commit 036b385f38
@@ -1375,7 +1375,7 @@ object LocalCache : ILocalCache {
repliesTo.forEach { it.addBoost(note) } repliesTo.forEach { it.addBoost(note) }
event.containedPost()?.let { event.containedPost()?.let {
justConsumeAndUpdateIndexes(it, relay, false) checkDeletionAndConsume(it, relay, false)
} }
refreshNewNoteObservers(note) refreshNewNoteObservers(note)
@@ -1405,7 +1405,7 @@ object LocalCache : ILocalCache {
repliesTo.forEach { it.addBoost(note) } repliesTo.forEach { it.addBoost(note) }
event.containedPost()?.let { event.containedPost()?.let {
justConsumeAndUpdateIndexes(it, relay, false) checkDeletionAndConsume(it, relay, false)
} }
refreshNewNoteObservers(note) refreshNewNoteObservers(note)
@@ -1440,7 +1440,7 @@ object LocalCache : ILocalCache {
repliesTo.forEach { it.addBoost(note) } repliesTo.forEach { it.addBoost(note) }
event.containedPost()?.let { event.containedPost()?.let {
justConsumeAndUpdateIndexes(it, relay, false) checkDeletionAndConsume(it, relay, false)
} }
refreshNewNoteObservers(note) refreshNewNoteObservers(note)
@@ -1683,7 +1683,7 @@ object LocalCache : ILocalCache {
if (existingZapRequest == null || existingZapRequest.event == null) { if (existingZapRequest == null || existingZapRequest.event == null) {
// tries to add it // tries to add it
event.zapRequest?.let { event.zapRequest?.let {
justConsumeAndUpdateIndexes(it, relay, false) checkDeletionAndConsume(it, relay, false)
} }
} }
@@ -2634,6 +2634,17 @@ object LocalCache : ILocalCache {
return justConsumeAndUpdateIndexes(event, relay?.url, wasVerified) return justConsumeAndUpdateIndexes(event, relay?.url, wasVerified)
} }
private fun checkDeletionAndConsume(
event: Event,
relay: NormalizedRelayUrl?,
wasVerified: Boolean,
): Boolean =
if (!deletionIndex.hasBeenDeleted(event)) {
justConsumeAndUpdateIndexes(event, relay, wasVerified)
} else {
false
}
private fun justConsumeAndUpdateIndexes( private fun justConsumeAndUpdateIndexes(
event: Event, event: Event,
relay: NormalizedRelayUrl?, relay: NormalizedRelayUrl?,