Add YouTube bullet comments extractor

Author: Ecomont

extractor/src/main/java/org/schabi/newpipe/extractor/services/youtube/WatchDataCache.java

@@ -0,0 +1,27 @@
+package org.schabi.newpipe.extractor.services.youtube;
+
+import org.schabi.newpipe.extractor.stream.StreamType;
+
+public class WatchDataCache {
+    public StreamType streamType;
+    public long startAt;
+    public boolean shouldBeLive = true;
+    public String currentUrl;
+    // save all the 4 last status
+    public StreamType lastStreamType;
+    public long lastStartAt;
+    public boolean lastShouldBeLive = true;
+    public String lastCurrentUrl;
+    // use the url to instance the extractor, then save the current data to lasts
+    public void init(final String url) {
+        if (url.equals(currentUrl)) {
+            return;
+        }
+        lastStreamType = streamType;
+        lastStartAt = startAt;
+        lastShouldBeLive = shouldBeLive;
+        lastCurrentUrl = currentUrl;
+        currentUrl = url;
+    }
+
+}

extractor/src/main/java/org/schabi/newpipe/extractor/services/youtube/YoutubeBulletCommentPair.java

@@ -0,0 +1,21 @@
+package org.schabi.newpipe.extractor.services.youtube;
+
+import com.grack.nanojson.JsonObject;
+
+public class YoutubeBulletCommentPair {
+    private final JsonObject data;
+    // the expected offset of the comment from the start of the video
+    private final long offsetDuration;
+    public YoutubeBulletCommentPair(final JsonObject item, final long offsetDuration) {
+        this.offsetDuration = offsetDuration;
+        this.data = item;
+    }
+
+    public JsonObject getData() {
+        return data;
+    }
+
+    public long getOffsetDuration() {
+        return offsetDuration;
+    }
+}

extractor/src/main/java/org/schabi/newpipe/extractor/services/youtube/YoutubeService.java

@@ -1,13 +1,15 @@
 package org.schabi.newpipe.extractor.services.youtube;
 
 import static org.schabi.newpipe.extractor.StreamingService.ServiceInfo.MediaCapability.AUDIO;
+import static org.schabi.newpipe.extractor.StreamingService.ServiceInfo.MediaCapability.BULLET_COMMENTS;
 import static org.schabi.newpipe.extractor.StreamingService.ServiceInfo.MediaCapability.COMMENTS;
 import static org.schabi.newpipe.extractor.StreamingService.ServiceInfo.MediaCapability.LIVE;
 import static org.schabi.newpipe.extractor.StreamingService.ServiceInfo.MediaCapability.VIDEO;
 
 import org.schabi.newpipe.extractor.StreamingService;
 import org.schabi.newpipe.extractor.channel.ChannelExtractor;
 import org.schabi.newpipe.extractor.channel.tabs.ChannelTabExtractor;
+import org.schabi.newpipe.extractor.bulletComments.BulletCommentsExtractor;
 import org.schabi.newpipe.extractor.comments.CommentsExtractor;
 import org.schabi.newpipe.extractor.exceptions.ExtractionException;
 import org.schabi.newpipe.extractor.feed.FeedExtractor;
@@ -25,6 +27,7 @@
 import org.schabi.newpipe.extractor.search.SearchExtractor;
 import org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeChannelExtractor;
 import org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeChannelTabExtractor;
+import org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeBulletCommentsExtractor;
 import org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeCommentsExtractor;
 import org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeFeedExtractor;
 import org.schabi.newpipe.extractor.services.youtube.extractors.YoutubeMixPlaylistExtractor;
@@ -42,6 +45,7 @@
 import org.schabi.newpipe.extractor.services.youtube.extractors.kiosk.YoutubeTrendingPodcastsEpisodesExtractor;
 import org.schabi.newpipe.extractor.services.youtube.linkHandler.YoutubeChannelLinkHandlerFactory;
 import org.schabi.newpipe.extractor.services.youtube.linkHandler.YoutubeChannelTabLinkHandlerFactory;
+import org.schabi.newpipe.extractor.services.youtube.linkHandler.YoutubeBulletCommentsLinkHandlerFactory;
 import org.schabi.newpipe.extractor.services.youtube.linkHandler.YoutubeCommentsLinkHandlerFactory;
 import org.schabi.newpipe.extractor.services.youtube.linkHandler.YoutubeLiveLinkHandlerFactory;
 import org.schabi.newpipe.extractor.services.youtube.linkHandler.YoutubePlaylistLinkHandlerFactory;
@@ -82,9 +86,10 @@
  */
 
 public class YoutubeService extends StreamingService {
+    public WatchDataCache watchDataCache = new WatchDataCache();
 
     public YoutubeService(final int id) {
-        super(id, "YouTube", EnumSet.of(AUDIO, VIDEO, LIVE, COMMENTS));
+        super(id, "YouTube", EnumSet.of(AUDIO, VIDEO, LIVE, COMMENTS, BULLET_COMMENTS));
     }
 
     @Override
@@ -258,6 +263,17 @@ public CommentsExtractor getCommentsExtractor(final ListLinkHandler urlIdHandler
         return new YoutubeCommentsExtractor(this, urlIdHandler);
     }
 
+    @Override
+    public ListLinkHandlerFactory getBulletCommentsLHFactory() {
+        return YoutubeBulletCommentsLinkHandlerFactory.getInstance();
+    }
+
+    @Override
+    public BulletCommentsExtractor getBulletCommentsExtractor(final ListLinkHandler linkHandler)
+            throws ExtractionException {
+        return new YoutubeBulletCommentsExtractor(this, linkHandler, watchDataCache);
+    }
+
     /*//////////////////////////////////////////////////////////////////////////
     // Localization
     //////////////////////////////////////////////////////////////////////////*/