Aʹh[SrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r J r J r J r SSK Jr SSKJr SSKJrJrJrJrJr "SS 5r"S S 5rg) z Stream Processing Services This module contains the core services for stream capture, processing, and HLS playlist management. It provides the main functionality for capturing HLS streams using FFmpeg and managing the resulting segments. N)Path)OptionalDictAnyList)settings)timezone)Channel StreamSession HLSSegmentVideoConfigurationAudioConfigurationc :\rSrSrSrSrS\4SjrS\S\ \ \ 44Sjr SS\S \ \S \ \S\\ 4S jjrS \S\\ 4S jrS \S\\ 4S jrSS\S \ \S \ \S\4SjjrS\S\4SjrSS\S \ \S \ \S\ \4SjjrSS\S\S\4SjjrSrg)StreamCaptureServicea Service for capturing and processing HLS streams using FFmpeg. This service provides the core functionality for stream capture, including FFmpeg command generation, process management, and error handling with automatic retry logic. Attributes: logger (Logger): Logger instance for recording operations ffmpeg_path (str): Path to the FFmpeg executable output_base_dir (str): Base directory for stream output c[R"S5UlSUl[R SUlUR5 g)z Initialize the stream capture service. Sets up logging, validates FFmpeg availability, and configures default settings for stream processing operations. zstream_processor.captureffmpeg OUTPUT_DIRN)logging getLoggerlogger ffmpeg_pathr STREAM_CONFIGoutput_base_dir_validate_ffmpegselfs AC:\Users\brahi\OneDrive\Desktop\Code\src\apps\streams\services.py__init__StreamCaptureService.__init__#sD''(BC $ (55lC returnc@[R"URS/SSSS9nURS:XaURR S5 g[ SUR35e![a [ S5e[Ra [ S 5ef=f) z Validate that FFmpeg is available and accessible. Returns: bool: True if FFmpeg is available, raises exception otherwise Raises: RuntimeError: If FFmpeg is not found or not executable z-versionT )capture_outputtexttimeoutrzFFmpeg validation successfulzFFmpeg test failed: z0FFmpeg not found in PATH. Please install FFmpeg.zFFmpeg validation timed out) subprocessrunr returncoderinfo RuntimeErrorstderrFileNotFoundErrorTimeoutExpired)rresults rr%StreamCaptureService._validate_ffmpeg6s >^^!!:.# F   A%   !?@"%9&--#IJJ  SQR R(( ><= = >sAA)A))4Bchannelc [UR5UR- nUS- nUS- nUS- nUUUUS.nUR5HEupxUR SSS9 UR S5 UR RSU35 MG U$![a*n UR RS US US U 35 eS n A ff=f) aG Create the necessary output directories for a channel. Creates the directory structure needed for HLS output, including the main channel directory, HLS subdirectory, and logs directory. Args: channel (Channel): Channel model instance Returns: Dict[str, Path]: Dictionary containing paths to created directories hlslogsiframes)baser4r5r6T)parentsexist_okizCreated directory: zFailed to create z directory : N) rrslugitemsmkdirchmodrr+OSErrorerror) rr2 base_pathhls_path logs_path iframes_path directoriesnamepathes rcreate_output_directories.StreamCaptureService.create_output_directoriesRs--.= u$&  9, #  &++-JD  4$ 7 5!   #6tf!=> .   !!$5dV;tfBqc"RS s?B C%CCN video_config audio_configcURU5nUSnURSSSSSSSS URS S S S /nU(a!URUR U55 O`URS SSSS[ [ RS5S[ [ RS5S[ RS/ 5 U(a!URURU55 O~URSSSSSSS[ RSS[ RS S![ RS"S#[ RS$S%[ RS"S&S'S(S)S*S+S,S+/5 URS-SS.[ UR5S/[ UR5S0S1S2S3S4S5S6S1S7[ US8- 5[ US9- 5/5 U$):a Build the FFmpeg command for stream capture. Constructs the complete FFmpeg command line arguments based on channel configuration and encoding parameters. Args: channel (Channel): Channel configuration video_config (VideoConfiguration, optional): Video encoding settings audio_config (AudioConfiguration, optional): Audio encoding settings Returns: List[str]: FFmpeg command as list of arguments r4z -hide_bannerz -loglevelr+z -user_agentz ? JJ4s800?@s800<=--i8    JJt00> ? JJf%h++L9800@--m<H11-@H11-@dt   % W556 c'"6"67 #S + &  $ 77 8 <' (  " r!c /nUR(aURSS/5 URSURS[UR5S[UR 5SUR /5 U$)z Build audio encoding options from configuration. Args: audio_config (AudioConfiguration): Audio configuration object Returns: List[str]: Audio encoding options for FFmpeg rNrOrPrRrTrV) normalizerrcodecrt sample_ratechannelsbitrate)rrLoptionss rrs)StreamCaptureService._build_audio_optionssv  ! ! NNE#@A B  L&& 3|//0 3|,,- L((   r!c^SURSURSURSURSURS[ UR 5SURSURS UR/nURS :Xa%URS URS S SSSSSS/ 5 U$)z Build video encoding options from configuration. Args: video_config (VideoConfiguration): Video configuration object Returns: List[str]: Video encoding options for FFmpeg rXrZr\r]r_z-rrarcrerYz-presetrfrgrhrirjrkrl) rprofilelevel resolution aspect_ratiort frame_rate min_bitrate max_bitraterrpreset)rrKrs rrv)StreamCaptureService._build_video_optionss L&& ,.. l(( ,)) |00 #l--. L,,  00  00      ' NN<..dt  r!c XURRSUR35 [RR UUUS[ R"5S9nURXU5nURRSSRU535 [R"U[R[RSSSS9n[UR5UlS UlUR#5 URRS UR35 U$![$arnS Ul[U5Ul[ R"5UlUR#5 URR+S U35 [-S U35eSnAff=f)a Start stream capture for a channel. Initiates the FFmpeg process for stream capture and creates a StreamSession to track the operation. Args: channel (Channel): Channel to capture video_config (VideoConfiguration, optional): Video encoding settings audio_config (AudioConfiguration, optional): Audio encoding settings Returns: StreamSession: Created session object Raises: RuntimeError: If capture fails to start z%Starting stream capture for channel: pending)r2rKrLstatus started_atzFFmpeg command:  T)stdoutr-r&bufsizeuniversal_newlinesactivez!Stream capture started with PID: failedz Failed to start stream capture: zStream capture failed: N)rr+rFr objectscreater nowr{joinr(PopenPIPErtpid process_idrsave Exception last_errorended_atr@r,)rr2rKrLsessionrzprocessrHs r start_capture"StreamCaptureService.start_capturesh. @OP ''..%%||~ / " >++G<PC KK  / ? @!&&!!#' G"%W[[!1G %GN LLN KK  @ N ON >%GN!$QG '||~G  LLN KK   @D E!8<= = >sCD-- F)7A-F$$F)rcURRSUR35 UR(aZ[R "SUR/5nUR SS9 URRSUR35 SUl [R"5Ul UR5 g![Ra& [R"SSUR/5 Nf=f![a<nURRS U35 UR!S U35 S nAg S nAff=f) z Stop an active stream capture session. Terminates the FFmpeg process and updates the session status. Args: session (StreamSession): Session to stop Returns: bool: True if successfully stopped, False otherwise z!Stopping stream capture session: killr$)r'z-9zTerminated process PID: completedTz Failed to stop capture session: z Stop failed: NF)rr+idrr(rwaitr/r)rr rrrrr@ add_error)rrrrHs r stop_capture!StreamCaptureService.stop_capture]s DDD E 2EE cSnURnURnXE:aURRSUS-SU35 UR XU5nUR U5(aU$US- nXE:a5URR SUS35 [R"U5 XE:aMURRS US UR35 g ![amnURRSUS-SU35 US- nXE:a5URR S US35 [R"U5 S nANS nAff=f) a Start stream capture with automatic retry logic. Implements the retry logic from the original bash script, attempting to restart capture on failure with configurable retry attempts and intervals. Args: channel (Channel): Channel to capture video_config (VideoConfiguration, optional): Video encoding settings audio_config (AudioConfiguration, optional): Audio encoding settings Returns: Optional[StreamSession]: Session if successful, None if all retries failed rzStream capture attempt r/zCapture failed, retrying in z seconds...zCapture attempt z failed: z Retrying in NzAll z capture attempts failed for ) retry_attemptsretry_intervalrr+r_monitor_capturewarningtimesleeprr@rF) rr2rKrLretries max_retriesrrrHs rcapture_with_retry'StreamCaptureService.capture_with_retrys\*,,  //# /   #:7Q;-q !VW,,WLQ((11"NqLG, ++:>:J+V >2##< D -J7<<.YZ / !!$4Wq[M1#"NO1 (KK''&~&6kBJJ~. /sA C!/?C!! E+A#EEr'c6[R"5n[R"5U- U:GaUR(aN[R"SSUR/SS9nURS:waUR R S5 g[URR55nUS- nUR5(aE[URS 55n[U5S:aUR RS 5 g[R"S 5 [R"5U- U:aGMUR R#S5 g![ a(nUR R S U35 S nAgS nAff=f)aZ Monitor a capture session for initial success. Waits for the capture to start producing segments and verifies that the process is running correctly. Args: session (StreamSession): Session to monitor timeout (int): Timeout in seconds for initial success check Returns: bool: True if capture appears successful, False otherwise psz-pT)r%rzFFmpeg process has terminatedFrp*.tsz!Stream capture appears successfulzError monitoring capture: NzCapture monitoring timed out)rrr(r)r*rr@rr2 get_hls_pathexistslistgloblenr+rrr) rrr' start_timer0rB playlist_filesegmentsrHs rr%StreamCaptureService._monitor_capturesGYY[ iikJ&0 %%'^^tW%7%78'+F((A- ))*IJ$  < < >? (< 7  ''))#HMM&$9:H8}q( (()LM# 1 1iikJ&0< :;   !!$>qc"BC s%AE&BE&E&& F0FF)rrr)NN)<)__name__ __module__ __qualname____firstlineno____doc__rboolrr rrtrrIrr rrr{rsrvr rrrintr__static_attributes__r!rrrsk  &>$>8&&T#t)_&V6:59 __12_12 _ c _B1CS 4 1C S J6:59 D>D>12D>12 D>  D>L$M$d$R6:59 8812812 8 - 8t/ //T//r!rcb\rSrSrSrSrS\S\4SjrS\S\4Sjr S S\S \ \ S\ 4S jjr S r g) HLSPlaylistManageriz Service for managing HLS playlists and segments. This service handles playlist file creation, segment management, and cleanup operations for HLS streams. c:[R"S5Ulg)z$Initialize the HLS playlist manager.zstream_processor.hlsN)rrrrs rrHLSPlaylistManager.__init__s''(>? r!r2r"c|[UR55nUS- n/SQn[US5nURSR U55 SSS5 UR R SU35 g!,(df  N-=f![a(nUR RSU35 SnAg SnAff=f) z Create a master HLS playlist file for a channel. Args: channel (Channel): Channel to create playlist for Returns: bool: True if playlist was created successfully z master.m3u8)#EXTM3U#EXT-X-VERSION:3z#EXT-X-INDEPENDENT-SEGMENTSzz#EXT-X-MEDIA:TYPE=CLOSED-CAPTIONS,GROUP-ID="CC",LANGUAGE="eng",NAME="english",DEFAULT=YES,AUTOSELECT=YES,INSTREAM-ID="CC1"zy#EXT-X-STREAM-INF:BANDWIDTH=3405600,RESOLUTION=1280x720,CODECS="avc1.4d401f,mp4a.40.2",FRAME-RATE=25,CLOSED-CAPTIONS="CC"rpw NzCreated master playlist: Tz"Failed to create master playlist: F) rropenwriterrr+rr@)rr2rB master_pathcontentfrHs rcreate_master_playlist)HLSPlaylistManager.create_master_playlists G0023H"]2KGk3'1 '*+( KK  8 F G ('   KK   B1#F G s..B !A8&B 8 BB B;B66B;c[UR55nUS- nUR5(dZ/SQn[US5nUR SR U5S-5 SSS5 UR RSU35 URU5 g!,(df  N>=f![a(nUR RSU35 SnAg SnAff=f) z Ensure that playlist files exist for a channel. Args: channel (Channel): Channel to check Returns: bool: True if playlists exist or were created z playlist.m3u8)rrz#EXT-X-TARGETDURATION:6z#EXT-X-MEDIA-SEQUENCE:0rrNzCreated playlist: Tz"Failed to ensure playlist exists: F) rrrrrrrr+rrr@)rr2rB playlist_pathrrrHs rensure_playlist_exists)HLSPlaylistManager.ensure_playlist_existss G0023H$6M ''))--GGDIIg.56.   #5m_!EF  ' ' 0.-  KK   B1#F G s0AB2$B!)7B2! B/+B22 C$<CC$N keep_countcrUc URn[UR55n[UR S5SS9nSn[ U5U:aCUSU*nUH7nUR 5 US- nURRSU35 M9 US:a+URRS US UR35 U$![a,nURRSUS U35 SnAMSnAff=f![a(nURRS U35 SnAgSnAff=f) z Clean up old segment files beyond the configured limit. Args: channel (Channel): Channel to clean up keep_count (int, optional): Number of segments to keep Returns: int: Number of segments deleted Nrc6UR5R$N)statst_mtime)xs r9HLSPlaylistManager.cleanup_old_segments..Rs1668CTCTr!)keyrrzDeleted segment: zFailed to delete segment r:z Cleaned up z old segments for zFailed to cleanup segments: )ryrrsortedrrunlinkrdebugr?rr+rFrr@) rr2rrBr deleted_countsegments_to_deletesegmentrHs rcleanup_old_segments'HLSPlaylistManager.cleanup_old_segmentsBs@   --J G0023HhmmF39TUHM8}z)%-l {%;"1GX(%*  )),=gY*GH 2q    ;}o=OPWP\P\~!^_ #X ++.GyPRSTRU,VWWX  KK   rsI   ,, !jjWWtxxr!