6ӴhISrSSKJr SSKJr SSKJr SSKJrJ r SSK J r J r J r SSKJrJrJrJrJrJr SSKr"S S \ \ 5r"S S \ \ 5r"S S\ \ \ 5r"SS\ \ 5rg)a Notification Models for Stream Processor Application This module contains Django models for managing notifications, including Telegram messages, email alerts, and other notification channels. These models track notification history, delivery status, and configuration settings. )models)User)timezone)MinValueValidatorMaxValueValidator)TimestampedModel UUIDModel StatusModel)validate_name_formatvalidate_json_configurationvalidate_webhook_configvalidate_email_configvalidate_telegram_configvalidate_template_contentNc\rSrSrSr\R "SS\/SS9r/SQr \R "S\ S S 9r \R"SSS S 9r \R"\S S9r\R "S\"S5\"S5/SS9r\R "S\"S5\"S5/SS9r\R "S\"S5\"S5/SS9r\R,"\\R0SSS9r"SS5rS rS!rS"rS#rS$rg%)&NotificationChannela  Model representing a notification delivery channel. Notification channels define how and where notifications should be sent, including configuration for different service types like Telegram, email, webhooks, and other messaging platforms. Attributes: name (CharField): Human-readable name for the channel channel_type (CharField): Type of notification channel is_active (BooleanField): Whether the channel is currently active configuration (JSONField): Channel-specific configuration data rate_limit (PositiveIntegerField): Maximum messages per minute retry_attempts (PositiveIntegerField): Number of retry attempts timeout_seconds (PositiveIntegerField): Timeout for delivery attempts created_by (ForeignKey): User who created this channel dTz0Human-readable name for the notification channel) max_lengthunique validators help_text))telegramz Telegram Bot)emailEmail)webhookWebhook)slackSlack)discordDiscord)smsSMSzType of notification channelrchoicesrz+Whether this notification channel is activedefaultdb_indexrz)Channel-specific configuration parametersr(riz%Maximum number of messages per minuter(rrr z.Number of retry attempts for failed deliveriesi,z(Timeout for delivery attempts in secondsnotification_channelsz*User who created this notification channel on_delete related_namercf\rSrSrSrSrS/r\R"S/S9\R"S/S9/r Sr g ) NotificationChannel.MetaizNotification ChannelzNotification Channelsname channel_typefields is_activeN __name__ __module__ __qualname____firstlineno__ verbose_nameverbose_name_pluralorderingrIndexindexes__static_attributes__r=EC:\Users\brahi\OneDrive\Desktop\Code\src\apps\notifications\models.pyMetar6is8- 58 LL 0 1 LL . rIrKc:URSURS3$)z2String representation of the notification channel. ())r8r9selfs rJ__str__NotificationChannel.__str__rs ))Bt00133rIcURS:Xa9URRSS5URRSS5S.$0$)z$Get Telegram-specific configuration.r bot_tokenchat_id)rTrVr9 configurationgetrOs rJget_telegram_config'NotificationChannel.get_telegram_configvsM    *!//33KD--11)R@  rIcURS:Xa9URRS/5URRSS5S.$0$)z!Get email-specific configuration.r recipientssubject_prefixz[Stream Processor])r]r^rWrOs rJget_email_config$NotificationChannel.get_email_configsO    '"0044\2F"&"4"4"8"89IK_"`  rIcURS:XaTURRSS5URRS05URRSS5S.$0$)z#Get webhook-specific configuration.rurlrUheadersmethodPOST)rbrcrdrWrOs rJget_webhook_config&NotificationChannel.get_webhook_configsc    )))--eR8--11)R@,,006B   rIr=N) r?r@rArB__doc__r CharFieldr r8 CHANNEL_TYPESr9 BooleanFieldr< JSONFielddictrXPositiveIntegerFieldrr rate_limitretry_attemptstimeout_seconds ForeignKeyrCASCADE created_byrKrQrZr_rfrHr=rIrJrrs>&   ()D  DM##0L##?I$$=M ,,%a(*;D*AB9J 00%a(*;B*?@BN 11%a(*;C*@A<O"" ..,> J  4rIrc:\rSrSrSr\R "SSSS9r/SQr\R "S\S S 9r \R "S SS S 9r \R"SS9r \R"SSSS9r\R"\SS9r\R"\SS9r"SS5rSrSrSrSrg)NotificationTemplatea Model for notification message templates. Templates define reusable message formats for different types of notifications, allowing for consistent messaging and easy customization of notification content. Attributes: name (CharField): Name for the template template_type (CharField): Type of notification this template is for subject_template (CharField): Subject line template (for email) message_template (TextField): Main message content template is_active (BooleanField): Whether the template is active variables (JSONField): Available template variables channel_types (JSONField): Compatible channel types rTz#Name for this notification templaterrr)jingle_detectedzJingle Detectedad_break_startedzAd Break Startedad_break_endedzAd Break Endedstream_startedzStream Startedstream_stoppedzStream Stopped stream_errorz Stream Error) system_alertz System Alert) health_checkz Health Checkr+z2Type of notification this template is designed forr%z4Subject line template (used for email notifications)rblankrz8Main message content template with variable placeholdersrz'Whether this template is active for user'z-List of available variables for this templater*z-List of compatible notification channel typesch\rSrSrSrSrSS/r\R"S/S9\R"S/S9/r Sr g ) NotificationTemplate.MetazNotification TemplatezNotification Templates template_typer8r:r<r=Nr>r=rIrJrKrs;. 6#V, LL 1 2 LL . rIrKc:URSURS3$)z3String representation of the notification template.rMrN)r8rrOs rJrQNotificationTemplate.__str__s ))Bt112!44rIctURR"S0UD6$![anSU3sSnA$SnAff=f)z Render the message template with provided context variables. Args: context (dict): Variables to substitute in the template Returns: str: Rendered message content z!Template error: Missing variable Nr=)message_templateformatKeyErrorrPcontextes rJrender_message#NotificationTemplate.render_messages> ;((//:': : ;6qc: : ;s 7277cUR(dSURS3$URR"S0UD6$![anSU3sSnA$SnAff=f)z Render the subject template with provided context variables. Args: context (dict): Variables to substitute in the template Returns: str: Rendered subject line [z] Notificationz Subject error: Missing variable Nr=)subject_templaterrrrs rJrender_subject#NotificationTemplate.render_subjects_$$t))*.9 9 :((//:': : :5aS9 9 :s? A A AAr=N)r?r@rArBrhrrir8TEMPLATE_TYPESrr TextFieldrrkr<rllist variables channel_typesrKrQrrrHr=rIrJrvrvs$   7 D N$$FM''H ''L ##;I  AI $$AM   5 ;:rIrvc \rSrSrSr\R "\\RSSS9r \R "\ \RSSSSS9r \R"S S S 9r\R"S SS S 9r\R "SS9r\R$"\SSS9r\R*"\R.SS9r\R*"SSSS9r\R4"SSS9r\R "SSS9r\R"SSSS 9r"SS5rSrSr S r!S!r"S'S#jr#S$r$S%r%S&r&g")( Notificationi a Model representing an individual notification instance. This model tracks individual notification messages that have been sent or are pending delivery, including their content, delivery status, and any error information. Attributes: channel (ForeignKey): Notification channel to use for delivery template (ForeignKey): Template used for this notification recipient (CharField): Target recipient identifier subject (CharField): Notification subject line message (TextField): Notification message content context_data (JSONField): Variables used for template rendering scheduled_at (DateTimeField): When the notification should be sent sent_at (DateTimeField): When the notification was actually sent delivery_attempts (PositiveIntegerField): Number of delivery attempts error_message (TextField): Last error message if delivery failed external_id (CharField): External service message ID notificationsz(Notification channel to use for deliveryr2Tz+Template used to generate this notification)r3nullrr4rrz2Target recipient identifier (email, chat ID, etc.))rrzNotification subject linerzNotification message contentrz%Variables used for template rendering)r(rrz%When this notification should be sentr*z(When this notification was actually sentrrrrz Number of delivery attempts madez%Last error message if delivery failed)rrrz(External service message ID for trackingc\rSrSrSrSrS/r\R"SS/S9\R"S/S9\R"S /S9\R"S/S9/r S r g ) Notification.Metaicr Notificationsz -scheduled_atchannelstatusr: scheduled_atsent_atr=Nr>r=rIrJrKrcsX% -#$ LLH 5 6 LL 0 1 LL , LL +  rIrKcxURRSUR=(d URSS3$)z*String representation of the notification.z - N2)rr8subjectmessagerOs rJrQNotification.__str__ns3,,##$C (I Sb8I'JKKrIcPURS:H=(a UR(+$)z.Check if the notification is pending delivery.pendingrrrOs rJ is_pendingNotification.is_pendingrs{{i'< ,<r=rIrJrKrsH* 2( LL / LL . LL - rIrKc:URSURS3$)z/String representation of the notification rule.rMrN)r8rrOs rJrQNotificationRule.__str__s))Bt/q11rIcUR(dgUR(dg[R"5UR- nUR 5UR S-:$)z7Check if the rule can be triggered based on throttling.FT<)r<last_triggeredrr total_secondsthrottle_minutes)rPtime_since_lasts rJ can_triggerNotificationRule.can_triggersM~~""",,.4+>+>>,,.43H3H23MNNrIcX[R"5UlURS/S9 g)z0Mark the rule as triggered and update timestamp.rrN)rrrrrOs rJmark_triggeredNotificationRule.mark_triggered s"&lln !1 2 3rIcUR(dgURR5Hup#X!;a gXU:wdM g g)z Check if event data meets the rule conditions. Args: event_data (dict): Event data to check against conditions Returns: bool: True if conditions are met, False otherwise TF) conditionsitems)rP event_datakeyexpected_values rJcheck_conditions!NotificationRule.check_conditionssE$(??#8#8#: C$.0 $; rI)rN)#r?r@rArBrhrrir8 EVENT_TYPESrrrrrsrrvrrkr<rlrmrrnrrrrr IntegerFieldrrKrQrrrrHr=rIrJrrs9(   3 D K!!FJ..> G  ..? H##<I !!IJ 22%a(*;D*ABH )) 5N ""QH   2 O4 rIr)rh django.dbrdjango.contrib.auth.modelsr django.utilsrdjango.core.validatorsrrapps.core.modelsrr r apps.core.validatorsr r r rrrjsonrrvrrr=rIrJrsv+!GEE z*Izzs:+Ys:lI #Y I XN'NrI