v3

Author: Arrowar

StreamingCommunity/Api/Service/crunchyroll/util/get_license.py

@@ -45,8 +45,8 @@ def wait(self):
 class CrunchyrollClient:
     def __init__(self) -> None:
         config = config_manager.get_dict("SITE_LOGIN", "crunchyroll")
-        self.device_id = config.get('device_id')
-        self.etp_rt = config.get('etp_rt')
+        self.device_id = str(config.get('device_id')).strip()
+        self.etp_rt = str(config.get('etp_rt')).strip()
         self.locale = "it-IT"
 
         self.access_token: Optional[str] = None

StreamingCommunity/Api/Service/realtime/util/get_license.py

@@ -1,11 +1,16 @@
 # 26.11.2025
 
+# External library
+from rich.console import Console
 
 # Internal utilities
 from StreamingCommunity.Util.headers import get_userAgent, get_headers
 from StreamingCommunity.Util.http_client import create_client
 
 
+# Variable
+console = Console()
+
 
 def get_playback_url(video_id: str, bearer_token: str, get_dash: bool, channel: str = "") -> str:
     """
@@ -26,8 +31,11 @@ def get_playback_url(video_id: str, bearer_token: str, get_dash: bool, channel:
         },
         'videoId': video_id,
     }
-
     response = create_client().post(bearer_token[channel]['endpoint'], headers=headers, json=json_data)
+    response.raise_for_status()
+
+    if response.status_code == 403:
+        console.print("[red]Set vpn to IT to download this content.")
 
     if not get_dash:
         return response.json()['data']['attributes']['streaming'][0]['url']

StreamingCommunity/Api/Service/tubitv/series.py

@@ -142,16 +142,10 @@ def download_series(select_season: MediaItem, season_selection: str = None, epis
         - episode_selection (str, optional): Pre-defined episode selection that bypasses manual input
     """
     start_message()
-
-    # Get bearer token
-    try:
-        bearer_token = get_bearer_token()
-    except Exception as e:
-        console.print(f"[red]Error getting bearer token: {e}")
-        return
+    bearer_token = get_bearer_token()
 
     # Init class
-    scrape_serie = GetSerieInfo(select_season.url, bearer_token)
+    scrape_serie = GetSerieInfo(select_season.url, bearer_token, select_season.name)
 
     # Collect information about season
     scrape_serie.getNumberSeason()

StreamingCommunity/Api/Service/tubitv/util/ScrapeSerie.py

@@ -19,7 +19,7 @@ def extract_content_id(url: str) -> str:
 
 
 class GetSerieInfo:
-    def __init__(self, url, bearer_token=None):
+    def __init__(self, url, bearer_token=None, series_name=None):
         """
         Initialize the GetSerieInfo class for scraping Tubi TV series information.
         
@@ -30,7 +30,7 @@ def __init__(self, url, bearer_token=None):
         self.url = url
         self.content_id = extract_content_id(url)
         self.bearer_token = bearer_token
-        self.series_name = None
+        self.series_name = series_name
         self.seasons_manager = SeasonManager()
         self.all_episodes_by_season = {}
 
@@ -66,12 +66,6 @@ def collect_info_title(self) -> None:
             # Store episodes by season
             self.all_episodes_by_season = episodes_by_season
 
-            # Get series name from first episode
-            first_season = list(episodes_by_season.values())[0]
-            if first_season and len(first_season) > 0:
-                first_episode = first_season[0]
-                self.series_name = first_episode.get('series_title', 'Unknown Series')
-            
             # Create seasons in SeasonManager
             for season_num in sorted(episodes_by_season.keys(), key=int):
                 season_data = {

StreamingCommunity/Api/Service/tubitv/util/get_license.py

@@ -34,8 +34,8 @@ def get_bearer_token():
         'platform': 'web',
         'device_id': generate_device_id(),
         'credentials': {
-            'email': config.get('email'),
-            'password': config.get('password')
+            'email': str(config.get('email')).strip(),
+            'password': str(config.get('password')).strip()
         },
     }
 

StreamingCommunity/Lib/DASH/decrypt.py

@@ -62,7 +62,7 @@ def decrypt_with_mp4decrypt(type, encrypted_path, kid, key, output_path=None):
 
     key_format = f"{kid.lower()}:{key.lower()}"
     cmd = [get_mp4decrypt_path(), "--key", key_format, encrypted_path, output_path]
-    logging.info(f"Running command: {' '.join(cmd)}")
+    logging.info(f"Running mp4decrypt command: {' '.join(cmd)}")
 
     progress_bar = None
     monitor_thread = None

StreamingCommunity/Lib/FFmpeg/merge.py

@@ -75,6 +75,7 @@ def join_video(video_path: str, out_path: str, codec: M3U8_Codec = None):
 
     # Output file and overwrite
     ffmpeg_cmd.extend([out_path, '-y'])
+    logging.info(f"FFMPEG Command: {' '.join(ffmpeg_cmd)} \n")
 
     # Run join
     if DEBUG_MODE:
@@ -122,7 +123,7 @@ def join_audios(video_path: str, audio_tracks: List[Dict[str, str]], out_path: s
     if use_shortest:
         for track in duration_diffs:
             color = "red" if track['has_error'] else "green"
-            console.print(f"[{color}]Audio {track['language']}: Video duration: {track['video_duration']:.2f}s, Audio duration: {track['audio_duration']:.2f}s, Difference: {track['difference']:.2f}s[/{color}]")
+            console.print(f"[{color}]Audio {track['language']}: Video duration: {track['video_duration']:.2f}s, Audio duration: {track['audio_duration']:.2f}s, Difference: {track['difference']:.2f}s[/{color}] \n")
 
     # Start command with locate ffmpeg
     ffmpeg_cmd = [get_ffmpeg_path()]
@@ -153,6 +154,7 @@ def join_audios(video_path: str, audio_tracks: List[Dict[str, str]], out_path: s
 
     # Output file and overwrite
     ffmpeg_cmd.extend([out_path, '-y'])
+    logging.info(f"FFMPEG Command: {' '.join(ffmpeg_cmd)} \n")
 
     # Run join
     if DEBUG_MODE:
@@ -197,7 +199,7 @@ def join_subtitle(video_path: str, subtitles_list: List[Dict[str, str]], out_pat
 
     # Overwrite
     ffmpeg_cmd += [out_path, "-y"]
-    logging.info(f"FFmpeg command: {ffmpeg_cmd}")
+    logging.info(f"FFMPEG Command: {' '.join(ffmpeg_cmd)} \n")
 
     # Run join
     if DEBUG_MODE:

StreamingCommunity/Lib/HLS/segments.py

@@ -157,11 +157,16 @@ def get_segments_count(self) -> int:
     def get_type_stream(self, segments) -> str:
         self.is_stream_ts = (".ts" in self.segments[len(self.segments) // 2]) if self.segments else False
         self.is_stream_mp4 = (".mp4" in self.segments[len(self.segments) // 2]) if self.segments else False
+        self.is_stream_aac = (".aac" in self.segments[len(self.segments) // 2]) if self.segments else False
 
         if self.is_stream_ts:
             return "ts"
         elif self.is_stream_mp4:
             return "mp4"
+        elif self.is_stream_aac:
+            return "aac"
+        else:
+            return None
 
     def get_info(self) -> None:
         """
@@ -386,10 +391,9 @@ async def download_segments_async(self, description: str, type: str):
         temp_dir = os.path.join(self.tmp_folder, "segments_temp")
         os.makedirs(temp_dir, exist_ok=True)
 
-        if self.stream_type == "ts":
+        if self.stream_type in ["ts", "aac"]:
 
             # Initialize progress bar
-            print("")
             total_segments = len(self.segments) + (1 if self.has_init_segment else 0)
             progress_bar = tqdm(
                 total=total_segments,

config.json

@@ -53,7 +53,7 @@
             "etp_rt": ""
         },
         "tubi": {
-            "email:": "",
+            "email": "",
             "password": ""
         }
     }