8420cfd822
# What this PR does - Adds 10 minutes lock for acknowledge reminder task to prevent task duplicates, that causes posting multiple reminder messages and flooding in Slack threads. - Adds a new signal for acknowledge reminder task instead of using `alert_group_action_triggered_signal` since it is used only to post reminder message in Slack thread and it's not needed to be processed by other representatives ## Which issue(s) this PR closes Related to https://github.com/grafana/oncall-private/issues/2953 ## Checklist - [x] Unit, integration, and e2e (if applicable) tests updated - [x] Documentation added (or `pr:no public docs` PR label added if not required) - [x] Added the relevant release notes label (see labels prefixed w/ `release:`). These labels dictate how your PR will show up in the autogenerated release notes.
63 lines
2.4 KiB
Python
63 lines
2.4 KiB
Python
import django.dispatch
|
|
|
|
from apps.slack.representatives.alert_group_representative import AlertGroupSlackRepresentative
|
|
from apps.slack.representatives.user_representative import UserSlackRepresentative
|
|
|
|
"""
|
|
There are three entities which require sync between web, slack and telegram.
|
|
AlertGroup, AlertGroup's logs and AlertGroup's resolution notes.
|
|
"""
|
|
# Signal to create alert group message in all connected integrations (Slack, Telegram)
|
|
alert_create_signal = django.dispatch.Signal()
|
|
|
|
alert_group_created_signal = django.dispatch.Signal()
|
|
|
|
alert_group_escalation_snapshot_built = django.dispatch.Signal()
|
|
|
|
# Signal to rerender alert group in all connected integrations (Slack, Telegram) when its state is changed
|
|
alert_group_action_triggered_signal = django.dispatch.Signal()
|
|
|
|
# Signal to rerender alert group's log message in all connected integrations (Slack, Telegram)
|
|
# when alert group state is changed
|
|
alert_group_update_log_report_signal = django.dispatch.Signal()
|
|
|
|
# Signal to rerender alert group's resolution note in all connected integrations (Slack)
|
|
alert_group_update_resolution_note_signal = django.dispatch.Signal()
|
|
|
|
# Signal to post acknowledge reminder message (Slack)
|
|
post_ack_reminder_message_signal = django.dispatch.Signal()
|
|
|
|
# Currently only writes error in Slack thread while notify user. Maybe it is worth to delete it?
|
|
user_notification_action_triggered_signal = django.dispatch.Signal()
|
|
|
|
alert_create_signal.connect(
|
|
AlertGroupSlackRepresentative.on_create_alert,
|
|
)
|
|
|
|
|
|
alert_group_action_triggered_signal.connect(
|
|
AlertGroupSlackRepresentative.on_alert_group_action_triggered,
|
|
)
|
|
|
|
alert_group_update_resolution_note_signal.connect(
|
|
AlertGroupSlackRepresentative.on_alert_group_update_resolution_note,
|
|
)
|
|
|
|
post_ack_reminder_message_signal.connect(
|
|
AlertGroupSlackRepresentative.on_alert_group_post_acknowledge_reminder_message,
|
|
)
|
|
|
|
user_notification_action_triggered_signal.connect(
|
|
UserSlackRepresentative.on_user_action_triggered,
|
|
)
|
|
|
|
|
|
def integration_config_on_alert_group_created(**kwargs):
|
|
alert_group = kwargs["alert_group"]
|
|
config = alert_group.channel.config
|
|
if hasattr(config, "on_alert_group_created"):
|
|
config.on_alert_group_created(alert_group)
|
|
|
|
|
|
# using the "alert_group_escalation_snapshot_built" signal to make sure at least one alert exists for the alert group
|
|
alert_group_escalation_snapshot_built.connect(integration_config_on_alert_group_created)
|