trustchain-oc1-orchestral
/
authentik
Archived
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

events: attach default transport to default triggers

This commit is contained in:
Jens Langhammer 2021-01-14 17:01:16 +01:00
parent 1342266368
commit c7d28f8ca9
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
authentik/events/migrations/0011_notification_trigger_default_v1.py
View File

@ -15,6 +15,7 @@ def notify_configuration_error(apps: Apps, schema_editor: BaseDatabaseSchemaEdit
"authentik_policies_event_matcher", "EventMatcherPolicy" "authentik_policies_event_matcher", "EventMatcherPolicy"
) )
NotificationTrigger = apps.get_model("authentik_events", "NotificationTrigger") NotificationTrigger = apps.get_model("authentik_events", "NotificationTrigger")
NotificationTransport = apps.get_model("authentik_events", "NotificationTransport")
admin_group = ( admin_group = (
Group.objects.using(db_alias) Group.objects.using(db_alias)
@ -30,6 +31,11 @@ def notify_configuration_error(apps: Apps, schema_editor: BaseDatabaseSchemaEdit
name="default-notify-configuration-error", name="default-notify-configuration-error",
defaults={"group": admin_group, "severity": NotificationSeverity.ALERT}, defaults={"group": admin_group, "severity": NotificationSeverity.ALERT},
) )
default_transport = NotificationTransport.objects.using(db_alias).get(
name="default-email-transport"
)
trigger.transports.add(default_transport)
trigger.save()
PolicyBinding.objects.using(db_alias).update_or_create( PolicyBinding.objects.using(db_alias).update_or_create(
target=trigger, target=trigger,
policy=policy, policy=policy,
@ -47,6 +53,7 @@ def notify_update(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
"authentik_policies_event_matcher", "EventMatcherPolicy" "authentik_policies_event_matcher", "EventMatcherPolicy"
) )
NotificationTrigger = apps.get_model("authentik_events", "NotificationTrigger") NotificationTrigger = apps.get_model("authentik_events", "NotificationTrigger")
NotificationTransport = apps.get_model("authentik_events", "NotificationTransport")
admin_group = ( admin_group = (
Group.objects.using(db_alias) Group.objects.using(db_alias)
@ -62,6 +69,11 @@ def notify_update(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
name="default-notify-update", name="default-notify-update",
defaults={"group": admin_group, "severity": NotificationSeverity.ALERT}, defaults={"group": admin_group, "severity": NotificationSeverity.ALERT},
) )
default_transport = NotificationTransport.objects.using(db_alias).get(
name="default-email-transport"
)
trigger.transports.add(default_transport)
trigger.save()
PolicyBinding.objects.using(db_alias).update_or_create( PolicyBinding.objects.using(db_alias).update_or_create(
target=trigger, target=trigger,
policy=policy, policy=policy,
@ -79,6 +91,7 @@ def notify_exception(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
"authentik_policies_event_matcher", "EventMatcherPolicy" "authentik_policies_event_matcher", "EventMatcherPolicy"
) )
NotificationTrigger = apps.get_model("authentik_events", "NotificationTrigger") NotificationTrigger = apps.get_model("authentik_events", "NotificationTrigger")
NotificationTransport = apps.get_model("authentik_events", "NotificationTransport")
admin_group = ( admin_group = (
Group.objects.using(db_alias) Group.objects.using(db_alias)
@ -98,6 +111,11 @@ def notify_exception(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
name="default-notify-exception", name="default-notify-exception",
defaults={"group": admin_group, "severity": NotificationSeverity.ALERT}, defaults={"group": admin_group, "severity": NotificationSeverity.ALERT},
) )
default_transport = NotificationTransport.objects.using(db_alias).get(
name="default-email-transport"
)
trigger.transports.add(default_transport)
trigger.save()
PolicyBinding.objects.using(db_alias).update_or_create( PolicyBinding.objects.using(db_alias).update_or_create(
target=trigger, target=trigger,
policy=policy_policy_exc, policy=policy_policy_exc,
@ -137,8 +155,8 @@ class Migration(migrations.Migration):
] ]
operations = [ operations = [
migrations.RunPython(transport_email_global),
migrations.RunPython(notify_configuration_error), migrations.RunPython(notify_configuration_error),
migrations.RunPython(notify_update), migrations.RunPython(notify_update),
migrations.RunPython(notify_exception), migrations.RunPython(notify_exception),
migrations.RunPython(transport_email_global),
] ]