X-Git-Url: https://git.pterodactylus.net/?p=Sone.git;a=blobdiff_plain;f=src%2Fmain%2Fkotlin%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FUpdatedSoneProcessor.kt;fp=src%2Fmain%2Fkotlin%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FUpdatedSoneProcessor.kt;h=54af30a6ce683e902e27d23061b5994d3264acaf;hp=28bac6d0cbc2e31cfeab3bb3644aa6c73e654212;hb=5c5bee980f9cab5792e34d1c9840f73b8b191830;hpb=faf66247a34f64946990a985d2ea3003465969cb

diff --git a/src/main/kotlin/net/pterodactylus/sone/core/UpdatedSoneProcessor.kt b/src/main/kotlin/net/pterodactylus/sone/core/UpdatedSoneProcessor.kt
index 28bac6d..54af30a 100644
--- a/src/main/kotlin/net/pterodactylus/sone/core/UpdatedSoneProcessor.kt
+++ b/src/main/kotlin/net/pterodactylus/sone/core/UpdatedSoneProcessor.kt
@@ -42,7 +42,7 @@ abstract class BasicUpdateSoneProcessor(private val database: Database, private
 					.map { PostRemovedEvent(it) }
 					.forEach(eventBus::post)
 			newPostReplies
-					.onEach { postReply -> if (postReply.time <= sone.followingTime) postReply.isKnown = true }
+					.onEach { postReply -> if (postReply.time <= sone.followingTime) database.setPostReplyKnown(postReply) }
 					.mapNotNull { postReply -> postReply.isKnown.ifFalse { NewPostReplyFoundEvent(postReply) } }
 					.forEach(eventBus::post)
 			removedPostReplies