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

wip

Browse Source 
Signed-off-by: Marc 'risson' Schmitt <marc.schmitt@risson.space>
This commit is contained in:
Marc 'risson' Schmitt
2025-06-04 16:54:28 +02:00
parent 86f81d92aa
commit 66f8377c79
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
authentik/crypto/tasks.py
View File

@ -6,14 +6,12 @@ from pathlib import Path
from cryptography.hazmat.backends import default_backend from cryptography.hazmat.backends import default_backend
from cryptography.hazmat.primitives.serialization import load_pem_private_key from cryptography.hazmat.primitives.serialization import load_pem_private_key
from cryptography.x509.base import load_pem_x509_certificate from cryptography.x509.base import load_pem_x509_certificate
from django.utils.translation import gettext_lazy as _
from dramatiq.actor import actor from dramatiq.actor import actor
from structlog.stdlib import get_logger from structlog.stdlib import get_logger
from authentik.crypto.models import CertificateKeyPair from authentik.crypto.models import CertificateKeyPair
from authentik.lib.config import CONFIG from authentik.lib.config import CONFIG
from authentik.tasks.middleware import CurrentTask from authentik.tasks.middleware import CurrentTask
from authentik.tasks.models import Task, TaskStatus
LOGGER = get_logger() LOGGER = get_logger()
@ -39,7 +37,7 @@ def ensure_certificate_valid(body: str):
@actor @actor
def certificate_discovery(): def certificate_discovery():
"""Discover, import and update certificates from the filesystem""" """Discover, import and update certificates from the filesystem"""
self: Task = CurrentTask.get_task() self = CurrentTask.get_task()
certs = {} certs = {}
private_keys = {} private_keys = {}
discovered = 0 discovered = 0
@ -84,6 +82,4 @@ def certificate_discovery():
dirty = True dirty = True
if dirty: if dirty:
cert.save() cert.save()
self.set_status( self.info(f"Successfully imported {discovered} files.")
TaskStatus.SUCCESSFUL, _("Successfully imported {count} files.".format(count=discovered))
)