dongge
/
AndroidCatVodSpider
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix bug

This commit is contained in:
FongMi 2023-12-13 23:12:24 +08:00
parent e22068f2bf
commit 567c69bb6f
4 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/src/main/java/com/github/catvod/api/AliYun.java
View File

@ -93,7 +93,6 @@ public class AliYun {
m3u8MediaMap = new HashMap<>(); m3u8MediaMap = new HashMap<>();
shareDownloadMap = new HashMap<>(); shareDownloadMap = new HashMap<>();
cache = Cache.objectFrom(Path.read(getCache())); cache = Cache.objectFrom(Path.read(getCache()));
OkHttp.string("http://127.0.0.1:" + Proxy.getPort() + "/go");
} }
public void setRefreshToken(String token) { public void setRefreshToken(String token) {

9
app/src/main/java/com/github/catvod/utils/ProxyVideo.java
View File

@ -3,7 +3,10 @@ package com.github.catvod.utils;
import static fi.iki.elonen.NanoHTTPD.Response.Status; import static fi.iki.elonen.NanoHTTPD.Response.Status;
import static fi.iki.elonen.NanoHTTPD.newFixedLengthResponse; import static fi.iki.elonen.NanoHTTPD.newFixedLengthResponse;
import android.os.SystemClock;
import com.github.catvod.net.OkHttp; import com.github.catvod.net.OkHttp;
import com.github.catvod.spider.Proxy;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.util.Locale; import java.util.Locale;
@ -14,8 +17,12 @@ import okhttp3.Response;
public class ProxyVideo { public class ProxyVideo {
private static final String GO_SERVER = "http://127.0.0.1:7777/";
public static NanoHTTPD.Response multi(String url, Map<String, String> headers, int thread) throws Exception { public static NanoHTTPD.Response multi(String url, Map<String, String> headers, int thread) throws Exception {
return proxy(String.format(Locale.getDefault(), "http://127.0.0.1:7777/?url=%s&thread=%d", URLEncoder.encode(url), thread), headers); if (OkHttp.string(GO_SERVER).isEmpty()) OkHttp.string("http://127.0.0.1:" + Proxy.getPort() + "/go");
while (OkHttp.string(GO_SERVER).isEmpty()) SystemClock.sleep(250);
return proxy(String.format(Locale.getDefault(), "%s?url=%s&thread=%d", GO_SERVER, URLEncoder.encode(url), thread), headers);
} }
public static NanoHTTPD.Response proxy(String url, Map<String, String> headers) throws Exception { public static NanoHTTPD.Response proxy(String url, Map<String, String> headers) throws Exception {

BIN
jar/custom_spider.jar
View File

Binary file not shown.

2
jar/custom_spider.jar.md5
View File

@ -1 +1 @@
5b3460279d173de4e0288eb56fac596f 22534319dabee7086d31f194a1e19e6a