|
|
|
|
@ -9,14 +9,11 @@ import com.fongmi.android.tv.server.process.Action; |
|
|
|
|
import com.fongmi.android.tv.server.process.Cache; |
|
|
|
|
import com.fongmi.android.tv.server.process.Local; |
|
|
|
|
import com.fongmi.android.tv.server.process.Process; |
|
|
|
|
import com.fongmi.android.tv.utils.M3U8; |
|
|
|
|
import com.github.catvod.utils.Asset; |
|
|
|
|
import com.google.common.net.HttpHeaders; |
|
|
|
|
|
|
|
|
|
import java.io.ByteArrayInputStream; |
|
|
|
|
import java.io.IOException; |
|
|
|
|
import java.io.InputStream; |
|
|
|
|
import java.nio.charset.StandardCharsets; |
|
|
|
|
import java.util.ArrayList; |
|
|
|
|
import java.util.HashMap; |
|
|
|
|
import java.util.List; |
|
|
|
|
@ -72,7 +69,6 @@ public class Nano extends NanoHTTPD { |
|
|
|
|
if (session.getMethod() == Method.POST) parse(session, files); |
|
|
|
|
if (url.contains("?")) url = url.substring(0, url.indexOf('?')); |
|
|
|
|
if (url.startsWith("/go")) return go(); |
|
|
|
|
if (url.startsWith("/m3u8")) return m3u8(session); |
|
|
|
|
if (url.startsWith("/proxy")) return proxy(session); |
|
|
|
|
if (url.startsWith("/tvbus")) return success(LiveConfig.getResp()); |
|
|
|
|
if (url.startsWith("/device")) return success(Device.get().toString()); |
|
|
|
|
@ -99,13 +95,6 @@ public class Nano extends NanoHTTPD { |
|
|
|
|
return success(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private Response m3u8(IHTTPSession session) { |
|
|
|
|
String url = session.getParms().get("url"); |
|
|
|
|
String result = M3U8.get(url, session.getHeaders()); |
|
|
|
|
if (result.isEmpty()) return redirect(url, session.getHeaders()); |
|
|
|
|
return newChunkedResponse(Response.Status.OK, MIME_PLAINTEXT, new ByteArrayInputStream(result.getBytes(StandardCharsets.UTF_8))); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private Response proxy(IHTTPSession session) { |
|
|
|
|
try { |
|
|
|
|
Map<String, String> params = session.getParms(); |
|
|
|
|
|