From bdd082d5d95bd1602123eae992338c89902c6bb3 Mon Sep 17 00:00:00 2001
From: FongMi <b8892778@gmail.com>
Date: Mon, 16 Dec 2024 19:47:04 +0800
Subject: [PATCH] Update tvbus

---
 .../main/java/com/fongmi/android/tv/bean/Core.java    |  6 ++++++
 .../com/fongmi/android/tv/player/extractor/TVBus.java |  7 +++----
 tvbus/src/main/java/com/tvbus/engine/TVCore.java      | 11 +++++++++++
 3 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/app/src/main/java/com/fongmi/android/tv/bean/Core.java b/app/src/main/java/com/fongmi/android/tv/bean/Core.java
index c0cc527b2..399ca963f 100644
--- a/app/src/main/java/com/fongmi/android/tv/bean/Core.java
+++ b/app/src/main/java/com/fongmi/android/tv/bean/Core.java
@@ -18,6 +18,8 @@ public class Core {
     private String pass;
     @SerializedName("broker")
     private String broker;
+    @SerializedName("domain")
+    private String domain;
     @SerializedName("resp")
     private String resp;
     @SerializedName("sign")
@@ -43,6 +45,10 @@ public class Core {
         return TextUtils.isEmpty(broker) ? "" : broker;
     }
 
+    public String getDomain() {
+        return TextUtils.isEmpty(domain) ? "" : domain;
+    }
+
     public String getResp() {
         return TextUtils.isEmpty(resp) ? "" : resp;
     }
diff --git a/app/src/main/java/com/fongmi/android/tv/player/extractor/TVBus.java b/app/src/main/java/com/fongmi/android/tv/player/extractor/TVBus.java
index f44824df7..81f12f84a 100644
--- a/app/src/main/java/com/fongmi/android/tv/player/extractor/TVBus.java
+++ b/app/src/main/java/com/fongmi/android/tv/player/extractor/TVBus.java
@@ -29,10 +29,9 @@ public class TVBus implements Source.Extractor, Listener {
 
     private void init(Core core) {
         App.get().setHook(core.getHook());
-        tvcore = new TVCore(getPath(core.getSo()));
-        tvcore.auth(core.getAuth()).broker(core.getBroker());
-        tvcore.name(core.getName()).pass(core.getPass());
-        tvcore.serv(0).play(8902).mode(1).listener(this);
+        tvcore = new TVCore(getPath(core.getSo())).listener(this);
+        tvcore.auth(core.getAuth()).name(core.getName()).pass(core.getPass());
+        tvcore.domain(core.getDomain()).broker(core.getBroker()).serv(0).play(8902).mode(1);
         tvcore.init();
     }
 
diff --git a/tvbus/src/main/java/com/tvbus/engine/TVCore.java b/tvbus/src/main/java/com/tvbus/engine/TVCore.java
index f2d5feb33..8a8ce78c8 100644
--- a/tvbus/src/main/java/com/tvbus/engine/TVCore.java
+++ b/tvbus/src/main/java/com/tvbus/engine/TVCore.java
@@ -61,6 +61,15 @@ public class TVCore {
         }
     }
 
+    public TVCore domain(String str) {
+        try {
+            if (str.length() > 0) setDomainSuffix(handle, str);
+            return this;
+        } catch (Throwable ignored) {
+            return this;
+        }
+    }
+
     public TVCore broker(String str) {
         try {
             if (str.length() > 0) setMKBroker(handle, str);
@@ -141,6 +150,8 @@ public class TVCore {
 
     private native void setAuthUrl(long handle, String str);
 
+    private native void setDomainSuffix(long handle, String str);
+
     private native void setMKBroker(long handle, String str);
 
     private native void setPassword(long handle, String str);