Fix telegram and proxy (#322)

* Add ENABLE_VIDEO

* Fix proxy

* Add error proxy

* Update config.json

* Fix telegram_bot (#312)

* Update config.json

* Fix telegram_bot

* fix bug

* Fix StreamingCommunity site

* Delete console.log

* fix doppio string_to_search

* Update __init__.py

* Update site.py

* Update config.json

* Update site.py

* Update config.json

* Update __init__.py

* Update __init__.py

* Fix proxy (#319)

* Add ENABLE_VIDEO

* Fix proxy

* Add error proxy

* Update config.json

* Refactor user input handling and improve messaging in __init__.py

---------

Co-authored-by: None <[email protected]>
Co-authored-by: l1n00 <>

* Fix proxy __init__

* Update os.py

---------

Co-authored-by: l1n00 <[email protected]>

Author: Arrowar

README.md

@@ -748,26 +748,24 @@ The `run-container` command mounts also the `config.json` file, so any change to
 The bot was created to replace terminal commands and allow interaction via Telegram. Each download runs within a screen session, enabling multiple downloads to run simultaneously.
 
 To run the bot in the background, simply start it inside a screen session and then press Ctrl + A, followed by D, to detach from the session without stopping the bot.
-</details>
-
-<details>
-<summary>🤖 Bot Commands</summary>
 
 Command Functions:
 
 🔹 /start – Starts a new search for a download. This command performs the same operations as manually running the script in the terminal with test_run.py.
 
 🔹 /list – Displays the status of active downloads, with options to:
-- Stop an incorrect download using /stop <ID>
-- View the real-time output of a download using /screen <ID>
+
+Stop an incorrect download using /stop <ID>.
+
+View the real-time output of a download using /screen <ID>.
 
 ⚠ Warning: If a download is interrupted, incomplete files may remain in the folder specified in config.json. These files must be deleted manually to avoid storage or management issues.
-</details>
 
-<details>
-<summary>🔧 Environment Setup</summary>
+🛠 Configuration: Currently, the bot's settings are stored in the config.json file, which is located in the same directory as the telegram_bot.py script.
+
+## .env Example:
 
-Create an `.env` file with:
+You need to create an .env file and enter your Telegram token and user ID to authorize only one user to use it
 
 ```
 TOKEN_TELEGRAM=IlTuo2131TOKEN$12D3Telegram

StreamingCommunity/Api/Player/vixcloud.py

@@ -1,6 +1,6 @@
 # 01.03.24
 
-import sys
+import time
 import logging
 from urllib.parse import urlparse, parse_qs, urlencode, urlunparse
 
@@ -24,7 +24,7 @@
 
 
 class VideoSource:
-    def __init__(self, url: str, is_series: bool, media_id: int = None):
+    def __init__(self, url: str, is_series: bool, media_id: int = None, proxy: str = None):
         """
         Initialize video source for streaming site.
         
@@ -35,6 +35,7 @@ def __init__(self, url: str, is_series: bool, media_id: int = None):
         """
         self.headers = {'user-agent': get_userAgent()}
         self.url = url
+        self.proxy = proxy
         self.is_series = is_series
         self.media_id = media_id
         self.iframe_src = None
@@ -55,7 +56,7 @@ def get_iframe(self, episode_id: int) -> None:
             }
 
         try:
-            response = httpx.get(f"{self.url}/iframe/{self.media_id}", params=params, timeout=MAX_TIMEOUT)
+            response = httpx.get(f"{self.url}/iframe/{self.media_id}", headers=self.headers, params=params, timeout=MAX_TIMEOUT, proxy=self.proxy)
             response.raise_for_status()
 
             # Parse response with BeautifulSoup to get iframe source
@@ -81,6 +82,7 @@ def parse_script(self, script_text: str) -> None:
             self.window_video = WindowVideo(converter.get('video'))
             self.window_streams = StreamsCollection(converter.get('streams'))
             self.window_parameter = WindowParameter(converter.get('masterPlaylist'))
+            time.sleep(0.5)
 
         except Exception as e:
             logging.error(f"Error parsing script: {e}")

StreamingCommunity/Api/Site/1337xx/__init__.py

@@ -24,7 +24,7 @@
 _useFor = "Torrent"
 _priority = 0
 _engineDownload = "Torrent"
-_deprecate = False
+_deprecate = True
 
 console = Console()
 msg = Prompt()
@@ -62,7 +62,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         return media_search_manager
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager, len_database)
         download_title(select_title)
 
     else:

StreamingCommunity/Api/Site/altadefinizione/__init__.py

@@ -110,7 +110,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         bot = get_bot_instance()
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager, len_database)
         process_search_result(select_title, selections)
 
     else:

StreamingCommunity/Api/Site/animeunity/__init__.py

@@ -109,7 +109,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         bot = get_bot_instance()
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager,len_database)
         process_search_result(select_title, selections)
 
     else:

StreamingCommunity/Api/Site/animeunity/util/ScrapeSerie.py

@@ -43,40 +43,38 @@ def setup(self, version: str = None, media_id: int = None, series_name: str = No
     def get_count_episodes(self):
         """
         Retrieve total number of episodes for the selected media.
+        This includes partial episodes (like episode 6.5).
         
         Returns:
-            int: Total episode count
+            int: Total episode count including partial episodes
         """
-        try:
-
-            response = httpx.get(
-                url=f"{self.url}/info_api/{self.media_id}/", 
-                headers=self.headers, 
-                timeout=max_timeout
-            )
-            response.raise_for_status()
-
-            # Parse JSON response and return episode count
-            return response.json()["episodes_count"]
-        
-        except Exception as e:
-            logging.error(f"Error fetching episode count: {e}")
-            return None
+        if self.episodes_cache is None:
+            self._fetch_all_episodes()
+            
+        if self.episodes_cache:
+            return len(self.episodes_cache)
+        return None
 
     def _fetch_all_episodes(self):
         """
         Fetch all episodes data at once and cache it
         """
         try:
-            all_episodes = []
-            count = self.get_count_episodes()
-            if not count:
-                return
+            # Get initial episode count
+            response = httpx.get(
+                url=f"{self.url}/info_api/{self.media_id}/",
+                headers=self.headers,
+                timeout=max_timeout
+            )
+            response.raise_for_status()
+            initial_count = response.json()["episodes_count"]
 
-            # Fetch episodes
+            all_episodes = []
             start_range = 1
-            while start_range <= count:
-                end_range = min(start_range + 119, count)
+            
+            # Fetch episodes in chunks
+            while start_range <= initial_count:
+                end_range = min(start_range + 119, initial_count)
 
                 response = httpx.get(
                     url=f"{self.url}/info_api/{self.media_id}/1",

StreamingCommunity/Api/Site/animeworld/__init__.py

@@ -75,7 +75,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         return media_search_manager
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager,len_database)
         process_search_result(select_title, selections)
 
     else:

StreamingCommunity/Api/Site/cb01new/__init__.py

@@ -62,7 +62,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         return media_search_manager
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager,len_database)
         process_search_result(select_title)
 
     else:

StreamingCommunity/Api/Site/guardaserie/__init__.py

@@ -75,7 +75,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         return media_search_manager
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager,len_database)
         process_search_result(select_title, selections)
 
     else:

StreamingCommunity/Api/Site/raiplay/__init__.py

@@ -84,7 +84,7 @@ def search(string_to_search: str = None, get_onlyDatabase: bool = False, direct_
         return media_search_manager
 
     if len_database > 0:
-        select_title = get_select_title(table_show_manager, media_search_manager)
+        select_title = get_select_title(table_show_manager, media_search_manager,len_database)
         process_search_result(select_title, selections)
 
     else: