Fixed MediaCCCRecentKiosk

Ignore faulty data/items (with duration <= 0)

Author: litetex

extractor/src/main/java/org/schabi/newpipe/extractor/services/media_ccc/extractors/MediaCCCRecentKiosk.java

@@ -16,7 +16,9 @@
 
 import javax.annotation.Nonnull;
 import java.io.IOException;
+import java.time.OffsetDateTime;
 import java.util.Comparator;
+import java.util.function.Function;
 
 public class MediaCCCRecentKiosk extends KioskExtractor<StreamInfoItem> {
 
@@ -51,11 +53,17 @@ public InfoItemsPage<StreamInfoItem> getInitialPage() throws IOException, Extrac
                 streamInfoItem -> streamInfoItem.getUploadDate().offsetDateTime());
         comparator = comparator.reversed();
 
-        final StreamInfoItemsCollector collector
-                = new StreamInfoItemsCollector(getServiceId(), comparator);
-        for (int i = 0; i < events.size(); i++) {
-            collector.commit(new MediaCCCRecentKioskExtractor(events.getObject(i)));
-        }
+        final StreamInfoItemsCollector collector =
+                new StreamInfoItemsCollector(getServiceId(), comparator);
+
+        events.stream()
+                .filter(JsonObject.class::isInstance)
+                .map(JsonObject.class::cast)
+                .map(MediaCCCRecentKioskExtractor::new)
+                // #813 / voc/voctoweb#609 -> returns faulty data -> filter it out
+                .filter(extractor -> extractor.getDuration() > 0)
+                .forEach(collector::commit);
+
         return new InfoItemsPage<>(collector, null);
     }
 

extractor/src/main/java/org/schabi/newpipe/extractor/services/media_ccc/extractors/MediaCCCRecentKioskExtractor.java

@@ -45,9 +45,9 @@ public boolean isAd() {
     }
 
     @Override
-    public long getDuration() throws ParsingException {
-        // duration and length have the same value, see
-        // https://github.com/voc/voctoweb/blob/master/app/views/public/shared/_event.json.jbuilder
+    public long getDuration() {
+        // duration and length have the same value
+        // see https://github.com/voc/voctoweb/blob/master/app/views/public/shared/_event.json.jbuilder
         return event.getInt("duration");
     }
 

extractor/src/test/java/org/schabi/newpipe/extractor/services/media_ccc/MediaCCCRecentListExtractorTest.java

@@ -30,7 +30,7 @@ public static void setUpClass() throws Exception {
     @Test
     void testStreamList() throws Exception {
         final List<StreamInfoItem> items = extractor.getInitialPage().getItems();
-        assertEquals(100, items.size());
+        assertFalse(items.isEmpty(), "No items returned");
 
         assertAll(items.stream().flatMap(this::getAllConditionsForItem));
     }