From: David ‘Bombe’ Roden Date: Fri, 8 Apr 2011 13:48:04 +0000 (+0200) Subject: Add “GetPostFeed” FCP command. X-Git-Tag: 0.6.5^2~39^2~40 X-Git-Url: https://git.pterodactylus.net/?a=commitdiff_plain;h=a50303a787867cdc2449da8846e1e365b771e109;p=Sone.git Add “GetPostFeed” FCP command. --- diff --git a/src/main/java/net/pterodactylus/sone/fcp/GetPostFeedCommand.java b/src/main/java/net/pterodactylus/sone/fcp/GetPostFeedCommand.java new file mode 100644 index 0000000..2dc59a1 --- /dev/null +++ b/src/main/java/net/pterodactylus/sone/fcp/GetPostFeedCommand.java @@ -0,0 +1,82 @@ +/* + * Sone - GetPostFeedCommand.java - Copyright © 2011 David Roden + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program. If not, see . + */ + +package net.pterodactylus.sone.fcp; + +import java.util.ArrayList; +import java.util.Collections; +import java.util.HashSet; +import java.util.List; +import java.util.Set; + +import net.pterodactylus.sone.core.Core; +import net.pterodactylus.sone.data.Post; +import net.pterodactylus.sone.data.Sone; +import net.pterodactylus.sone.freenet.fcp.FcpException; +import net.pterodactylus.util.filter.Filters; +import freenet.support.SimpleFieldSet; +import freenet.support.api.Bucket; + +/** + * Implementation of an FCP interface for other clients or plugins to + * communicate with Sone. + * + * @author David ‘Bombe’ Roden + */ +public class GetPostFeedCommand extends AbstractSoneCommand { + + /** + * Creates a new “GetPostFeed” command. + * + * @param core + * The core + */ + public GetPostFeedCommand(Core core) { + super(core); + } + + /** + * {@inheritDoc} + */ + @Override + public Reply execute(SimpleFieldSet parameters, Bucket data, AccessType accessType) throws FcpException { + Sone sone = getSone(parameters, "Sone"); + int startPost = getInt(parameters, "StartPost", 0); + int maxPosts = getInt(parameters, "MaxPosts", -1); + + Set allPosts = new HashSet(); + allPosts.addAll(sone.getPosts()); + for (String friendSoneId : sone.getFriends()) { + if (!getCore().hasSone(friendSoneId)) { + continue; + } + allPosts.addAll(getCore().getSone(friendSoneId).getPosts()); + } + allPosts.addAll(getCore().getDirectedPosts(sone)); + allPosts = Filters.filteredSet(allPosts, Post.FUTURE_POSTS_FILTER); + + List sortedPosts = new ArrayList(allPosts); + Collections.sort(sortedPosts, Post.TIME_COMPARATOR); + + if (sortedPosts.size() < startPost) { + return new Reply(encodePosts(Collections. emptyList())); + } + + return new Reply(encodePosts(sortedPosts.subList(startPost, (maxPosts == -1) ? sortedPosts.size() : Math.min(startPost + maxPosts, sortedPosts.size())))); + } + +}