mirror of
https://github.com/TeamNewPipe/NewPipe.git
synced 2025-12-17 02:10:48 +00:00
Compare commits
1 Commits
fix-timest
...
open-in-br
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
83a0abddcc |
@@ -93,7 +93,6 @@ import org.schabi.newpipe.local.dialog.PlaylistDialog;
|
|||||||
import org.schabi.newpipe.local.history.HistoryRecordManager;
|
import org.schabi.newpipe.local.history.HistoryRecordManager;
|
||||||
import org.schabi.newpipe.local.playlist.LocalPlaylistFragment;
|
import org.schabi.newpipe.local.playlist.LocalPlaylistFragment;
|
||||||
import org.schabi.newpipe.player.Player;
|
import org.schabi.newpipe.player.Player;
|
||||||
import org.schabi.newpipe.player.PlayerIntentType;
|
|
||||||
import org.schabi.newpipe.player.PlayerService;
|
import org.schabi.newpipe.player.PlayerService;
|
||||||
import org.schabi.newpipe.player.PlayerType;
|
import org.schabi.newpipe.player.PlayerType;
|
||||||
import org.schabi.newpipe.player.event.OnKeyDownListener;
|
import org.schabi.newpipe.player.event.OnKeyDownListener;
|
||||||
@@ -1167,12 +1166,8 @@ public final class VideoDetailFragment
|
|||||||
final PlayQueue queue = setupPlayQueueForIntent(false);
|
final PlayQueue queue = setupPlayQueueForIntent(false);
|
||||||
tryAddVideoPlayerView();
|
tryAddVideoPlayerView();
|
||||||
|
|
||||||
final Context context = requireContext();
|
final Intent playerIntent = NavigationHelper.getPlayerIntent(requireContext(),
|
||||||
final Intent playerIntent =
|
PlayerService.class, queue, true, autoPlayEnabled);
|
||||||
NavigationHelper.getPlayerIntent(context, PlayerService.class, queue,
|
|
||||||
PlayerIntentType.AllOthers)
|
|
||||||
.putExtra(Player.PLAY_WHEN_READY, autoPlayEnabled)
|
|
||||||
.putExtra(Player.RESUME_PLAYBACK, true);
|
|
||||||
ContextCompat.startForegroundService(activity, playerIntent);
|
ContextCompat.startForegroundService(activity, playerIntent);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -24,12 +24,12 @@ import static com.google.android.exoplayer2.Player.DISCONTINUITY_REASON_SEEK_ADJ
|
|||||||
import static com.google.android.exoplayer2.Player.DISCONTINUITY_REASON_SKIP;
|
import static com.google.android.exoplayer2.Player.DISCONTINUITY_REASON_SKIP;
|
||||||
import static com.google.android.exoplayer2.Player.DiscontinuityReason;
|
import static com.google.android.exoplayer2.Player.DiscontinuityReason;
|
||||||
import static com.google.android.exoplayer2.Player.Listener;
|
import static com.google.android.exoplayer2.Player.Listener;
|
||||||
import static com.google.android.exoplayer2.Player.REPEAT_MODE_ALL;
|
|
||||||
import static com.google.android.exoplayer2.Player.REPEAT_MODE_OFF;
|
import static com.google.android.exoplayer2.Player.REPEAT_MODE_OFF;
|
||||||
import static com.google.android.exoplayer2.Player.REPEAT_MODE_ONE;
|
import static com.google.android.exoplayer2.Player.REPEAT_MODE_ONE;
|
||||||
import static com.google.android.exoplayer2.Player.RepeatMode;
|
import static com.google.android.exoplayer2.Player.RepeatMode;
|
||||||
import static org.schabi.newpipe.extractor.ServiceList.YouTube;
|
import static org.schabi.newpipe.extractor.ServiceList.YouTube;
|
||||||
import static org.schabi.newpipe.extractor.utils.Utils.isNullOrEmpty;
|
import static org.schabi.newpipe.extractor.utils.Utils.isNullOrEmpty;
|
||||||
|
import static org.schabi.newpipe.player.helper.PlayerHelper.nextRepeatMode;
|
||||||
import static org.schabi.newpipe.player.helper.PlayerHelper.retrievePlaybackParametersFromPrefs;
|
import static org.schabi.newpipe.player.helper.PlayerHelper.retrievePlaybackParametersFromPrefs;
|
||||||
import static org.schabi.newpipe.player.helper.PlayerHelper.retrieveSeekDurationFromPreferences;
|
import static org.schabi.newpipe.player.helper.PlayerHelper.retrieveSeekDurationFromPreferences;
|
||||||
import static org.schabi.newpipe.player.helper.PlayerHelper.savePlaybackParametersToPrefs;
|
import static org.schabi.newpipe.player.helper.PlayerHelper.savePlaybackParametersToPrefs;
|
||||||
@@ -109,7 +109,6 @@ import org.schabi.newpipe.player.playback.MediaSourceManager;
|
|||||||
import org.schabi.newpipe.player.playback.PlaybackListener;
|
import org.schabi.newpipe.player.playback.PlaybackListener;
|
||||||
import org.schabi.newpipe.player.playqueue.PlayQueue;
|
import org.schabi.newpipe.player.playqueue.PlayQueue;
|
||||||
import org.schabi.newpipe.player.playqueue.PlayQueueItem;
|
import org.schabi.newpipe.player.playqueue.PlayQueueItem;
|
||||||
import org.schabi.newpipe.player.playqueue.SinglePlayQueue;
|
|
||||||
import org.schabi.newpipe.player.resolver.AudioPlaybackResolver;
|
import org.schabi.newpipe.player.resolver.AudioPlaybackResolver;
|
||||||
import org.schabi.newpipe.player.resolver.VideoPlaybackResolver;
|
import org.schabi.newpipe.player.resolver.VideoPlaybackResolver;
|
||||||
import org.schabi.newpipe.player.resolver.VideoPlaybackResolver.SourceType;
|
import org.schabi.newpipe.player.resolver.VideoPlaybackResolver.SourceType;
|
||||||
@@ -119,10 +118,8 @@ import org.schabi.newpipe.player.ui.PlayerUiList;
|
|||||||
import org.schabi.newpipe.player.ui.PopupPlayerUi;
|
import org.schabi.newpipe.player.ui.PopupPlayerUi;
|
||||||
import org.schabi.newpipe.player.ui.VideoPlayerUi;
|
import org.schabi.newpipe.player.ui.VideoPlayerUi;
|
||||||
import org.schabi.newpipe.util.DependentPreferenceHelper;
|
import org.schabi.newpipe.util.DependentPreferenceHelper;
|
||||||
import org.schabi.newpipe.util.ExtractorHelper;
|
|
||||||
import org.schabi.newpipe.util.ListHelper;
|
import org.schabi.newpipe.util.ListHelper;
|
||||||
import org.schabi.newpipe.util.NavigationHelper;
|
import org.schabi.newpipe.util.NavigationHelper;
|
||||||
import org.schabi.newpipe.util.PermissionHelper;
|
|
||||||
import org.schabi.newpipe.util.SerializedCache;
|
import org.schabi.newpipe.util.SerializedCache;
|
||||||
import org.schabi.newpipe.util.StreamTypeUtil;
|
import org.schabi.newpipe.util.StreamTypeUtil;
|
||||||
import org.schabi.newpipe.util.image.PicassoHelper;
|
import org.schabi.newpipe.util.image.PicassoHelper;
|
||||||
@@ -133,11 +130,9 @@ import java.util.stream.IntStream;
|
|||||||
|
|
||||||
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
|
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
|
||||||
import io.reactivex.rxjava3.core.Observable;
|
import io.reactivex.rxjava3.core.Observable;
|
||||||
import io.reactivex.rxjava3.core.Single;
|
|
||||||
import io.reactivex.rxjava3.disposables.CompositeDisposable;
|
import io.reactivex.rxjava3.disposables.CompositeDisposable;
|
||||||
import io.reactivex.rxjava3.disposables.Disposable;
|
import io.reactivex.rxjava3.disposables.Disposable;
|
||||||
import io.reactivex.rxjava3.disposables.SerialDisposable;
|
import io.reactivex.rxjava3.disposables.SerialDisposable;
|
||||||
import io.reactivex.rxjava3.schedulers.Schedulers;
|
|
||||||
|
|
||||||
public final class Player implements PlaybackListener, Listener {
|
public final class Player implements PlaybackListener, Listener {
|
||||||
public static final boolean DEBUG = MainActivity.DEBUG;
|
public static final boolean DEBUG = MainActivity.DEBUG;
|
||||||
@@ -159,13 +154,15 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
// Intent
|
// Intent
|
||||||
//////////////////////////////////////////////////////////////////////////*/
|
//////////////////////////////////////////////////////////////////////////*/
|
||||||
|
|
||||||
|
public static final String REPEAT_MODE = "repeat_mode";
|
||||||
public static final String PLAYBACK_QUALITY = "playback_quality";
|
public static final String PLAYBACK_QUALITY = "playback_quality";
|
||||||
public static final String PLAY_QUEUE_KEY = "play_queue_key";
|
public static final String PLAY_QUEUE_KEY = "play_queue_key";
|
||||||
|
public static final String ENQUEUE = "enqueue";
|
||||||
|
public static final String ENQUEUE_NEXT = "enqueue_next";
|
||||||
public static final String RESUME_PLAYBACK = "resume_playback";
|
public static final String RESUME_PLAYBACK = "resume_playback";
|
||||||
public static final String PLAY_WHEN_READY = "play_when_ready";
|
public static final String PLAY_WHEN_READY = "play_when_ready";
|
||||||
public static final String PLAYER_TYPE = "player_type";
|
public static final String PLAYER_TYPE = "player_type";
|
||||||
public static final String PLAYER_INTENT_TYPE = "player_intent_type";
|
public static final String IS_MUTED = "is_muted";
|
||||||
public static final String PLAYER_INTENT_DATA = "player_intent_data";
|
|
||||||
|
|
||||||
/*//////////////////////////////////////////////////////////////////////////
|
/*//////////////////////////////////////////////////////////////////////////
|
||||||
// Time constants
|
// Time constants
|
||||||
@@ -250,8 +247,6 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
private final SerialDisposable progressUpdateDisposable = new SerialDisposable();
|
private final SerialDisposable progressUpdateDisposable = new SerialDisposable();
|
||||||
@NonNull
|
@NonNull
|
||||||
private final CompositeDisposable databaseUpdateDisposable = new CompositeDisposable();
|
private final CompositeDisposable databaseUpdateDisposable = new CompositeDisposable();
|
||||||
@NonNull
|
|
||||||
private final CompositeDisposable streamItemDisposable = new CompositeDisposable();
|
|
||||||
|
|
||||||
// This is the only listener we need for thumbnail loading, since there is always at most only
|
// This is the only listener we need for thumbnail loading, since there is always at most only
|
||||||
// one thumbnail being loaded at a time. This field is also here to maintain a strong reference,
|
// one thumbnail being loaded at a time. This field is also here to maintain a strong reference,
|
||||||
@@ -352,134 +347,49 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
|
|
||||||
@SuppressWarnings("MethodLength")
|
@SuppressWarnings("MethodLength")
|
||||||
public void handleIntent(@NonNull final Intent intent) {
|
public void handleIntent(@NonNull final Intent intent) {
|
||||||
|
// fail fast if no play queue was provided
|
||||||
final PlayerIntentType playerIntentType = intent.getParcelableExtra(PLAYER_INTENT_TYPE);
|
final String queueCache = intent.getStringExtra(PLAY_QUEUE_KEY);
|
||||||
if (playerIntentType == null) {
|
if (queueCache == null) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
final PlayerType newPlayerType;
|
final PlayQueue newQueue = SerializedCache.getInstance().take(queueCache, PlayQueue.class);
|
||||||
// TODO: this should be in the second switch below, but I’m not sure whether I
|
if (newQueue == null) {
|
||||||
// can move the initUIs stuff without breaking the setup for edge cases somehow.
|
return;
|
||||||
switch (playerIntentType) {
|
|
||||||
case TimestampChange -> {
|
|
||||||
// TODO: this breaks out of the pattern of asking for the permission before
|
|
||||||
// sending the PlayerIntent, but I’m not sure yet how to combine the permissions
|
|
||||||
// with the new enum approach. Maybe it’s better that the player asks anyway?
|
|
||||||
if (!PermissionHelper.isPopupEnabledElseAsk(context)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
newPlayerType = PlayerType.POPUP;
|
|
||||||
}
|
|
||||||
default -> {
|
|
||||||
newPlayerType = PlayerType.retrieveFromIntent(intent);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
playerType = newPlayerType;
|
final PlayerType oldPlayerType = playerType;
|
||||||
|
playerType = PlayerType.retrieveFromIntent(intent);
|
||||||
initUIsForCurrentPlayerType();
|
initUIsForCurrentPlayerType();
|
||||||
|
// We need to setup audioOnly before super(), see "sourceOf"
|
||||||
isAudioOnly = audioPlayerSelected();
|
isAudioOnly = audioPlayerSelected();
|
||||||
|
|
||||||
if (intent.hasExtra(PLAYBACK_QUALITY)) {
|
if (intent.hasExtra(PLAYBACK_QUALITY)) {
|
||||||
videoResolver.setPlaybackQuality(intent.getStringExtra(PLAYBACK_QUALITY));
|
videoResolver.setPlaybackQuality(intent.getStringExtra(PLAYBACK_QUALITY));
|
||||||
}
|
}
|
||||||
|
|
||||||
final boolean playWhenReady = intent.getBooleanExtra(PLAY_WHEN_READY, true);
|
// Resolve enqueue intents
|
||||||
|
if (intent.getBooleanExtra(ENQUEUE, false) && playQueue != null) {
|
||||||
|
playQueue.append(newQueue.getStreams());
|
||||||
|
return;
|
||||||
|
|
||||||
switch (playerIntentType) {
|
// Resolve enqueue next intents
|
||||||
case Enqueue -> {
|
} else if (intent.getBooleanExtra(ENQUEUE_NEXT, false) && playQueue != null) {
|
||||||
if (playQueue != null) {
|
final int currentIndex = playQueue.getIndex();
|
||||||
final PlayQueue newQueue = getPlayQueueFromCache(intent);
|
playQueue.append(newQueue.getStreams());
|
||||||
if (newQueue == null) {
|
playQueue.move(playQueue.size() - 1, currentIndex + 1);
|
||||||
return;
|
|
||||||
}
|
|
||||||
playQueue.append(newQueue.getStreams());
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: This falls through to the old logic, there was no playQueue
|
|
||||||
// yet so we should start the player and add the new video
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case EnqueueNext -> {
|
|
||||||
if (playQueue != null) {
|
|
||||||
final PlayQueue newQueue = getPlayQueueFromCache(intent);
|
|
||||||
if (newQueue == null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
final PlayQueueItem newItem = newQueue.getStreams().get(0);
|
|
||||||
newQueue.enqueueNext(newItem, false);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: This falls through to the old logic, there was no playQueue
|
|
||||||
// yet so we should start the player and add the new video
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case TimestampChange -> {
|
|
||||||
final TimestampChangeData dat = intent.getParcelableExtra(PLAYER_INTENT_DATA);
|
|
||||||
assert dat != null;
|
|
||||||
final Single<StreamInfo> single =
|
|
||||||
ExtractorHelper.getStreamInfo(dat.getServiceId(), dat.getUrl(), false);
|
|
||||||
streamItemDisposable.add(single.subscribeOn(Schedulers.io())
|
|
||||||
.observeOn(AndroidSchedulers.mainThread())
|
|
||||||
.subscribe(info -> {
|
|
||||||
final @Nullable PlayQueue oldPlayQueue = playQueue;
|
|
||||||
info.setStartPosition(dat.getSeconds());
|
|
||||||
final PlayQueueItem playQueueItem = new PlayQueueItem(info);
|
|
||||||
|
|
||||||
// If the stream is already playing,
|
|
||||||
// we can just seek to the appropriate timestamp
|
|
||||||
if (oldPlayQueue != null
|
|
||||||
&& playQueueItem.isSameItem(oldPlayQueue.getItem())) {
|
|
||||||
// Player can have state = IDLE when playback is stopped or failed
|
|
||||||
// and we should retry in this case
|
|
||||||
if (simpleExoPlayer.getPlaybackState()
|
|
||||||
== com.google.android.exoplayer2.Player.STATE_IDLE) {
|
|
||||||
simpleExoPlayer.prepare();
|
|
||||||
}
|
|
||||||
simpleExoPlayer.seekTo(oldPlayQueue.getIndex(),
|
|
||||||
dat.getSeconds() * 1000L);
|
|
||||||
simpleExoPlayer.setPlayWhenReady(playWhenReady);
|
|
||||||
|
|
||||||
} else {
|
|
||||||
final PlayQueue newPlayQueue;
|
|
||||||
|
|
||||||
// If there is no queue yet, just add our item
|
|
||||||
if (oldPlayQueue == null) {
|
|
||||||
newPlayQueue = new SinglePlayQueue(playQueueItem);
|
|
||||||
|
|
||||||
// else we add the timestamped stream behind the current video
|
|
||||||
// and start playing it.
|
|
||||||
} else {
|
|
||||||
oldPlayQueue.enqueueNext(playQueueItem, true);
|
|
||||||
oldPlayQueue.offsetIndex(1);
|
|
||||||
newPlayQueue = oldPlayQueue;
|
|
||||||
}
|
|
||||||
initPlayback(newPlayQueue, playWhenReady);
|
|
||||||
}
|
|
||||||
|
|
||||||
}, throwable -> {
|
|
||||||
// This will only show a snackbar if the passed context has a root view:
|
|
||||||
// otherwise it will resort to showing a notification, so we are safe
|
|
||||||
// here.
|
|
||||||
ErrorUtil.createNotification(context,
|
|
||||||
new ErrorInfo(throwable, UserAction.PLAY_ON_POPUP, dat.getUrl(),
|
|
||||||
null, dat.getUrl()));
|
|
||||||
}));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
case AllOthers -> {
|
|
||||||
// fallthrough; TODO: put other intent data in separate cases
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
final PlayQueue newQueue = getPlayQueueFromCache(intent);
|
|
||||||
if (newQueue == null) {
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// branching parameters for below
|
final PlaybackParameters savedParameters = retrievePlaybackParametersFromPrefs(this);
|
||||||
|
final float playbackSpeed = savedParameters.speed;
|
||||||
|
final float playbackPitch = savedParameters.pitch;
|
||||||
|
final boolean playbackSkipSilence = getPrefs().getBoolean(getContext().getString(
|
||||||
|
R.string.playback_skip_silence_key), getPlaybackSkipSilence());
|
||||||
|
|
||||||
final boolean samePlayQueue = playQueue != null && playQueue.equalStreamsAndIndex(newQueue);
|
final boolean samePlayQueue = playQueue != null && playQueue.equalStreamsAndIndex(newQueue);
|
||||||
|
final int repeatMode = intent.getIntExtra(REPEAT_MODE, getRepeatMode());
|
||||||
|
final boolean playWhenReady = intent.getBooleanExtra(PLAY_WHEN_READY, true);
|
||||||
|
final boolean isMuted = intent.getBooleanExtra(IS_MUTED, isMuted());
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* TODO As seen in #7427 this does not work:
|
* TODO As seen in #7427 this does not work:
|
||||||
@@ -494,7 +404,7 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
if (!exoPlayerIsNull()
|
if (!exoPlayerIsNull()
|
||||||
&& newQueue.size() == 1 && newQueue.getItem() != null
|
&& newQueue.size() == 1 && newQueue.getItem() != null
|
||||||
&& playQueue != null && playQueue.size() == 1 && playQueue.getItem() != null
|
&& playQueue != null && playQueue.size() == 1 && playQueue.getItem() != null
|
||||||
&& newQueue.getItem().isSameItem(playQueue.getItem())
|
&& newQueue.getItem().getUrl().equals(playQueue.getItem().getUrl())
|
||||||
&& newQueue.getItem().getRecoveryPosition() != PlayQueueItem.RECOVERY_UNSET) {
|
&& newQueue.getItem().getRecoveryPosition() != PlayQueueItem.RECOVERY_UNSET) {
|
||||||
// Player can have state = IDLE when playback is stopped or failed
|
// Player can have state = IDLE when playback is stopped or failed
|
||||||
// and we should retry in this case
|
// and we should retry in this case
|
||||||
@@ -520,8 +430,7 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
|
|
||||||
} else if (intent.getBooleanExtra(RESUME_PLAYBACK, false)
|
} else if (intent.getBooleanExtra(RESUME_PLAYBACK, false)
|
||||||
&& DependentPreferenceHelper.getResumePlaybackEnabled(context)
|
&& DependentPreferenceHelper.getResumePlaybackEnabled(context)
|
||||||
// !samePlayQueue
|
&& !samePlayQueue
|
||||||
&& (playQueue == null || !playQueue.equalStreamsAndIndex(newQueue))
|
|
||||||
&& !newQueue.isEmpty()
|
&& !newQueue.isEmpty()
|
||||||
&& newQueue.getItem() != null
|
&& newQueue.getItem() != null
|
||||||
&& newQueue.getItem().getRecoveryPosition() == PlayQueueItem.RECOVERY_UNSET) {
|
&& newQueue.getItem().getRecoveryPosition() == PlayQueueItem.RECOVERY_UNSET) {
|
||||||
@@ -537,30 +446,30 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
newQueue.setRecovery(newQueue.getIndex(),
|
newQueue.setRecovery(newQueue.getIndex(),
|
||||||
state.getProgressMillis());
|
state.getProgressMillis());
|
||||||
}
|
}
|
||||||
initPlayback(newQueue, playWhenReady);
|
initPlayback(newQueue, repeatMode, playbackSpeed, playbackPitch,
|
||||||
|
playbackSkipSilence, playWhenReady, isMuted);
|
||||||
},
|
},
|
||||||
error -> {
|
error -> {
|
||||||
if (DEBUG) {
|
if (DEBUG) {
|
||||||
Log.w(TAG, "Failed to start playback", error);
|
Log.w(TAG, "Failed to start playback", error);
|
||||||
}
|
}
|
||||||
// In case any error we can start playback without history
|
// In case any error we can start playback without history
|
||||||
initPlayback(newQueue, playWhenReady);
|
initPlayback(newQueue, repeatMode, playbackSpeed, playbackPitch,
|
||||||
|
playbackSkipSilence, playWhenReady, isMuted);
|
||||||
},
|
},
|
||||||
() -> {
|
() -> {
|
||||||
// Completed but not found in history
|
// Completed but not found in history
|
||||||
initPlayback(newQueue, playWhenReady);
|
initPlayback(newQueue, repeatMode, playbackSpeed, playbackPitch,
|
||||||
|
playbackSkipSilence, playWhenReady, isMuted);
|
||||||
}
|
}
|
||||||
));
|
));
|
||||||
} else {
|
} else {
|
||||||
// Good to go...
|
// Good to go...
|
||||||
// In a case of equal PlayQueues we can re-init old one but only when it is disposed
|
// In a case of equal PlayQueues we can re-init old one but only when it is disposed
|
||||||
initPlayback(samePlayQueue ? playQueue : newQueue, playWhenReady);
|
initPlayback(samePlayQueue ? playQueue : newQueue, repeatMode, playbackSpeed,
|
||||||
|
playbackPitch, playbackSkipSilence, playWhenReady, isMuted);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
public void handleIntentPost(final PlayerType oldPlayerType) {
|
|
||||||
if (oldPlayerType != playerType && playQueue != null) {
|
if (oldPlayerType != playerType && playQueue != null) {
|
||||||
// If playerType changes from one to another we should reload the player
|
// If playerType changes from one to another we should reload the player
|
||||||
// (to disable/enable video stream or to set quality)
|
// (to disable/enable video stream or to set quality)
|
||||||
@@ -571,19 +480,6 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
NavigationHelper.sendPlayerStartedEvent(context);
|
NavigationHelper.sendPlayerStartedEvent(context);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Nullable
|
|
||||||
private static PlayQueue getPlayQueueFromCache(@NonNull final Intent intent) {
|
|
||||||
final String queueCache = intent.getStringExtra(PLAY_QUEUE_KEY);
|
|
||||||
if (queueCache == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
final PlayQueue newQueue = SerializedCache.getInstance().take(queueCache, PlayQueue.class);
|
|
||||||
if (newQueue == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return newQueue;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void initUIsForCurrentPlayerType() {
|
private void initUIsForCurrentPlayerType() {
|
||||||
if ((UIs.get(MainPlayerUi.class).isPresent() && playerType == PlayerType.MAIN)
|
if ((UIs.get(MainPlayerUi.class).isPresent() && playerType == PlayerType.MAIN)
|
||||||
|| (UIs.get(PopupPlayerUi.class).isPresent() && playerType == PlayerType.POPUP)) {
|
|| (UIs.get(PopupPlayerUi.class).isPresent() && playerType == PlayerType.POPUP)) {
|
||||||
@@ -617,13 +513,16 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void initPlayback(@NonNull final PlayQueue queue,
|
private void initPlayback(@NonNull final PlayQueue queue,
|
||||||
final boolean playOnReady) {
|
@RepeatMode final int repeatMode,
|
||||||
|
final float playbackSpeed,
|
||||||
|
final float playbackPitch,
|
||||||
|
final boolean playbackSkipSilence,
|
||||||
|
final boolean playOnReady,
|
||||||
|
final boolean isMuted) {
|
||||||
destroyPlayer();
|
destroyPlayer();
|
||||||
initPlayer(playOnReady);
|
initPlayer(playOnReady);
|
||||||
final boolean playbackSkipSilence = getPrefs().getBoolean(getContext().getString(
|
setRepeatMode(repeatMode);
|
||||||
R.string.playback_skip_silence_key), getPlaybackSkipSilence());
|
setPlaybackParameters(playbackSpeed, playbackPitch, playbackSkipSilence);
|
||||||
final PlaybackParameters savedParameters = retrievePlaybackParametersFromPrefs(this);
|
|
||||||
setPlaybackParameters(savedParameters.speed, savedParameters.pitch, playbackSkipSilence);
|
|
||||||
|
|
||||||
playQueue = queue;
|
playQueue = queue;
|
||||||
playQueue.init();
|
playQueue.init();
|
||||||
@@ -631,7 +530,7 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
|
|
||||||
UIs.call(PlayerUi::initPlayback);
|
UIs.call(PlayerUi::initPlayback);
|
||||||
|
|
||||||
simpleExoPlayer.setVolume(isMuted() ? 0 : 1);
|
simpleExoPlayer.setVolume(isMuted ? 0 : 1);
|
||||||
notifyQueueUpdateToListeners();
|
notifyQueueUpdateToListeners();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -713,7 +612,6 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
|
|
||||||
databaseUpdateDisposable.clear();
|
databaseUpdateDisposable.clear();
|
||||||
progressUpdateDisposable.set(null);
|
progressUpdateDisposable.set(null);
|
||||||
streamItemDisposable.clear();
|
|
||||||
cancelLoadingCurrentThumbnail();
|
cancelLoadingCurrentThumbnail();
|
||||||
|
|
||||||
UIs.destroyAll(Object.class); // destroy every UI: obviously every UI extends Object
|
UIs.destroyAll(Object.class); // destroy every UI: obviously every UI extends Object
|
||||||
@@ -1280,25 +1178,16 @@ public final class Player implements PlaybackListener, Listener {
|
|||||||
return exoPlayerIsNull() ? REPEAT_MODE_OFF : simpleExoPlayer.getRepeatMode();
|
return exoPlayerIsNull() ? REPEAT_MODE_OFF : simpleExoPlayer.getRepeatMode();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void cycleNextRepeatMode() {
|
public void setRepeatMode(@RepeatMode final int repeatMode) {
|
||||||
if (!exoPlayerIsNull()) {
|
if (!exoPlayerIsNull()) {
|
||||||
@RepeatMode final int repeatMode;
|
|
||||||
switch (simpleExoPlayer.getRepeatMode()) {
|
|
||||||
case REPEAT_MODE_OFF:
|
|
||||||
repeatMode = REPEAT_MODE_ONE;
|
|
||||||
break;
|
|
||||||
case REPEAT_MODE_ONE:
|
|
||||||
repeatMode = REPEAT_MODE_ALL;
|
|
||||||
break;
|
|
||||||
case REPEAT_MODE_ALL:
|
|
||||||
default:
|
|
||||||
repeatMode = REPEAT_MODE_OFF;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
simpleExoPlayer.setRepeatMode(repeatMode);
|
simpleExoPlayer.setRepeatMode(repeatMode);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void cycleNextRepeatMode() {
|
||||||
|
setRepeatMode(nextRepeatMode(getRepeatMode()));
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onRepeatModeChanged(@RepeatMode final int repeatMode) {
|
public void onRepeatModeChanged(@RepeatMode final int repeatMode) {
|
||||||
if (DEBUG) {
|
if (DEBUG) {
|
||||||
|
|||||||
@@ -1,26 +0,0 @@
|
|||||||
package org.schabi.newpipe.player
|
|
||||||
|
|
||||||
import android.os.Parcelable
|
|
||||||
import kotlinx.parcelize.Parcelize
|
|
||||||
|
|
||||||
// We model this as an enum class plus one struct for each enum value
|
|
||||||
// so we can consume it from Java properly. After converting to Kotlin,
|
|
||||||
// we could switch to a sealed enum class & a proper Kotlin `when` match.
|
|
||||||
|
|
||||||
@Parcelize
|
|
||||||
enum class PlayerIntentType : Parcelable {
|
|
||||||
Enqueue,
|
|
||||||
EnqueueNext,
|
|
||||||
TimestampChange,
|
|
||||||
AllOthers
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A timestamp on the given was clicked and we should switch the playing stream to it.
|
|
||||||
*/
|
|
||||||
@Parcelize
|
|
||||||
data class TimestampChangeData(
|
|
||||||
val serviceId: Int,
|
|
||||||
val url: String,
|
|
||||||
val seconds: Int
|
|
||||||
) : Parcelable
|
|
||||||
@@ -169,9 +169,7 @@ public final class PlayerService extends MediaBrowserServiceCompat {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (player != null) {
|
if (player != null) {
|
||||||
final PlayerType oldPlayerType = player.getPlayerType();
|
|
||||||
player.handleIntent(intent);
|
player.handleIntent(intent);
|
||||||
player.handleIntentPost(oldPlayerType);
|
|
||||||
player.UIs().get(MediaSessionPlayerUi.class)
|
player.UIs().get(MediaSessionPlayerUi.class)
|
||||||
.ifPresent(ui -> ui.handleMediaButtonIntent(intent));
|
.ifPresent(ui -> ui.handleMediaButtonIntent(intent));
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
package org.schabi.newpipe.player.helper;
|
package org.schabi.newpipe.player.helper;
|
||||||
|
|
||||||
|
import static com.google.android.exoplayer2.Player.REPEAT_MODE_ALL;
|
||||||
|
import static com.google.android.exoplayer2.Player.REPEAT_MODE_OFF;
|
||||||
|
import static com.google.android.exoplayer2.Player.REPEAT_MODE_ONE;
|
||||||
import static org.schabi.newpipe.player.helper.PlayerHelper.AutoplayType.AUTOPLAY_TYPE_ALWAYS;
|
import static org.schabi.newpipe.player.helper.PlayerHelper.AutoplayType.AUTOPLAY_TYPE_ALWAYS;
|
||||||
import static org.schabi.newpipe.player.helper.PlayerHelper.AutoplayType.AUTOPLAY_TYPE_NEVER;
|
import static org.schabi.newpipe.player.helper.PlayerHelper.AutoplayType.AUTOPLAY_TYPE_NEVER;
|
||||||
import static org.schabi.newpipe.player.helper.PlayerHelper.AutoplayType.AUTOPLAY_TYPE_WIFI;
|
import static org.schabi.newpipe.player.helper.PlayerHelper.AutoplayType.AUTOPLAY_TYPE_WIFI;
|
||||||
@@ -22,6 +25,7 @@ import androidx.core.content.ContextCompat;
|
|||||||
import androidx.preference.PreferenceManager;
|
import androidx.preference.PreferenceManager;
|
||||||
|
|
||||||
import com.google.android.exoplayer2.PlaybackParameters;
|
import com.google.android.exoplayer2.PlaybackParameters;
|
||||||
|
import com.google.android.exoplayer2.Player.RepeatMode;
|
||||||
import com.google.android.exoplayer2.SeekParameters;
|
import com.google.android.exoplayer2.SeekParameters;
|
||||||
import com.google.android.exoplayer2.source.ProgressiveMediaSource;
|
import com.google.android.exoplayer2.source.ProgressiveMediaSource;
|
||||||
import com.google.android.exoplayer2.trackselection.AdaptiveTrackSelection;
|
import com.google.android.exoplayer2.trackselection.AdaptiveTrackSelection;
|
||||||
@@ -406,9 +410,23 @@ public final class PlayerHelper {
|
|||||||
return singlePlayQueue;
|
return singlePlayQueue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// endregion
|
// endregion
|
||||||
// region Utils used by player
|
// region Utils used by player
|
||||||
|
|
||||||
|
@RepeatMode
|
||||||
|
public static int nextRepeatMode(@RepeatMode final int repeatMode) {
|
||||||
|
switch (repeatMode) {
|
||||||
|
case REPEAT_MODE_OFF:
|
||||||
|
return REPEAT_MODE_ONE;
|
||||||
|
case REPEAT_MODE_ONE:
|
||||||
|
return REPEAT_MODE_ALL;
|
||||||
|
case REPEAT_MODE_ALL:
|
||||||
|
default:
|
||||||
|
return REPEAT_MODE_OFF;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@ResizeMode
|
@ResizeMode
|
||||||
public static int retrieveResizeModeFromPrefs(final Player player) {
|
public static int retrieveResizeModeFromPrefs(final Player player) {
|
||||||
return player.getPrefs().getInt(player.getContext().getString(R.string.last_resize_mode),
|
return player.getPrefs().getInt(player.getContext().getString(R.string.last_resize_mode),
|
||||||
|
|||||||
@@ -23,7 +23,6 @@ import androidx.core.content.ContextCompat;
|
|||||||
import org.schabi.newpipe.MainActivity;
|
import org.schabi.newpipe.MainActivity;
|
||||||
import org.schabi.newpipe.R;
|
import org.schabi.newpipe.R;
|
||||||
import org.schabi.newpipe.player.Player;
|
import org.schabi.newpipe.player.Player;
|
||||||
import org.schabi.newpipe.player.PlayerIntentType;
|
|
||||||
import org.schabi.newpipe.player.mediasession.MediaSessionPlayerUi;
|
import org.schabi.newpipe.player.mediasession.MediaSessionPlayerUi;
|
||||||
import org.schabi.newpipe.util.NavigationHelper;
|
import org.schabi.newpipe.util.NavigationHelper;
|
||||||
|
|
||||||
@@ -255,9 +254,7 @@ public final class NotificationUtil {
|
|||||||
} else {
|
} else {
|
||||||
// We are playing in fragment. Don't open another activity just show fragment. That's it
|
// We are playing in fragment. Don't open another activity just show fragment. That's it
|
||||||
final Intent intent = NavigationHelper.getPlayerIntent(
|
final Intent intent = NavigationHelper.getPlayerIntent(
|
||||||
player.getContext(), MainActivity.class, null,
|
player.getContext(), MainActivity.class, null, true);
|
||||||
PlayerIntentType.AllOthers);
|
|
||||||
intent.putExtra(Player.RESUME_PLAYBACK, true);
|
|
||||||
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
|
intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
|
||||||
intent.setAction(Intent.ACTION_MAIN);
|
intent.setAction(Intent.ACTION_MAIN);
|
||||||
intent.addCategory(Intent.CATEGORY_LAUNCHER);
|
intent.addCategory(Intent.CATEGORY_LAUNCHER);
|
||||||
|
|||||||
@@ -291,22 +291,6 @@ public abstract class PlayQueue implements Serializable {
|
|||||||
broadcast(new AppendEvent(itemList.size()));
|
broadcast(new AppendEvent(itemList.size()));
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Add the given item after the current stream.
|
|
||||||
*
|
|
||||||
* @param item item to add.
|
|
||||||
* @param skipIfSame if set, skip adding if the next stream is the same stream.
|
|
||||||
*/
|
|
||||||
public void enqueueNext(@NonNull final PlayQueueItem item, final boolean skipIfSame) {
|
|
||||||
final int currentIndex = getIndex();
|
|
||||||
// if the next item is the same item as the one we want to enqueue, skip if flag is true
|
|
||||||
if (skipIfSame && item.isSameItem(getItem(currentIndex + 1))) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
append(List.of(item));
|
|
||||||
move(size() - 1, currentIndex + 1);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Removes the item at the given index from the play queue.
|
* Removes the item at the given index from the play queue.
|
||||||
* <p>
|
* <p>
|
||||||
@@ -545,7 +529,8 @@ public abstract class PlayQueue implements Serializable {
|
|||||||
final PlayQueueItem stream = streams.get(i);
|
final PlayQueueItem stream = streams.get(i);
|
||||||
final PlayQueueItem otherStream = other.streams.get(i);
|
final PlayQueueItem otherStream = other.streams.get(i);
|
||||||
// Check is based on serviceId and URL
|
// Check is based on serviceId and URL
|
||||||
if (!stream.isSameItem(otherStream)) {
|
if (stream.getServiceId() != otherStream.getServiceId()
|
||||||
|
|| !stream.getUrl().equals(otherStream.getUrl())) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -38,7 +38,7 @@ public class PlayQueueItem implements Serializable {
|
|||||||
private long recoveryPosition;
|
private long recoveryPosition;
|
||||||
private Throwable error;
|
private Throwable error;
|
||||||
|
|
||||||
public PlayQueueItem(@NonNull final StreamInfo info) {
|
PlayQueueItem(@NonNull final StreamInfo info) {
|
||||||
this(info.getName(), info.getUrl(), info.getServiceId(), info.getDuration(),
|
this(info.getName(), info.getUrl(), info.getServiceId(), info.getDuration(),
|
||||||
info.getThumbnails(), info.getUploaderName(),
|
info.getThumbnails(), info.getUploaderName(),
|
||||||
info.getUploaderUrl(), info.getStreamType());
|
info.getUploaderUrl(), info.getStreamType());
|
||||||
@@ -71,22 +71,6 @@ public class PlayQueueItem implements Serializable {
|
|||||||
this.recoveryPosition = RECOVERY_UNSET;
|
this.recoveryPosition = RECOVERY_UNSET;
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Whether these two items should be treated as the same stream
|
|
||||||
* for the sake of keeping the same player running when e.g. jumping between timestamps.
|
|
||||||
*
|
|
||||||
* @param other the {@link PlayQueueItem} to compare against.
|
|
||||||
* @return whether the two items are the same so the stream can be re-used.
|
|
||||||
*/
|
|
||||||
public boolean isSameItem(@Nullable final PlayQueueItem other) {
|
|
||||||
if (other == null) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
// We assume that the same service & URL uniquely determines
|
|
||||||
// that we can keep the same stream running.
|
|
||||||
return serviceId == other.serviceId
|
|
||||||
&& url.equals(other.url);
|
|
||||||
}
|
|
||||||
|
|
||||||
@NonNull
|
@NonNull
|
||||||
public String getTitle() {
|
public String getTitle() {
|
||||||
return title;
|
return title;
|
||||||
|
|||||||
@@ -16,9 +16,7 @@ public final class SinglePlayQueue extends PlayQueue {
|
|||||||
public SinglePlayQueue(final StreamInfo info) {
|
public SinglePlayQueue(final StreamInfo info) {
|
||||||
super(0, List.of(new PlayQueueItem(info)));
|
super(0, List.of(new PlayQueueItem(info)));
|
||||||
}
|
}
|
||||||
public SinglePlayQueue(final PlayQueueItem item) {
|
|
||||||
super(0, List.of(item));
|
|
||||||
}
|
|
||||||
public SinglePlayQueue(final StreamInfo info, final long startPosition) {
|
public SinglePlayQueue(final StreamInfo info, final long startPosition) {
|
||||||
super(0, List.of(new PlayQueueItem(info)));
|
super(0, List.of(new PlayQueueItem(info)));
|
||||||
getItem().setRecoveryPosition(startPosition);
|
getItem().setRecoveryPosition(startPosition);
|
||||||
|
|||||||
@@ -9,7 +9,6 @@ import android.content.Context;
|
|||||||
import android.content.Intent;
|
import android.content.Intent;
|
||||||
import android.net.Uri;
|
import android.net.Uri;
|
||||||
import android.os.Build;
|
import android.os.Build;
|
||||||
import android.os.Parcelable;
|
|
||||||
import android.util.Log;
|
import android.util.Log;
|
||||||
import android.widget.Toast;
|
import android.widget.Toast;
|
||||||
|
|
||||||
@@ -58,10 +57,8 @@ import org.schabi.newpipe.local.subscription.SubscriptionFragment;
|
|||||||
import org.schabi.newpipe.local.subscription.SubscriptionsImportFragment;
|
import org.schabi.newpipe.local.subscription.SubscriptionsImportFragment;
|
||||||
import org.schabi.newpipe.player.PlayQueueActivity;
|
import org.schabi.newpipe.player.PlayQueueActivity;
|
||||||
import org.schabi.newpipe.player.Player;
|
import org.schabi.newpipe.player.Player;
|
||||||
import org.schabi.newpipe.player.PlayerIntentType;
|
|
||||||
import org.schabi.newpipe.player.PlayerService;
|
import org.schabi.newpipe.player.PlayerService;
|
||||||
import org.schabi.newpipe.player.PlayerType;
|
import org.schabi.newpipe.player.PlayerType;
|
||||||
import org.schabi.newpipe.player.TimestampChangeData;
|
|
||||||
import org.schabi.newpipe.player.helper.PlayerHelper;
|
import org.schabi.newpipe.player.helper.PlayerHelper;
|
||||||
import org.schabi.newpipe.player.helper.PlayerHolder;
|
import org.schabi.newpipe.player.helper.PlayerHolder;
|
||||||
import org.schabi.newpipe.player.playqueue.PlayQueue;
|
import org.schabi.newpipe.player.playqueue.PlayQueue;
|
||||||
@@ -88,7 +85,7 @@ public final class NavigationHelper {
|
|||||||
public static <T> Intent getPlayerIntent(@NonNull final Context context,
|
public static <T> Intent getPlayerIntent(@NonNull final Context context,
|
||||||
@NonNull final Class<T> targetClazz,
|
@NonNull final Class<T> targetClazz,
|
||||||
@Nullable final PlayQueue playQueue,
|
@Nullable final PlayQueue playQueue,
|
||||||
@NonNull final PlayerIntentType playerIntentType) {
|
final boolean resumePlayback) {
|
||||||
final Intent intent = new Intent(context, targetClazz);
|
final Intent intent = new Intent(context, targetClazz);
|
||||||
|
|
||||||
if (playQueue != null) {
|
if (playQueue != null) {
|
||||||
@@ -98,31 +95,44 @@ public final class NavigationHelper {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
intent.putExtra(Player.PLAYER_TYPE, PlayerType.MAIN.valueForIntent());
|
intent.putExtra(Player.PLAYER_TYPE, PlayerType.MAIN.valueForIntent());
|
||||||
|
intent.putExtra(Player.RESUME_PLAYBACK, resumePlayback);
|
||||||
intent.putExtra(PlayerService.SHOULD_START_FOREGROUND_EXTRA, true);
|
intent.putExtra(PlayerService.SHOULD_START_FOREGROUND_EXTRA, true);
|
||||||
intent.putExtra(Player.PLAYER_INTENT_TYPE, (Parcelable) playerIntentType);
|
|
||||||
|
|
||||||
return intent;
|
return intent;
|
||||||
}
|
}
|
||||||
|
|
||||||
@NonNull
|
@NonNull
|
||||||
public static Intent getPlayerTimestampIntent(@NonNull final Context context,
|
public static <T> Intent getPlayerIntent(@NonNull final Context context,
|
||||||
@NonNull final TimestampChangeData
|
@NonNull final Class<T> targetClazz,
|
||||||
timestampChangeData) {
|
@Nullable final PlayQueue playQueue,
|
||||||
final Intent intent = new Intent(context, PlayerService.class);
|
final boolean resumePlayback,
|
||||||
|
final boolean playWhenReady) {
|
||||||
|
return getPlayerIntent(context, targetClazz, playQueue, resumePlayback)
|
||||||
|
.putExtra(Player.PLAY_WHEN_READY, playWhenReady);
|
||||||
|
}
|
||||||
|
|
||||||
intent.putExtra(Player.PLAYER_INTENT_TYPE, (Parcelable) PlayerIntentType.TimestampChange);
|
@NonNull
|
||||||
intent.putExtra(Player.PLAYER_INTENT_DATA, timestampChangeData);
|
public static <T> Intent getPlayerEnqueueIntent(@NonNull final Context context,
|
||||||
|
@NonNull final Class<T> targetClazz,
|
||||||
return intent;
|
@Nullable final PlayQueue playQueue) {
|
||||||
|
// when enqueueing `resumePlayback` is always `false` since:
|
||||||
|
// - if there is a video already playing, the value of `resumePlayback` just doesn't make
|
||||||
|
// any difference.
|
||||||
|
// - if there is nothing already playing, it is useful for the enqueue action to have a
|
||||||
|
// slightly different behaviour than the normal play action: the latter resumes playback,
|
||||||
|
// the former doesn't. (note that enqueue can be triggered when nothing is playing only
|
||||||
|
// by long pressing the video detail fragment, playlist or channel controls
|
||||||
|
return getPlayerIntent(context, targetClazz, playQueue, false)
|
||||||
|
.putExtra(Player.ENQUEUE, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
@NonNull
|
@NonNull
|
||||||
public static <T> Intent getPlayerEnqueueNextIntent(@NonNull final Context context,
|
public static <T> Intent getPlayerEnqueueNextIntent(@NonNull final Context context,
|
||||||
@NonNull final Class<T> targetClazz,
|
@NonNull final Class<T> targetClazz,
|
||||||
@Nullable final PlayQueue playQueue) {
|
@Nullable final PlayQueue playQueue) {
|
||||||
return getPlayerIntent(context, targetClazz, playQueue, PlayerIntentType.EnqueueNext)
|
// see comment in `getPlayerEnqueueIntent` as to why `resumePlayback` is false
|
||||||
// see comment in `getPlayerEnqueueIntent` as to why `resumePlayback` is false
|
return getPlayerIntent(context, targetClazz, playQueue, false)
|
||||||
.putExtra(Player.RESUME_PLAYBACK, false);
|
.putExtra(Player.ENQUEUE_NEXT, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* PLAY */
|
/* PLAY */
|
||||||
@@ -156,10 +166,8 @@ public final class NavigationHelper {
|
|||||||
|
|
||||||
Toast.makeText(context, R.string.popup_playing_toast, Toast.LENGTH_SHORT).show();
|
Toast.makeText(context, R.string.popup_playing_toast, Toast.LENGTH_SHORT).show();
|
||||||
|
|
||||||
final Intent intent = getPlayerIntent(context, PlayerService.class, queue,
|
final Intent intent = getPlayerIntent(context, PlayerService.class, queue, resumePlayback);
|
||||||
PlayerIntentType.AllOthers);
|
intent.putExtra(Player.PLAYER_TYPE, PlayerType.POPUP.valueForIntent());
|
||||||
intent.putExtra(Player.PLAYER_TYPE, PlayerType.POPUP.valueForIntent())
|
|
||||||
.putExtra(Player.RESUME_PLAYBACK, resumePlayback);
|
|
||||||
ContextCompat.startForegroundService(context, intent);
|
ContextCompat.startForegroundService(context, intent);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -169,10 +177,8 @@ public final class NavigationHelper {
|
|||||||
Toast.makeText(context, R.string.background_player_playing_toast, Toast.LENGTH_SHORT)
|
Toast.makeText(context, R.string.background_player_playing_toast, Toast.LENGTH_SHORT)
|
||||||
.show();
|
.show();
|
||||||
|
|
||||||
final Intent intent = getPlayerIntent(context, PlayerService.class, queue,
|
final Intent intent = getPlayerIntent(context, PlayerService.class, queue, resumePlayback);
|
||||||
PlayerIntentType.AllOthers);
|
|
||||||
intent.putExtra(Player.PLAYER_TYPE, PlayerType.AUDIO.valueForIntent());
|
intent.putExtra(Player.PLAYER_TYPE, PlayerType.AUDIO.valueForIntent());
|
||||||
intent.putExtra(Player.RESUME_PLAYBACK, resumePlayback);
|
|
||||||
ContextCompat.startForegroundService(context, intent);
|
ContextCompat.startForegroundService(context, intent);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -185,17 +191,7 @@ public final class NavigationHelper {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Toast.makeText(context, R.string.enqueued, Toast.LENGTH_SHORT).show();
|
Toast.makeText(context, R.string.enqueued, Toast.LENGTH_SHORT).show();
|
||||||
|
final Intent intent = getPlayerEnqueueIntent(context, PlayerService.class, queue);
|
||||||
// when enqueueing `resumePlayback` is always `false` since:
|
|
||||||
// - if there is a video already playing, the value of `resumePlayback` just doesn't make
|
|
||||||
// any difference.
|
|
||||||
// - if there is nothing already playing, it is useful for the enqueue action to have a
|
|
||||||
// slightly different behaviour than the normal play action: the latter resumes playback,
|
|
||||||
// the former doesn't. (note that enqueue can be triggered when nothing is playing only
|
|
||||||
// by long pressing the video detail fragment, playlist or channel controls
|
|
||||||
final Intent intent = getPlayerIntent(context, PlayerService.class, queue,
|
|
||||||
PlayerIntentType.Enqueue)
|
|
||||||
.putExtra(Player.RESUME_PLAYBACK, false);
|
|
||||||
|
|
||||||
intent.putExtra(Player.PLAYER_TYPE, playerType.valueForIntent());
|
intent.putExtra(Player.PLAYER_TYPE, playerType.valueForIntent());
|
||||||
ContextCompat.startForegroundService(context, intent);
|
ContextCompat.startForegroundService(context, intent);
|
||||||
|
|||||||
@@ -5,10 +5,9 @@ import static org.schabi.newpipe.MainActivity.DEBUG;
|
|||||||
import android.content.ActivityNotFoundException;
|
import android.content.ActivityNotFoundException;
|
||||||
import android.content.ClipData;
|
import android.content.ClipData;
|
||||||
import android.content.ClipboardManager;
|
import android.content.ClipboardManager;
|
||||||
|
import android.content.ComponentName;
|
||||||
import android.content.Context;
|
import android.content.Context;
|
||||||
import android.content.Intent;
|
import android.content.Intent;
|
||||||
import android.content.pm.PackageManager;
|
|
||||||
import android.content.pm.ResolveInfo;
|
|
||||||
import android.graphics.Bitmap;
|
import android.graphics.Bitmap;
|
||||||
import android.net.Uri;
|
import android.net.Uri;
|
||||||
import android.os.Build;
|
import android.os.Build;
|
||||||
@@ -23,6 +22,7 @@ import androidx.core.content.FileProvider;
|
|||||||
|
|
||||||
import org.schabi.newpipe.BuildConfig;
|
import org.schabi.newpipe.BuildConfig;
|
||||||
import org.schabi.newpipe.R;
|
import org.schabi.newpipe.R;
|
||||||
|
import org.schabi.newpipe.RouterActivity;
|
||||||
import org.schabi.newpipe.extractor.Image;
|
import org.schabi.newpipe.extractor.Image;
|
||||||
import org.schabi.newpipe.util.image.ImageStrategy;
|
import org.schabi.newpipe.util.image.ImageStrategy;
|
||||||
import org.schabi.newpipe.util.image.PicassoHelper;
|
import org.schabi.newpipe.util.image.PicassoHelper;
|
||||||
@@ -62,8 +62,9 @@ public final class ShareUtils {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Open the url with the system default browser. If no browser is set as default, falls back to
|
* Open the url with the system default browser. If no browser is installed, falls back to
|
||||||
* {@link #openAppChooser(Context, Intent, boolean)}.
|
* {@link #openAppChooser(Context, Intent, boolean)} (for displaying that no apps are available
|
||||||
|
* to handle the action, or possible OEM-related edge cases).
|
||||||
* <p>
|
* <p>
|
||||||
* This function selects the package to open based on which apps respond to the {@code http://}
|
* This function selects the package to open based on which apps respond to the {@code http://}
|
||||||
* schema alone, which should exclude special non-browser apps that are can handle the url (e.g.
|
* schema alone, which should exclude special non-browser apps that are can handle the url (e.g.
|
||||||
@@ -77,44 +78,26 @@ public final class ShareUtils {
|
|||||||
* @param url the url to browse
|
* @param url the url to browse
|
||||||
**/
|
**/
|
||||||
public static void openUrlInBrowser(@NonNull final Context context, final String url) {
|
public static void openUrlInBrowser(@NonNull final Context context, final String url) {
|
||||||
// Resolve using a generic http://, so we are sure to get a browser and not e.g. the yt app.
|
// Target a generic http://, so we are sure to get a browser and not e.g. the yt app.
|
||||||
// Note that this requires the `http` schema to be added to `<queries>` in the manifest.
|
// Note that this requires the `http` schema to be added to `<queries>` in the manifest.
|
||||||
final ResolveInfo defaultBrowserInfo;
|
|
||||||
final Intent browserIntent = new Intent(Intent.ACTION_VIEW, Uri.parse("http://"));
|
final Intent browserIntent = new Intent(Intent.ACTION_VIEW, Uri.parse("http://"));
|
||||||
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {
|
|
||||||
defaultBrowserInfo = context.getPackageManager().resolveActivity(browserIntent,
|
|
||||||
PackageManager.ResolveInfoFlags.of(PackageManager.MATCH_DEFAULT_ONLY));
|
|
||||||
} else {
|
|
||||||
defaultBrowserInfo = context.getPackageManager().resolveActivity(browserIntent,
|
|
||||||
PackageManager.MATCH_DEFAULT_ONLY);
|
|
||||||
}
|
|
||||||
|
|
||||||
final Intent intent = new Intent(Intent.ACTION_VIEW, Uri.parse(url))
|
final Intent intent = new Intent(Intent.ACTION_VIEW, Uri.parse(url))
|
||||||
.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
|
.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
|
||||||
|
|
||||||
if (defaultBrowserInfo == null) {
|
// See https://stackoverflow.com/a/58801285 and `setSelector` documentation
|
||||||
// No app installed to open a web URL, but it may be handled by other apps so try
|
intent.setSelector(browserIntent);
|
||||||
// opening a system chooser for the link in this case (it could be bypassed by the
|
try {
|
||||||
// system if there is only one app which can open the link or a default app associated
|
context.startActivity(intent);
|
||||||
// with the link domain on Android 12 and higher)
|
} catch (final ActivityNotFoundException e) {
|
||||||
|
// No browser is available. This should, in the end, yield a nice AOSP error message
|
||||||
|
// indicating that no app is available to handle this action.
|
||||||
|
//
|
||||||
|
// Note: there are some situations where modified OEM ROMs have apps that appear
|
||||||
|
// to be browsers but are actually app choosers. If starting the Activity fails
|
||||||
|
// related to this, opening the system app chooser is still the correct behavior.
|
||||||
|
intent.setSelector(null);
|
||||||
openAppChooser(context, intent, true);
|
openAppChooser(context, intent, true);
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
final String defaultBrowserPackage = defaultBrowserInfo.activityInfo.packageName;
|
|
||||||
|
|
||||||
if (defaultBrowserPackage.equals("android")) {
|
|
||||||
// No browser set as default (doesn't work on some devices)
|
|
||||||
openAppChooser(context, intent, true);
|
|
||||||
} else {
|
|
||||||
try {
|
|
||||||
intent.setPackage(defaultBrowserPackage);
|
|
||||||
context.startActivity(intent);
|
|
||||||
} catch (final ActivityNotFoundException e) {
|
|
||||||
// Not a browser but an app chooser because of OEMs changes
|
|
||||||
intent.setPackage(null);
|
|
||||||
openAppChooser(context, intent, true);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -190,6 +173,18 @@ public final class ShareUtils {
|
|||||||
chooserIntent.putExtra(Intent.EXTRA_TITLE, context.getString(R.string.open_with));
|
chooserIntent.putExtra(Intent.EXTRA_TITLE, context.getString(R.string.open_with));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Avoid opening in NewPipe
|
||||||
|
// (Implementation note: if the URL is one for which NewPipe itself
|
||||||
|
// is set as handler on Android >= 12, we actually remove the only eligible app
|
||||||
|
// for this link, and browsers will not be offered to the user. For that, use
|
||||||
|
// `openUrlInBrowser`.)
|
||||||
|
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {
|
||||||
|
chooserIntent.putExtra(
|
||||||
|
Intent.EXTRA_EXCLUDE_COMPONENTS,
|
||||||
|
new ComponentName[]{new ComponentName(context, RouterActivity.class)}
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
// Migrate any clip data and flags from the original intent.
|
// Migrate any clip data and flags from the original intent.
|
||||||
final int permFlags = intent.getFlags() & (Intent.FLAG_GRANT_READ_URI_PERMISSION
|
final int permFlags = intent.getFlags() & (Intent.FLAG_GRANT_READ_URI_PERMISSION
|
||||||
| Intent.FLAG_GRANT_WRITE_URI_PERMISSION
|
| Intent.FLAG_GRANT_WRITE_URI_PERMISSION
|
||||||
|
|||||||
@@ -1,27 +1,63 @@
|
|||||||
package org.schabi.newpipe.util.text;
|
package org.schabi.newpipe.util.text;
|
||||||
|
|
||||||
import android.content.Context;
|
import android.content.Context;
|
||||||
import android.content.Intent;
|
|
||||||
import androidx.core.content.ContextCompat;
|
|
||||||
|
|
||||||
import androidx.annotation.NonNull;
|
import androidx.annotation.NonNull;
|
||||||
|
|
||||||
|
import org.schabi.newpipe.MainActivity;
|
||||||
|
import org.schabi.newpipe.error.ErrorInfo;
|
||||||
|
import org.schabi.newpipe.error.ErrorUtil;
|
||||||
|
import org.schabi.newpipe.error.UserAction;
|
||||||
import org.schabi.newpipe.extractor.NewPipe;
|
import org.schabi.newpipe.extractor.NewPipe;
|
||||||
import org.schabi.newpipe.extractor.StreamingService;
|
import org.schabi.newpipe.extractor.StreamingService;
|
||||||
import org.schabi.newpipe.extractor.exceptions.ExtractionException;
|
import org.schabi.newpipe.extractor.exceptions.ExtractionException;
|
||||||
import org.schabi.newpipe.extractor.exceptions.ParsingException;
|
import org.schabi.newpipe.extractor.exceptions.ParsingException;
|
||||||
import org.schabi.newpipe.extractor.linkhandler.LinkHandlerFactory;
|
import org.schabi.newpipe.extractor.linkhandler.LinkHandlerFactory;
|
||||||
import org.schabi.newpipe.player.TimestampChangeData;
|
import org.schabi.newpipe.extractor.stream.StreamInfo;
|
||||||
|
import org.schabi.newpipe.player.playqueue.PlayQueue;
|
||||||
|
import org.schabi.newpipe.player.playqueue.SinglePlayQueue;
|
||||||
|
import org.schabi.newpipe.util.ExtractorHelper;
|
||||||
import org.schabi.newpipe.util.NavigationHelper;
|
import org.schabi.newpipe.util.NavigationHelper;
|
||||||
|
|
||||||
import java.util.regex.Matcher;
|
import java.util.regex.Matcher;
|
||||||
import java.util.regex.Pattern;
|
import java.util.regex.Pattern;
|
||||||
|
|
||||||
|
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
|
||||||
|
import io.reactivex.rxjava3.core.Single;
|
||||||
|
import io.reactivex.rxjava3.disposables.CompositeDisposable;
|
||||||
|
import io.reactivex.rxjava3.schedulers.Schedulers;
|
||||||
|
|
||||||
public final class InternalUrlsHandler {
|
public final class InternalUrlsHandler {
|
||||||
|
private static final String TAG = InternalUrlsHandler.class.getSimpleName();
|
||||||
|
private static final boolean DEBUG = MainActivity.DEBUG;
|
||||||
|
|
||||||
private static final Pattern AMPERSAND_TIMESTAMP_PATTERN = Pattern.compile("(.*)&t=(\\d+)");
|
private static final Pattern AMPERSAND_TIMESTAMP_PATTERN = Pattern.compile("(.*)&t=(\\d+)");
|
||||||
|
private static final Pattern HASHTAG_TIMESTAMP_PATTERN =
|
||||||
|
Pattern.compile("(.*)#timestamp=(\\d+)");
|
||||||
|
|
||||||
private InternalUrlsHandler() {
|
private InternalUrlsHandler() {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Handle a YouTube timestamp comment URL in NewPipe.
|
||||||
|
* <p>
|
||||||
|
* This method will check if the provided url is a YouTube comment description URL ({@code
|
||||||
|
* https://www.youtube.com/watch?v=}video_id{@code #timestamp=}time_in_seconds). If yes, the
|
||||||
|
* popup player will be opened when the user will click on the timestamp in the comment,
|
||||||
|
* at the time and for the video indicated in the timestamp.
|
||||||
|
*
|
||||||
|
* @param disposables a field of the Activity/Fragment class that calls this method
|
||||||
|
* @param context the context to use
|
||||||
|
* @param url the URL to check if it can be handled
|
||||||
|
* @return true if the URL can be handled by NewPipe, false if it cannot
|
||||||
|
*/
|
||||||
|
public static boolean handleUrlCommentsTimestamp(@NonNull final CompositeDisposable
|
||||||
|
disposables,
|
||||||
|
final Context context,
|
||||||
|
@NonNull final String url) {
|
||||||
|
return handleUrl(context, url, HASHTAG_TIMESTAMP_PATTERN, disposables);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Handle a YouTube timestamp description URL in NewPipe.
|
* Handle a YouTube timestamp description URL in NewPipe.
|
||||||
* <p>
|
* <p>
|
||||||
@@ -30,13 +66,36 @@ public final class InternalUrlsHandler {
|
|||||||
* player will be opened when the user will click on the timestamp in the video description,
|
* player will be opened when the user will click on the timestamp in the video description,
|
||||||
* at the time and for the video indicated in the timestamp.
|
* at the time and for the video indicated in the timestamp.
|
||||||
*
|
*
|
||||||
|
* @param disposables a field of the Activity/Fragment class that calls this method
|
||||||
* @param context the context to use
|
* @param context the context to use
|
||||||
* @param url the URL to check if it can be handled
|
* @param url the URL to check if it can be handled
|
||||||
* @return true if the URL can be handled by NewPipe, false if it cannot
|
* @return true if the URL can be handled by NewPipe, false if it cannot
|
||||||
*/
|
*/
|
||||||
public static boolean handleUrlDescriptionTimestamp(final Context context,
|
public static boolean handleUrlDescriptionTimestamp(@NonNull final CompositeDisposable
|
||||||
|
disposables,
|
||||||
|
final Context context,
|
||||||
@NonNull final String url) {
|
@NonNull final String url) {
|
||||||
final Matcher matcher = AMPERSAND_TIMESTAMP_PATTERN.matcher(url);
|
return handleUrl(context, url, AMPERSAND_TIMESTAMP_PATTERN, disposables);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Handle an URL in NewPipe.
|
||||||
|
* <p>
|
||||||
|
* This method will check if the provided url can be handled in NewPipe or not. If this is a
|
||||||
|
* service URL with a timestamp, the popup player will be opened and true will be returned;
|
||||||
|
* else, false will be returned.
|
||||||
|
*
|
||||||
|
* @param context the context to use
|
||||||
|
* @param url the URL to check if it can be handled
|
||||||
|
* @param pattern the pattern to use
|
||||||
|
* @param disposables a field of the Activity/Fragment class that calls this method
|
||||||
|
* @return true if the URL can be handled by NewPipe, false if it cannot
|
||||||
|
*/
|
||||||
|
private static boolean handleUrl(final Context context,
|
||||||
|
@NonNull final String url,
|
||||||
|
@NonNull final Pattern pattern,
|
||||||
|
@NonNull final CompositeDisposable disposables) {
|
||||||
|
final Matcher matcher = pattern.matcher(url);
|
||||||
if (!matcher.matches()) {
|
if (!matcher.matches()) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
@@ -61,7 +120,7 @@ public final class InternalUrlsHandler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (linkType == StreamingService.LinkType.STREAM && seconds != -1) {
|
if (linkType == StreamingService.LinkType.STREAM && seconds != -1) {
|
||||||
return playOnPopup(context, matchedUrl, service, seconds);
|
return playOnPopup(context, matchedUrl, service, seconds, disposables);
|
||||||
} else {
|
} else {
|
||||||
NavigationHelper.openRouterActivity(context, matchedUrl);
|
NavigationHelper.openRouterActivity(context, matchedUrl);
|
||||||
return true;
|
return true;
|
||||||
@@ -75,12 +134,15 @@ public final class InternalUrlsHandler {
|
|||||||
* @param url the URL of the content
|
* @param url the URL of the content
|
||||||
* @param service the service of the content
|
* @param service the service of the content
|
||||||
* @param seconds the position in seconds at which the floating player will start
|
* @param seconds the position in seconds at which the floating player will start
|
||||||
|
* @param disposables disposables created by the method are added here and their lifecycle
|
||||||
|
* should be handled by the calling class
|
||||||
* @return true if the playback of the content has successfully started or false if not
|
* @return true if the playback of the content has successfully started or false if not
|
||||||
*/
|
*/
|
||||||
public static boolean playOnPopup(final Context context,
|
public static boolean playOnPopup(final Context context,
|
||||||
final String url,
|
final String url,
|
||||||
@NonNull final StreamingService service,
|
@NonNull final StreamingService service,
|
||||||
final int seconds) {
|
final int seconds,
|
||||||
|
@NonNull final CompositeDisposable disposables) {
|
||||||
final LinkHandlerFactory factory = service.getStreamLHFactory();
|
final LinkHandlerFactory factory = service.getStreamLHFactory();
|
||||||
final String cleanUrl;
|
final String cleanUrl;
|
||||||
|
|
||||||
@@ -90,14 +152,19 @@ public final class InternalUrlsHandler {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
final Intent intent = NavigationHelper.getPlayerTimestampIntent(context,
|
final Single<StreamInfo> single =
|
||||||
new TimestampChangeData(
|
ExtractorHelper.getStreamInfo(service.getServiceId(), cleanUrl, false);
|
||||||
service.getServiceId(),
|
disposables.add(single.subscribeOn(Schedulers.io())
|
||||||
cleanUrl,
|
.observeOn(AndroidSchedulers.mainThread())
|
||||||
seconds
|
.subscribe(info -> {
|
||||||
));
|
final PlayQueue playQueue = new SinglePlayQueue(info, seconds * 1000L);
|
||||||
ContextCompat.startForegroundService(context, intent);
|
NavigationHelper.playOnPopupPlayer(context, playQueue, false);
|
||||||
|
}, throwable -> {
|
||||||
|
// This will only show a snackbar if the passed context has a root view:
|
||||||
|
// otherwise it will resort to showing a notification, so we are safe here.
|
||||||
|
ErrorUtil.showSnackbar(context,
|
||||||
|
new ErrorInfo(throwable, UserAction.PLAY_ON_POPUP, url, null, url));
|
||||||
|
}));
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -192,7 +192,7 @@ public final class TextLinkifier {
|
|||||||
* <p>
|
* <p>
|
||||||
* Instead of using an {@link android.content.Intent#ACTION_VIEW} intent in the description of
|
* Instead of using an {@link android.content.Intent#ACTION_VIEW} intent in the description of
|
||||||
* a content, this method will parse the {@link CharSequence} and replace all current web links
|
* a content, this method will parse the {@link CharSequence} and replace all current web links
|
||||||
* with {@link ShareUtils#openUrlInBrowser(Context, String)}.
|
* with {@link ShareUtils#openUrlInBrowser(Context, String, boolean)}.
|
||||||
* </p>
|
* </p>
|
||||||
*
|
*
|
||||||
* <p>
|
* <p>
|
||||||
@@ -240,7 +240,7 @@ public final class TextLinkifier {
|
|||||||
for (final URLSpan span : urls) {
|
for (final URLSpan span : urls) {
|
||||||
final String url = span.getURL();
|
final String url = span.getURL();
|
||||||
final LongPressClickableSpan longPressClickableSpan =
|
final LongPressClickableSpan longPressClickableSpan =
|
||||||
new UrlLongPressClickableSpan(context, url);
|
new UrlLongPressClickableSpan(context, disposables, url);
|
||||||
|
|
||||||
textBlockLinked.setSpan(longPressClickableSpan,
|
textBlockLinked.setSpan(longPressClickableSpan,
|
||||||
textBlockLinked.getSpanStart(span),
|
textBlockLinked.getSpanStart(span),
|
||||||
|
|||||||
@@ -46,7 +46,7 @@ final class TimestampLongPressClickableSpan extends LongPressClickableSpan {
|
|||||||
@Override
|
@Override
|
||||||
public void onClick(@NonNull final View view) {
|
public void onClick(@NonNull final View view) {
|
||||||
playOnPopup(context, relatedStreamUrl, relatedInfoService,
|
playOnPopup(context, relatedStreamUrl, relatedInfoService,
|
||||||
timestampMatchDTO.seconds());
|
timestampMatchDTO.seconds(), disposables);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -7,22 +7,29 @@ import androidx.annotation.NonNull;
|
|||||||
|
|
||||||
import org.schabi.newpipe.util.external_communication.ShareUtils;
|
import org.schabi.newpipe.util.external_communication.ShareUtils;
|
||||||
|
|
||||||
|
import io.reactivex.rxjava3.disposables.CompositeDisposable;
|
||||||
|
|
||||||
final class UrlLongPressClickableSpan extends LongPressClickableSpan {
|
final class UrlLongPressClickableSpan extends LongPressClickableSpan {
|
||||||
|
|
||||||
@NonNull
|
@NonNull
|
||||||
private final Context context;
|
private final Context context;
|
||||||
@NonNull
|
@NonNull
|
||||||
|
private final CompositeDisposable disposables;
|
||||||
|
@NonNull
|
||||||
private final String url;
|
private final String url;
|
||||||
|
|
||||||
UrlLongPressClickableSpan(@NonNull final Context context,
|
UrlLongPressClickableSpan(@NonNull final Context context,
|
||||||
|
@NonNull final CompositeDisposable disposables,
|
||||||
@NonNull final String url) {
|
@NonNull final String url) {
|
||||||
this.context = context;
|
this.context = context;
|
||||||
|
this.disposables = disposables;
|
||||||
this.url = url;
|
this.url = url;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onClick(@NonNull final View view) {
|
public void onClick(@NonNull final View view) {
|
||||||
if (!InternalUrlsHandler.handleUrlDescriptionTimestamp(context, url)) {
|
if (!InternalUrlsHandler.handleUrlDescriptionTimestamp(
|
||||||
|
disposables, context, url)) {
|
||||||
ShareUtils.openUrlInApp(context, url);
|
ShareUtils.openUrlInApp(context, url);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user