ZɴhUSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r J r J r JrJr SSKJrJr SSKJr SSKJr SSKJr SSKrSS KJrJrJrJr SS KJrJ r "S S 5r!"S S5r"g)z Jingle Detection Services This module contains services for jingle detection, image comparison, and ad break analysis. It provides the core functionality for detecting jingles in video streams using OpenCV and managing ad break timing. N)Path)OptionalDictAnyListTuple)datetime timedelta)settings)timezone) VideoFileClip)JingleTemplateJingleDetectionAdBreakDetectionStatistics) StreamSession HLSSegmentc \rSrSrSrS\S\4SjrSSjrS\\ \\\ 44S jr S \S\\4S jr S \S \S\ 4SjrS\S\4SjrS\S\S\\ \\\ \ 44SjrS\S\\4SjrS\S\ SS4SjrSrg)JingleDetectora Service for detecting jingles in video streams using image comparison. This service extracts frames from video segments and compares them against reference jingle templates to identify advertisement breaks and program transitions. Attributes: logger (Logger): Logger instance for recording operations jingles_folder (str): Path to jingle template images iframes_folder (str): Path for temporary iframe storage similarity_threshold (float): Default similarity threshold for detection jingles_folderiframes_folderc[R"S5Ul[U5Ul[U5Ul[ RSUlUR5Ul UR5 g)z Initialize the jingle detector. Args: jingles_folder (str): Path to directory containing jingle templates iframes_folder (str): Path to directory for storing extracted frames zstream_processor.jinglesSIMILARITY_THRESHOLDN) logging getLoggerloggerrrrr JINGLE_CONFIGsimilarity_threshold_load_jingle_templatesjingle_templates_create_directories)selfrrs AC:\Users\brahi\OneDrive\Desktop\Code\src\apps\jingles\services.py__init__JingleDetector.__init__+sj''(BC #>2">2%-$:$:;Q$R!!% ; ; =   "returnNc*URUR4HCnURSSS9 URS5 URR SU35 ME g![ a'nURRSUSU35 eSnAff=f)z Create necessary directories for jingle detection operations. Creates the jingles folder and iframes folder if they don't exist, with appropriate permissions for the application. T)parentsexist_okizCreated directory: zFailed to create directory : N)rrmkdirchmodrdebugOSErrorerror)r#folderes r$r""JingleDetector._create_directoriesCs**D,?,?@F  TD 9 U# !!$7x"@A A   !!$?xr!"MN s?A!! B+"B  Bc/n[RRSS9nUHnUR5(aRUR UR UR U45 URRSUR35 MjURRSUR 35 M URRS[U5S35 U$)a/ Load jingle templates from the database and filesystem. Loads active jingle templates from the database and verifies that their corresponding image files exist on disk. Returns: List[Tuple[str, str, JingleTemplate]]: List of tuples containing (template_name, image_path, template_object) T) is_activezLoaded jingle template: z!Jingle template image not found: zLoaded z jingle templates) robjectsfilter image_existsappendslug image_pathrr/namewarninginfolen)r# templatesr!templates r$r %JingleDetector._load_jingle_templatesSs *118848H(H$$&&  MM''"  !!$"22CDEr' video_pathc n[U5RnURUS3- nURR SU35 [ 5R S5RU5R[U5SSSS9nUR"5 [[R"[URUS3- 555nURR S [U5S U35 U$![a-nURRS US U35 /sS nA$S nAff=f)aZ Extract I-frames from a video file using FFmpeg. Extracts keyframes (I-frames) from the video file and saves them as PNG images for comparison with jingle templates. Args: video_path (str): Path to the video file Returns: List[str]: List of paths to extracted frame images Raises: RuntimeError: If frame extraction fails z_%d.pngzExtracting frames from: yzselect=gt(scene\,0.10)vfrtrue)vfvsync frame_ptsz_*.pngz Extracted z frames from zError extracting frames from r,N)rstemrrr/FFmpegoptioninputoutputstrexecutesortedglobr@ Exceptionr1)r#rD video_nameoutput_patternffmpeg frame_filesr3s r$extract_iframesJingleDetector.extract_iframests( ! j)..J!00j\3IIN KK   8 E Fz"'0$   NN !3## F&;;,"K KK   3{+;*calcHist compareHistHISTCMP_BHATTACHARYYA matchTemplateTM_CCOEFF_NORMEDr/rUr1)r#r\r] start_timeimage_1image_2hist_1hist_2 hist_difftemplate_match template_diff combined_diffend_timer3s r$compare_imagesJingleDetector.compare_imagessb% Jjj.Gjj.G'/ ##&JL\\7)aS$3xHF\\7)aS$3xHF8Q8QRI!..vs?S?STUVWXYZN.M'_1DEMyy{H KK  ()>s(CD,S13  !   KK   8< = sA"D?%CD?? E1 E,,E1 iframe_pathc([RRU5(a5[R"U5 URR SU35 gg![ a+nURRSUSU35 SnAgSnAff=f)z Remove an extracted iframe file from disk. Args: iframe_path (str): Path to the iframe file to remove Returns: bool: True if file was removed successfully, False otherwise zRemoved iframe: TFzError removing iframe r,N)ospathexistsremoverr/r0r>)r#rwr3s r$ remove_iframeJingleDetector.remove_iframesy ww~~k** +& !!$4[M"BC  KK  "8 Rs K L sAA B&!B  Bts_filesessionc URRSU35 URU5nU(dURRSU35 gUHnURRSU35 URHupVnUR Xd5nURRSUSUSUS35 UR =(d UR n X:a*URR S US US35 XTX4s s $M M g![a,n URRS US U 35 Sn A MSn A ff=f) a Detect jingles in a video segment file. Extracts frames from the video segment and compares them against all loaded jingle templates to find matches. Args: ts_file (str): Path to the video segment file session (StreamSession): Stream session this segment belongs to Returns: Optional[Tuple[str, str, float, JingleTemplate]]: Tuple containing (jingle_name, iframe_path, similarity_score, template) if detected, None if no jingle is detected z)Processing segment for jingle detection: zNo frames extracted from NzAnalyzing frame: z Comparison: z vs z = rbzJingle detected: z with similarity zError comparing with template r,) rr/rZr!rurr?rUr1) r#rriframesrw jingle_namejingle_image_pathrB similarity thresholdr3s r$ detect_jingleJingleDetector.detect_jinglese EgYOP&&w/ KK   9'C D#K KK   1+? @=A *,33::#OO#%%(:%5*$',6,?'(;     7 ~F#==/+ ,,W__hG    KK   9'**RsK L sB8B<< C;+C66C;rBc:[RRUUSSSS.S9up4UR5 U(a)URR SUR 35 gg![a(nURRSU35 SnAgSnAff=f)z Update detection statistics for a template and session. Args: session (StreamSession): Stream session template (JingleTemplate): Jingle template that was detected r)total_detectionsconfirmed_detectionsfalse_positives)rrBdefaultsz%Created new detection statistics for z%Error updating detection statistics: N) rr7 get_or_createupdate_statisticsrr/r=rUr1)r#rrBstatscreatedr3s r$r&JingleDetector._update_detection_stats\s K088FF!(),-'(GNE  # # % !!$I(--"YZ K KK   EaSI J J KsA$A(( B2BB)rr!rrr)r(N)__name__ __module__ __qualname____firstlineno____doc__rQr%r"rrrr rZfloatruboolr}rrrrrrr__static_attributes__r'r$rrs #s#C#0 U3^3K-L(MB1#1$s)1f333c3e3j(7S7=7XeTWY\^cesTsNtEu7r1z1h6O1fK}KK[_Kr'rc\rSrSrSrSrS\S\\4Sjr S\S\4Sjr S\S\S\4S jr SS \ S \ S\ 4S jjrS\S\\\44S jrSrg)AdBreakAnalyzerizz Service for analyzing jingle detections to identify advertisement breaks. This service processes sequences of jingle detections to identify when advertisement breaks start and end, calculating durations and managing ad break records. c[R"S5Ul[RSUl[RSUlg)z!Initialize the ad break analyzer.zstream_processor.adbreaksMIN_AD_BREAK_DURATIONMAX_AD_BREAK_DURATIONN)rrrr r min_duration max_duration)r#s r$r%AdBreakAnalyzer.__init__s?''(CD %223JK$223JKr'rr(cURn[RRUSS9R 5nUcUR U5$UR X15$)aT Process a jingle detection to potentially create or update ad breaks. Analyzes the detection in the context of previous detections to determine if it represents the start or end of an ad break. Args: detection (JingleDetection): New jingle detection to process Returns: Optional[AdBreak]: Created or updated ad break record T)rend_time__isnull)rrr7r8first_start_ad_break _end_ad_break)r#rractive_adbreaks r$process_detection!AdBreakAnalyzer.process_detectionsh##!//!0  %'   !'' 2 2%%n@ @r'c [RRURURRR SUUR SS9nURRSUR35 U$)z Start a new advertisement break. Args: detection (JingleDetection): Detection that starts the ad break Returns: AdBreak: Created ad break record Globalactive)r channel_nameregionstart_detectionrkstatuszStarted new ad break: ) rr7rrchannelr;detection_timerr?r)r#rad_breaks r$rAdBreakAnalyzer._start_ad_breaksr??))%%"**2277% // *  1(++?@r'rcVURUR- R5nURUs=::aUR::apO OmX!lURUl[U5UlSUl UR5 URRSURSUSS35 U$X!lURUlSUlSUlSUlSUl UR5 URRSURS USS35 U$) z End an active advertisement break. Args: ad_break (AdBreak): Active ad break to end detection (JingleDetection): Detection that ends the ad break Returns: AdBreak: Updated ad break record completedzCompleted ad break: z (duration: .1fzs)NrzReset ad break: z (invalid duration: )rrk total_secondsrr end_detectionrtintduration_secondsrsaverr?rr)r#rrdurations r$rAdBreakAnalyzer._end_ad_breaks,,x/B/BBQQS    =D,=,= =%. " ) 8 8H (+H H %)HO MMO KK  &x{{m4&s^2/ &(1 $"+":":H %)H " $H (,H %&HO MMO KK  "8;;-0&&.s^27  r'rtimeout_minutesc[R"5[US9- n[RR UUSSS9nSnUHn[R"5UR - R5n/SQn[R"U5n [R"5Ul Xl SUl SUS - S S 3Ul UR5 US - nURR!S UR"SU S35 M U$)a~ Clean up ad breaks that have been active too long without ending. Finds ad breaks that have been active longer than the timeout and either completes them with estimated durations or cancels them. Args: session (StreamSession): Stream session to clean up timeout_minutes (int): Timeout in minutes for active ad breaks Returns: int: Number of ad breaks cleaned up )minutesTr)rstart_time__ltrrr)!#(-27<AFKPUZ_dinsx}rzAuto-completed after rrz minutes with estimated durationrazAuto-completed stale ad break: z with estimated duration: s)r nowr rr7r8rkrrandomchoicertrrnotesrrr?r) r#rr timeout_time stale_breaks cleaned_countrelapsedad_duration_optionsrandom_durations r$cleanup_stale_ad_breaks'AdBreakAnalyzer.cleanup_stale_ad_breakss ||~ /(JJ --'! .  $H||~(;(;;JJLG#  %mm,?@O!) H (7 %)HO4WRZ4DDdeHN MMO Q M KK  1(++?,,;+rs]  33( !( ]]9[K[K| v v r'