hڑ SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r J r J r J r SSKJr SSKJr SSKJr SS KJrJrJrJrJr SS KJrJr SS KJr \R>"S 5r S \!4Sjr"S\S \ \#\44Sjr$S\S \ \#4Sjr%S\S \ \#4Sjr&S/S\S\ \S\ \S \ \#4Sjjr'S0S\S\(S \!4Sjjr)\"SSSS9S/S\#S\#S\#4S jj5r*S/S\S\ \S\ \S \4S!jjr+S/S\S\ \S\ \S \ \4S"jjr,\S#\#4S$j5r-S\S \!4S%jr.\S&\#4S'j5r/\S(5r0S1S\S)\ \(S \(4S*jjr1S\S \!4S+jr2\S,5r3\S\#4S-j5r4\S.5r5g)2z Celery Tasks for Stream Processing This module contains all stream processing functionality as Celery tasks for better task management. All FFmpeg operations, HLS processing, and stream management are handled as background tasks. N)Path)OptionalDictAnyList) shared_task)timezone)settings)Channel StreamSession HLSSegmentVideoConfigurationAudioConfiguration)JingleDetectorAdBreakAnalyzer)NotificationServicezstream_processor.tasksreturnc [R"SS/SSSS9nURS:Xa[R S5 g[ SUR 35e![a [ S 5e[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 ffmpegz-versionT )capture_outputtexttimeoutrzFFmpeg validation successfulzFFmpeg test failed: z0FFmpeg not found in PATH. Please install FFmpeg.zFFmpeg validation timed out) subprocessrun returncodeloggerinfo RuntimeErrorstderrFileNotFoundErrorTimeoutExpired)results >C:\Users\brahi\OneDrive\Desktop\Code\src\apps\streams\tasks.py_validate_ffmpegr&s: z "      ! KK6 7!5fmm_EF F OMNN  $ $:899:s>AA4B channelc [[RS5UR- nUS- nUS- nUS- nUUUUS.nUR 5H?upgUR SSS9 UR S5 [RS U35 MA U$![a$n[RS US US U35 eS nAff=f)z Create the necessary output directories for a channel. Args: channel (Channel): Channel model instance Returns: Dict[str, Path]: Dictionary containing paths to created directories OUTPUT_DIRhlslogsiframes)baser*r+r,T)parentsexist_okizCreated directory: zFailed to create z directory : N) rr STREAM_CONFIGslugitemsmkdirchmodrrOSErrorerror) r' base_pathhls_path logs_path iframes_path directoriesnamepathes r%_create_output_directoriesr@<sX++L9:W\\II5 HF"Iy(L K"'')   JJtdJ 3 JJu  KK-dV4 5 *    LL,TF+dV2aSI J  s9B CB>>C audio_configc /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 -afloudnorm=I=-16:LRA=11:TP=-1-c:a-ar-ac-b:a) normalizeextendcodecstr sample_ratechannelsbitrate)rAoptionss r%_build_audio_optionsrQasvG<=> NN "" s<++, s<(() $$  N video_configc^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 -c:v -profile:v-level-s-aspectz-r-b:v-maxrate-bufsizeh264z-preset-crf20 -sc_threshold0-g48 -keyint_min) rKprofilelevel resolution aspect_ratiorL frame_rate min_bitrate max_bitraterJpreset)rSrPs r%_build_video_optionsrm|s  ""l**,$$ l%%<,, c,))* ((L,,L,, GV# |** D S $ 4    NrRc^[U5nUSnSSSSSSSS S URS S S S /nU(aUR[U55 O`URSSSSS[ [ R S5S[ [ R S5S[ R S/ 5 U(aUR[U55 O~URSSSSSSS[ RSS [ RS!S"[ RS#S$[ RS%S&[ RS#S'S(S)S*S+S,S-S,/5 URS.SS/[ UR5S0[ UR5S1S2S3S4S5S6S7S2S8[ US9- 5[ US:- 5/5 U$);a5 Build the FFmpeg command for stream capture. 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 r*rz -hide_bannerz -loglevelrz -user_agentz">"@ 3  !'**o ' %00::<  =W\\NJcdI LL #$7#8 2 2,$+LL%.!)!9!9!; 3 I& &   #&zl*=  Y ""  3A378 <<  $"2"2 2 KK@AUAUXYAY@ZZ[\ ]***# # ':'<$$66"0(2),Q%-\\^%=%=%?-1 7   /s:E G A9G AK A;KA KKKKKc [RSUR35 [RR UUUS[ R"5S9n[XU5n[RSSRU535 [R"U[R[RSSSS9n[UR5UlS UlUR#5 [RS UR35 U$![$alnS Ul[U5Ul[ R"5UlUR#5 [R+S U35 [-S U35eSnAff=f)aY Start stream capture for a channel. 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)r'rSrAstatusrzFFmpeg command:  Tr )stdoutr!rbufsizeuniversal_newlinesactivez!Stream capture started with PID: failedz Failed to start stream capture: zStream capture failed: N)rrr=r rcreater rrjoinrPopenPIPErLpidrrsaver last_errorended_atr7r )r'rSrArrprocessr?s r%_start_capturersJ& KK7 ~FG##**!!<<> +G":#G<H  &sxx}o67"" ????#  !-!  7 }EF :! V#<<>  7s;<4QC899:sB"2+> >* +s;C9C D. AD))D.rc [RSU35 [RR US9n[ U5nU(a[RSU35 [ 5nURSURR[UR5UR5(a[UR55OSURS.S9 S[UR5URRUR(aURR5S .$S S .$S U3n[R!U5 [#U5e![R$a' S US 3n[R!U5 [#U5e["an[R!SU35 eS nAff=f)z Stop an active stream capture session. Args: session_id (str): UUID of the stream session to stop Returns: dict: Task result with session information z%Stopping stream capture for session: rz0Stream capture stopped successfully for session stream_stoppedUnknown)rrdurationsegments_processedrTN)rrrrz*Failed to stop stream capture for session zStream session with ID rz!Stop stream capture task failed: )rrr rr _stop_capturerrr'r=rLrrrrrr7rr)rrrrrr?s r%stop_stream_capturers* ;J<HI ''++z+: (  KKJ:,W X$7#8 2 2.$+OO$8$8"%gjj/;B;K;K;M;MG$4$4$6 7S\*1*D*D  3  !'**o ' 4 4! %*[KK,w/A/A.BBX YZ[& ` l7+=+=*>>]^_ W!;Grr1rr'get_output_pathrprocess_segmentrLrtemplater=rprocess_detectionrrrrrrupdaterrrr7rr) rsegmentjingles_folderiframes_folderdetector detectionr$analyzerad_breakrrr?s r%process_new_segmentr~sK .zl;<$$((J(7%%))-?? LLT U#? ?h&<&<\&JIVgoo&=&=&M&M&OQZ[!.A,,W5 gjj/ $(4    KK5j\IDVDVD[D[C\] ^'(H11)&>&H&H&J"+"6"6  3  MM #ILL 1(1166$-$>$>3;s8;;/   **a/*,@+AB  " "#*:,jA  Y ""   7s;<  ((,, ,;G OO % %(CA3&G H     s8A3J6HJAL3L.+;L'&L.'L+)L..L3c[RS5 [RR SS/S9nSnSn/nUGHgnUR (a[ R"5UR - nUR5S:aMURS:Xa=SURS3nURU5 [RU5 US - nMUR(aSS KnUR"S S UR/S SS9nUR S:waSURSURS3nURU5 [RU5 SUl[ R"5UlSUlUR)5 US - nGMaUS - nGMj U(aFUS:a@[15n U R3SUUU[ R"5R55S.S9 [R7SUSUS35 S UUUS.$!UR*a? SUR3nURU5 [RU5 US - nGM*f=f![,aIn SURSU 3nURU5 [R/U5 US - nS n A GM|S n A ff=f![,an [R/SU 35 eS n A ff=f) z Periodic task to check the health of active stream sessions. This task monitors active streams for issues and sends alerts if problems are detected. Returns: dict: Health check results zRunning stream health checkr processing) status__inri,zSession z has no segments after 5 minutesr NrrTr)rrzProcess z for session rrzProcess terminated unexpectedlyz!Health check timeout for session zHealth check error for session r0 health_check)healthy_sessionsunhealthy_sessionsissuesrrzStream health check completed: z healthy, z unhealthy)rr r r zStream health check failed: )rrr rfilterrr r total_secondsrrappendrrrrrrrrrr#rr7rrrr) active_sessions healthy_countunhealthy_countr rtime_since_startissuerr$r?rs r%check_stream_healthrsV 23(//66 ,/7  &G/ %%%'/||~8J8J'J$'557#="55:&.wzzl:Z$[E"MM%0"NN51+q0O$%%%!!+!4););<+/$&" ",,1&.w/A/A.B-PWPZPZ|[e$fE"MM%0"NN51.6GN/7||~G,1RG.#LLN+q0O$2(" U'f o)#6#8 2 2,(5*9$!)!9!9!;  3   5m_JN__ijk -"1   =&44!"CGJJ< P e,u-'1, ! %9'**RsK e$ U#1$  %8  3A378 sAKBI,KI,-B/HKI,%A4KA I)$I,%K(I))I,, J?6=J:3K:J??K K* K%%K* keep_countcBUc URn[UR55n[UR S5SS9nSn[ U5U:a=USU*nUH1nUR 5 US- n[RSU35 M3 US:a%[RS US UR35 U$![a&n[RSUS U35 SnAMSnAff=f![a"n[RS 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 r%'_cleanup_old_segments..Nsqvvx?P?PrR)keyrr zDeleted segment: zFailed to delete segment r0 Cleaned up z old segments for zFailed to cleanup segments: )rrrsortedrrunlinkrrr6rrr=rr7)r'rr9r deleted_countsegments_to_deleterr?s r%_cleanup_old_segmentsr%>s")) ,,./(--/5PQ x=: %!),J;!7 -ONN$!Q&MLL#4WI!>? . 1  KK+m_4Fw||nU V ONN%>wir!#MNNO  3A378sBAC2!-B?0C2? C/ C*$C2*C//C22 D<DDcd[UR55nUS- n/SQn[US5nURSR U55 SSS5 [ R SU35 g!,(df  N'=f![a"n[ 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)z#EXTM3Uz#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"r{w NzCreated master playlist: Tz"Failed to create master playlist: F) rropenwriterrrrr7)r'r9 master_pathcontentfr?s r%_create_master_playlistr.fs,,./.  +s #q GGDIIg& '$  / }=> $ #  9!=>s..B!A2 B2 B<B B/ B**B/c[RS5 [RR SS9nSnUH@n[ U5nX- nUS:a'[R SUSUR35 M@MB SS K J n [R"5U"S S 9- n[RR US S9nUR5nUR!5 [R SUSUS35 SUUS.$![a0n[RSURSU35 S nAMS nAff=f![an[RSU35 eS nAff=f)z Periodic task to clean up old segment files and maintain disk space. This task removes old segment files beyond the configured retention limits for each channel. Returns: dict: Cleanup results zRunning segment cleanup taskT) is_activerr z segments for channel z'Failed to cleanup segments for channel r0N) timedelta)daysF)processed_at__lt is_availablezSegment cleanup completed: z files, z DB records)r files_deleteddb_records_deletedzSegment cleanup task failed: )rrr rr r%rr=rr7rzr1r rrcountdelete) rN total_deletedr'r#r?r1 cutoff_time old_segmentsdb_deleted_counts r%cleanup_old_segmentsr>sl+ 34??))D)9 G  5g > .  1$KK+m_6BD;> D8%D3-D;3D88D;; E#EE#c[RSU35 [RR US9n[ U5nU(a#S[ UR5URS.$[S5e![Ra' SUS3n[RU5 [U5e[an[RSU35 eS nAff=f) zz Create HLS playlists for a channel. Args: channel_id (str): UUID of the channel Returns: dict: Task result z Creating playlists for channel: rT)rrrz Failed to create master playlistrrzPlaylist creation task failed: N) rrr rrr.rLrr=rrr7)rr'rrr?s r%create_playlist_for_channelr@s 6zlCD//%%%4*'2 !'**o '   >? ?   #&zl*=  Y ""  6qc:; sA)A7, A77AC:CCc >[RS5 [RR SS9R 5n[RR [ R"5R5S9R 5nSSK J n URR [ R"5R5S9R 5nSSK J n URR [ R"5R5S 9R 5n[5nURS S UUUU[ R"5R5S .S 9 SUUUUS.$![an[R!SU35 eSnAff=f)z Send periodic status updates about system operation. This task provides regular status reports about stream processing activity and system health. Returns: dict: Status report data z!Generating periodic status reportr)r)started_at__dater)JingleDetection)detection_time__date)AdBreak)start_time__date system_alertperiodic_report) status_typersessions_todaydetections_todayad_breaks_todayrrT)rrrJrKrLzPeriodic status task failed: N)rrr rr r8r rdateapps.jingles.modelsrCrErrrrr7)rtotal_sessions_todayrCrKrErLrr?s r%send_periodic_statusrPsp- 89(//66h6GMMO,44;;%\\^002 < %'  8*2299!)!4!4!6: %'  0!//00%\\^0021 %'  34..(0#2"6$4#2%\\^557  / .2 0.     4QC89 sE1E44 F>FF)NN)rr)6__doc__rrrloggingshutilrpathlibrtypingrrrrceleryr django.utilsr django.confr modelsr r rrrapps.jingles.servicesrrapps.notifications.servicesr getLoggerrboolr&rLr@rQrmrrrrrrrrrrr%r.r>r@rPrRr%r_s   ,,! ^^A;   3 4:$::""DdO"J'9d3i6 '9 d3i J2615[ [-.[-.[ #Y [|,m,c,4,^ $A2>f3ff^af?fV2615@: @:-.@:-.@: @:J26153 3-.3-.3m 3l 4C4 4n4=4T4n XCX Xv ` `F%7% %QT%P W  F 5 5p "C" "J 7 7rR