import java.util.Date; import java.util.List; import net.yacy.cora.document.feed.RSSFeed; import net.yacy.cora.document.feed.RSSMessage; import net.yacy.cora.protocol.RequestHeader; import net.yacy.cora.util.CommonPattern; import net.yacy.peers.EventChannel; import net.yacy.search.Switchboard; import net.yacy.server.serverObjects; import net.yacy.server.serverSwitch; public class feed { public static serverObjects respond(final RequestHeader header, final serverObjects post, final serverSwitch env) { final Switchboard sb = (Switchboard) env; // insert default values final serverObjects prop = new serverObjects(); prop.put("channel_title", ""); prop.put("channel_description", ""); prop.put("channel_pubDate", ""); prop.put("item", "0"); if ((post == null) || (env == null)) return prop; final boolean authorized = sb.verifyAuthentication(header); final String channelNames = post.get("set"); if (channelNames == null) return prop; final String[] channels = CommonPattern.COMMA.split(channelNames); // several channel names can be given and separated by comma int messageCount = 0; int messageMaxCount = Math.min(post.getInt("count", 100), 1000); channelIteration: for (final String channelName: channels) { // prevent that unauthorized access to this servlet get results from private data final EventChannel channel = EventChannel.valueOf(channelName); if (channel == null) continue channelIteration; if (!authorized && EventChannel.privateChannels.contains(channel)) continue channelIteration; // allow only public channels if not authorized if ("TEST".equals(channelName)) { // for interface testing return at least one single result prop.putXML("channel_title", "YaCy News Testchannel"); prop.putXML("channel_description", ""); prop.put("channel_pubDate", (new Date()).toString()); prop.putXML("item_" + messageCount + "_title", channelName + ": " + "YaCy Test Entry " + (new Date()).toString()); prop.putXML("item_" + messageCount + "_description", "abcdefg"); prop.putXML("item_" + messageCount + "_link", "http://yacy.net"); prop.put("item_" + messageCount + "_pubDate", (new Date()).toString()); prop.put("item_" + messageCount + "_guid", System.currentTimeMillis()); messageCount++; messageMaxCount--; continue channelIteration; } // read the channel final RSSFeed feed = EventChannel.channels(channel); if (feed == null || feed.isEmpty()) continue channelIteration; RSSMessage message = feed.getChannel(); List descriptions = message.getDescriptions(); String description = descriptions.size() > 0 ? descriptions.get(0) : ""; if (message != null) { prop.putXML("channel_title", message.getTitle()); prop.putXML("channel_description", description); prop.put("channel_pubDate", message.getPubDate()); } while (messageMaxCount > 0 && !feed.isEmpty()) { message = feed.pollMessage(); if (message == null) continue; // create RSS entry prop.putXML("item_" + messageCount + "_title", channelName + ": " + message.getTitle()); descriptions = message.getDescriptions(); description = descriptions.size() > 0 ? descriptions.get(0) : ""; prop.putXML("item_" + messageCount + "_description", description); prop.putXML("item_" + messageCount + "_link", message.getLink()); prop.put("item_" + messageCount + "_pubDate", message.getPubDate()); prop.putXML("item_" + messageCount + "_guid", message.getGuid()); messageCount++; messageMaxCount--; } if (messageMaxCount == 0) break channelIteration; } prop.put("item", messageCount); // return rewrite properties return prop; } }