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=327a53c4ef323f57faf24177e6afeb171aa6d2d8;hb=156dcb1729b154faa5630c3b3e66644f4178b556;hpb=b047ee44669ce31726b17c54425697b53f08d2fe

diff --git a/src/main/java/net/pterodactylus/sone/core/Core.java b/src/main/java/net/pterodactylus/sone/core/Core.java
index 327a53c..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 {
@@ -691,7 +689,7 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
 		}
 		database.storeSone(sone);
 		soneDownloader.addSone(sone);
-		soneDownloaders.execute(soneDownloader.fetchSoneWithUriAction(sone));
+		soneDownloaders.execute(soneDownloader.fetchSoneAsUskAction(sone));
 		return sone;
 	}
 
@@ -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));
@@ -1650,7 +1652,7 @@ public class Core extends AbstractService implements SoneProvider, PostProvider,
 			}
 		}
 		soneDownloader.addSone(sone);
-		soneDownloaders.execute(soneDownloader.fetchSoneAction(sone));
+		soneDownloaders.execute(soneDownloader.fetchSoneAsSskAction(sone));
 	}
 
 	/**