Don’t check for non-existing Sone-following times on your own posts/replies
[Sone.git] / src / main / java / net / pterodactylus / sone / core / Core.java
index ccf633c..4319d8b 100644 (file)
@@ -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));