X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fdatabase%2Fmemory%2FMemoryBookmarkDatabase.java;h=594cf2b3bc05a1afcc82f8a19355eee1604ae1ad;hb=3b711e4ff7898c71778dd3a8695ee3e0e3542861;hp=78c8a4f093b421465ae8271f564bad4b276a2a12;hpb=36b8e20651c14970ca30a1b8ed43af219b367bc9;p=Sone.git diff --git a/src/main/java/net/pterodactylus/sone/database/memory/MemoryBookmarkDatabase.java b/src/main/java/net/pterodactylus/sone/database/memory/MemoryBookmarkDatabase.java index 78c8a4f..594cf2b 100644 --- a/src/main/java/net/pterodactylus/sone/database/memory/MemoryBookmarkDatabase.java +++ b/src/main/java/net/pterodactylus/sone/database/memory/MemoryBookmarkDatabase.java @@ -8,6 +8,7 @@ import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import net.pterodactylus.sone.data.Post; +import net.pterodactylus.sone.data.Post.EmptyPost; import net.pterodactylus.sone.database.BookmarkDatabase; import com.google.common.base.Function; @@ -45,13 +46,16 @@ public class MemoryBookmarkDatabase implements BookmarkDatabase { } } - @Override - public void bookmarkPost(String postId) { - lock.writeLock().lock(); + public void stop() { + saveBookmarkedPosts(); + } + + private void saveBookmarkedPosts() { + lock.readLock().lock(); try { - bookmarkedPosts.add(postId); + configurationLoader.saveBookmarkedPosts(this.bookmarkedPosts); } finally { - lock.writeLock().unlock(); + lock.readLock().unlock(); } } @@ -60,6 +64,7 @@ public class MemoryBookmarkDatabase implements BookmarkDatabase { lock.writeLock().lock(); try { bookmarkedPosts.add(post.getId()); + saveBookmarkedPosts(); } finally { lock.writeLock().unlock(); } @@ -70,6 +75,7 @@ public class MemoryBookmarkDatabase implements BookmarkDatabase { lock.writeLock().lock(); try { bookmarkedPosts.remove(post.getId()); + saveBookmarkedPosts(); } finally { lock.writeLock().unlock(); } @@ -89,11 +95,12 @@ public class MemoryBookmarkDatabase implements BookmarkDatabase { public Set getBookmarkedPosts() { lock.readLock().lock(); try { - return from(bookmarkedPosts).transformAndConcat( - new Function>() { + return from(bookmarkedPosts).transform( + new Function() { @Override - public Iterable apply(String postId) { - return memoryDatabase.getPost(postId).asSet(); + public Post apply(String postId) { + return memoryDatabase.getPost(postId) + .or(new EmptyPost(postId)); } }).toSet(); } finally {