дhKISrSSKJr SSKJr SSKJr SSKJrJ r SSK J r J r J r SSKJrJrJrJrJrJrJrJrJrJrJrJrJr SSKrSSKr"S S \ \ 5r"S S \ \ 5r"S S\ \ 5r "SS\ \ \ 5r!"SS\ \ 5r"g)a Stream Models for Stream Processor Application This module contains Django models for managing streaming operations, including channel configuration, stream sessions, HLS segments, and monitoring data. These models provide the data structure for the entire stream processing workflow. )models)User)timezone)MinValueValidatorMaxValueValidator)TimestampedModel UUIDModel StatusModel) validate_hls_urlvalidate_directory_pathvalidate_name_formatvalidate_slug_formatvalidate_segment_durationvalidate_max_segmentsvalidate_retry_attemptsvalidate_video_dimensionsvalidate_video_bitratevalidate_audio_bitratevalidate_sample_ratevalidate_audio_channelsvalidate_framerateNc\rSrSrSr\R "SS\/SS9r\R"SS\ /SS9r \R"S\ /S S 9r\R"SS S 9r\R""SSS S9r\R "S\/SS 9r\R*"S\/SS9r\R*"S\/SS9r\R*"S\/SS9r\R*"S\"S5\"S5/SS9r\R>"\ \RBSSS9r""SS5r#S r$S!r%S"r&S#r'S$r(S%r)g&)'Channela Model representing a streaming channel configuration. A channel defines the source stream URL, encoding parameters, and output configuration for a specific streaming operation. Multiple stream sessions can be associated with a single channel. Attributes: name (CharField): Human-readable name for the channel slug (SlugField): URL-friendly identifier for the channel hls_url (URLField): Source HLS stream URL to capture description (TextField): Optional description of the channel is_active (BooleanField): Whether the channel is currently active output_directory (CharField): Directory path for stream output segment_duration (PositiveIntegerField): HLS segment duration in seconds max_segments (PositiveIntegerField): Maximum number of segments to keep retry_attempts (PositiveIntegerField): Number of retry attempts on failure retry_interval (PositiveIntegerField): Seconds between retry attempts created_by (ForeignKey): User who created this channel dTz#Human-readable name for the channel) max_lengthunique validators help_textz'URL-friendly identifier for the channelz Source HLS stream URL to capture)rrrz+Optional description of the channel contentblankrz(Whether this channel is currently activedefaultdb_indexrz&Directory path for stream output filesz'Duration of each HLS segment in secondsr$rr z.Maximum number of segments to keep in playlistz+Number of retry attempts on capture failurei,z&Seconds to wait between retry attemptschannelszUser who created this channel on_delete related_namerc\rSrSrSrSrS/r\R"S/S9\R"S/S9\R"S/S9/r S r g ) Channel.MetazrChannelsnameslugfields is_active created_atN __name__ __module__ __qualname____firstlineno__ verbose_nameverbose_name_pluralorderingrIndexindexes__static_attributes__r:?C:\Users\brahi\OneDrive\Desktop\Code\src\apps\streams\models.pyMetar1zsE (8 LL ) LL . LL / rFrHcUR$)z%String representation of the channel.)r4selfs rG__str__Channel.__str__s yyrFcj[RRURUR5$)z*Get the full output path for this channel.)ospathjoinoutput_directoryr5rJs rGget_output_pathChannel.get_output_paths!ww||D11499==rFc^[RRUR5S5$)z)Get the HLS output path for this channel.hls)rOrPrQrSrJs rG get_hls_pathChannel.get_hls_paths ww||D002E::rFc^[RRUR5S5$)z)Get the path to the master playlist file.z playlist.m3u8)rOrPrQrWrJs rGget_playlist_pathChannel.get_playlist_paths ww||D--/AArFcPURRSS9R5$)z9Get the currently active stream session for this channel.active)status)sessionsfilterfirstrJs rGget_active_sessionChannel.get_active_sessions#}}##8#4::<r?__doc__r CharFieldr r4 SlugFieldrr5URLFieldr hls_url TextField description BooleanFieldr8r rRPositiveIntegerFieldrsegment_durationr max_segmentsrretry_attemptsrrretry_interval ForeignKeyrCASCADE created_byrHrLrSrWrZrbrEr:rFrGrrs,   ()7  D   ();  Doo$%4G ""?K ##<I''+,:22-.; ..)*BL00+,?N 00%a(*;C*@A:N"" ..1 J  >;B=rFrc\rSrSrSr\R "SSSS9r\R "SSS S 9r\R "S S S S 9r \R"S\ "S5\ "S5/SS9r \R "SSSS 9r\R "SSSS 9r\R "SS/SQSS9r\R "SS/SQSS9r\R "SS/SQS S9r\R "S S!S"S 9r"S#S$5rS%rS&rg')(VideoConfigurationa Model for video encoding configuration parameters. This model stores video encoding settings that can be applied to stream processing operations, allowing for different quality profiles and encoding options. Attributes: name (CharField): Name for this video configuration resolution (CharField): Video resolution (e.g., "1920x1080") aspect_ratio (CharField): Video aspect ratio (e.g., "16:9") frame_rate (PositiveIntegerField): Video frame rate in FPS min_bitrate (CharField): Minimum video bitrate max_bitrate (CharField): Maximum video bitrate codec (CharField): Video codec to use preset (CharField): Encoding preset for speed/quality trade-off profile (CharField): Video profile setting level (CharField): Video level setting 2Tz!Name for this video configurationrrr1280x720z!Video resolution (width x height)rr$rr)z16:9zVideo aspect ratior+xz%Video frame rate in frames per secondr(2000kz%Minimum video bitrate (e.g., '2000k')4000kz%Maximum video bitrate (e.g., '4000k')h264))rzH.264)h265zH.265)vp9VP9zVideo codec to use for encodingrr$choicesrmedium) ) ultrafastz Ultra Fast) superfastz Super Fast)veryfastz Very Fast)fasterFaster)fastFast)rMedium)slowSlow)slowerSlower)veryslowz Very Slowz+Encoding preset for speed/quality trade-offmain))baselineBaseline)rMain)highHighzVideo profile settingz3.1z(Video level setting (e.g., '3.1', '4.0')c"\rSrSrSrSrS/rSrg)VideoConfiguration.MetaizVideo ConfigurationzVideo Configurationsr4r:Nr<r=r>r?r@rArBrEr:rFrGrHr, 48rFrHc:URSURS3$)z1String representation of the video configuration. ())r4 resolutionrJs rGrLVideoConfiguration.__str__s))Bt/q11rFr:N)r<r=r>r?rdrrer4r aspect_ratiorlrr frame_rate min_bitrate max_bitratecodecpresetprofilelevelrHrLrEr:rFrGrurusJ*   5 D!!5J ##&L ,,%a(*;C*@A9J""9K ""9K    4 E    @F" * G   < E  2rFruc\rSrSrSr\R "SSSS9r\R "SS/S QS S 9r\R "SS S S9r \R"S/SQSS9r \R"S/SQSS9r \R"SSS9r"SS5rSrSrg)AudioConfigurationi a7 Model for audio encoding configuration parameters. This model stores audio encoding settings that can be applied to stream processing operations, allowing for different audio quality profiles and encoding options. Attributes: name (CharField): Name for this audio configuration codec (CharField): Audio codec to use bitrate (CharField): Audio bitrate setting sample_rate (PositiveIntegerField): Audio sample rate in Hz channels (PositiveIntegerField): Number of audio channels normalize (BooleanField): Whether to apply audio normalization rwTz!Name for this audio configurationrxryaac))rAAC)mp3MP3)opusOpuszAudio codec to use for encodingr128kz$Audio bitrate (e.g., '128k', '256k')r{逻))i@z8 kHz)i>z16 kHz)i"Vz 22.05 kHz)iDz44.1 kHz)rz48 kHz)iwz96 kHzzAudio sample rate in Hz)r$rr))r+Mono)rStereo)r'z 5.1 SurroundzNumber of audio channelsz+Apply audio normalization (loudnorm filter)r$rc"\rSrSrSrSrS/rSrg)AudioConfiguration.MetaiUzAudio ConfigurationzAudio Configurationsr4r:Nrr:rFrGrHrUrrFrHc:URSURS3$)z1String representation of the audio configuration.rr)r4bitraterJs rGrLAudioConfiguration.__str__Zs))Bt||nA..rFr:N)r<r=r>r?rdrrer4rrrl sample_rater,rk normalizerHrLrEr:rFrGrr s"   5 D    4 E8G -- , K** -H##?I  /rFrc\rSrSrSr\R "\\RSSS9r \R "\ \RSSSS9r \R "\ \RSSS S9r\R"SSS S 9r\R"SSS S 9r\R$"S SS9r\R$"S SS9r\R*"SSS9r\R."SSSS9r\R2"\SSS9r"SS5rSrSrSrSr Sr!g) StreamSessioni_aK Model representing an active or historical stream session. A stream session tracks a specific instance of stream capture and processing, including start/end times, configuration used, and processing statistics. Attributes: channel (ForeignKey): Channel this session belongs to video_config (ForeignKey): Video configuration used audio_config (ForeignKey): Audio configuration used started_at (DateTimeField): When the session started ended_at (DateTimeField): When the session ended (if applicable) segments_processed (PositiveIntegerField): Number of segments processed errors_count (PositiveIntegerField): Number of errors encountered last_error (TextField): Last error message encountered process_id (CharField): System process ID for monitoring statistics (JSONField): Additional statistics data r_zChannel this session belongs tor-Tz)Video configuration used for this session)r.nullr"rz)Audio configuration used for this sessionzWhen the stream capture startedrr"rzWhen the stream capture endedrz)Number of segments successfully processedrz.Number of errors encountered during processingzLast error message encounteredr!rwz System process ID for monitoring)rr"rz"Additional statistics and metadata)r$r"rc\rSrSrSrSrS/r\R"SS/S9\R"S/S9\R"S/S9/r S r g ) StreamSession.MetaizStream SessionzStream Sessionsz -started_atchannelr^r6 started_atr:Nr;r:rFrGrHrsH' /!? LLH 5 6 LL / LL + rFrHchURRSURSURS3$)z,String representation of the stream session.z - rr)rr4r^rrJs rGrLStreamSession.__str__s/,,##$C }Bt6GqIIrFcUR(a6UR=(d [R"5nXR- $g)z&Calculate the duration of the session.N)rended_atrnow)rKend_times rGdurationStreamSession.durations- ??}}6 Hoo- -rFcPURS;=(a UR(+$)z*Check if the session is currently running.)r] processing)r^rrJs rG is_runningStreamSession.is_runnings{{66Lt}};LLrFc\U=RS- slXlURSS/S9 g)z6Add an error to the session and increment error count.r+ errors_count last_error update_fieldsN)rrsave)rK error_messages rG add_errorStreamSession.add_errors+ Q'  > ?rF)rN)"r<r=r>r?rdrrqrrrrruSET_NULL video_configr audio_config DateTimeFieldrrrlsegments_processedrrirre process_id JSONFielddict statisticsrHrLrrrrEr:rFrGrr_sI*..3 G$$// = L$$// = L%% 3J ## 1H 44= ..BL !!2J !!4J!!6J   JM@rFrc\rSrSrSr\R "\\RSSS9r \R"SSS9r \R"S S S9r \R"S S 9r\R"\"S 5\"S5/SS9r\R&"SSSS9r\R*"SSS9r\R."SSSS9r"SS5rSrSrSrSrSrg) HLSSegmentia Model representing an individual HLS segment file. This model tracks individual .ts segment files that make up the HLS stream, including their metadata, file paths, and processing status. Attributes: session (ForeignKey): Stream session this segment belongs to filename (CharField): Name of the segment file file_path (CharField): Full path to the segment file sequence_number (PositiveIntegerField): Sequence number in playlist duration (FloatField): Duration of the segment in seconds file_size (PositiveBigIntegerField): Size of the segment file in bytes processed_at (DateTimeField): When the segment was processed is_available (BooleanField): Whether the file is currently available segmentsz&Stream session this segment belongs tor-r&zName of the segment file)rrr zFull path to the segment filez#Sequence number in the HLS playlist)rg?gN@z"Duration of the segment in seconds)rrTz!Size of the segment file in bytesrzWhen the segment was processed) auto_now_addrz/Whether the segment file is currently availabler#c\rSrSrSrSrSS/rSS/r\R"SS/S9\R"S/S9\R"S/S9/r S r g ) HLSSegment.Metaiz HLS Segmentz HLS Segmentssessionsequence_numberr6 processed_at is_availabler:N) r<r=r>r?r@rArBunique_togetherrrCrDrEr:rFrGrHrsZ$ ,01$&78 LL,= > ? LL 0 1 LL 0 1 rFrHc`URRRSUR3$)z)String representation of the HLS segment.z - Segment )rrr4rrJs rGrLHLSSegment.__str__$s+,,&&++,K8L8L7MNNrFcT[RRUR5$)z2Check if the segment file actually exists on disk.)rOrPexists file_pathrJs rG file_existsHLSSegment.file_exists(sww~~dnn--rFcv[RRUR5$![a gf=f)z#Get the actual file size from disk.N)rOrPgetsizerOSErrorrJs rG get_file_sizeHLSSegment.get_file_size,s0 77??4>>2 2  s (+ 88c[RRUR5(a8[R"UR5 SUlUR S/S9 gg![a gf=f)z"Delete the segment file from disk.FrrT)rOrPrrremoverrrrJs rG delete_fileHLSSegment.delete_file3sk ww~~dnn-- $..)$)! (8 9 .   sA%A** A76A7)rN)r<r=r>r?rdrrqrrrrrefilenamerrlr FloatFieldrrrPositiveBigIntegerField file_sizerrrkrrHrLrrrrEr:rFrGrrs&..: G,H   1I 117O  %c*,=d,CD6H .. 5I''2L &&CL   O. rFr)#rd django.dbrdjango.contrib.auth.modelsr django.utilsrdjango.core.validatorsrrapps.core.modelsrr r apps.core.validatorsr r r rrrrrrrrrrrOjsonrrurrrr:rFrGr s+!GEE |= |=~q2)9q2hO/)9O/du@$iu@pf!9frF