diff --git a/src/main/java/me/kavin/piped/server/ServerLauncher.java b/src/main/java/me/kavin/piped/server/ServerLauncher.java index 8af9028..6207f7c 100644 --- a/src/main/java/me/kavin/piped/server/ServerLauncher.java +++ b/src/main/java/me/kavin/piped/server/ServerLauncher.java @@ -315,7 +315,8 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher { } })).map(GET, "/feed/rss", AsyncServlet.ofBlocking(executor, request -> { try { - return getRawResponse(FeedHandlers.feedResponseRSS(request.getQueryParameter("authToken")), + return getRawResponse(FeedHandlers.feedResponseRSS(request.getQueryParameter("authToken"), + request.getQueryParameter("filter")), "application/atom+xml", "public, s-maxage=120"); } catch (Exception e) { return getErrorResponse(e, request.getPath()); @@ -339,7 +340,8 @@ public class ServerLauncher extends MultithreadedHttpServerLauncher { })).map(GET, "/feed/unauthenticated/rss", AsyncServlet.ofBlocking(executor, request -> { try { return getRawResponse(FeedHandlers.unauthenticatedFeedResponseRSS( - getArray(request.getQueryParameter("channels")) + getArray(request.getQueryParameter("channels")), + request.getQueryParameter("filter") ), "application/atom+xml", "public, s-maxage=120"); } catch (Exception e) { return getErrorResponse(e, request.getPath()); diff --git a/src/main/java/me/kavin/piped/server/handlers/auth/FeedHandlers.java b/src/main/java/me/kavin/piped/server/handlers/auth/FeedHandlers.java index 136e0c1..34f1977 100644 --- a/src/main/java/me/kavin/piped/server/handlers/auth/FeedHandlers.java +++ b/src/main/java/me/kavin/piped/server/handlers/auth/FeedHandlers.java @@ -21,6 +21,7 @@ import org.hibernate.Session; import org.hibernate.StatelessSession; import org.schabi.newpipe.extractor.channel.ChannelInfo; +import javax.annotation.Nullable; import java.io.IOException; import java.util.*; import java.util.concurrent.TimeUnit; @@ -119,7 +120,7 @@ public class FeedHandlers { return null; } - public static byte[] feedResponseRSS(String session) throws FeedException { + public static byte[] feedResponseRSS(String session, @Nullable String filter) throws FeedException { if (StringUtils.isBlank(session)) ExceptionHandler.throwErrorResponse(new InvalidRequestResponse("session is a required parameter")); @@ -131,6 +132,7 @@ public class FeedHandlers { SyndFeed feed = FeedHelpers.createRssFeed(user.getUsername()); final List entries = FeedHelpers.generateAuthenticatedFeed(s, user.getId(), 100) + .filter(FeedHelpers.createFeedFilter(filter)) .map(video -> { var channel = video.getChannel(); return ChannelHelpers.createEntry(video, channel); @@ -173,7 +175,7 @@ public class FeedHandlers { } } - public static byte[] unauthenticatedFeedResponseRSS(String[] channelIds) throws Exception { + public static byte[] unauthenticatedFeedResponseRSS(String[] channelIds, @Nullable String filter) throws Exception { Set filteredChannels = Arrays.stream(channelIds) .filter(ChannelHelpers::isValidId) @@ -183,7 +185,9 @@ public class FeedHandlers { ExceptionHandler.throwErrorResponse(new InvalidRequestResponse("No valid channel IDs provided")); try (StatelessSession s = DatabaseSessionFactory.createStatelessSession()) { - List