244 lines
9.6 KiB
Java
244 lines
9.6 KiB
Java
package ctbrec.sites.bonga;
|
|
|
|
import java.io.IOException;
|
|
import java.net.HttpCookie;
|
|
import java.util.ArrayList;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Map.Entry;
|
|
import java.util.concurrent.BlockingQueue;
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
|
|
|
import org.json.JSONArray;
|
|
import org.json.JSONObject;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import ctbrec.Config;
|
|
import ctbrec.io.HttpClient;
|
|
import javafx.application.Platform;
|
|
import okhttp3.Cookie;
|
|
import okhttp3.FormBody;
|
|
import okhttp3.HttpUrl;
|
|
import okhttp3.Request;
|
|
import okhttp3.RequestBody;
|
|
import okhttp3.Response;
|
|
|
|
public class BongaCamsHttpClient extends HttpClient {
|
|
|
|
private static final transient Logger LOG = LoggerFactory.getLogger(BongaCamsHttpClient.class);
|
|
private int userId = 0;
|
|
|
|
public BongaCamsHttpClient() {
|
|
super("bongacams");
|
|
addSortByPopularCookie();
|
|
}
|
|
|
|
/**
|
|
* Adds a cookie, which defines the sort order for returned model lists
|
|
*/
|
|
private void addSortByPopularCookie() {
|
|
Cookie sortByCookie = new Cookie.Builder()
|
|
.domain("bongacams.com")
|
|
.name("bcmlsf9")
|
|
.value("%7B%22limit%22%3A20%2C%22c_limit%22%3A10%2C%22th_type%22%3A%22live%22%2C%22sorting%22%3A%22popular%22%2C%22display%22%3A%22auto%22%7D")
|
|
.build();
|
|
|
|
Map<String, List<Cookie>> cookies = cookieJar.getCookies();
|
|
for (Entry<String, List<Cookie>> entry : cookies.entrySet()) {
|
|
List<Cookie> cookieList = entry.getValue();
|
|
for (Iterator<Cookie> iterator = cookieList.iterator(); iterator.hasNext();) {
|
|
Cookie cookie = iterator.next();
|
|
if(cookie.name().equals("bcmlsf9")) {
|
|
iterator.remove();
|
|
}
|
|
}
|
|
entry.getValue().add(sortByCookie);
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public synchronized boolean login() throws IOException {
|
|
if(loggedIn) {
|
|
return true;
|
|
}
|
|
|
|
boolean cookiesWorked = checkLoginSuccess();
|
|
if(cookiesWorked) {
|
|
loggedIn = true;
|
|
LOG.debug("Logged in with cookies");
|
|
return true;
|
|
}
|
|
|
|
BlockingQueue<Boolean> queue = new LinkedBlockingQueue<>();
|
|
|
|
Runnable showDialog = () -> {
|
|
// login with javafx WebView
|
|
BongaCamsLoginDialog loginDialog = new BongaCamsLoginDialog();
|
|
|
|
// transfer cookies from WebView to OkHttp cookie jar
|
|
transferCookies(loginDialog);
|
|
|
|
try {
|
|
queue.put(true);
|
|
} catch (InterruptedException e) {
|
|
LOG.error("Error while signaling termination", e);
|
|
}
|
|
};
|
|
|
|
if(Platform.isFxApplicationThread()) {
|
|
showDialog.run();
|
|
} else {
|
|
Platform.runLater(showDialog);
|
|
try {
|
|
queue.take();
|
|
} catch (InterruptedException e) {
|
|
LOG.error("Error while waiting for login dialog to close", e);
|
|
throw new IOException(e);
|
|
}
|
|
}
|
|
|
|
loggedIn = checkLoginSuccess();
|
|
if(loggedIn) {
|
|
LOG.info("Logged in. User ID is {}", userId);
|
|
} else {
|
|
LOG.info("Login failed");
|
|
}
|
|
return loggedIn;
|
|
}
|
|
|
|
/**
|
|
* Check, if the login worked by requesting roomdata and looking
|
|
* @throws IOException
|
|
*/
|
|
private boolean checkLoginSuccess() throws IOException {
|
|
String modelName = getAnyModelName();
|
|
// we request the roomData of a random model, because it contains
|
|
// user data, if the user is logged in, which we can use to verify, that the login worked
|
|
String url = BongaCams.BASE_URL + "/tools/amf.php";
|
|
RequestBody body = new FormBody.Builder()
|
|
.add("method", "getRoomData")
|
|
.add("args[]", modelName)
|
|
.add("args[]", "false")
|
|
//.add("method", "ping") // TODO alternative request, but
|
|
//.add("args[]", <userId>) // where to get the userId
|
|
.build();
|
|
Request request = new Request.Builder()
|
|
.url(url)
|
|
.addHeader("User-Agent", Config.getInstance().getSettings().httpUserAgent)
|
|
.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 = execute(request)) {
|
|
if(response.isSuccessful()) {
|
|
JSONObject json = new JSONObject(response.body().string());
|
|
if(json.optString("status").equals("success")) {
|
|
JSONObject userData = json.getJSONObject("userData");
|
|
userId = userData.optInt("userId");
|
|
return userId > 0;
|
|
} else {
|
|
throw new IOException("Request was not successful: " + json.toString(2));
|
|
}
|
|
} else {
|
|
throw new IOException(response.code() + " " + response.message());
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Fetches the list of online models and returns the name of the first model
|
|
*/
|
|
private String getAnyModelName() throws IOException {
|
|
Request request = new Request.Builder()
|
|
.url(BongaCams.BASE_URL + "/tools/listing_v3.php?livetab=female&online_only=true&is_mobile=true&offset=0")
|
|
.addHeader("User-Agent", Config.getInstance().getSettings().httpUserAgent)
|
|
.addHeader("Accept", "application/json, text/javascript, */*")
|
|
.addHeader("Accept-Language", "en")
|
|
.addHeader("Referer", BongaCams.BASE_URL)
|
|
.addHeader("X-Requested-With", "XMLHttpRequest")
|
|
.build();
|
|
try(Response response = execute(request)) {
|
|
if (response.isSuccessful()) {
|
|
String content = response.body().string();
|
|
JSONObject json = new JSONObject(content);
|
|
if(json.optString("status").equals("success")) {
|
|
JSONArray _models = json.getJSONArray("models");
|
|
JSONObject m = _models.getJSONObject(0);
|
|
String name = m.getString("username");
|
|
return name;
|
|
} else {
|
|
throw new IOException("Request was not successful: " + content);
|
|
}
|
|
} else {
|
|
throw new IOException(response.code() + ' ' + response.message());
|
|
}
|
|
}
|
|
}
|
|
|
|
private void transferCookies(BongaCamsLoginDialog loginDialog) {
|
|
HttpUrl redirectedUrl = HttpUrl.parse(loginDialog.getUrl());
|
|
List<Cookie> cookies = new ArrayList<>();
|
|
for (HttpCookie webViewCookie : loginDialog.getCookies()) {
|
|
Cookie cookie = Cookie.parse(redirectedUrl, webViewCookie.toString());
|
|
cookies.add(cookie);
|
|
}
|
|
cookieJar.saveFromResponse(redirectedUrl, cookies);
|
|
|
|
HttpUrl origUrl = HttpUrl.parse(BongaCamsLoginDialog.URL);
|
|
cookies = new ArrayList<>();
|
|
for (HttpCookie webViewCookie : loginDialog.getCookies()) {
|
|
Cookie cookie = Cookie.parse(origUrl, webViewCookie.toString());
|
|
cookies.add(cookie);
|
|
}
|
|
cookieJar.saveFromResponse(origUrl, cookies);
|
|
}
|
|
|
|
// @Override
|
|
// public boolean login() throws IOException {
|
|
// String url = BongaCams.BASE_URL + "/login";
|
|
// String dateTime = new SimpleDateFormat("d.MM.yyyy', 'HH:mm:ss").format(new Date());
|
|
// RequestBody body = new FormBody.Builder()
|
|
// .add("security_log_additional_info","{\"language\":\"en\",\"cookieEnabled\":true,\"javaEnabled\":false,\"flashVersion\":\"31.0.0\",\"dateTime\":\""+dateTime+"\",\"ips\":[\"192.168.0.1\"]}")
|
|
// .add("log_in[username]", Config.getInstance().getSettings().bongaUsername)
|
|
// .add("log_in[password]", Config.getInstance().getSettings().bongaPassword)
|
|
// .add("log_in[remember]", "1")
|
|
// .add("log_in[bfpt]", "")
|
|
// .add("header_form", "1")
|
|
// .build();
|
|
// Request request = new Request.Builder()
|
|
// .url(url)
|
|
// .post(body)
|
|
// .addHeader("User-Agent", Config.getInstance().getSettings().httpUserAgent)
|
|
// .addHeader("Accept","application/json")
|
|
// .addHeader("Accept-Language", "en")
|
|
// .addHeader("Referer", BongaCams.BASE_URL)
|
|
// .addHeader("X-Requested-With", "XMLHttpRequest")
|
|
// .build();
|
|
// try(Response response = execute(request)) {
|
|
// if(response.isSuccessful()) {
|
|
// JSONObject json = new JSONObject(response.body().string());
|
|
// if(json.optString("status").equals("success")) {
|
|
// return true;
|
|
// } else {
|
|
// LOG.debug("Login response: {}", json.toString(2));
|
|
// Platform.runLater(() -> new BongaCamsLoginDialog());
|
|
// throw new IOException("Login not successful");
|
|
// }
|
|
// } else {
|
|
// throw new IOException(response.code() + " " + response.message());
|
|
// }
|
|
// }
|
|
// }
|
|
|
|
public int getUserId() throws IOException {
|
|
if(userId == 0) {
|
|
login();
|
|
}
|
|
return userId;
|
|
}
|
|
}
|