Bump v3.2.6

Author: Arrowar

README.md

@@ -111,7 +111,7 @@ python run_streaming.py
 Download HTTP Live Streaming (HLS) content from m3u8 URLs.
 
 ```python
-from StreamingCommunity.Download import HLS_Downloader
+from StreamingCommunity import HLS_Downloader
 
 # Initialize with m3u8 URL and optional output path
 downloader = HLS_Downloader(
@@ -132,7 +132,7 @@ See [HLS example](./Test/Download/HLS.py) for complete usage.
 Direct MP4 file downloader with support for custom headers and referrer.
 
 ```python
-from StreamingCommunity.Download import MP4_downloader
+from StreamingCommunity import MP4_downloader
 
 # Basic usage
 downloader = MP4_downloader(
@@ -164,7 +164,7 @@ See [MP4 example](./Test/Download/MP4.py) for complete usage.
 Download content via torrent magnet links.
 
 ```python
-from StreamingCommunity.Download import TOR_downloader
+from StreamingCommunity import TOR_downloader
 
 # Initialize torrent client
 client = TOR_downloader()
@@ -488,8 +488,6 @@ To enable qBittorrent integration, follow the setup guide [here](https://github.
         "default_video_workser": 12,
         "default_audio_workser": 12,
         "segment_timeout": 8,
-        "download_audio": true,
-        "merge_audio": true,
         "specific_list_audio": [
             "ita"
         ],
@@ -514,7 +512,6 @@ To enable qBittorrent integration, follow the setup guide [here](https://github.
 
 #### Audio Settings
 - `download_audio`: Whether to download audio tracks
-- `merge_audio`: Whether to merge audio with video
 - `specific_list_audio`: List of audio languages to download
   * Can be changed with `--specific_list_audio ita,eng`
 

StreamingCommunity/Api/Site/altadefinizione/film.py

@@ -12,10 +12,9 @@
 
 # Internal utilities
 from StreamingCommunity.Util.os import os_manager
-from StreamingCommunity.Util.message import start_message
 from StreamingCommunity.Util.headers import get_headers
+from StreamingCommunity.Util.message import start_message
 from StreamingCommunity.Util.config_json import config_manager
-from StreamingCommunity.Lib.Downloader import HLS_Downloader
 from StreamingCommunity.TelegramHelp.telegram_bot import get_bot_instance, TelegramSession
 
 
@@ -25,6 +24,7 @@
 
 
 # Player
+from StreamingCommunity import HLS_Downloader
 from StreamingCommunity.Api.Player.supervideo import VideoSource
 
 

StreamingCommunity/Api/Site/altadefinizione/series.py

@@ -11,7 +11,6 @@
 
 # Internal utilities
 from StreamingCommunity.Util.message import start_message
-from StreamingCommunity.Lib.Downloader import HLS_Downloader
 from StreamingCommunity.TelegramHelp.telegram_bot import get_bot_instance, TelegramSession
 
 
@@ -29,6 +28,7 @@
 
 
 # Player
+from StreamingCommunity import HLS_Downloader
 from StreamingCommunity.Api.Player.supervideo import VideoSource
 
 

StreamingCommunity/Api/Site/animeunity/serie.py

@@ -12,7 +12,6 @@
 # Internal utilities
 from StreamingCommunity.Util.os import os_manager
 from StreamingCommunity.Util.message import start_message
-from StreamingCommunity.Lib.Downloader import MP4_downloader
 from StreamingCommunity.TelegramHelp.telegram_bot import TelegramSession, get_bot_instance
 
 
@@ -24,6 +23,7 @@
 
 
 # Player
+from StreamingCommunity import MP4_downloader
 from StreamingCommunity.Api.Player.vixcloud import VideoSourceAnime
 
 

StreamingCommunity/Api/Site/animeworld/film.py

@@ -9,7 +9,6 @@
 # Internal utilities
 from StreamingCommunity.Util.os import os_manager
 from StreamingCommunity.Util.message import start_message
-from StreamingCommunity.Lib.Downloader import MP4_downloader
 
 
 # Logic class
@@ -19,6 +18,7 @@
 
 
 # Player
+from StreamingCommunity import MP4_downloader
 from StreamingCommunity.Api.Player.sweetpixel import VideoSource
 
 

StreamingCommunity/Api/Site/animeworld/serie.py

@@ -1,7 +1,6 @@
 # 11.03.24
 
 import os
-import logging
 from typing import Tuple
 
 
@@ -13,7 +12,6 @@
 # Internal utilities
 from StreamingCommunity.Util.os import os_manager
 from StreamingCommunity.Util.message import start_message
-from StreamingCommunity.Lib.Downloader import MP4_downloader
 
 
 # Logic class
@@ -24,6 +22,7 @@
 
 
 # Player
+from StreamingCommunity import MP4_downloader
 from StreamingCommunity.Api.Player.sweetpixel import VideoSource
 
 

StreamingCommunity/Api/Site/cb01new/film.py

@@ -10,7 +10,6 @@
 # Internal utilities
 from StreamingCommunity.Util.os import os_manager
 from StreamingCommunity.Util.message import start_message
-from StreamingCommunity.Lib.Downloader import HLS_Downloader
 
 
 # Logic class
@@ -19,6 +18,7 @@
 
 
 # Player
+from StreamingCommunity import HLS_Downloader
 from StreamingCommunity.Api.Player.maxstream import VideoSource
 
 

StreamingCommunity/Api/Site/crunchyroll/film.py

@@ -9,11 +9,9 @@
 
 
 # Internal utilities
-from StreamingCommunity.Util.os import os_manager
 from StreamingCommunity.Util.message import start_message
 from StreamingCommunity.Util.config_json import config_manager
-from StreamingCommunity.Util.os import get_wvd_path
-from StreamingCommunity.Lib.Downloader.DASH.downloader import DASH_Download
+from StreamingCommunity.Util.os import os_manager, get_wvd_path
 
 
 # Logic class
@@ -22,6 +20,7 @@
 
 
 # Player
+from StreamingCommunity import DASH_Downloader
 from .util.get_license import get_playback_session, get_auth_token, generate_device_id
 
 
@@ -55,7 +54,7 @@ def download_film(select_title: MediaItem) -> str:
     query_params = parse_qs(parsed_url.query)
 
     # Download the episode
-    r_proc = DASH_Download(
+    r_proc = DASH_Downloader(
         cdm_device=get_wvd_path(),
         license_url='https://www.crunchyroll.com/license/v1/license/widevine',
         mpd_url=mpd_url,

StreamingCommunity/Api/Site/crunchyroll/series.py

@@ -12,13 +12,11 @@
 
 # Internal utilities
 from StreamingCommunity.Util.message import start_message
-from StreamingCommunity.Util.os import os_manager
-from StreamingCommunity.Util.os import get_wvd_path
-from StreamingCommunity.Lib.Downloader.DASH.downloader import DASH_Download
+from StreamingCommunity.Util.os import os_manager, get_wvd_path
 
 
 # Logic class
-from .util.ScrapeSerie import GetSerieInfo
+from .util.ScrapeSerie import GetSerieInfo, delete_stream_episode
 from StreamingCommunity.Api.Template.Util import (
     manage_selection, 
     map_episode_title,
@@ -31,6 +29,7 @@
 
 
 # Player
+from StreamingCommunity import DASH_Downloader
 from .util.get_license import get_playback_session, get_auth_token, generate_device_id
 
 
@@ -65,12 +64,14 @@ def download_video(index_season_selected: int, index_episode_selected: int, scra
     # Generate mpd and license URLs
     url_id = obj_episode.get('url').split('/')[-1]
     device_id = generate_device_id()
-    mpd_url, mpd_headers = get_playback_session(get_auth_token(device_id), device_id, url_id)
+    token_mpd = get_auth_token(device_id)
+    
+    mpd_url, mpd_headers = get_playback_session(token_mpd, device_id, url_id)
     parsed_url = urlparse(mpd_url)
     query_params = parse_qs(parsed_url.query)
 
     # Download the episode
-    r_proc = DASH_Download(
+    r_proc = DASH_Downloader(
         cdm_device=get_wvd_path(),
         license_url='https://www.crunchyroll.com/license/v1/license/widevine',
         mpd_url=mpd_url,
@@ -95,6 +96,9 @@ def download_video(index_season_selected: int, index_episode_selected: int, scra
         try: os.remove(status['path'])
         except Exception: pass
 
+    # Delete episode stream
+    delete_stream_episode(url_id, query_params['playbackGuid'][0], mpd_headers)
+
     return status['path'], status['stopped']
 
 def download_episode(index_season_selected: int, scrape_serie: GetSerieInfo, download_all: bool = False, episode_selection: str = None) -> None:

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

@@ -45,6 +45,26 @@ def get_season_episodes(season_id, headers, params):
     )
     return response
 
+def delete_stream_episode(episode_id, stream_id, headers):
+    """
+    Deletes a specific stream episode by episode ID and stream ID.
+    """
+    url = f'https://www.crunchyroll.com/playback/v1/token/{episode_id}/{stream_id}'
+    headers = get_headers()
+    
+    response = requests.delete(
+        url,
+        headers=headers,
+        impersonate="chrome110"
+    )
+    
+    if response.status_code == 204:
+        return True
+    
+    else:
+        logging.error(f"Failed to delete stream episode: {response.status_code} - {response.text}")
+        return False
+
 
 class GetSerieInfo:
     def __init__(self, series_id):