U h5U @szdZddlmZmZmZddlmZddlmZddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZmZmZmZdd lmZdd lmZmZmZmZdd lm Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/m0Z0ddl1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z9m:Z:m;Z;mZ>m?Z?Gddde Z@eedde"e#e$e%ge(dgdedde(dgdedddgdedd dgded!d"dgded#d$dgdd%Gd&d'd'ejAZBeed(d)e"e#e&e'gd*gd+ed,d-d*gded.d/d*gded0d1d*gded2d3d*gded4d5d*gdd%Gd6d7d7ejAZCeed8d9e"e#gd:gd+ed;dd?d?ejDZEeed@dAe"e#gdBgd+edCdDdBgdedEdFdBgdedGdHdBgdedIdJdBgdedKdLdBgdd%GdMdNdNejAZFeedOdPe"e#gdBgd+edQdRdBgdedSdTdBgdedUdVdBgdedWdXdBgdedYdZdBgdd%Gd[d\d\ejAZGd]S)^z REST API Views for Streams Application This module contains Django REST Framework views for managing streaming channels, sessions, configurations, and related operations through a RESTful API interface. )viewsetsstatus permissions)action)Response)PageNumberPagination)UserRateThrottle)DjangoFilterBackend)get_object_or_404)timezone)CountSumAvgQ) timedelta) extend_schemaextend_schema_viewOpenApiParameterOpenApiExample) OpenApiTypes) PAGINATION_PARAMETERSORDERING_PARAMETERSEARCH_PARAMETERCHANNEL_STATUS_PARAMETERSESSION_STATUS_PARAMETERCHANNEL_FILTER_PARAMETERCHANNEL_EXAMPLESSUCCESS_EXAMPLESERROR_EXAMPLES)Channel StreamSession HLSSegmentVideoConfigurationAudioConfiguration)start_stream_capturestop_stream_capturecreate_playlist_for_channel)StreamControlThrottleDetectionAPIThrottle)ChannelSerializerStreamSessionSerializerHLSSegmentSerializerVideoConfigurationSerializerAudioConfigurationSerializerChannelStatsSerializerStreamStartSerializerc@seZdZdZdZdZdZdS)StandardResultsSetPaginationz Standard pagination configuration for API responses. Provides consistent pagination across all API endpoints with configurable page sizes and metadata.  page_sizedN)__name__ __module__ __qualname____doc__r2page_size_query_param max_page_sizer:r::/var/www/html/JingleDetector/src/apps/streams/api/views.pyr0%sr0z List channelsz/Retrieve a paginated list of streaming channelsChannels)summary description parametersexamplestagszCreate channelzCreate a new streaming channel)r=r>r@rAz Get channelz!Retrieve a specific channel by ID)r=r>rAzUpdate channelzUpdate an existing channelzPartially update channelz$Partially update an existing channelzDelete channelz(Delete a channel and all associated data)listcreateretrieveupdatepartial_updatedestroyc @sZeZdZdZejdZe Z e j gZ eZegZddgZdddgZdddgZd gZd d Zed d eedddddddededddgdeddgegdd3ddZedd ed!ededddgd"eddgegdd4d#d$Zed%d&e edd'dgd"edd(gd)d5d*d+Z!ed,d-d.e dd/idgd"ed0d(gd)d1d2Z"dS)6ChannelViewSetz ViewSet for managing streaming channels via REST API. Provides CRUD operations for channels along with custom actions for starting/stopping streams and retrieving statistics. created_by is_activenameslugr> created_at updated_atz -created_atcCs|j|jjddS)z Set the current user as the channel creator. Args: serializer: Channel serializer instance )rIN)saverequestuser)self serializerr:r:r;perform_createfszChannelViewSet.perform_createzStart stream capturezTStart stream capture for a specific channel with optional video/audio configurationszStream StartedTzStream started for News Channelzabc123-def456-ghi789z$f47ac10b-58cc-4372-a567-0e02b2c3d479successmessagetask_id channel_id)valuevalidation_error not_foundiir<)r=r>rP responsesrApost)detailmethodsthrottle_classesNc Cs|}|r"tdditjdSt|jd}|sFt|jtjdSzxt j t |j |j drpt |j dnd|j drt |j dndd}td d |j|j t |j d tjdWStk r}ztdt |itjdWYSd}~XYnXdS) a Start stream capture for a specific channel. Args: request: HTTP request with optional configuration IDs pk: Channel primary key Returns: Response: Success/error response with task information errorz,Channel already has an active stream sessionr)datavideo_config_idNaudio_config_id)rYrgrhTzStream started for rU) get_objectget_active_sessionrrHTTP_400_BAD_REQUESTr/rfis_validerrorsr$delaystridvalidated_datagetrKHTTP_202_ACCEPTED ExceptionHTTP_500_INTERNAL_SERVER_ERROR)rRrPpkchannelrStasker:r:r; start_streamos>   zChannelViewSet.start_streamzStop stream capturez1Stop active stream capture for a specific channel task_startedr=r>r_rAc Cs|}|}|s&tdditjdSz:tt|j}tdd|j |jt|jdtj dWSt k r}ztdt|itj dWYSd}~XYnXdS)z Stop active stream for a specific channel. Args: request: HTTP request pk: Channel primary key Returns: Response: Success/error response with task information rdz/No active stream session found for this channelreTStream stopped for )rVrWrX session_idN) rirjrrrkr%rnrorprKrsrtru)rRrPrvrwactive_sessionrxryr:r:r; stop_streams,  zChannelViewSet.stop_streamzGet channel statisticszjRetrieve detailed statistics for a specific channel including session counts, durations, and success rates)irrrarbc Cs|}|j}tjj|d}|}|jddgd}|dkrP||dnd}|jdd} d} g} | D].} | rlt|  } | | 7} | | ql| rt | t | nd}||jddgd|| t |d t||r|d jnd d }t|}t|jS) z Get detailed statistics for a specific channel. Args: request: HTTP request pk: Channel primary key Returns: Response: Channel statistics data )session__channel completedactive status__inrr3re processing -started_atN)total_sessionsactive_sessionstotal_segmentstotal_duration success_rateavg_session_durationZlast_session_at)risessionsallr!objectsfiltercountdurationint total_secondsappendsumlenroundexistsorder_byfirst started_atr.rrf)rRrPrvrwrsegmentsrZsuccessful_sessionsrZcompleted_sessionsrZsession_durationssessionduration_secondsr stats_datarSr:r:r; statisticss6     zChannelViewSet.statisticszGet active channelsz@Retrieve all channels that currently have active stream sessionsrmanyFcCs.|jjddgd}|j|dd}t|jS)z Get all channels with active streams. Args: request: HTTP request Returns: Response: List of channels with active sessions rr)Zsessions__status__inTr)querysetrdistinctget_serializerrrf)rRrPZactive_channelsrSr:r:r;r s  zChannelViewSet.active)N)N)N)#r4r5r6r7rrrselect_relatedrr)serializer_classrIsAuthenticatedpermission_classesr0pagination_classr filter_backendsfilterset_fields search_fieldsordering_fieldsorderingrTrr/rrrr'rzrrr.rrr:r:r:r;rH1sv$     1 % 2  rHzList stream sessionsz,Retrieve a paginated list of stream sessionsSessions)r=r>r?rAzCreate stream sessionzCreate a new stream sessionzGet stream sessionz(Retrieve a specific stream session by IDzUpdate stream sessionz!Update an existing stream sessionzPartially update stream sessionz+Partially update an existing stream sessionzDelete stream sessionz/Delete a stream session and all associated datac@seZdZdZejdddZe Z e j gZ eZegZddgZdddgZdgZed d ed ed ed ddgdeddgdd"ddZeddededdidgdeddgdd#ddZeddgdd d!ZdS)$StreamSessionViewSetz ViewSet for managing stream sessions via REST API. Provides CRUD operations for sessions along with custom actions for stopping sessions and retrieving segments. rw video_config audio_configrrended_atrzStop stream sessionz%Stop a specific active stream sessionr{r[r\r]rr|Tr`rNc Cs|}|s"tdditjdSz4tt|j}tdd|j j |jdtj dWSt k r}ztdt|itj dWYSd}~XYnXdS)z Stop a specific stream session. Args: request: HTTP request pk: Session primary key Returns: Response: Success/error response with task information rdz Session is not currently runningreTr})rVrWrXN)ri is_runningrrrkr%rnrorprwrKrsrtru)rRrPrvrrxryr:r:r;stopms(  zStreamSessionViewSet.stopzGet session segmentsz3Retrieve HLS segments for a specific stream sessionrr)r=r>r?r_rArrcCs^|}|jd}|}|||}|dk rHt|dd}||jSt|dd}t|jS)a Get segments for a specific session. Args: request: HTTP request with optional pagination pk: Session primary key Returns: Response: Paginated list of session segments -processed_atNTr) rirrrpaginate_querysetr+get_paginated_responserfr)rRrPrvrr paginatorpagerSr:r:r;rs     zStreamSessionViewSet.segmentsFcCs*|jjddgd}|j|dd}t|jS)z Get all active stream sessions. Args: request: HTTP request Returns: Response: List of active sessions rrrTr)rrrrrf)rRrPrrSr:r:r;rs zStreamSessionViewSet.active)N)N)r4r5r6r7r rrrrr*rrrrr0rr rrrrrrrrrrr+rrr:r:r:r;r9sF"   #   rzList HLS segmentsz=Retrieve a paginated list of HLS segments across all sessionsSegmentszGet HLS segmentz%Retrieve a specific HLS segment by ID)rBrDc@s~eZdZdZejdZe Z e j gZ eZegZddgZddgZdgZedd d e d d id gdeddgdddZdS)HLSSegmentViewSetz ViewSet for HLS segments (read-only). Provides read-only access to segment information for monitoring and debugging purposes. rr is_available processed_atsequence_numberrzGet recent segmentszHRetrieve the 50 most recently processed HLS segments across all sessionsrTrrr|FrrrcCs,|jddd}|j|dd}t|jS)z Get recently processed segments across all sessions. Args: request: HTTP request Returns: Response: List of recent segments rN2Tr)rrrrrf)rRrPrecent_segmentsrSr:r:r;recentszHLSSegmentViewSet.recentN)r4r5r6r7r!rrrrr+rrrrr0rr rrrrrrrr:r:r:r;rs"  rzList video configurationsz0Retrieve a list of video encoding configurationsConfigurationszCreate video configurationz)Create a new video encoding configurationzGet video configurationz-Retrieve a specific video configuration by IDzUpdate video configurationz&Update an existing video configurationz$Partially update video configurationz0Partially update an existing video configurationzDelete video configurationzDelete a video configurationc@s8eZdZdZejZeZ e j gZ e ZddgZdgZdS)VideoConfigurationViewSetz ViewSet for video encoding configurations. Provides CRUD operations for video encoding presets that can be used with stream sessions. rKrMN)r4r5r6r7r"rrrr,rrrrr0rrrr:r:r:r;rs" rzList audio configurationsz0Retrieve a list of audio encoding configurationszCreate audio configurationz)Create a new audio encoding configurationzGet audio configurationz-Retrieve a specific audio configuration by IDzUpdate audio configurationz&Update an existing audio configurationz$Partially update audio configurationz0Partially update an existing audio configurationzDelete audio configurationzDelete an audio configurationc@s8eZdZdZejZeZ e j gZ e ZddgZdgZdS)AudioConfigurationViewSetz ViewSet for audio encoding configurations. Provides CRUD operations for audio encoding presets that can be used with stream sessions. rKrMN)r4r5r6r7r#rrrr-rrrrr0rrrr:r:r:r;r4s" rN)Hr7rest_frameworkrrrrest_framework.decoratorsrrest_framework.responserZrest_framework.paginationrZrest_framework.throttlingrZdjango_filters.rest_frameworkr django.shortcutsr django.utilsr django.db.modelsr r rrdatetimerdrf_spectacular.utilsrrrrdrf_spectacular.typesrZ core.schemarrrrrrrrrZapps.streams.modelsrr r!r"r#apps.streams.tasksr$r%r&apps.core.throttlingr'r(Zapps.streams.api.serializersr)r*r+r,r-r.r/r0 ModelViewSetrHrReadOnlyModelViewSetrrrr:r:r:r;sV         ,$  #f !u '!!