U hQ0@sdZddlmZddlmZddlmZmZmZm Z m Z Gdddej Z Gdddej Z Gd d d ej ZGd d d ej ZGd ddej ZGdddej ZGdddejZGdddejZdS)a REST API Serializers for Streams Application This module contains Django REST Framework serializers for converting complex datatypes such as model instances to native Python datatypes that can then be easily rendered into JSON, XML or other content types. ) serializers)User)Channel StreamSession HLSSegmentVideoConfigurationAudioConfigurationc@seZdZdZGdddZdS)UserSerializerz Serializer for User model with basic information. Provides a simple representation of user data for API responses. c@s$eZdZeZdddddgZdgZdS)zUserSerializer.Metaidusernameemail first_name last_nameN)__name__ __module__ __qualname__rmodelfieldsread_only_fieldsrr@/var/www/html/JingleDetector/src/apps/streams/api/serializers.pyMetasrN)rrr__doc__rrrrrr sr c@s&eZdZdZGdddZddZdS)VideoConfigurationSerializerz Serializer for VideoConfiguration model. Handles serialization of video encoding configuration parameters for API consumption and creation. c @s8eZdZeZddddddddd d d d d g Zdd d gZdS)z!VideoConfigurationSerializer.Metar name resolution aspect_ratio frame_rate min_bitrate max_bitratecodecpresetprofilelevel created_at updated_atN)rrrrrrrrrrrr#s rcCsz|rv|d}t|dkr$tdz2t|dt|d}}|dksP|dkrTtWntk rttdYnX|S)a( Validate resolution format (WIDTHxHEIGHT). Args: value (str): Resolution string to validate Returns: str: Validated resolution Raises: ValidationError: If resolution format is invalid xz;Resolution must be in format WIDTHxHEIGHT (e.g., 1920x1080)rz/Resolution dimensions must be positive integers)splitlenrValidationErrorint ValueError)selfvaluepartswidthheightrrrvalidate_resolution,s    z0VideoConfigurationSerializer.validate_resolutionN)rrrrrr3rrrrrs rc@s&eZdZdZGdddZddZdS)AudioConfigurationSerializerz Serializer for AudioConfiguration model. Handles serialization of audio encoding configuration parameters for API consumption and creation. c @s0eZdZeZddddddddd g Zddd gZd S) z!AudioConfigurationSerializer.Metar rr bitrate sample_ratechannels normalizer$r%N)rrrrrrrrrrrrTsrcCsl|jd}|rh|ds(tdz t|dd}|dkrFtWntk rftdYnX|S)z Validate audio bitrate format. Returns: str: Validated bitrate Raises: ValidationError: If bitrate format is invalid r5kz&Bitrate must end with "k" (e.g., 128k)Nrz1Bitrate must be a positive number followed by "k")validated_datagetlowerendswithrr+r,r-)r.r5raterrrvalidate_bitrate\s  z-AudioConfigurationSerializer.validate_bitrateN)rrrrrr@rrrrr4Lsr4c@sPeZdZdZeddZeZeZ GdddZ ddZ dd Z d d Z d S) ChannelSerializerz Serializer for Channel model. Provides complete channel information including related configurations and active session status for comprehensive API responses. T read_onlyc@s@eZdZeZddddddddd d d d d dddgZdd ddgZdS)zChannelSerializer.Metar rslughls_url description is_activeoutput_directorysegment_duration max_segmentsretry_attemptsretry_interval created_byactive_sessiontotal_sessionsr$r%N)rrrrrrrrrrrrs&rcCs.|}|r*t|j|j|j|j|jdSdS)z Get active session information for the channel. Args: obj (Channel): Channel instance Returns: dict: Active session data or None )r status started_atsegments_processed errors_countN)get_active_sessionstrr rPrQrRrS)r.objrNrrrrTs z$ChannelSerializer.get_active_sessioncCs |jS)z Get total number of sessions for the channel. Args: obj (Channel): Channel instance Returns: int: Total session count )sessionscountr.rVrrrget_total_sessionss z$ChannelSerializer.get_total_sessionscCs |r|dstd|S)z Validate HLS URL format. Args: value (str): HLS URL to validate Returns: str: Validated URL Raises: ValidationError: If URL format is invalid z.m3u8zHLS URL should end with .m3u8)r=r>rr+r.r/rrrvalidate_hls_urls z"ChannelSerializer.validate_hls_urlN)rrrrr rMrSerializerMethodFieldrNrOrrTrZr\rrrrrAzs   rAc@s>eZdZdZeZeZGdddZddZ ddZ dS) HLSSegmentSerializerz Serializer for HLSSegment model. Provides segment information with file status and metadata for monitoring and debugging purposes. c @s:eZdZeZddddddddd d d g Zdddd d d gZd S) zHLSSegmentSerializer.Metar filenamesequence_numberduration file_sizefile_size_human is_available file_exists processed_atr$r%N)rrrrrrrrrrrrs(rcCs|S)z Check if the segment file exists on disk. Args: obj (HLSSegment): Segment instance Returns: bool: True if file exists, False otherwise )rerYrrrget_file_existss z$HLSSegmentSerializer.get_file_existscCsJ|jrF|j}dD](}|dkr0|dd|S|d}q|ddSdS)z Get human-readable file size. Args: obj (HLSSegment): Segment instance Returns: str: Human-readable file size )BKBMBGBg@z.1f z TBUnknown)rb)r.rVsizeunitrrrget_file_size_humans   z(HLSSegmentSerializer.get_file_size_humanN) rrrrrr]rercrrgrprrrrr^s   r^c@sleZdZdZeddZeddZeddZ e Z e Z e ZGdddZddZdd Zd d Zd S) StreamSessionSerializerz Serializer for StreamSession model. Provides comprehensive session information including channel details, configurations, statistics, and recent segments. TrBc@sHeZdZeZddddddddd d d d d ddddgZdd d d d ddgZdS)zStreamSessionSerializer.Metar channel video_config audio_configrPrQended_atra is_runningrRrS last_error process_id statisticsrecent_segmentsr$r%N)rrrrrrrrrrrrs6rcCs|}|rt|SdS)z Get session duration in seconds. Args: obj (StreamSession): Session instance Returns: int: Duration in seconds or None N)rar, total_seconds)r.rVrarrr get_durations z$StreamSessionSerializer.get_durationcCs|S)z Check if session is currently running. Args: obj (StreamSession): Session instance Returns: bool: True if running, False otherwise )rvrYrrrget_is_running*s z&StreamSessionSerializer.get_is_runningcCs"|jddd}t|ddjS)z Get recent segments for the session. Args: obj (StreamSession): Session instance Returns: list: Recent segment data z -processed_atNT)many)segmentsorder_byr^data)r.rVrzrrrget_recent_segments6s z+StreamSessionSerializer.get_recent_segmentsN)rrrrrArrrrsr4rtrr]rarvrzrr|r}rrrrrrqs     rqc@s<eZdZdZejdddZejdddZddZddZ d S) StreamStartSerializerz Serializer for stream start operation parameters. Handles validation and serialization of parameters needed to start a new stream session. FT)required allow_nullcCs$|r tjj|ds td|S)a Validate video configuration exists. Args: value (UUID): Video configuration ID Returns: UUID: Validated ID Raises: ValidationError: If configuration doesn't exist r zVideo configuration not found)robjectsfilterexistsrr+r[rrrvalidate_video_config_idOs z.StreamStartSerializer.validate_video_config_idcCs$|r tjj|ds td|S)a Validate audio configuration exists. Args: value (UUID): Audio configuration ID Returns: UUID: Validated ID Raises: ValidationError: If configuration doesn't exist rzAudio configuration not found)rrrrrr+r[rrrvalidate_audio_config_idcs z.StreamStartSerializer.validate_audio_config_idN) rrrrr UUIDFieldvideo_config_idaudio_config_idrrrrrrrDs rc@sLeZdZdZeZeZeZeZ e Z eZ ej ddZdS)ChannelStatsSerializerz Serializer for channel statistics data. Provides aggregated statistics for channel performance and usage metrics. T)rN)rrrrr IntegerFieldrOactive_sessionstotal_segmentstotal_duration FloatField success_rateavg_session_duration DateTimeFieldlast_session_atrrrrrxsrN)rrest_frameworkrdjango.contrib.auth.modelsrapps.streams.modelsrrrrrModelSerializerr rr4rAr^rq Serializerrrrrrrs   1.L7G4