pull/137/head
FongMi 2 years ago
parent 079fe386fa
commit a6cc97f85f
  1. 6
      app/src/main/java/com/fongmi/android/tv/api/ApiConfig.java
  2. 2
      app/src/main/java/com/fongmi/android/tv/server/Server.java
  3. 22
      drpy/src/main/java/com/hiker/drpy/Proxy.java
  4. 7
      drpy/src/main/java/com/hiker/drpy/Spider.java
  5. 3
      drpy/src/main/java/com/hiker/drpy/method/Function.java

@ -22,8 +22,6 @@ import com.google.gson.JsonParser;
import org.json.JSONObject;
import java.io.ByteArrayInputStream;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
@ -249,9 +247,7 @@ public class ApiConfig {
}
public Object[] proxyLocal(Map<?, ?> params) {
if (params.containsKey("do") && params.get("do").equals("port")) {
return new Object[]{200, "text/plain; charset=utf-8", new ByteArrayInputStream("ok".getBytes(StandardCharsets.UTF_8))};
} else if (params.containsKey("do") && params.get("do").equals("js")) {
if (params.containsKey("do") && params.get("do").equals("js")) {
return jsLoader.proxyInvoke(params);
} else if (params.containsKey("do") && params.get("do").equals("py")) {
return pyLoader.proxyInvoke(params);

@ -5,6 +5,7 @@ import android.net.wifi.WifiManager;
import android.text.format.Formatter;
import com.fongmi.android.tv.App;
import com.hiker.drpy.Proxy;
import java.net.Inet4Address;
import java.net.InetAddress;
@ -46,6 +47,7 @@ public class Server {
do {
try {
nano = new Nano(port);
Proxy.set(port);
nano.start();
break;
} catch (Exception e) {

@ -1,32 +1,14 @@
package com.hiker.drpy;
import com.github.catvod.net.OkHttp;
public class Proxy {
private static int port;
static void tryPort() {
if (port > 0) return;
int port = 9978;
while (port < 9999) {
boolean ok = string(port).equals("ok");
if (ok) Proxy.port = port;
if (ok) break;
port++;
}
}
private static String string(int port) {
try {
return OkHttp.newCall("http://127.0.0.1:" + port + "/proxy?do=port").execute().body().string();
} catch (Exception e) {
return "";
}
public static void set(int port) {
Proxy.port = port;
}
public static String getUrl() {
tryPort();
return "http://127.0.0.1:" + port + "/proxy";
}
}

@ -110,11 +110,8 @@ public class Spider extends com.github.catvod.crawler.Spider {
@Override
public Object[] proxyLocal(Map<?, ?> params) throws Exception {
if ("catvod".equals(params.get("from"))) {
return proxy2(params);
} else {
return submit(() -> proxy1(params)).get();
}
if ("catvod".equals(params.get("from"))) return proxy2(params);
else return submit(() -> proxy1(params)).get();
}
@Override

@ -40,8 +40,7 @@ public class Function implements Callable<Object[]> {
private final JSCallFunction jsCallFunction = new JSCallFunction() {
@Override
public Object call(Object... args) {
result = args[0];
return null;
return result = args[0];
}
};
}

Loading…
Cancel
Save