Save dark/light mode

src/gucken/__init__.py

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

src/gucken/gucken.py

@@ -1,6 +1,5 @@
-import warnings
-warnings.filterwarnings('ignore', message='Using slow pure-python SequenceMatcher. Install python-Levenshtein to remove this warning')
-
+from textual._types import IgnoreReturnCallbackType
+from textual.command import Hits, Provider as TextualProvider, Hit, DiscoveryHit
 import argparse
 import logging
 from asyncio import gather
@@ -200,7 +199,48 @@ def move_item(lst: list, from_index: int, to_index: int) -> list:
     return lst
 
 
-client_id = "1238219157464416266"
+CLIENT_ID = "1238219157464416266"
+
+
+class GuckenCommands(TextualProvider):
+
+    @property
+    def _commands(self) -> tuple[tuple[str, IgnoreReturnCallbackType, str], ...]:
+        return (
+            (
+                "Toggle light/dark mode",  # 🌇 / 🌃
+                self.app.action_toggle_dark,
+                "Toggle the application between light and dark mode",
+            ),
+            (
+                "Quit the application",  # ❌
+                self.app.action_quit,
+                "Quit the application as soon as possible",
+            ),
+        )
+
+    """
+    (
+        "Application folders",  # 📁
+        self.app.action_quit,
+        "Displays a list of all folders used",
+    ),
+    (
+        "Create Shortcut",  # 🔗
+        self.app.action_quit,
+        "The will create shortcuts to gucken",
+    )
+    """
+
+    async def discover(self) -> Hits:
+        for name, runnable, help_text in self._commands:
+            yield DiscoveryHit(name, runnable, help=help_text)
+
+    async def search(self, query: str) -> Hits:
+        matcher = self.matcher(query)
+        for name, runnable, help_text in self._commands:
+            if (match := matcher.match(name)) > 0:
+                yield Hit(match, matcher.highlight(name), runnable, help=help_text)
 
 
 class GuckenApp(App):
@@ -214,6 +254,7 @@ class GuckenApp(App):
     BINDINGS: ClassVar[list[BindingType]] = [
         Binding("q", "quit", "Quit", show=False, priority=False),
     ]
+    COMMANDS = {GuckenCommands}
 
     def __init__(self, debug: bool, search: str):
         super().__init__(watch_css=debug)
@@ -409,6 +450,13 @@ def select_changed(self, event: Select.Changed) -> None:
 
     # TODO: dont lock - no async
     async def on_mount(self) -> None:
+        self.dark = gucken_settings_manager.settings["settings"]["ui"]["dark"]
+
+        def update_dark(value: bool):
+            gucken_settings_manager.settings["settings"]["ui"]["dark"] = value
+
+        self.watch(self, "dark", update_dark)
+
         lang = self.query_one("#lang", DataTable)
         lang.add_columns("Language")
         for l in self.language:
@@ -445,7 +493,7 @@ def set_search():
 
     async def enable_RPC(self):
         if self.RPC is None:
-            self.RPC = AioPresence(client_id)
+            self.RPC = AioPresence(CLIENT_ID)
         try:
             await self.RPC.connect()
         except DiscordNotFound:
@@ -489,11 +537,11 @@ def fuzzy_sort_key(result):
             items = []
             for series in final_results:
                 items.append(ClickableListItem(
-                        Markdown(
-                            f"##### {series.name} {series.production_year} [{series.provider_name}]"
-                            f"\n{series.description}"
-                        )
-                    ))
+                    Markdown(
+                        f"##### {series.name} {series.production_year} [{series.provider_name}]"
+                        f"\n{series.description}"
+                    )
+                ))
             await results_list_view.extend(items)
         results_list_view.loading = False
         if len(final_results) > 0:
@@ -709,7 +757,8 @@ def delete_chapters_file():
                         if len(script_opts) > 0:
                             args.append(f"--script-opts={','.join(script_opts)}")
 
-                        args.append("--scripts-append=" + str(Path(__file__).parent.joinpath("resources", "mpv_gucken.lua")))
+                        args.append(
+                            "--scripts-append=" + str(Path(__file__).parent.joinpath("resources", "mpv_gucken.lua")))
 
                     if isinstance(_player, VLCPlayer):
                         prepend_data = []

src/gucken/resources/default_settings.toml

@@ -36,5 +36,8 @@ enabled = true
 aniworld_to = true
 serienstream_to = false
 
+[settings.ui]
+dark = true
+
 [meta]
 version = "0.0.0"

test/benchmark/extract_html.py

@@ -0,0 +1,58 @@
+import re
+import time
+from bs4 import BeautifulSoup
+
+html = '''
+<input type="hidden" id="recaptcha-token" value="03AFcWeA63UNMqNIJHmaB6Xj6nRTgNHQisxw1SbdigJVrSWeexc8cCphD9Pc6JSeKSaaKZ3xrx_KXB14FXzO-HCNoG_DyJssDdZfeXuQnlpV5LWaVTc-02MqlYD8B0857IoymZ_aE7jbAErFjWJW4rmc_iwsi9NB8ELWFoMkv_rlT2baeDt5OG2FUosCIHSpzqq6CcKkKSk1MyVfV3XQyABbvvTfREOc3oVNhOKOD1foy0yk7p19ZhoANtlWX-4ARIzlCl_HuUPQuJxRPHZRcaQdRyQPr0rQrB1iSIkFx47xwRpmOVS6S_uWS5803pEIhy-Nx6tQ7vIwxgYC6VWVNeWm8WWY0p3VsKU7YBmWpsiidINyF_eQp6YoTOLOOpAtoUgiRZ8jb39GWgTHGYEuOceJMG9iKQC_puFRZsqb25xb3BV0jO5omOh1ejbagj2w6GcsuCyYJBgc626vS6Kiq0R4j6KUWZv268F2GDUHMJ9P-oNE6SkYgqsyDV_SUlWGNM_NCVUrNXbTCPMcDYDtG1uMniIWpjrl2uA3IdTM2P6bT9hiwzbBXF3WC9SaNWz3ZJtbP7sVQBy4dJJgySLKDv03j7XHBEMaBHs3q2HUg5EuUhWTa9NES9dfUfzPRytv29flC9_AFS_CX51pI2W4zN8OzqbeHT3SJnqPZDYxU7s2eU5sFj5XALklpH1AD80kRXFzK6RUfibxslQdHa_mehpOmIOqtlBi4OC6zDCMGt0o6kYhjYb-a4PkYgdUrxN8GdPFx5dpKckXPDducXSO0-Lsdo6zJQEJwvwwjSRJfPtMiPHtgGo0f1JKPjkiFy2G3NxvPeGSK_xo9qhbZ_M4Hp-ngbVYPqngpfm4yHH-xymrpuReF7E9gJr0sRPxNDmuDgGR9nkbxXN7YuS_ezoxlL9GJft5RkbpZgE8qVcv0NJAZymoTuh24IrYM8rZ0sFvaS3RyIgjM7szquv5_e0NgwXZQWAFWIOA47WjVgKs89VvpnwzLON7AoSB7YqSlMkDjH1rT2P4B3FBlNpPEwEqy23dMk3cfFZ_bhVBPI5kClgoNHbtF4E_dcwY1azHNgcpHLglNP-ekJcKW2k1rwArPsN6YGlKKlXIp4Q-k60VPJRPw3cpIzGfZ6HzCO4dWG5nMqEFsJxWJIt574aIaOBoYt9ZBCWBJcsayRpDwiUOsYaYR646gp35dHowVR9GdNHUmJsCEyhEDweyJZY3xGNqs7GSeBSpnIr-OMurrxEdlvJOhX5GCPl-_JLc1wXmoOP2iJAh1s6i-h9tzCdhtHj32xGccz-yh48Gi4nEPxfAk7TFlj0Ti0w5M2WVQ0v87oHjlStmj17vOAge4wcAN8kQZ-BrqWYSMO6DtoL45_3TdD42V-2hG0hOcxV8HsOYHnoymZqHg_WApHsENg5CfO6OywSNbRnNUaE9dDxsqt9KAUG0g8HIMGzuilefp2EdVTyiNbVtjcuBTg3agGvcS7UMsRLDXAyCqSRI3CLcBVvDaTuQXKovxUZpzDEtQQqtUUmvSuNbK0rHCpBKSQubqONThBTeegy3o3CIuKiA">
+'''
+
+
+# String manipulation method
+def extract_value_string(html):
+    start = html.find('id="recaptcha-token"')
+    if start != -1:
+        start = html.find('value="', start) + len('value="')
+        end = html.find('"', start)
+        return html[start:end]
+    return None
+
+
+# Regex method
+def extract_value_regex(html):
+    pattern = r'<input[^>]*id="recaptcha-token"[^>]*value="([^"]+)"'
+    match = re.search(pattern, html)
+    if match:
+        return match.group(1)
+    return None
+
+
+# BeautifulSoup method
+def extract_value_bs4(html):
+    soup = BeautifulSoup(html, 'html.parser')
+    input_tag = soup.find('input', {'id': 'recaptcha-token'})
+    if input_tag:
+        return input_tag.get('value')
+    return None
+
+
+# Measure performance of string manipulation method
+start_time = time.time()
+for _ in range(100000):
+    token = extract_value_string(html)
+string_duration = time.time() - start_time
+
+# Measure performance of regex method
+start_time = time.time()
+for _ in range(100000):
+    token = extract_value_regex(html)
+regex_duration = time.time() - start_time
+
+# Measure performance of BeautifulSoup method
+start_time = time.time()
+for _ in range(100000):
+    token = extract_value_bs4(html)
+bs4_duration = time.time() - start_time
+
+print(f"String manipulation duration: {string_duration:.6f} seconds")
+print(f"Regex duration: {regex_duration:.6f} seconds")
+print(f"BeautifulSoup duration: {bs4_duration:.6f} seconds")

test/benchmark/http/Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "benchmark"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+may_minihttp = "0.1.3"

test/benchmark/http/new_session.py

@@ -0,0 +1,72 @@
+import time
+import asyncio
+import requests
+import httpx
+import aiohttp
+import urllib.request
+import http.client
+
+HOST = "127.0.0.1"
+PORT = 8080
+URL = f"http://{HOST}:{PORT}"
+
+
+def benchmark_http_client_sync():
+    # Has no sessions
+    start_time = time.time()
+    for _ in range(1000):
+        conn = http.client.HTTPConnection(HOST, port=PORT)
+        conn.request("GET", "/")
+        conn.close()
+    end_time = time.time()
+    return end_time - start_time
+
+def benchmark_requests():
+    start_time = time.time()
+    for _ in range(100):
+        with requests.Session() as session:
+            session.get(URL)
+    end_time = time.time()
+    return end_time - start_time
+
+
+async def benchmark_aiohttp():
+    start_time = time.time()
+    for _ in range(100):
+        async with aiohttp.ClientSession() as session:
+            await session.get(URL)
+    end_time = time.time()
+    return end_time - start_time
+
+
+def benchmark_httpx():
+    start_time = time.time()
+    for _ in range(100):
+        with httpx.Client() as client:
+            client.get(URL)
+    end_time = time.time()
+    return end_time - start_time
+
+
+def benchmark_urllib():
+    start_time = time.time()
+    for _ in range(100):
+        opener = urllib.request.build_opener()
+        opener.open(URL)
+        opener.close()
+    end_time = time.time()
+    return end_time - start_time
+
+
+if __name__ == "__main__":
+    sync_time = benchmark_requests()
+    async_time = asyncio.run(benchmark_aiohttp())
+    httpx_time = benchmark_httpx()
+    urllib_time = benchmark_urllib()
+    http_client_sync_time = benchmark_http_client_sync()
+
+    print(f"HTTP:     {http_client_sync_time} seconds")
+    print(f"Requests: {sync_time} seconds")
+    print(f"Aiohttp:  {async_time} seconds")
+    print(f"HTTPX:    {httpx_time} seconds")
+    print(f"Urllib:   {urllib_time} seconds")

test/benchmark/http/same_session.py

@@ -0,0 +1,72 @@
+import time
+import asyncio
+import requests
+import httpx
+import aiohttp
+import urllib.request
+import http.client
+
+HOST = "127.0.0.1"
+PORT = 8080
+URL = f"http://{HOST}:{PORT}"
+
+
+def benchmark_http_client_sync():
+    start_time = time.time()
+    for _ in range(1000):
+        conn = http.client.HTTPConnection(HOST, port=PORT)
+        conn.request("GET", "/")
+        conn.close()
+    end_time = time.time()
+    return end_time - start_time
+
+
+def benchmark_requests():
+    start_time = time.time()
+    with requests.Session() as session:
+        for _ in range(1000):
+            session.get(URL)
+    end_time = time.time()
+    return end_time - start_time
+
+
+async def benchmark_aiohttp():
+    start_time = time.time()
+    async with aiohttp.ClientSession() as session:
+        for _ in range(1000):
+            await session.get(URL)
+    end_time = time.time()
+    return end_time - start_time
+
+
+def benchmark_httpx():
+    start_time = time.time()
+    with httpx.Client() as client:
+        for _ in range(1000):
+            client.get(URL)
+    end_time = time.time()
+    return end_time - start_time
+
+
+def benchmark_urllib():
+    start_time = time.time()
+    opener = urllib.request.build_opener()
+    for _ in range(1000):
+        opener.open(URL)
+    opener.close()
+    end_time = time.time()
+    return end_time - start_time
+
+
+if __name__ == "__main__":
+    sync_time = benchmark_requests()
+    async_time = asyncio.run(benchmark_aiohttp())
+    httpx_time = benchmark_httpx()
+    urllib_time = benchmark_urllib()
+    http_client_sync_time = benchmark_http_client_sync()
+
+    print(f"HTTP:     {http_client_sync_time} seconds")
+    print(f"Requests: {sync_time} seconds")
+    print(f"Aiohttp:  {async_time} seconds")
+    print(f"HTTPX:    {httpx_time} seconds")
+    print(f"Urllib:   {urllib_time} seconds")

test/benchmark/http/src/main.rs

@@ -0,0 +1,18 @@
+extern crate may_minihttp;
+
+use std::io;
+use may_minihttp::{HttpServer, HttpService, Request, Response};
+
+#[derive(Clone)]
+struct HelloWorld;
+
+impl HttpService for HelloWorld {
+    fn call(&mut self, _req: Request, _res: &mut Response) -> io::Result<()> {
+        Ok(())
+    }
+}
+
+fn main() {
+    let server = HttpServer(HelloWorld).start("0.0.0.0:8080").unwrap();
+    server.join().unwrap();
+}