Add LoadX, Fix VEO, Add PiP mode

Author: Commandcracker

README.md

@@ -126,8 +126,8 @@ List of supported video hoster.
 - [x] Vidmoly
 - [x] Streamtape (Removed from AniWorld & SerienStream)
 - [x] Luluvdo
+- [x] LoadX
 - [ ] Filemoon
-- [ ] LoadX
 
 ## Player
 

pyproject.toml

@@ -7,18 +7,18 @@ maintainers = [{name="Commandcracker"}]
 license = {file = "LICENSE.txt"}
 readme = "README.md"
 dependencies = [
-  "textual>=3.0.1",
-  "beautifulsoup4>=4.13.3",
+  "textual>=3.1.1",
+  "beautifulsoup4>=4.13.4",
   "httpx[http2]>=0.28.1",
   "pypresence>=4.3.0",
-  "packaging>=24.2",
+  "packaging>=25.0",
   "platformdirs>=4.3.7",
   "toml>=0.10.2",
   "fuzzywuzzy>=0.18.0",
   "async_lru>=2.0.5",
   "rich-argparse>=1.7.0"
   #"yt-dlp>=2025.3.31",
-  #"mpv>=1.0.7",
+  #"mpv>=1.0.8",
 ]
 keywords = [
   "gucken",

src/gucken/__init__.py

@@ -1,4 +1,4 @@
 import warnings
 warnings.filterwarnings('ignore', message='Using slow pure-python SequenceMatcher. Install python-Levenshtein to remove this warning')
 
-__version__ = "0.3.2"
+__version__ = "0.3.3"

src/gucken/gucken.py

@@ -304,6 +304,11 @@ def compose(self) -> ComposeResult:
                             id="autoplay",
                             value=settings["autoplay"]["enabled"],
                         )
+                        yield RadioButton(
+                            "PiP Mode (MPV & VLC only)",
+                            id="pip",
+                            value=settings["pip"],
+                        )
                         yield Select.from_values(
                             available_players_keys,
                             id="player",
@@ -312,7 +317,7 @@ def compose(self) -> ComposeResult:
                                 Select.BLANK if player == "AutomaticPlayer" else player
                             ),
                         )
-                    with Collapsible(title="ani-skip (only for MPV and VLC)", collapsed=False):
+                    with Collapsible(title="ani-skip (MPV & VLC only)", collapsed=False):
                         yield RadioButton(
                             "Skip opening",
                             id="ani_skip_opening",
@@ -381,6 +386,10 @@ async def radio_button_changed(self, event: RadioButton.Changed):
             settings["autoplay"]["enabled"] = event.value
             return
 
+        if id == "pip":
+            settings["pip"] = event.value
+            return
+
         settings[id] = event.value
 
         if id == "discord_presence":
@@ -707,6 +716,24 @@ async def update():
 
             self.app.call_later(update)
 
+        # Picture-in-Picture mode
+        if gucken_settings_manager.settings["settings"]["pip"]:
+            if isinstance(_player, MPVPlayer):
+                args.append("--ontop")
+                args.append("--no-border")
+                args.append("--snap-window")
+
+            if isinstance(_player, VLCPlayer):
+                args.append("--video-on-top")
+                args.append("--qt-minimal-view")
+                args.append("--no-video-deco")
+
+        if direct_link.force_hls:
+            # TODO: make work for vlc and others
+            if isinstance(_player, MPVPlayer):
+                args.append("--demuxer=lavf")
+                args.append("--demuxer-lavf-format=hls")
+
         if self._debug:
             logs_path = user_log_path("gucken", ensure_exists=True)
             if isinstance(_player, MPVPlayer):

src/gucken/hoster/common.py

@@ -8,6 +8,7 @@
 class DirectLink:
     url: str
     headers: dict[str, str] = None
+    force_hls: bool = False
 
     async def check_is_working(self) -> bool:
         try:

src/gucken/hoster/loadx.py

@@ -1,15 +1,17 @@
-from re import compile as re_compile
-
 from ..networking import AsyncClient
-
 from .common import DirectLink, Hoster
+from ..utils import json_loads
 
-LOADX_PATTERN = re_compile("")
 
-# TODO: WIP !!!
 class LoadXHoster(Hoster):
     async def get_direct_link(self) -> DirectLink:
-        # https://github.com/Gujal00/ResolveURL/blob/master/script.module.resolveurl/lib/resolveurl/plugins/loadx.py
-        # https://github.com/bytedream/stream-bypass/blob/c4085f9ac83d9313ebc8e9629067c91dc7fbe064/src/lib/match.ts#L122
-
-        return DirectLink("WIP")
+        async with AsyncClient(verify=False) as client:
+            response = await client.head(self.url)
+            id_hash = response.url.path.split("/")[2]
+            host = response.url.host
+            response = await client.post(
+                f"https://{host}/player/index.php?data={id_hash}&do=getVideo",
+               headers={"X-Requested-With": "XMLHttpRequest"}
+            )
+            data = json_loads(response.text)
+            return DirectLink(url=data.get("videoSource"), force_hls=True)

src/gucken/hoster/veo.py

@@ -1,38 +1,81 @@
 from base64 import b64decode
-from re import compile as re_compile
-from ..utils import json_loads
+from re import compile as re_compile, escape as re_escape
+
+from bs4 import BeautifulSoup
 
+from ..utils import json_loads
 from ..networking import AsyncClient
 from .common import DirectLink, Hoster
 
 REDIRECT_PATTERN = re_compile("https?://[^'\"<>]+")
 
-EXTRACT_VEO_HLS_PATTERN = re_compile(r"'hls': '(?P<hls>.*)'")
-HIDDEN_JSON_PATTERN = re_compile(r"var a168c='(?P<hidden_json>[^']+)'")
+# Credit
+# https://github.com/wolfswolke/aniworld_scraper/blob/41bd0f23cbc02352481dd92e6d986d1fe30c76bf/src/logic/search_for_links.py#L23
+
+def deb_func1(input_string):
+    result = ''
+    for char in input_string:
+        char_code = ord(char)
+        if 0x41 <= char_code <= 0x5a:
+            char_code = (char_code - 0x41 + 0xd) % 0x1a + 0x41
+        elif 0x61 <= char_code <= 0x7a:
+            char_code = (char_code - 0x61 + 0xd) % 0x1a + 0x61
+        result += chr(char_code)
+    return result
+
+PATTERNS = [
+    re_compile(re_escape('@$')),
+    re_compile(re_escape('^^')),
+    re_compile(re_escape('~@')),
+    re_compile(re_escape('%?')),
+    re_compile(re_escape('*~')),
+    re_compile(re_escape('!!')),
+    re_compile(re_escape('#&'))
+]
+
+def regex_func(input_string):
+    for pattern in PATTERNS:
+        input_string = pattern.sub('_', input_string)
+    return input_string
+
+def deb_func3(input_string, shift):
+    result = []
+    for char in input_string:
+        result.append(chr(ord(char) - shift))
+    return ''.join(result)
+
+def deb_func(input_var):
+    math_output = deb_func1(input_var)
+    regexed_string = regex_func(math_output)
+    cleaned_string = regexed_string.replace('_', '')
+    b64_string1 = b64decode(cleaned_string).decode('utf-8')
+    decoded_string = deb_func3(b64_string1, 3)
+    reversed_string = decoded_string[::-1]
+    b64_string2 = b64decode(reversed_string).decode('utf-8')
+    return json_loads(b64_string2)
+
+def find_script_element(raw_html):
+    soup = BeautifulSoup(raw_html, features="html.parser")
+    script_object = soup.find_all("script")
+    obfuscated_string = ""
+    for script in script_object:
+        script = str(script)
+        if "KGMAaM=" in script:
+            obfuscated_string = script
+            break
+    if obfuscated_string == "":
+        return None
+    obfuscated_string = obfuscated_string.split('MKGMa="')[1]
+    obfuscated_string = obfuscated_string.split('"')[0]
+    output = deb_func(obfuscated_string)
+    return output["source"]
+
 
 class VOEHoster(Hoster):
     async def get_direct_link(self) -> DirectLink:
         async with AsyncClient(verify=False) as client:
             redirect_response = await client.get(self.url)
             redirect_match = REDIRECT_PATTERN.search(redirect_response.text)
             redirect_link = redirect_match.group()
-
             response = await client.get(redirect_link)
-
-            match = HIDDEN_JSON_PATTERN.search(response.text)
-            if match:
-                hidden_json = b64decode(match.group("hidden_json")).decode()
-                hidden_json = hidden_json[::-1]
-                hidden_json = json_loads(hidden_json)
-                hidden_json = hidden_json["source"]
-                return DirectLink(hidden_json)
-
-            hls_match = EXTRACT_VEO_HLS_PATTERN.search(response.text)
-            hls_link = hls_match.group("hls")
-            hls_link = b64decode(hls_link).decode()
-            return DirectLink(
-                url=hls_link,
-                # Requires "host", "origin" or "referer"
-                # can be "bypassed" by http get once for players without headers
-                headers = {"Referer": "https://nathanfromsubject.com/"}
-            )
+            return DirectLink(find_script_element(response.text))

src/gucken/player/vlc.py

@@ -37,8 +37,17 @@ def play(
         if title:
             args.append(f"--input-title-format={title}")
         if headers:
+            # Hehe
             if headers.get("Referer"):
                 args.append(f"--http-referrer={headers.get('Referer')}")
+            if headers.get("referer"):
+                args.append(f"--http-referrer={headers.get('referer')}")
             if headers.get("User-Agent"):
                 args.append(f"--http-user-agent={headers.get('User-Agent')}")
+            if headers.get("user-agent"):
+                args.append(f"--http-user-agent={headers.get('user-agent')}")
+            if headers.get("User-agent"):
+                args.append(f"--http-user-agent={headers.get('User-agent')}")
+            if headers.get("user-Agent"):
+                args.append(f"--http-user-agent={headers.get('user-Agent')}")
         return args

src/gucken/provider/aniworld.py

@@ -13,6 +13,7 @@
 from ..hoster.filemoon import FilemoonHoster
 from ..hoster.luluvdo import LuluvdoHoster
 from ..hoster.streamtape import StreamtapeHoster
+from ..hoster.loadx import LoadXHoster
 from .common import Episode, Hoster, Language, Provider, SearchResult, Series
 from ..utils import json_loads
 from ..utils import fully_unescape
@@ -34,6 +35,8 @@ def provider_to_hoster(provider: str, url: str) -> Hoster:
         return LuluvdoHoster(url)
     if provider == "Vidmoly":
         return VidmolyHoster(url)
+    if provider == "LoadX":
+        return LoadXHoster(url)
 
 
 def lang_img_src_lang_name_to_lang(name: str) -> Language:
@@ -295,6 +298,8 @@ async def get_episodes_from_soup(
                 hoster.add(LuluvdoHoster)
             if t == "Vidmoly":
                 hoster.add(VidmolyHoster)
+            if t == "LoadX":
+                hoster.add(LoadXHoster)
 
         e_count += 1
         title_en = fully_unescape(title.find("span").text.strip())

src/gucken/provider/serienstream.py

@@ -4,6 +4,7 @@
 
 from bs4 import BeautifulSoup
 
+from ..hoster.loadx import LoadXHoster
 from ..networking import AcceptLanguage, AsyncClient
 from ..hoster.veo import VOEHoster
 from ..hoster.vidoza import VidozaHoster
@@ -44,7 +45,8 @@ def provider_to_hoster(provider: str, url: str) -> Hoster:
         return LuluvdoHoster(url)
     if provider == "Vidmoly":
         return VidmolyHoster(url)
-
+    if provider == "LoadX":
+        return LoadXHoster(url)
 
 def lang_img_src_lang_name_to_lang(name: str) -> Language:
     if name == "english":
@@ -306,6 +308,8 @@ async def get_episodes_from_soup(
                 hoster.add(LuluvdoHoster)
             if t == "Vidmoly":
                 hoster.add(VidmolyHoster)
+            if t == "LoadX":
+                hoster.add(LoadXHoster)
 
         e_count += 1
         title_en = fully_unescape(title.find("span").text.strip())