U phI@shdZddlZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZmZmZdd lmZdd lmZmZmZmZdd lmZddl m Z ddl m!Z!ddl"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*m+Z+m,Z,m-Z-ddl.m/Z/m0Z0m1Z1ddl2m3Z3Gddde eZ4Gddde eZ5Gddde eZ6e ddZ7e ddZ8e dd Z9e d!d"Z:e d#d$Z;Gd%d&d&e eZe eed+gd,d-Z?e eed+gd.d/Z@e eed+gd0d1ZAGd2d3d3e eZBGd4d5d5e eZCGd6d7d7e eZDd8d9ZEd:d;ZFdS)|S)z(Add additional context for the template.r'r( status_filterr$)superget_context_datar0r1r2get_active_sessionactive_session)r4kwargscontextchannel __class__r6r7r<As   z ChannelListView.get_context_data) __name__ __module__ __qualname____doc__rmodel template_namecontext_object_name paginate_byr8r< __classcell__r6r6rBr7r#sr#cs,eZdZdZeZdZdZfddZZ S)ChannelDetailViewzP Detail view for individual channels with session history and controls. zstreams/channels/detail.htmlrAc s^tjf|}|jjddddd|d<|j|d<tj |d<t j |d <|S) z2Add session history and configuration information. video_config audio_config -started_atN Zrecent_sessionsr> video_configs audio_configs) r;r<objectsessionsr.r/r=rr-allrr4r?r@rBr6r7r<Ws z"ChannelDetailView.get_context_data) rDrErFrGrrHrIrJr<rLr6r6rBr7rMNs rMcs4eZdZdZeZeZdZe dZ fddZ Z S)ChannelCreateViewz1 Create view for new streaming channels. streams/channels/form.htmlzstreams:channel_listcs|jj|j_t|S)z,Set the current user as the channel creator.)r0userinstancer&r; form_validr4formrBr6r7r\ts zChannelCreateView.form_valid) rDrErFrGrrHr form_classrIr success_urlr\rLr6r6rBr7rXjs rXcCsHtt|d}|jjdd}|||r4d|jdndd}t|d|S) z3 HLS media player for live stream viewing. idr)r(z/media/streams/z/hls/index.m3u8N)rAr>hls_urlzstreams/hls_player.html)rrrUr3firstslugr)r0 channel_idrAr>r@r6r6r7hls_player_view{s rhcCstt|d}ttjd|jd}g}|rj|d}ttt |t j j dd}dd|d d D}||d }t |d |S) z9 Browse and view TS segment files for a channel. ra OUTPUT_DIRhlsz*.tsTkeyreversecSs(g|] }|tj|tj|dqS))pathnamesize)osrnbasenamegetsize.0fr6r6r7 sz#ts_file_browser..N2)rAts_fileszstreams/ts_browser.htmlrrrr STREAM_CONFIGrfexistssortedglobstrrqrngetmtimer)r0rgrAZhls_pathryZ ts_patternr@r6r6r7ts_file_browsers rcCstt|d}ttjd|jd}g}|rj|d}ttt |t j j dd}dd|d d D}||d }t |d |S) z/ View extracted iframes for a channel. rariiframesz*.pngTrkcSsg|]}|tj|dqS))rnro)rqrnrrrtr6r6r7rwsz"iframe_gallery..Nd)rA iframe_fileszstreams/iframe_gallery.htmlrz)r0rgrAZ iframes_pathrZiframe_patternr@r6r6r7iframe_gallerys rcCs0tt|d}|jjdd}||d}t|d|S)z1 Preview jingle templates for a channel. raTr*)rAjingle_templateszstreams/jingle_preview.html)rrrr3r)r0rgrArr@r6r6r7jingle_previews  rc Cstt|d}dddd}||kr(td|dkrDttjd|}n ttjd|j|||}|rt| s|td d d d d d d}|j }| |d} t |d2} t| | d} d|d| d<| W5QRSQRXdS)zB Serve media files (TS, PNG, M3U8) for the media players. )rfrjrz ../jingles)rjrjingleszInvalid file typerrizFile not foundz video/mp2tzapplication/vnd.apple.mpegurlz image/pngz image/jpeg)z.tsz.m3u8z.pngz.jpgz.jpegzapplication/octet-streamrb) content_typezinline; filename=""zContent-DispositionN)rrr rr MEDIA_ROOTr{rfr|is_filesuffixlowerr2openr read) r0Z channel_slugZ file_typefilenamerAZ file_mappings file_path content_typesfile_extrrvresponser6r6r7serve_media_files0     rcs4eZdZdZeZeZdZddZ fddZ Z S)ChannelUpdateViewz6 Update view for existing streaming channels. rYcCstdd|jjidS)z3Redirect to channel detail after successful update.streams:channel_detailpk)r?)rrTrr4r6r6r7get_success_urlsz!ChannelUpdateView.get_success_urlcst|jdt|S)z!Add success message after update.zChannel updated successfully!r successr0r;r\r]rBr6r7r\szChannelUpdateView.form_valid) rDrErFrGrrHrr_rIrr\rLr6r6rBr7rs rcs8eZdZdZeZdZdZdZddZ fddZ Z S) StreamSessionListViewzF List view for stream sessions with filtering and pagination. zstreams/sessions/list.htmlrUr%cCsVtjdddd}|jjd}|r4|j|d}|jjd}|rR|j|d}|S)z,Filter sessions based on channel and status.rArNrOrP)rgr(rc)rr-r.r/r0r1r2r3)r4r5rgr(r6r6r7r8s  z"StreamSessionListView.get_querysetc sVtjf|}tjjdd|d<|jjdd|d<|jjdd|d<tj |d <|S) zAdd filter options to context.Tr*r$rAr9Zchannel_filterr(r:Zstatus_choices) r;r<rr-r3r0r1r2rSTATUS_CHOICESrWrBr6r7r<%s  z&StreamSessionListView.get_context_data) rDrErFrGrrHrIrJrKr8r<rLr6r6rBr7r srcs,eZdZdZeZdZdZfddZZ S)StreamSessionDetailViewzN Detail view for individual stream sessions with segment information. zstreams/sessions/detail.htmlsessionc stjf|}|jjddd|d<|jj}||d<|jdd|d<|rt d d |D}||d <t d d |D}||d <|S)z'Add segment information and statistics. -processed_atNr%Zrecent_segmentstotal_segmentsT) is_availableZavailable_segmentscss|]}|jr|jVqdSN)durationrusegr6r6r7 Esz;StreamSessionDetailView.get_context_data..total_durationcss|]}|jr|jVqdSr) file_sizerr6r6r7rHs total_size) r;r<rTsegmentsr/rVcountr3r|sum)r4r?r@rrrrBr6r7r<8s  z(StreamSessionDetailView.get_context_data) rDrErFrGrrHrIrJr<rLr6r6rBr7r/s rPOSTc Cstt|d}|r.t|dtd|jdSz|jd}|jd}t j t |j ||d}t |d|j|jd r||}t|d ||d WStd|jdWStk r}z,t|d t |td|jdWYSd }~XYnXd S)z HTMX endpoint to start stream capture for a channel. Args: request: HTTP request object channel_id: ID of the channel to start streaming Returns: HttpResponse: HTML content for HTMX swap raz,Channel already has an active stream sessionrrrNrO)rgvideo_config_idaudio_config_idzStream capture started for HX-Request#streams/partials/stream_status.htmlrAr>zFailed to start stream: N)rrr=r errorrrrr2rdelayrrbrroheadersrefresh_from_dbr Exception)r0rgrArrtaskr>er6r6r7 start_streamNs0      rc Cstt|d}|s0t|dtd|jjdSznt t |j }t |d|jj |jdr|j}||}t|d||dWStd|jjdWStk r}z.t|d t |td|jjdWYSd }~XYnXd S) z HTMX endpoint to stop an active stream session. Args: request: HTTP request object session_id: ID of the session to stop Returns: HttpResponse: HTML content for HTMX swap raz Session is not currently runningrrzStream stopped for rrrzFailed to stop stream: N)rr is_runningr rrrArrrrrbrrorr2rr=rr)r0 session_idrrrAr>rr6r6r7 stop_streams&    rc Cstt|d}|r.t|dtd|jdSz.|jj}| t |d|dtdWSt k r}z,t|dt |td|jdWYSd }~XYnXd S) z Delete a stream session and all associated segments. Args: request: HTTP request object session_id: ID of the session to delete Returns: HttpResponse: Redirect to session list raz/Cannot delete a running session. Stop it first.zstreams:session_detailrz Session for z has been deletedzstreams:session_listzFailed to delete session: N) rrrr rrrbrArodeleterrr)r0rr channel_namerr6r6r7delete_sessions   rcs4eZdZdZeZdZdZddZfddZ Z S)ConfigurationListViewz@ Combined list view for video and audio configurations. zstreams/configs/list.htmlZconfigurationscCs tjS)z?Return empty queryset since we handle data in get_context_data.)rr-nonerr6r6r7r8sz"ConfigurationListView.get_querysetc s:tjf|}tjd|d<tjd|d<|S)z(Get both video and audio configurations.rorRrS)r;r<rr-rVr/rrWrBr6r7r<sz&ConfigurationListView.get_context_data) rDrErFrGrrHrIrJr8r<rLr6r6rBr7rs rcs4eZdZdZeZeZdZe dZ fddZ Z S)VideoConfigurationCreateViewz/ Create view for video configurations. zstreams/configs/video_form.htmlstreams:config_listcst|jdt|S)Add success message.z)Video configuration created successfully!rr]rBr6r7r\sz'VideoConfigurationCreateView.form_valid) rDrErFrGrrHr r_rIrr`r\rLr6r6rBr7rs rcs4eZdZdZeZeZdZe dZ fddZ Z S)AudioConfigurationCreateViewz/ Create view for audio configurations. zstreams/configs/audio_form.htmlrcst|jdt|S)rz)Audio configuration created successfully!rr]rBr6r7r\sz'AudioConfigurationCreateView.form_valid) rDrErFrGrrHr!r_rIrr`r\rLr6r6rBr7rs rc Csjz.tt|d}|||d}t|d|WStk rd}ztd|dWYSd}~XYnXdS)z HTMX endpoint for real-time stream status updates. Args: request: HTTP request object session_id: ID of the session to check Returns: HttpResponse: HTML fragment with session status ra)rrrz$streams/partials/session_status.htmlz!
Error: z
N)rrrrrrr )r0rrr@rr6r6r7 stream_statuss  rcCsPtt|d}|jd}|jdd}t|d}||}||d}t|d|S)z HTMX endpoint for paginated segment list. Args: request: HTTP request object session_id: ID of the session Returns: HttpResponse: HTML fragment with segment list rarpagerrQ)rrz"streams/partials/segment_list.html) rrrr/r1r2rget_pager)r0rrrr paginatorZ segments_pager@r6r6r7 segment_list!s    r)GrGrqr~pathlibrdjango.shortcutsrrrdjango.contrib.auth.mixinsrdjango.contrib.auth.decoratorsrdjango.views.decorators.httprdjango.views.decorators.csrfr django.contribr django.httpr r r django.urlsrZdjango.views.genericrrrrdjango.core.paginatorrdjango.utils.decoratorsr django.confrmodelsrrrrrtasksrrrformsrr r!Zapps.jingles.modelsr"r#rMrXrhrrrrrrrrrrrrrrrr6r6r6r7sj            /     -&2+