forked from j62/ctbrec
Remove stray java file
This commit is contained in:
0xb00bface
parent
dc95b431dc
commit
f79441d414
|
|
@ -1,193 +0,0 @@
|
||||||
package ctbrec.sites.bonga;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.io.InputStream;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.concurrent.ExecutionException;
|
|
||||||
|
|
||||||
import org.json.JSONObject;
|
|
||||||
import org.slf4j.Logger;
|
|
||||||
import org.slf4j.LoggerFactory;
|
|
||||||
|
|
||||||
import com.iheartradio.m3u8.Encoding;
|
|
||||||
import com.iheartradio.m3u8.Format;
|
|
||||||
import com.iheartradio.m3u8.ParseException;
|
|
||||||
import com.iheartradio.m3u8.PlaylistException;
|
|
||||||
import com.iheartradio.m3u8.PlaylistParser;
|
|
||||||
import com.iheartradio.m3u8.data.MasterPlaylist;
|
|
||||||
import com.iheartradio.m3u8.data.Playlist;
|
|
||||||
import com.iheartradio.m3u8.data.PlaylistData;
|
|
||||||
import com.iheartradio.m3u8.data.StreamInfo;
|
|
||||||
|
|
||||||
import ctbrec.AbstractModel;
|
|
||||||
import ctbrec.recorder.download.StreamSource;
|
|
||||||
import ctbrec.sites.Site;
|
|
||||||
import okhttp3.FormBody;
|
|
||||||
import okhttp3.Request;
|
|
||||||
import okhttp3.RequestBody;
|
|
||||||
import okhttp3.Response;
|
|
||||||
|
|
||||||
public class BongaCamsModel extends AbstractModel {
|
|
||||||
|
|
||||||
private static final transient Logger LOG = LoggerFactory.getLogger(BongaCamsModel.class);
|
|
||||||
|
|
||||||
private BongaCams site;
|
|
||||||
private int userId;
|
|
||||||
private String onlineState = "n/a";
|
|
||||||
private boolean online = false;
|
|
||||||
private List<StreamSource> streamSources = new ArrayList<>();
|
|
||||||
private int[] resolution;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean isOnline(boolean ignoreCache) throws IOException, ExecutionException, InterruptedException {
|
|
||||||
return online;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setOnline(boolean online) {
|
|
||||||
this.online = online;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String getOnlineState(boolean failFast) throws IOException, ExecutionException {
|
|
||||||
return onlineState;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setOnlineState(String onlineState) {
|
|
||||||
this.onlineState = onlineState;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public List<StreamSource> getStreamSources() throws IOException, ExecutionException, ParseException, PlaylistException {
|
|
||||||
String streamUrl = getStreamUrl();
|
|
||||||
if (streamUrl == null) {
|
|
||||||
return Collections.emptyList();
|
|
||||||
}
|
|
||||||
Request req = new Request.Builder().url(streamUrl).build();
|
|
||||||
Response response = site.getHttpClient().execute(req);
|
|
||||||
try {
|
|
||||||
InputStream inputStream = response.body().byteStream();
|
|
||||||
PlaylistParser parser = new PlaylistParser(inputStream, Format.EXT_M3U, Encoding.UTF_8);
|
|
||||||
Playlist playlist = parser.parse();
|
|
||||||
MasterPlaylist master = playlist.getMasterPlaylist();
|
|
||||||
for (PlaylistData playlistData : master.getPlaylists()) {
|
|
||||||
|
|
||||||
StreamSource streamsource = new StreamSource();
|
|
||||||
streamsource.mediaPlaylistUrl = streamUrl.replace("playlist.m3u8", playlistData.getUri());
|
|
||||||
if (playlistData.hasStreamInfo()) {
|
|
||||||
StreamInfo info = playlistData.getStreamInfo();
|
|
||||||
streamsource.bandwidth = info.getBandwidth();
|
|
||||||
streamsource.width = info.hasResolution() ? info.getResolution().width : 0;
|
|
||||||
streamsource.height = info.hasResolution() ? info.getResolution().height : 0;
|
|
||||||
} else {
|
|
||||||
streamsource.bandwidth = 0;
|
|
||||||
streamsource.width = 0;
|
|
||||||
streamsource.height = 0;
|
|
||||||
}
|
|
||||||
streamSources.add(streamsource);
|
|
||||||
}
|
|
||||||
} finally {
|
|
||||||
response.close();
|
|
||||||
}
|
|
||||||
return streamSources;
|
|
||||||
}
|
|
||||||
|
|
||||||
private String getStreamUrl() throws IOException {
|
|
||||||
String url = BongaCams.BASE_URL + "/tools/amf.php";
|
|
||||||
RequestBody body = new FormBody.Builder()
|
|
||||||
.add("method", "getRoomData")
|
|
||||||
.add("args[]", getName())
|
|
||||||
.add("args[]", "false")
|
|
||||||
.build();
|
|
||||||
Request request = new Request.Builder()
|
|
||||||
.url(url)
|
|
||||||
.addHeader("User-Agent", "Mozilla/5.0 (Android 9.0; Mobile; rv:61.0) Gecko/61.0 Firefox/61.0")
|
|
||||||
.addHeader("Accept", "application/json, text/javascript, */*")
|
|
||||||
.addHeader("Accept-Language", "en")
|
|
||||||
.addHeader("Referer", BongaCams.BASE_URL)
|
|
||||||
.addHeader("X-Requested-With", "XMLHttpRequest")
|
|
||||||
.post(body)
|
|
||||||
.build();
|
|
||||||
try(Response response = site.getHttpClient().execute(request)) {
|
|
||||||
if(response.isSuccessful()) {
|
|
||||||
JSONObject json = new JSONObject(response.body().string());
|
|
||||||
if(json.optString("status").equals("success")) {
|
|
||||||
JSONObject localData = json.getJSONObject("localData");
|
|
||||||
String server = localData.getString("videoServerUrl");
|
|
||||||
return "https:" + server + "/hls/stream_" + getName() + "/playlist.m3u8";
|
|
||||||
} else {
|
|
||||||
throw new IOException("Request was not successful: " + json.toString(2));
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
throw new IOException(response.code() + " " + response.message());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void invalidateCacheEntries() {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void receiveTip(int tokens) throws IOException {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int[] getStreamResolution(boolean failFast) throws ExecutionException {
|
|
||||||
if(resolution == null) {
|
|
||||||
if(failFast) {
|
|
||||||
return new int[2];
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
List<StreamSource> streamSources = getStreamSources();
|
|
||||||
Collections.sort(streamSources);
|
|
||||||
StreamSource best = streamSources.get(streamSources.size()-1);
|
|
||||||
resolution = new int[] {best.width, best.height};
|
|
||||||
} catch (ExecutionException | IOException | ParseException | PlaylistException e) {
|
|
||||||
LOG.error("Couldn't determine stream resolution", e);
|
|
||||||
}
|
|
||||||
return resolution;
|
|
||||||
} else {
|
|
||||||
return resolution;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean follow() throws IOException {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean unfollow() throws IOException {
|
|
||||||
// TODO Auto-generated method stub
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void setSite(Site site) {
|
|
||||||
if(site instanceof BongaCams) {
|
|
||||||
this.site = (BongaCams) site;
|
|
||||||
} else {
|
|
||||||
throw new IllegalArgumentException("Site has to be an instance of BongaCams");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Site getSite() {
|
|
||||||
return site;
|
|
||||||
}
|
|
||||||
|
|
||||||
public int getUserId() {
|
|
||||||
return userId;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setUserId(int userId) {
|
|
||||||
this.userId = userId;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue