hg
/
JY-TVBoxOS
mirror of https://github.com/q215613905/TVBoxOS.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

1兼容道长本地js(drpy);js引擎-req方法识别Content-Type(完善);

Browse Source
pull/68/head
于俊 3 years ago
parent 7b512162c7
commit caad279508
3 changed files with 185 additions and 144 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. 7
      app/src/main/java/com/github/tvbox/osc/util/js/JSEngine.java
  2. 289
      app/src/main/java/com/github/tvbox/osc/util/js/SpiderJS.java
  3. 33
      app/src/main/java/com/github/tvbox/osc/util/js/UTF8BOMFighter.java

7
app/src/main/java/com/github/tvbox/osc/util/js/JSEngine.java
Unescape View File

@ -258,9 +258,12 @@ public class JSEngine {
} else if (returnBuffer == 2) {
jsObject.setProperty("content", Base64.encodeToString(response.body().bytes(), Base64.DEFAULT));
} else {
String res=response.body().string();
String res;
if(headers.get("Content-Type")!=null && headers.get("Content-Type").contains("=")){
res=new String(res.getBytes(),headers.get("Content-Type").split("=")[1].trim());
byte[] responseBytes = UTF8BOMFighter.removeUTF8BOM(response.body().bytes());
res=new String(responseBytes,headers.get("Content-Type").split("=")[1].trim());
}else {
res=response.body().string();
}
jsObject.setProperty("content", res);
}

289
app/src/main/java/com/github/tvbox/osc/util/js/SpiderJS.java
Unescape View File

@ -1,142 +1,147 @@
package com.github.tvbox.osc.util.js;
import android.content.Context;
import com.github.catvod.crawler.Spider;
import com.github.tvbox.quickjs.JSArray;
import com.github.tvbox.quickjs.JSModule;
import com.github.tvbox.quickjs.JSObject;
import java.util.HashMap;
import java.util.List;
import java.util.UUID;
public class SpiderJS extends Spider {
private String key;
private String js;
private String ext;
private JSObject jsObject = null;
private JSEngine.JSThread jsThread = null;
public SpiderJS(String key, String js, String ext) {
this.key = key;
this.js = js;
this.ext = ext;
}
void checkLoaderJS() {
if (jsThread == null) {
jsThread = JSEngine.getInstance().getJSThread();
}
if (jsObject == null && jsThread != null) {
try {
jsThread.postVoid((ctx, globalThis) -> {
String moduleKey = "__" + UUID.randomUUID().toString().replace("-", "") + "__";
String jsContent = JSEngine.getInstance().loadModule(js);
try {
if (js.contains(".js?")) {
int spIdx = js.indexOf(".js?");
String[] query = js.substring(spIdx + 4).split("&|=");
js = js.substring(0, spIdx);
for (int i = 0; i < query.length; i += 2) {
String key = query[i];
String val = query[i + 1];
String sub = JSModule.convertModuleName(js, val);
String content = JSEngine.getInstance().loadModule(sub);
jsContent = jsContent.replace("__" + key.toUpperCase() + "__", content);
}
}
} catch (Exception e) {
e.printStackTrace();
}
jsContent = jsContent.replace("export default {", "__JS_SPIDER__ ={");
jsContent = jsContent.replace("__JS_SPIDER__", "globalThis." + moduleKey);
ctx.evaluateModule(jsContent, js);
jsObject = (JSObject) ctx.getProperty(globalThis, moduleKey);
jsObject.getJSFunction("init").call(ext);
return null;
});
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
}
String postFunc(String func, Object... args) {
checkLoaderJS();
if (jsObject != null) {
try {
return jsThread.post((ctx, globalThis) -> (String) jsObject.getJSFunction(func).call(args));
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
return "";
}
@Override
public void init(Context context, String extend) {
super.init(context, extend);
checkLoaderJS();
}
@Override
public String homeContent(boolean filter) {
return postFunc("home", filter);
}
@Override
public String homeVideoContent() {
return postFunc("homeVod");
}
@Override
public String categoryContent(String tid, String pg, boolean filter, HashMap<String, String> extend) {
try {
JSObject obj = jsThread.post((ctx, globalThis) -> {
JSObject o = ctx.createNewJSObject();
if (extend != null) {
for (String s : extend.keySet()) {
o.setProperty(s, extend.get(s));
}
}
return o;
});
return postFunc("category", tid, pg, filter, obj);
} catch (Throwable throwable) {
throwable.printStackTrace();
}
return "";
}
@Override
public String detailContent(List<String> ids) {
return postFunc("detail", ids.get(0));
}
@Override
public String playerContent(String flag, String id, List<String> vipFlags) {
try {
JSArray array = jsThread.post((ctx, globalThis) -> {
JSArray arr = ctx.createNewJSArray();
if (vipFlags != null) {
for (int i = 0; i < vipFlags.size(); i++) {
arr.set(vipFlags.get(i), i);
}
}
return arr;
});
return postFunc("play", flag, id, array);
} catch (Throwable throwable) {
throwable.printStackTrace();
}
return "";
}
@Override
public String searchContent(String key, boolean quick) {
return postFunc("search", key, quick);
}
}
package com.github.tvbox.osc.util.js;
import android.content.Context;
import com.github.catvod.crawler.Spider;
import com.github.tvbox.quickjs.JSArray;
import com.github.tvbox.quickjs.JSModule;
import com.github.tvbox.quickjs.JSObject;
import java.util.HashMap;
import java.util.List;
import java.util.UUID;
public class SpiderJS extends Spider {
private String key;
private String js;
private String ext;
private JSObject jsObject = null;
private JSEngine.JSThread jsThread = null;
public SpiderJS(String key, String js, String ext) {
this.key = key;
this.js = js;
this.ext = ext;
}
void checkLoaderJS() {
if (jsThread == null) {
jsThread = JSEngine.getInstance().getJSThread();
}
if (jsObject == null && jsThread != null) {
try {
jsThread.postVoid((ctx, globalThis) -> {
String moduleKey = "__" + UUID.randomUUID().toString().replace("-", "") + "__";
String jsContent = JSEngine.getInstance().loadModule(js);
try {
if (js.contains(".js?")) {
int spIdx = js.indexOf(".js?");
String[] query = js.substring(spIdx + 4).split("&|=");
js = js.substring(0, spIdx);
for (int i = 0; i < query.length; i += 2) {
String key = query[i];
String val = query[i + 1];
String sub = JSModule.convertModuleName(js, val);
String content = JSEngine.getInstance().loadModule(sub);
jsContent = jsContent.replace("__" + key.toUpperCase() + "__", content);
}
}
} catch (Exception e) {
e.printStackTrace();
}
if(jsContent.contains("export default{")){
jsContent = jsContent.replace("export default{", "globalThis." + moduleKey+" ={");
}else if(jsContent.contains("export default {")){
jsContent = jsContent.replace("export default {", "globalThis." + moduleKey+" ={");
}else {
jsContent = jsContent.replace("__JS_SPIDER__", "globalThis." + moduleKey);
}
ctx.evaluateModule(jsContent, js);
jsObject = (JSObject) ctx.getProperty(globalThis, moduleKey);
jsObject.getJSFunction("init").call(ext);
return null;
});
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
}
String postFunc(String func, Object... args) {
checkLoaderJS();
if (jsObject != null) {
try {
return jsThread.post((ctx, globalThis) -> (String) jsObject.getJSFunction(func).call(args));
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
return "";
}
@Override
public void init(Context context, String extend) {
super.init(context, extend);
checkLoaderJS();
}
@Override
public String homeContent(boolean filter) {
return postFunc("home", filter);
}
@Override
public String homeVideoContent() {
return postFunc("homeVod");
}
@Override
public String categoryContent(String tid, String pg, boolean filter, HashMap<String, String> extend) {
try {
JSObject obj = jsThread.post((ctx, globalThis) -> {
JSObject o = ctx.createNewJSObject();
if (extend != null) {
for (String s : extend.keySet()) {
o.setProperty(s, extend.get(s));
}
}
return o;
});
return postFunc("category", tid, pg, filter, obj);
} catch (Throwable throwable) {
throwable.printStackTrace();
}
return "";
}
@Override
public String detailContent(List<String> ids) {
return postFunc("detail", ids.get(0));
}
@Override
public String playerContent(String flag, String id, List<String> vipFlags) {
try {
JSArray array = jsThread.post((ctx, globalThis) -> {
JSArray arr = ctx.createNewJSArray();
if (vipFlags != null) {
for (int i = 0; i < vipFlags.size(); i++) {
arr.set(vipFlags.get(i), i);
}
}
return arr;
});
return postFunc("play", flag, id, array);
} catch (Throwable throwable) {
throwable.printStackTrace();
}
return "";
}
@Override
public String searchContent(String key, boolean quick) {
return postFunc("search", key, quick);
}
}

33
app/src/main/java/com/github/tvbox/osc/util/js/UTF8BOMFighter.java
Unescape View File

@ -0,0 +1,33 @@
package com.github.tvbox.osc.util.js;
public class UTF8BOMFighter {
private static final byte[] UTF8_BOM_BYTES = new byte[]{(byte) 0xEF, (byte) 0xBB, (byte) 0xBF};
private UTF8BOMFighter() {
}
static public String removeUTF8BOM(String xmlText) {
byte[] bytes = xmlText.getBytes();
boolean containsBOM = bytes.length > 3
&& bytes[0] == UTF8_BOM_BYTES[0]
&& bytes[1] == UTF8_BOM_BYTES[1]
&& bytes[2] == UTF8_BOM_BYTES[2];
if (containsBOM) {
xmlText = new String(bytes, 3, bytes.length - 3);
}
return xmlText;
}
static byte[] removeUTF8BOM(byte[] bytes) {
boolean containsBOM = bytes.length > 3
&& bytes[0] == UTF8_BOM_BYTES[0]
&& bytes[1] == UTF8_BOM_BYTES[1]
&& bytes[2] == UTF8_BOM_BYTES[2];
if (containsBOM) {
byte[] copy = new byte[bytes.length - 3];
System.arraycopy(bytes, 3, copy, 0, bytes.length - 3);
return copy;
}
return bytes;
}
}
Write Preview
Loading…
Cancel
Save