habsi/authentik
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

events: assign default triggers to default admin group, create default transport

Browse Source
This commit is contained in:
Jens Langhammer
2021-01-12 23:28:17 +01:00
parent b14c5039ed
commit 95c1473dd2
3 changed files with 21 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
authentik/events/forms.py
View File

@ -38,9 +38,9 @@ class NotificationTriggerForm(forms.ModelForm):
model = NotificationTrigger model = NotificationTrigger
fields = [ fields = [
"name", "name",
"group",
"transports", "transports",
"severity", "severity",
"group",
] ]
widgets = { widgets = {
"name": forms.TextInput(), "name": forms.TextInput(),

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

@ -4,7 +4,7 @@ from django.apps.registry import Apps
from django.db import migrations from django.db import migrations
from django.db.backends.base.schema import BaseDatabaseSchemaEditor from django.db.backends.base.schema import BaseDatabaseSchemaEditor
from authentik.events.models import EventAction from authentik.events.models import EventAction, TransportMode
def notify_configuration_error(apps: Apps, schema_editor: BaseDatabaseSchemaEditor): def notify_configuration_error(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
@ -18,14 +18,14 @@ def notify_configuration_error(apps: Apps, schema_editor: BaseDatabaseSchemaEdit
admin_group = Group.objects.using(db_alias).filter( admin_group = Group.objects.using(db_alias).filter(
name="authentik Admins", is_superuser=True name="authentik Admins", is_superuser=True
) ).first()
policy, _ = EventMatcherPolicy.objects.using(db_alias).update_or_create( policy, _ = EventMatcherPolicy.objects.using(db_alias).update_or_create(
name="default-match-configuration-error", name="default-match-configuration-error",
defaults={"action": EventAction.CONFIGURATION_ERROR}, defaults={"action": EventAction.CONFIGURATION_ERROR},
) )
trigger, _ = NotificationTrigger.objects.using(db_alias).update_or_create( trigger, _ = NotificationTrigger.objects.using(db_alias).update_or_create(
name="default-notify-configuration-error", defaults={"trigger": admin_group} name="default-notify-configuration-error", defaults={"group": admin_group}
) )
PolicyBinding.objects.using(db_alias).update_or_create( PolicyBinding.objects.using(db_alias).update_or_create(
target=trigger, target=trigger,
@ -47,14 +47,14 @@ def notify_update(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
admin_group = Group.objects.using(db_alias).filter( admin_group = Group.objects.using(db_alias).filter(
name="authentik Admins", is_superuser=True name="authentik Admins", is_superuser=True
) ).first()
policy, _ = EventMatcherPolicy.objects.using(db_alias).update_or_create( policy, _ = EventMatcherPolicy.objects.using(db_alias).update_or_create(
name="default-match-update", name="default-match-update",
defaults={"action": EventAction.UPDATE_AVAILABLE}, defaults={"action": EventAction.UPDATE_AVAILABLE},
) )
trigger, _ = NotificationTrigger.objects.using(db_alias).update_or_create( trigger, _ = NotificationTrigger.objects.using(db_alias).update_or_create(
name="default-notify-update", defaults={"trigger": admin_group} name="default-notify-update", defaults={"group": admin_group}
) )
PolicyBinding.objects.using(db_alias).update_or_create( PolicyBinding.objects.using(db_alias).update_or_create(
target=trigger, target=trigger,
@ -76,7 +76,7 @@ def notify_exception(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
admin_group = Group.objects.using(db_alias).filter( admin_group = Group.objects.using(db_alias).filter(
name="authentik Admins", is_superuser=True name="authentik Admins", is_superuser=True
) ).first()
policy_policy_exc, _ = EventMatcherPolicy.objects.using(db_alias).update_or_create( policy_policy_exc, _ = EventMatcherPolicy.objects.using(db_alias).update_or_create(
name="default-match-policy-exception", name="default-match-policy-exception",
@ -87,7 +87,7 @@ def notify_exception(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
defaults={"action": EventAction.PROPERTY_MAPPING_EXCEPTION}, defaults={"action": EventAction.PROPERTY_MAPPING_EXCEPTION},
) )
trigger, _ = NotificationTrigger.objects.using(db_alias).update_or_create( trigger, _ = NotificationTrigger.objects.using(db_alias).update_or_create(
name="default-notify-exception", defaults={"trigger": admin_group} name="default-notify-exception", defaults={"group": admin_group}
) )
PolicyBinding.objects.using(db_alias).update_or_create( PolicyBinding.objects.using(db_alias).update_or_create(
target=trigger, target=trigger,
@ -105,6 +105,16 @@ def notify_exception(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
) )
def transport_email_global(apps: Apps, schema_editor: BaseDatabaseSchemaEditor):
db_alias = schema_editor.connection.alias
NotificationTransport = apps.get_model("authentik_events", "NotificationTransport")
NotificationTransport.objects.using(db_alias).update_or_create(
name="default-email-transport",
defaults={"mode": TransportMode.EMAIL},
)
class Migration(migrations.Migration): class Migration(migrations.Migration):
dependencies = [ dependencies = [
@ -121,4 +131,5 @@ class Migration(migrations.Migration):
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),
] ]

2
authentik/events/models.py
View File

@ -203,6 +203,8 @@ class NotificationTransport(models.Model):
json={ json={
"body": notification.body, "body": notification.body,
"severity": notification.severity, "severity": notification.severity,
"user_email": notification.user.email,
"user_username": notification.user.username,
}, },
) )
response.raise_for_status() response.raise_for_status()