8h9^SrSSKJrJrJr SSKJr SSKJr SSK J r SSK J r SSK Jr SSKJr SS KJr SS KJrJrJrJr SSKJr SS KJr S S KJrJrJrJrJr S SK J!r!J"r"J#r# S SK$J%r%J&r&J'r' "SS\\5r("SS\\5r)"SS\\5r*"SS\\5r+"SS\\5r,"SS\\5r-\\ \ "S/5S555r.\\ \ "S/5S555r/\\ \ "S/5S555r0"S S!\\5r1"S"S#\\5r2"S$S%\\5r3S&r4S'r5g())z Stream Management Views This module contains views for managing streaming channels, sessions, configurations, and real-time stream control operations. )renderget_object_or_404redirect)LoginRequiredMixin)login_required)require_http_methods) csrf_protect)messages) JsonResponse) reverse_lazy)ListView DetailView CreateView UpdateView)method_decorator)Channel StreamSession HLSSegmentVideoConfigurationAudioConfiguration)start_stream_capturestop_stream_capturecreate_playlist_for_channel) ChannelFormVideoConfigurationFormAudioConfigurationFormcB^\rSrSrSr\rSrSrSr Sr U4Sjr Sr U=r $) ChannelListViewzJ List view for streaming channels with filtering and search capabilities. zstreams/channel_list.htmlchannelsc[RRS5RS5nURR R S5nU(a/URUS9URUS9-URUS9-nURR R S5nUS:XaURS S 9nU$US :XaURS S 9nU$) z6Filter channels based on search and status parameters. created_byz -created_atsearch)name__icontains)slug__icontains)description__icontainsstatusactiveT is_activeinactiveF)robjectsselect_relatedorder_byrequestGETgetfilter)selfquerysetr%r)s >C:\Users\brahi\OneDrive\Desktop\Code\src\apps\streams\views.py get_querysetChannelListView.get_queryset#s??11,?HHW!!%%h/  &' & '-  H!!%%h/ X 6Hz !7Hc >[TU]"S0UD6nURRR SS5US'URRR SS5US'USHnUR 5UlM U$)z(Add additional context for the template.r%r) status_filterr!)superget_context_datar1r2r3get_active_sessionactive_session)r5kwargscontextchannel __class__s r7r@ ChannelListView.get_context_data;s'*4V4 LL,,002>#'<<#3#3#7#7"#E z*G%,%?%?%AG "+r:r>)__name__ __module__ __qualname____firstlineno____doc__rmodel template_namecontext_object_name paginate_byr8r@__static_attributes__ __classcell__rFs@r7rrs. E/M$K0  r:rc8^\rSrSrSr\rSrSrU4Sjr Sr U=r $)ChannelDetailViewHzH Detail view for individual channels with session history and controls. zstreams/channel_detail.htmlrEc \>[TU]"S 0UD6nURRR SS5R S5SSUS'URR 5US'[RR5US'[RR5US 'U$) z2Add session history and configuration information. video_config audio_config -started_atN recent_sessionsrB video_configs audio_configsr>) r?r@objectsessionsr/r0rArr.allrr5rCrDrFs r7r@"ChannelDetailView.get_context_dataQs'*4V4&*[[%9%9%H%H N& (= !#2&'!" %)KK$B$B$D !$6#=#=#A#A#C #5#=#=#A#A#C r:r>) rHrIrJrKrLrrMrNrOr@rQrRrSs@r7rUrUHs$ E1M#r:rUcH^\rSrSrSr\r\rSr \ "S5r U4Sjr Sr U=r$)ChannelCreateViewdz) Create view for new streaming channels. streams/channel_form.htmlzstreams:channel_listc>URRURl[R "URS5 [ TU]U5$)z,Set the current user as the channel creator.zChannel created successfully!)r1userinstancer$r successr? form_validr5formrFs r7rlChannelCreateView.form_validns>#'<<#4#4  'FGw!$''r:r>)rHrIrJrKrLrrMr form_classrNr success_urlrlrQrRrSs@r7rereds. EJ/M56K((r:rec>^\rSrSrSr\r\rSr Sr U4Sjr Sr U=r $)ChannelUpdateViewuz. Update view for existing streaming channels. rgcB[SSURR0S9$)z3Redirect to channel detail after successful update.streams:channel_detailpk)rC)r r_rwr5s r7get_success_url!ChannelUpdateView.get_success_url~s4dDKKNN=STTr:cd>[R"URS5 [TU]U5$)z!Add success message after update.zChannel updated successfully!r rkr1r?rlrms r7rlChannelUpdateView.form_valids('FGw!$''r:r>)rHrIrJrKrLrrMrrprNryrlrQrRrSs@r7rsrsus) EJ/MU((r:rscB^\rSrSrSr\rSrSrSr Sr U4Sjr Sr U=r $) StreamSessionListViewz> List view for stream sessions with filtering and pagination. zstreams/session_list.htmlr`r"cR[RRSSS5RS5nURR R S5nU(aURUS9nURR R S5nU(aURUS9nU$)z,Filter sessions based on channel and status.rErXrYrZ) channel_idr))r))rr.r/r0r1r2r3r4)r5r6rr)s r7r8"StreamSessionListView.get_querysets ((77 ~~ (= !  \\%%)))4 *=H!!%%h/ f5Hr:c 2>[TU]"S 0UD6n[RR SS9US'UR R RSS5US'UR R RSS5US'[RUS 'U$) zAdd filter options to context.Tr+r!rEr<channel_filterr)r=status_choicesr>) r?r@rr.r4r1r2r3rSTATUS_CHOICESrbs r7r@&StreamSessionListView.get_context_datas'*4V4%oo44t4D $(LL$4$4$8$8B$G !#'<<#3#3#7#7"#E $1$@$@ !r:r>)rHrIrJrKrLrrMrNrOrPr8r@rQrRrSs@r7rrs. E/M$K$r:rc8^\rSrSrSr\rSrSrU4Sjr Sr U=r $)StreamSessionDetailViewzF Detail view for individual stream sessions with segment information. zstreams/session_detail.htmlsessionc >[TU]"S 0UD6nURRR S5SSUS'URRR 5nUR 5US'URSS9R 5US'UR5(a,[S U55nXBS '[S U55nXRS 'U$)z'Add segment information and statistics. -processed_atNr"recent_segmentstotal_segmentsT) is_availableavailable_segmentsc3^# UH#oR(dMURv M% g7fN)duration.0segs r7 ;StreamSessionDetailView.get_context_data..s R#\\--total_durationc3^# UH#oR(dMURv M% g7fr) file_sizers r7rrsPhs--]S]]hr total_sizer>) r?r@r_segmentsr0racountr4existssum)r5rCrDrrrrFs r7r@(StreamSessionDetailView.get_context_datas'*4V4&*[[%9%9%B%B?%STWUW%X!";;''++-$,NN$4 !(0T(J(P(P(R$% ??   R RRN(6$ %PhPPJ$.L !r:r>) rHrIrJrKrLrrMrNrOr@rQrRrSs@r7rrs$ E1M#r:rPOSTc [[US9nUR5(a+[R"US5 [ SUR S9$URRS5nURRS5n[R"[UR5UUS9n[R"USUR35 URRS 5(a0UR!5 UR5n[#US UUS .5$[ SUR S9$![$aAn[R"US [U535 [ SUR S9sS nA$S nAff=f)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 idz,Channel already has an active stream sessionrvrwrXrY)rvideo_config_idaudio_config_idzStream capture started for HX-Request#streams/partials/stream_status.htmlrErBzFailed to start stream: N)rrrAr errorrrwrr3rdelaystrrrknameheadersrefresh_from_dbr Exception)r1rrErrtaskrBes r7 start_streamrsR J7G!!##w NO0WZZ@@A!,,**>:!,,**>:$))7::++  $? ~"NO ??  | , ,  # # %$779N'#H""0K  0WZZ@@ Aw":3q6( CD0WZZ@@As%CD7#D77 F6E=7F=Fc[[US9nUR5(d5[R"US5 [ SUR RS9$[R"[UR55n[R"USUR R35 URRS5(a<UR nUR!5 UR#5n[%USUUS.5$[ SUR RS9$![&aKn[R"US [U535 [ SUR RS9sS nA$S nAff=f) 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 rz Session is not currently runningrvrzStream stopped for rrrzFailed to stop stream: N)rr is_runningr rrrErwrrrrrkrrr3rrArr)r1 session_idrrrErBrs r7 stop_streamrs? *=G     w BC0W__5G5GHHI"((WZZ9$78L8L7M"NO ??  | , ,ooG  # # %$779N'#H""0K  0W__5G5GHH Iw"9#a& BC0W__5G5GHHIs&B2D+ D++ F5AE;5F;Fc[[US9nUR5(a+[R"US5 [ SUR S9$URRnUR5 [R"USUS35 [ S5$![aAn[R"US[U535 [ SUR S9sS nA$S nAff=f) 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 rz/Cannot delete a running session. Stop it first.zstreams:session_detailrz Session for z has been deletedzstreams:session_listzFailed to delete session: N) rrrr rrrrErdeleterkrr)r1rr channel_namers r7delete_sessionr0s *=Gw QR0WZZ@@ A++ L>O"PQ.// Aw"^\rSrSrSr\rSrSrSr U4Sjr Sr U=r $)ConfigurationListViewiQz8 Combined list view for video and audio configurations. zstreams/config_list.htmlconfigurationsc>[RR5$)z?Return empty queryset since we handle data in get_context_data.)rr.nonerxs r7r8"ConfigurationListView.get_querysetZs!))..00r:c >[TU]"S0UD6n[RR 5R S5US'[ RR 5R S5US'U$)z(Get both video and audio configurations.rr]r^r>)r?r@rr.rar0rrbs r7r@&ConfigurationListView.get_context_data^sb'*4V4#5#=#=#A#A#C#L#LV#T #5#=#=#A#A#C#L#LV#T r:r>) rHrIrJrKrLrrMrNrOr8r@rQrRrSs@r7rrQs) E.M*1r:rcH^\rSrSrSr\r\rSr \ "S5r U4Sjr Sr U=r$)VideoConfigurationCreateViewifz' Create view for video configurations. zstreams/video_config_form.htmlstreams:config_listcd>[R"URS5 [TU]U5$)Add success message.z)Video configuration created successfully!r|rms r7rl'VideoConfigurationCreateView.form_validp('RSw!$''r:r>)rHrIrJrKrLrrMrrprNr rqrlrQrRrSs@r7rrf. E'J4M45K((r:rcH^\rSrSrSr\r\rSr \ "S5r U4Sjr Sr U=r$)AudioConfigurationCreateViewivz' Create view for audio configurations. zstreams/audio_config_form.htmlrcd>[R"URS5 [TU]U5$)rz)Audio configuration created successfully!r|rms r7rl'AudioConfigurationCreateView.form_validrr:r>)rHrIrJrKrLrrMrrprNr rqrlrQrRrSs@r7rrvrr:rc[[US9nUUR5UR5S.n[ USU5$![ an[ SUS35sSnA$SnAff=f)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 r)rrrz$streams/partials/session_status.htmlz!
Error: z
N)rrrrrr HttpResponse)r1rrrDrs r7 stream_statusrsq K#MjA((*!,,.  gEwOO K?s&IJJKsr:r7rsdA@99=5#$$MM94^^YYNN,((,^*J8(*J("(*J(&#.#L0*> vh/A /Ad vh(I (IV vhA A<.* (#5z ( (#5z ( K4Jr: