X-Git-Url: https://git.pterodactylus.net/?p=Sone.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FCore.java;h=4319d8bc56a28b1013391d437ce7c3ff39eb78e2;hp=ccf633c180b3a3a01fe7c5445df3d70c6411fd4f;hb=156dcb1729b154faa5630c3b3e66644f4178b556;hpb=4b42574c9ec4490100ac3e87b9c2f3aac965a202

diff --git a/src/main/java/net/pterodactylus/sone/core/Core.java b/src/main/java/net/pterodactylus/sone/core/Core.java
index ccf633c..4319d8b 100644
--- a/src/main/java/net/pterodactylus/sone/core/Core.java
+++ b/src/main/java/net/pterodactylus/sone/core/Core.java
@@ -113,8 +113,6 @@ import kotlin.jvm.functions.Function1;
 
 /**
  * The Sone core.
- *
- * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
  */
 @Singleton
 public class Core extends AbstractService implements SoneProvider, PostProvider, PostReplyProvider {
@@ -861,7 +859,9 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
 		soneChangeDetector.onNewPosts(new PostProcessor() {
 			@Override
 			public void processPost(Post post) {
-				if (post.getTime() < database.getFollowingTime(newSone.getId())) {
+				if (post.getSone().equals(newSone)) {
+					post.setKnown(true);
+				} else if (post.getTime() < database.getFollowingTime(newSone.getId())) {
 					post.setKnown(true);
 				} else if (!post.isKnown()) {
 					events.add(new NewPostFoundEvent(post));
@@ -877,7 +877,9 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
 		soneChangeDetector.onNewPostReplies(new PostReplyProcessor() {
 			@Override
 			public void processPostReply(PostReply postReply) {
-				if (postReply.getTime() < database.getFollowingTime(newSone.getId())) {
+				if (postReply.getSone().equals(newSone)) {
+					postReply.setKnown(true);
+				} else if (postReply.getTime() < database.getFollowingTime(newSone.getId())) {
 					postReply.setKnown(true);
 				} else if (!postReply.isKnown()) {
 					events.add(new NewPostReplyFoundEvent(postReply));