ctbrecuser
/
ctbrec
forked from j62/ctbrec
1
0
Fork 0
Code Pull Requests Activity

Revert change, which prevents ChaturbateModel to work correctly

This commit is contained in:
0xboobface 2018-11-23 21:15:04 +01:00
parent 2121f56804
commit 3445fa5ca0
1 changed files with 15 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
common/src/main/java/ctbrec/sites/chaturbate/ChaturbateModel.java
View File

@ -26,7 +26,6 @@ import okhttp3.Response;
public class ChaturbateModel extends AbstractModel { public class ChaturbateModel extends AbstractModel {
private static final transient Logger LOG = LoggerFactory.getLogger(ChaturbateModel.class); private static final transient Logger LOG = LoggerFactory.getLogger(ChaturbateModel.class);
private Chaturbate chaturbate;
/** /**
* This constructor exists only for deserialization. Please don't call it directly * This constructor exists only for deserialization. Please don't call it directly
@ -36,31 +35,30 @@ public class ChaturbateModel extends AbstractModel {
ChaturbateModel(Chaturbate site) { ChaturbateModel(Chaturbate site) {
this.site = site; this.site = site;
this.chaturbate = site;
} }
@Override @Override
public boolean isOnline(boolean ignoreCache) throws IOException, ExecutionException, InterruptedException { public boolean isOnline(boolean ignoreCache) throws IOException, ExecutionException, InterruptedException {
StreamInfo info; StreamInfo info;
if(ignoreCache) { if(ignoreCache) {
info = chaturbate.loadStreamInfo(getName()); info = getChaturbate().loadStreamInfo(getName());
LOG.trace("Model {} room status: {}", getName(), info.room_status); LOG.trace("Model {} room status: {}", getName(), info.room_status);
} else { } else {
info = chaturbate.getStreamInfo(getName()); info = getChaturbate().getStreamInfo(getName());
} }
return Objects.equals("public", info.room_status); return Objects.equals("public", info.room_status);
} }
@Override @Override
public int[] getStreamResolution(boolean failFast) throws ExecutionException { public int[] getStreamResolution(boolean failFast) throws ExecutionException {
int[] resolution = chaturbate.streamResolutionCache.getIfPresent(getName()); int[] resolution = getChaturbate().streamResolutionCache.getIfPresent(getName());
if(resolution != null) { if(resolution != null) {
return chaturbate.getResolution(getName()); return getChaturbate().getResolution(getName());
} else { } else {
if(failFast) { if(failFast) {
return new int[2]; return new int[2];
} else { } else {
return chaturbate.getResolution(getName()); return getChaturbate().getResolution(getName());
} }
} }
} }
@ -71,8 +69,8 @@ public class ChaturbateModel extends AbstractModel {
*/ */
@Override @Override
public void invalidateCacheEntries() { public void invalidateCacheEntries() {
chaturbate.streamInfoCache.invalidate(getName()); getChaturbate().streamInfoCache.invalidate(getName());
chaturbate.streamResolutionCache.invalidate(getName()); getChaturbate().streamResolutionCache.invalidate(getName());
} }
public String getOnlineState() throws IOException, ExecutionException { public String getOnlineState() throws IOException, ExecutionException {
@ -81,20 +79,20 @@ public class ChaturbateModel extends AbstractModel {
@Override @Override
public String getOnlineState(boolean failFast) throws IOException, ExecutionException { public String getOnlineState(boolean failFast) throws IOException, ExecutionException {
StreamInfo info = chaturbate.streamInfoCache.getIfPresent(getName()); StreamInfo info = getChaturbate().streamInfoCache.getIfPresent(getName());
return info != null ? info.room_status : "n/a"; return info != null ? info.room_status : "n/a";
} }
public StreamInfo getStreamInfo() throws IOException, ExecutionException { public StreamInfo getStreamInfo() throws IOException, ExecutionException {
return chaturbate.getStreamInfo(getName()); return getChaturbate().getStreamInfo(getName());
} }
public MasterPlaylist getMasterPlaylist() throws IOException, ParseException, PlaylistException, ExecutionException { public MasterPlaylist getMasterPlaylist() throws IOException, ParseException, PlaylistException, ExecutionException {
return chaturbate.getMasterPlaylist(getName()); return getChaturbate().getMasterPlaylist(getName());
} }
@Override @Override
public void receiveTip(int tokens) throws IOException { public void receiveTip(int tokens) throws IOException {
chaturbate.sendTip(getName(), tokens); getChaturbate().sendTip(getName(), tokens);
} }
@Override @Override
@ -167,4 +165,8 @@ public class ChaturbateModel extends AbstractModel {
throw new IOException("HTTP status " + resp.code() + " " + resp.message()); throw new IOException("HTTP status " + resp.code() + " " + resp.message());
} }
} }
private Chaturbate getChaturbate() {
return (Chaturbate) site;
}
} }