2018-04-08 11:08:19 +00:00
|
|
|
package org.schabi.newpipe.util;
|
|
|
|
|
|
|
|
import android.content.Context;
|
2018-11-20 22:10:50 +00:00
|
|
|
import android.util.SparseArray;
|
2018-04-08 11:08:19 +00:00
|
|
|
import android.view.LayoutInflater;
|
|
|
|
import android.view.View;
|
|
|
|
import android.view.ViewGroup;
|
|
|
|
import android.widget.BaseAdapter;
|
|
|
|
import android.widget.ImageView;
|
|
|
|
import android.widget.Spinner;
|
|
|
|
import android.widget.TextView;
|
|
|
|
|
2019-10-28 02:35:51 +00:00
|
|
|
import org.schabi.newpipe.DownloaderImpl;
|
2018-04-08 11:08:19 +00:00
|
|
|
import org.schabi.newpipe.R;
|
|
|
|
import org.schabi.newpipe.extractor.stream.AudioStream;
|
|
|
|
import org.schabi.newpipe.extractor.stream.Stream;
|
2018-09-23 18:12:23 +00:00
|
|
|
import org.schabi.newpipe.extractor.stream.SubtitlesStream;
|
2018-04-08 11:08:19 +00:00
|
|
|
import org.schabi.newpipe.extractor.stream.VideoStream;
|
|
|
|
|
|
|
|
import java.io.Serializable;
|
|
|
|
import java.util.Collections;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.concurrent.Callable;
|
|
|
|
|
|
|
|
import io.reactivex.Single;
|
|
|
|
import io.reactivex.android.schedulers.AndroidSchedulers;
|
|
|
|
import io.reactivex.schedulers.Schedulers;
|
|
|
|
import us.shandian.giga.util.Utility;
|
|
|
|
|
|
|
|
/**
|
2018-12-23 21:07:27 +00:00
|
|
|
* A list adapter for a list of {@link Stream streams},
|
|
|
|
* currently supporting {@link VideoStream}, {@link AudioStream} and {@link SubtitlesStream}
|
2018-04-08 11:08:19 +00:00
|
|
|
*/
|
2018-11-20 22:10:50 +00:00
|
|
|
public class StreamItemAdapter<T extends Stream, U extends Stream> extends BaseAdapter {
|
2018-04-08 11:08:19 +00:00
|
|
|
private final Context context;
|
|
|
|
|
2018-08-28 18:02:25 +00:00
|
|
|
private final StreamSizeWrapper<T> streamsWrapper;
|
2018-11-20 22:10:50 +00:00
|
|
|
private final SparseArray<SecondaryStreamHelper<U>> secondaryStreams;
|
2018-04-08 11:08:19 +00:00
|
|
|
|
2018-11-20 22:10:50 +00:00
|
|
|
public StreamItemAdapter(Context context, StreamSizeWrapper<T> streamsWrapper, SparseArray<SecondaryStreamHelper<U>> secondaryStreams) {
|
2018-04-08 11:08:19 +00:00
|
|
|
this.context = context;
|
|
|
|
this.streamsWrapper = streamsWrapper;
|
2018-11-20 22:10:50 +00:00
|
|
|
this.secondaryStreams = secondaryStreams;
|
|
|
|
}
|
|
|
|
|
|
|
|
public StreamItemAdapter(Context context, StreamSizeWrapper<T> streamsWrapper, boolean showIconNoAudio) {
|
|
|
|
this(context, streamsWrapper, showIconNoAudio ? new SparseArray<>() : null);
|
2018-04-08 11:08:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
public StreamItemAdapter(Context context, StreamSizeWrapper<T> streamsWrapper) {
|
2018-11-20 22:10:50 +00:00
|
|
|
this(context, streamsWrapper, null);
|
2018-04-08 11:08:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
public List<T> getAll() {
|
|
|
|
return streamsWrapper.getStreamsList();
|
|
|
|
}
|
|
|
|
|
2018-11-20 22:10:50 +00:00
|
|
|
public SparseArray<SecondaryStreamHelper<U>> getAllSecondary() {
|
|
|
|
return secondaryStreams;
|
|
|
|
}
|
|
|
|
|
2018-04-08 11:08:19 +00:00
|
|
|
@Override
|
|
|
|
public int getCount() {
|
|
|
|
return streamsWrapper.getStreamsList().size();
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public T getItem(int position) {
|
|
|
|
return streamsWrapper.getStreamsList().get(position);
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public long getItemId(int position) {
|
|
|
|
return position;
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public View getDropDownView(int position, View convertView, ViewGroup parent) {
|
|
|
|
return getCustomView(position, convertView, parent, true);
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public View getView(int position, View convertView, ViewGroup parent) {
|
|
|
|
return getCustomView(((Spinner) parent).getSelectedItemPosition(), convertView, parent, false);
|
|
|
|
}
|
|
|
|
|
|
|
|
private View getCustomView(int position, View convertView, ViewGroup parent, boolean isDropdownItem) {
|
|
|
|
if (convertView == null) {
|
|
|
|
convertView = LayoutInflater.from(context).inflate(R.layout.stream_quality_item, parent, false);
|
|
|
|
}
|
|
|
|
|
|
|
|
final ImageView woSoundIconView = convertView.findViewById(R.id.wo_sound_icon);
|
|
|
|
final TextView formatNameView = convertView.findViewById(R.id.stream_format_name);
|
|
|
|
final TextView qualityView = convertView.findViewById(R.id.stream_quality);
|
|
|
|
final TextView sizeView = convertView.findViewById(R.id.stream_size);
|
|
|
|
|
|
|
|
final T stream = getItem(position);
|
|
|
|
|
|
|
|
int woSoundIconVisibility = View.GONE;
|
|
|
|
String qualityString;
|
|
|
|
|
|
|
|
if (stream instanceof VideoStream) {
|
2018-11-20 22:10:50 +00:00
|
|
|
VideoStream videoStream = ((VideoStream) stream);
|
|
|
|
qualityString = videoStream.getResolution();
|
|
|
|
|
|
|
|
if (secondaryStreams != null) {
|
|
|
|
if (videoStream.isVideoOnly()) {
|
|
|
|
woSoundIconVisibility = secondaryStreams.get(position) == null ? View.VISIBLE : View.INVISIBLE;
|
|
|
|
} else if (isDropdownItem) {
|
|
|
|
woSoundIconVisibility = View.INVISIBLE;
|
2018-09-23 18:12:23 +00:00
|
|
|
}
|
2018-04-08 11:08:19 +00:00
|
|
|
}
|
|
|
|
} else if (stream instanceof AudioStream) {
|
2018-12-23 21:07:27 +00:00
|
|
|
AudioStream audioStream = ((AudioStream) stream);
|
|
|
|
qualityString = audioStream.getAverageBitrate() > 0
|
|
|
|
? audioStream.getAverageBitrate() + "kbps"
|
|
|
|
: audioStream.getFormat().getName();
|
2018-09-23 18:12:23 +00:00
|
|
|
} else if (stream instanceof SubtitlesStream) {
|
|
|
|
qualityString = ((SubtitlesStream) stream).getDisplayLanguageName();
|
|
|
|
if (((SubtitlesStream) stream).isAutoGenerated()) {
|
|
|
|
qualityString += " (" + context.getString(R.string.caption_auto_generated) + ")";
|
|
|
|
}
|
2018-04-08 11:08:19 +00:00
|
|
|
} else {
|
|
|
|
qualityString = stream.getFormat().getSuffix();
|
|
|
|
}
|
|
|
|
|
|
|
|
if (streamsWrapper.getSizeInBytes(position) > 0) {
|
2018-11-20 22:10:50 +00:00
|
|
|
SecondaryStreamHelper secondary = secondaryStreams == null ? null : secondaryStreams.get(position);
|
|
|
|
if (secondary != null) {
|
|
|
|
long size = secondary.getSizeInBytes() + streamsWrapper.getSizeInBytes(position);
|
|
|
|
sizeView.setText(Utility.formatBytes(size));
|
|
|
|
} else {
|
|
|
|
sizeView.setText(streamsWrapper.getFormattedSize(position));
|
|
|
|
}
|
2018-04-08 11:08:19 +00:00
|
|
|
sizeView.setVisibility(View.VISIBLE);
|
|
|
|
} else {
|
|
|
|
sizeView.setVisibility(View.GONE);
|
|
|
|
}
|
|
|
|
|
2018-09-23 18:12:23 +00:00
|
|
|
if (stream instanceof SubtitlesStream) {
|
|
|
|
formatNameView.setText(((SubtitlesStream) stream).getLanguageTag());
|
|
|
|
} else {
|
|
|
|
formatNameView.setText(stream.getFormat().getName());
|
|
|
|
}
|
|
|
|
|
2018-04-08 11:08:19 +00:00
|
|
|
qualityView.setText(qualityString);
|
|
|
|
woSoundIconView.setVisibility(woSoundIconVisibility);
|
|
|
|
|
|
|
|
return convertView;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* A wrapper class that includes a way of storing the stream sizes.
|
|
|
|
*/
|
|
|
|
public static class StreamSizeWrapper<T extends Stream> implements Serializable {
|
2018-09-23 18:12:23 +00:00
|
|
|
private static final StreamSizeWrapper<Stream> EMPTY = new StreamSizeWrapper<>(Collections.emptyList(), null);
|
2018-04-08 11:08:19 +00:00
|
|
|
private final List<T> streamsList;
|
2018-11-08 22:03:30 +00:00
|
|
|
private final long[] streamSizes;
|
2018-09-23 18:12:23 +00:00
|
|
|
private final String unknownSize;
|
2018-04-08 11:08:19 +00:00
|
|
|
|
2018-12-23 21:07:27 +00:00
|
|
|
public StreamSizeWrapper(List<T> sL, Context context) {
|
|
|
|
this.streamsList = sL != null
|
|
|
|
? sL
|
|
|
|
: Collections.emptyList();
|
2018-04-08 11:08:19 +00:00
|
|
|
this.streamSizes = new long[streamsList.size()];
|
2018-09-23 18:12:23 +00:00
|
|
|
this.unknownSize = context == null ? "--.-" : context.getString(R.string.unknown_content);
|
2018-04-08 11:08:19 +00:00
|
|
|
|
2018-09-23 18:12:23 +00:00
|
|
|
for (int i = 0; i < streamSizes.length; i++) streamSizes[i] = -2;
|
2018-04-08 11:08:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Helper method to fetch the sizes of all the streams in a wrapper.
|
|
|
|
*
|
|
|
|
* @param streamsWrapper the wrapper
|
|
|
|
* @return a {@link Single} that returns a boolean indicating if any elements were changed
|
|
|
|
*/
|
|
|
|
public static <X extends Stream> Single<Boolean> fetchSizeForWrapper(StreamSizeWrapper<X> streamsWrapper) {
|
|
|
|
final Callable<Boolean> fetchAndSet = () -> {
|
|
|
|
boolean hasChanged = false;
|
|
|
|
for (X stream : streamsWrapper.getStreamsList()) {
|
2018-09-23 18:12:23 +00:00
|
|
|
if (streamsWrapper.getSizeInBytes(stream) > -2) {
|
2018-04-08 11:08:19 +00:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
2019-10-28 02:35:51 +00:00
|
|
|
final long contentLength = DownloaderImpl.getInstance().getContentLength(stream.getUrl());
|
2018-04-08 11:08:19 +00:00
|
|
|
streamsWrapper.setSize(stream, contentLength);
|
|
|
|
hasChanged = true;
|
|
|
|
}
|
|
|
|
return hasChanged;
|
|
|
|
};
|
|
|
|
|
|
|
|
return Single.fromCallable(fetchAndSet)
|
|
|
|
.subscribeOn(Schedulers.io())
|
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
|
.onErrorReturnItem(true);
|
|
|
|
}
|
|
|
|
|
|
|
|
public List<T> getStreamsList() {
|
|
|
|
return streamsList;
|
|
|
|
}
|
|
|
|
|
|
|
|
public long getSizeInBytes(int streamIndex) {
|
|
|
|
return streamSizes[streamIndex];
|
|
|
|
}
|
|
|
|
|
|
|
|
public long getSizeInBytes(T stream) {
|
|
|
|
return streamSizes[streamsList.indexOf(stream)];
|
|
|
|
}
|
|
|
|
|
|
|
|
public String getFormattedSize(int streamIndex) {
|
2018-09-23 18:12:23 +00:00
|
|
|
return formatSize(getSizeInBytes(streamIndex));
|
2018-04-08 11:08:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
public String getFormattedSize(T stream) {
|
2018-09-23 18:12:23 +00:00
|
|
|
return formatSize(getSizeInBytes(stream));
|
|
|
|
}
|
|
|
|
|
|
|
|
private String formatSize(long size) {
|
|
|
|
if (size > -1) {
|
|
|
|
return Utility.formatBytes(size);
|
|
|
|
}
|
|
|
|
return unknownSize;
|
2018-04-08 11:08:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
public void setSize(int streamIndex, long sizeInBytes) {
|
|
|
|
streamSizes[streamIndex] = sizeInBytes;
|
|
|
|
}
|
|
|
|
|
|
|
|
public void setSize(T stream, long sizeInBytes) {
|
|
|
|
streamSizes[streamsList.indexOf(stream)] = sizeInBytes;
|
|
|
|
}
|
|
|
|
|
|
|
|
public static <X extends Stream> StreamSizeWrapper<X> empty() {
|
|
|
|
//noinspection unchecked
|
|
|
|
return (StreamSizeWrapper<X>) EMPTY;
|
|
|
|
}
|
|
|
|
}
|
2018-11-08 22:03:30 +00:00
|
|
|
}
|