AuditLogProjector::applyAuditableEvent() - Code Metrics - OpenConext/Stepup-Middleware - Measure and Improve Code Quality continuously with Scrutinizer

AuditLogProjector::applyAuditableEvent() C
last analyzed 2025-09-30 14:23 UTC

↳ Parent: AuditLogProjector
Complexity

Conditions	12
Paths	257
Size

Total Lines	63
Code Lines	35
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	12
eloc	35
nc	257
nop	2
dl	0
loc	63
rs	5.4208
c	0
b	0
f	0
How to fix Long Method Complexity

<?php

/**
 * Copyright 2014 SURFnet bv
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */


namespace Surfnet\StepupMiddleware\ApiBundle\Identity\Projector;

use Broadway\Domain\DomainMessage;
use DateTime as CoreDateTime;
use Ramsey\Uuid\Uuid;
use Surfnet\Stepup\DateTime\DateTime;
use Surfnet\Stepup\Identity\AuditLog\Metadata;
use Surfnet\Stepup\Identity\Event\AuditableEvent;
use Surfnet\Stepup\Identity\Event\CompliedWithRecoveryCodeRevocationEvent;
use Surfnet\Stepup\Identity\Event\IdentityForgottenEvent;
use Surfnet\Stepup\Identity\Event\RecoveryTokenRevokedEvent;
use Surfnet\Stepup\Identity\Value\CommonName;
use Surfnet\Stepup\Identity\Value\Institution;
use Surfnet\Stepup\Identity\Value\RecoveryTokenIdentifierFactory;
use Surfnet\Stepup\Identity\Value\RecoveryTokenType;
use Surfnet\Stepup\Identity\Value\VettingType;
use Surfnet\Stepup\Projector\Projector;
use Surfnet\StepupMiddleware\ApiBundle\Exception\RuntimeException;
use Surfnet\StepupMiddleware\ApiBundle\Identity\Entity\AuditLogEntry;
use Surfnet\StepupMiddleware\ApiBundle\Identity\Entity\Identity;
use Surfnet\StepupMiddleware\ApiBundle\Identity\Repository\AuditLogRepository;
use Surfnet\StepupMiddleware\ApiBundle\Identity\Repository\IdentityRepository;

/**
 * @SuppressWarnings(PHPMD.CouplingBetweenObjects)
 */

class AuditLogProjector extends Projector
{
    public function __construct(
        private readonly AuditLogRepository $auditLogRepository,
        private readonly IdentityRepository $identityRepository,
    ) {
    }

    /**
     * @param DomainMessage $domainMessage
     */

    public function handle(DomainMessage $domainMessage): void
    {
        $event = $domainMessage->getPayload();

        switch (true) {
            case $event instanceof IdentityForgottenEvent:

                // Don't insert the IdentityForgottenEvent into the audit log, as we'd remove it immediately afterwards.
                $this->applyIdentityForgottenEvent($event);
                break;
            // Finally apply the auditable event, most events are auditable this so first handle the unique variants
            case $event instanceof AuditableEvent:

                $this->applyAuditableEvent($event, $domainMessage);
                break;
        }
    }

    /**

     * @SuppressWarnings(PHPMD.CyclomaticComplexity)
     * @SuppressWarnings(PHPMD.NPathComplexity)
     */

    private function applyAuditableEvent(AuditableEvent $event, DomainMessage $domainMessage): void

    {
        $auditLogMetadata = $event->getAuditLogMetadata();

        $metadata = $domainMessage->getMetadata()->serialize();
        $entry = new AuditLogEntry();
        $entry->id = (string)Uuid::uuid4();

        if (isset($metadata['actorId'])) {
            $actor = $this->identityRepository->find($metadata['actorId']);

            if (!$actor instanceof Identity) {
                throw new RuntimeException(
                    sprintf(
                        'Cannot create AuditLogEntry, given Actor Identity "%s" does not exist',
                        $metadata['actorId'],
                    ),
                );
            }

            $entry->actorId = $metadata['actorId'];
            $entry->actorCommonName = $actor->commonName;
        }

        $this->augmentActorCommonName($entry, $auditLogMetadata);

        if (isset($metadata['actorInstitution'])) {
            $entry->actorInstitution = new Institution($metadata['actorInstitution']);
        }

        $entry->identityId = (string)$auditLogMetadata->identityId;
        $entry->identityInstitution = $auditLogMetadata->identityInstitution;
        $entry->event = $event::class;
        $entry->recordedOn = new DateTime(new CoreDateTime($domainMessage->getRecordedOn()->toString()));

        if ($auditLogMetadata->secondFactorId instanceof \Surfnet\Stepup\Identity\Value\SecondFactorId) {
            $entry->secondFactorId = (string)$auditLogMetadata->secondFactorId;
        }

        if ($auditLogMetadata->secondFactorType instanceof \Surfnet\StepupBundle\Value\SecondFactorType) {
            $entry->secondFactorType = (string)$auditLogMetadata->secondFactorType;
        }

        if (!$event instanceof RecoveryTokenRevokedEvent
            && !$event instanceof CompliedWithRecoveryCodeRevocationEvent
            && $auditLogMetadata->recoveryTokenId
        ) {
            $entry->recoveryTokenIdentifier = (string)$auditLogMetadata->recoveryTokenId;
        }

        if ($auditLogMetadata->recoveryTokenType instanceof \Surfnet\Stepup\Identity\Value\RecoveryTokenType) {
            $entry->recoveryTokenType = (string)$auditLogMetadata->recoveryTokenType;
        }

        if ($auditLogMetadata->secondFactorIdentifier instanceof \Surfnet\Stepup\Identity\Value\SecondFactorIdentifier) {
            $entry->secondFactorIdentifier = (string)$auditLogMetadata->secondFactorIdentifier;
        }

        if ($auditLogMetadata->raInstitution instanceof \Surfnet\Stepup\Identity\Value\Institution) {
            $entry->raInstitution = (string)$auditLogMetadata->raInstitution;
        }

        $this->auditLogRepository->save($entry);
    }

    protected function applyIdentityForgottenEvent(IdentityForgottenEvent $event): void
    {
        $entries = $this->auditLogRepository->findByIdentityId($event->identityId);
        foreach ($entries as $auditLogEntry) {
            $auditLogEntry->actorCommonName = CommonName::unknown();

            if ($auditLogEntry->recoveryTokenIdentifier) {
                $auditLogEntry->recoveryTokenIdentifier = RecoveryTokenIdentifierFactory::unknownForType(
                    new RecoveryTokenType($auditLogEntry->recoveryTokenType),
                );
            }
        }

        $entriesWhereActor = $this->auditLogRepository->findEntriesWhereIdentityIsActorOnly($event->identityId);
        foreach ($entriesWhereActor as $auditLogEntry) {
            $auditLogEntry->actorCommonName = CommonName::unknown();
        }

        $this->auditLogRepository->saveAll($entries);
        $this->auditLogRepository->saveAll($entriesWhereActor);
    }

    private function augmentActorCommonName(AuditLogEntry $entry, Metadata $auditLogMetadata): void

    {
        if (property_exists($auditLogMetadata, 'vettingType') && $auditLogMetadata->vettingType instanceof VettingType) {
            $entry->actorCommonName = new CommonName(
                $entry->actorCommonName->getCommonName() . $auditLogMetadata->vettingType->auditLog()
                                         getCommonName() . $auditLogMetadata->vettingType->auditLog()
            );
        }
    }
}

OpenConext / Stepup-Middleware

AuditLogProjector::applyAuditableEvent() C last analyzed 2025-09-30 14:23 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like

AuditLogProjector::applyAuditableEvent() C
last analyzed 2025-09-30 14:23 UTC
