Surfnet\Stepup\Identity\EventSourcing\IdentityRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	1
A	obtainInformation()	0	15	4

<?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\Stepup\Identity\EventSourcing;

use Broadway\Domain\DomainMessage;
use Broadway\EventHandling\EventBus as EventBusInterface;
use Broadway\EventSourcing\AggregateFactory\AggregateFactory;
use Broadway\EventSourcing\EventSourcingRepository;
use Broadway\EventSourcing\EventStreamDecorator;
use Broadway\EventStore\EventStore as EventStoreInterface;
use Broadway\EventStore\EventStreamNotFoundException;
use Broadway\Repository\AggregateNotFoundException;
use Psr\Log\LoggerInterface;
use Surfnet\Stepup\Helper\UserDataFilterInterface;
use Surfnet\Stepup\Identity\Identity;
use Surfnet\Stepup\Identity\Value\IdentityId;
use Surfnet\StepupMiddleware\CommandHandlingBundle\SensitiveData\RightToObtainDataInterface;

class IdentityRepository extends EventSourcingRepository
{
    /**
     * @param EventStreamDecorator[] $eventStreamDecorators
     */
    public function __construct(
        protected EventStoreInterface $events,
        EventBusInterface $eventBus,
        AggregateFactory $aggregateFactory,
        private readonly UserDataFilterInterface $userDataFilter,
        protected LoggerInterface $logger,
        array $eventStreamDecorators = [],
    ) {
        parent::__construct(
            $this->events,
            $eventBus,
            Identity::class,
            $aggregateFactory,
            $eventStreamDecorators,
        );
    }

    public function obtainInformation(IdentityId $id): array
    {
        try {
            $domainEventStream = $this->events->load($id);
            $data = [];
            /** @var DomainMessage $domainMessage */
            foreach ($domainEventStream as $domainMessage) {
                if ($domainMessage->getPayload() instanceof RightToObtainDataInterface) {
                    $index = $domainMessage->getPlayhead() . '-' . $domainMessage->getType();
                    $data[$index] = $this->userDataFilter->filter($domainMessage->getPayload());
                }
            }
            return $data;
        } catch (EventStreamNotFoundException $e) {
            throw AggregateNotFoundException::create($id, $e);
        }
    }
}