From b0283cae71f5d2b5a38ce6841d9d32fb75c119b2 Mon Sep 17 00:00:00 2001
From: FongMi <b8892778@gmail.com>
Date: Wed, 31 Jul 2024 19:56:14 +0800
Subject: [PATCH] Add proxy extractor

---
 .../com/fongmi/android/tv/player/Source.java  |  2 ++
 .../android/tv/player/extractor/Proxy.java    | 25 +++++++++++++++++++
 2 files changed, 27 insertions(+)
 create mode 100644 app/src/main/java/com/fongmi/android/tv/player/extractor/Proxy.java

diff --git a/app/src/main/java/com/fongmi/android/tv/player/Source.java b/app/src/main/java/com/fongmi/android/tv/player/Source.java
index eab75b1b9..2cfdbec13 100644
--- a/app/src/main/java/com/fongmi/android/tv/player/Source.java
+++ b/app/src/main/java/com/fongmi/android/tv/player/Source.java
@@ -7,6 +7,7 @@ import com.fongmi.android.tv.bean.Flag;
 import com.fongmi.android.tv.bean.Result;
 import com.fongmi.android.tv.player.extractor.Force;
 import com.fongmi.android.tv.player.extractor.JianPian;
+import com.fongmi.android.tv.player.extractor.Proxy;
 import com.fongmi.android.tv.player.extractor.Push;
 import com.fongmi.android.tv.player.extractor.TVBus;
 import com.fongmi.android.tv.player.extractor.Thunder;
@@ -39,6 +40,7 @@ public class Source {
         extractors = new ArrayList<>();
         extractors.add(new Force());
         extractors.add(new JianPian());
+        extractors.add(new Proxy());
         extractors.add(new Push());
         extractors.add(new Thunder());
         extractors.add(new TVBus());
diff --git a/app/src/main/java/com/fongmi/android/tv/player/extractor/Proxy.java b/app/src/main/java/com/fongmi/android/tv/player/extractor/Proxy.java
new file mode 100644
index 000000000..1a8ac53ee
--- /dev/null
+++ b/app/src/main/java/com/fongmi/android/tv/player/extractor/Proxy.java
@@ -0,0 +1,25 @@
+package com.fongmi.android.tv.player.extractor;
+
+import com.fongmi.android.tv.player.Source;
+import com.fongmi.android.tv.server.Server;
+
+public class Proxy implements Source.Extractor {
+
+    @Override
+    public boolean match(String scheme, String host) {
+        return "proxy".equals(scheme);
+    }
+
+    @Override
+    public String fetch(String url) throws Exception {
+        return url.replace("proxy://", Server.get().getAddress("/proxy?"));
+    }
+
+    @Override
+    public void stop() {
+    }
+
+    @Override
+    public void exit() {
+    }
+}