hg
/
FONGMITV
mirror of https://github.com/FongMi/TV.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Clean code

Browse Source
pull/137/head
FongMi 3 years ago
parent 0a049ce8b6
commit 2675952078
5 changed files with 111 additions and 87 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 1
      quickjs/src/main/assets/js/lib/cat.js
  2. 13
      quickjs/src/main/assets/js/lib/http.js
  3. 15
      quickjs/src/main/java/com/fongmi/quickjs/bean/Req.java
  4. 97
      quickjs/src/main/java/com/fongmi/quickjs/method/Global.java
  5. 72
      quickjs/src/main/java/com/fongmi/quickjs/utils/JSUtil.java

1
quickjs/src/main/assets/js/lib/cat.js
View File

File diff suppressed because one or more lines are too long

13
quickjs/src/main/assets/js/lib/http.js
Unescape View File

@ -0,0 +1,13 @@
function http(url, options = {}) {
if (options?.async === false) return _http(url, options)
return new Promise(resolve => _http(url, Object.assign({
complete: res => resolve(res)
}, options))).catch(err => {
console.error(err.name, err.message, err.stack)
return {
ok: false,
status: 500,
url
}
})
}

15
quickjs/src/main/java/com/fongmi/quickjs/bean/Req.java
Unescape View File

@ -7,7 +7,10 @@ import com.google.gson.Gson;
import com.google.gson.JsonElement;
import com.google.gson.annotations.SerializedName;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Objects;
public class Req {
@ -67,4 +70,16 @@ public class Req {
public Map<String, String> getHeader() {
return Json.toMap(getHeaders());
}
public String getCharset() {
Map<String, String> header = getHeader();
List<String> keys = Arrays.asList("Content-Type", "content-type");
for (String key : keys) if (header.containsKey(key)) return getCharset(Objects.requireNonNull(header.get(key)));
return "UTF-8";
}
private String getCharset(String value) {
for (String text : value.split(";")) if (text.contains("charset=")) return text.split("=")[1];
return "UTF-8";
}
}

97
quickjs/src/main/java/com/fongmi/quickjs/method/Global.java
Unescape View File

@ -1,6 +1,5 @@
package com.fongmi.quickjs.method;
import android.text.TextUtils;
import android.util.Base64;
import androidx.annotation.Keep;
@ -9,38 +8,24 @@ import com.fongmi.quickjs.bean.Req;
import com.fongmi.quickjs.utils.JSUtil;
import com.fongmi.quickjs.utils.Parser;
import com.fongmi.quickjs.utils.Proxy;
import com.github.catvod.net.OkHttp;
import com.github.catvod.utils.Json;
import com.github.catvod.utils.Util;
import com.google.gson.Gson;
import com.whl.quickjs.wrapper.JSFunction;
import com.whl.quickjs.wrapper.JSMethod;
import com.whl.quickjs.wrapper.JSObject;
import com.whl.quickjs.wrapper.QuickJSContext;
import java.io.UnsupportedEncodingException;
import java.lang.reflect.Method;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;
import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import okhttp3.Call;
import okhttp3.FormBody;
import okhttp3.Headers;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
public class Global {
@ -85,7 +70,7 @@ public class Global {
@Keep
@JSMethod
public String js2Proxy(Boolean dynamic, Integer siteType, String siteKey, String url, JSObject headers) {
return getProxy(true) + "&from=catvod" + "&header=" + URLEncoder.encode(ctx.stringify(headers)) + "&url=" + URLEncoder.encode(url);
return getProxy(true) + "&from=catvod" + "&header=" + URLEncoder.encode(headers.stringify()) + "&url=" + URLEncoder.encode(url);
}
@Keep
@ -116,25 +101,21 @@ public class Global {
return null;
}
@Keep
@JSMethod
public void _http(String url, JSObject options) {
}
@Keep
@JSMethod
public JSObject req(String url, JSObject object) {
try {
JSObject jsObject = ctx.createNewJSObject();
JSObject jsHeader = ctx.createNewJSObject();
Req req = Req.objectFrom(ctx.stringify(object));
Headers headers = Headers.of(req.getHeader());
Response response = call(url, req, headers).execute();
setHeader(response, jsHeader);
jsObject.setProperty("headers", jsHeader);
setContent(jsObject, headers, req.getBuffer(), response.body().bytes());
return jsObject;
Response response = JSUtil.call(url, req).execute();
return JSUtil.toResponse(ctx, response, req);
} catch (Throwable e) {
JSObject jsObject = ctx.createNewJSObject();
JSObject jsHeader = ctx.createNewJSObject();
jsObject.setProperty("headers", jsHeader);
jsObject.setProperty("content", "");
return jsObject;
return JSUtil.toFailure(ctx);
}
}
@ -198,62 +179,4 @@ public class Global {
}
}, delay);
}
private Call call(String url, Req req, Headers headers) {
OkHttpClient client = req.getRedirect() == 1 ? OkHttp.client() : OkHttp.noRedirect();
client = client.newBuilder().connectTimeout(req.getTimeout(), TimeUnit.MILLISECONDS).readTimeout(req.getTimeout(), TimeUnit.MILLISECONDS).writeTimeout(req.getTimeout(), TimeUnit.MILLISECONDS).build();
return client.newCall(getRequest(url, req, headers));
}
private Request getRequest(String url, Req req, Headers headers) {
if (req.getMethod().equalsIgnoreCase("post")) {
return new Request.Builder().url(url).headers(headers).post(getPostBody(req, headers.get("Content-Type"))).build();
} else if (req.getMethod().equalsIgnoreCase("header")) {
return new Request.Builder().url(url).headers(headers).head().build();
} else {
return new Request.Builder().url(url).headers(headers).get().build();
}
}
private RequestBody getPostBody(Req req, String contentType) {
if (req.getData() != null && req.getPostType().equals("form")) return getFormBody(req);
if (req.getData() != null) return RequestBody.create(gson.toJson(req.getData()), MediaType.get("application/json"));
if (req.getBody() != null && contentType != null) return RequestBody.create(req.getBody(), MediaType.get(contentType));
return RequestBody.create("", null);
}
private RequestBody getFormBody(Req req) {
FormBody.Builder formBody = new FormBody.Builder();
Map<String, String> params = Json.toMap(req.getData());
for (String key : params.keySet()) formBody.add(key, params.get(key));
return formBody.build();
}
private void setHeader(Response response, JSObject object) {
for (Map.Entry<String, List<String>> entry : response.headers().toMultimap().entrySet()) {
if (entry.getValue().size() == 1) object.setProperty(entry.getKey(), entry.getValue().get(0));
if (entry.getValue().size() >= 2) object.setProperty(entry.getKey(), JSUtil.toArray(ctx, entry.getValue()));
}
}
private String getCharset(Headers headers) {
String contentType = headers.get("Content-Type");
if (TextUtils.isEmpty(contentType)) return "UTF-8";
for (String text : contentType.split(";")) if (text.contains("charset=")) return text.split("=")[1];
return "UTF-8";
}
private void setContent(JSObject jsObject, Headers headers, int buffer, byte[] bytes) throws UnsupportedEncodingException {
switch (buffer) {
case 1:
jsObject.setProperty("content", JSUtil.toArray(ctx, bytes));
break;
case 2:
jsObject.setProperty("content", Util.base64(bytes));
break;
default:
jsObject.setProperty("content", new String(bytes, getCharset(headers)));
break;
}
}
}

72
quickjs/src/main/java/com/fongmi/quickjs/utils/JSUtil.java
Unescape View File

@ -1,11 +1,27 @@
package com.fongmi.quickjs.utils;
import com.fongmi.quickjs.bean.Req;
import com.github.catvod.net.OkHttp;
import com.github.catvod.utils.Json;
import com.github.catvod.utils.Util;
import com.google.gson.Gson;
import com.whl.quickjs.wrapper.JSArray;
import com.whl.quickjs.wrapper.JSObject;
import com.whl.quickjs.wrapper.QuickJSContext;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import okhttp3.Call;
import okhttp3.FormBody;
import okhttp3.Headers;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
public class JSUtil {
@ -29,4 +45,60 @@ public class JSUtil {
for (String s : map.keySet()) obj.setProperty(s, map.get(s));
return obj;
}
public static Call call(String url, Req req) {
OkHttpClient client = req.getRedirect() == 1 ? OkHttp.client() : OkHttp.noRedirect();
client = client.newBuilder().connectTimeout(req.getTimeout(), TimeUnit.MILLISECONDS).readTimeout(req.getTimeout(), TimeUnit.MILLISECONDS).writeTimeout(req.getTimeout(), TimeUnit.MILLISECONDS).build();
return client.newCall(getRequest(url, req, Headers.of(req.getHeader())));
}
public static JSObject toResponse(QuickJSContext ctx, Response response, Req req) throws IOException {
JSObject jsObject = ctx.createNewJSObject();
JSObject jsHeader = ctx.createNewJSObject();
setHeader(ctx, response, jsHeader);
jsObject.setProperty("headers", jsHeader);
if (req.getBuffer() == 0) jsObject.setProperty("content", new String(response.body().bytes(), req.getCharset()));
if (req.getBuffer() == 1) jsObject.setProperty("content", JSUtil.toArray(ctx, response.body().bytes()));
if (req.getBuffer() == 2) jsObject.setProperty("content", Util.base64(response.body().bytes()));
return jsObject;
}
public static JSObject toFailure(QuickJSContext ctx) {
JSObject jsObject = ctx.createNewJSObject();
JSObject jsHeader = ctx.createNewJSObject();
jsObject.setProperty("headers", jsHeader);
jsObject.setProperty("content", "");
return jsObject;
}
private static Request getRequest(String url, Req req, Headers headers) {
if (req.getMethod().equalsIgnoreCase("post")) {
return new Request.Builder().url(url).headers(headers).post(getPostBody(req, headers.get("Content-Type"))).build();
} else if (req.getMethod().equalsIgnoreCase("header")) {
return new Request.Builder().url(url).headers(headers).head().build();
} else {
return new Request.Builder().url(url).headers(headers).get().build();
}
}
private static RequestBody getPostBody(Req req, String contentType) {
if (req.getData() != null && req.getPostType().equals("form")) return getFormBody(req);
if (req.getData() != null) return RequestBody.create(new Gson().toJson(req.getData()), MediaType.get("application/json"));
if (req.getBody() != null && contentType != null) return RequestBody.create(req.getBody(), MediaType.get(contentType));
return RequestBody.create("", null);
}
private static RequestBody getFormBody(Req req) {
FormBody.Builder formBody = new FormBody.Builder();
Map<String, String> params = Json.toMap(req.getData());
for (String key : params.keySet()) formBody.add(key, params.get(key));
return formBody.build();
}
private static void setHeader(QuickJSContext ctx, Response response, JSObject object) {
for (Map.Entry<String, List<String>> entry : response.headers().toMultimap().entrySet()) {
if (entry.getValue().size() == 1) object.setProperty(entry.getKey(), entry.getValue().get(0));
if (entry.getValue().size() >= 2) object.setProperty(entry.getKey(), JSUtil.toArray(ctx, entry.getValue()));
}
}
}

Write Preview
Loading…
Cancel
Save