CultuurNet\UDB3\Role\ReadModel\Detail\Projector

Complexity

Total Complexity

9

Size/Duplication

Total Lines	140
Duplicated Lines	20 %

Coupling/Cohesion

Components	1
Dependencies	16

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	applyRoleCreated()	0	12	1
A	applyRoleDeleted()	0	4	1
A	applyPermissionAdded()	0	17	2
A	applyPermissionRemoved()	0	21	1
A	applyRoleRenamed()	0	11	1
A	applyConstraintAdded()	15	15	1
A	applyConstraintUpdated()	13	13	1
A	applyConstraintRemoved()	0	13	1

<?php

namespace CultuurNet\UDB3\Role\ReadModel\Detail;

use CultuurNet\UDB3\Role\Events\ConstraintAdded;
use CultuurNet\UDB3\Role\Events\ConstraintRemoved;
use CultuurNet\UDB3\Role\Events\ConstraintUpdated;
use CultuurNet\UDB3\Role\Events\PermissionAdded;
use CultuurNet\UDB3\Role\Events\PermissionRemoved;
use CultuurNet\UDB3\Role\Events\RoleCreated;
use CultuurNet\UDB3\Role\Events\RoleDeleted;
use CultuurNet\UDB3\Role\Events\RoleRenamed;
use CultuurNet\UDB3\Role\ReadModel\RoleProjector;

class Projector extends RoleProjector
{
    /**
     * @param RoleCreated $roleCreated
     */
    protected function applyRoleCreated(RoleCreated $roleCreated)
    {
        $this->saveNewDocument(
            $roleCreated->getUuid()->toNative(),
            function (\stdClass $json) use ($roleCreated) {
                $json->uuid = $roleCreated->getUuid()->toNative();
                $json->name = $roleCreated->getName()->toNative();
                $json->permissions = [];
                return $json;
            }
        );
    }

    /**
     * @param RoleRenamed $roleRenamed
     */
    protected function applyRoleRenamed(RoleRenamed $roleRenamed)
    {
        $document = $this->loadDocumentFromRepositoryByUuid(
            $roleRenamed->getUuid()->toNative()
        );

        $json = $document->getBody();
        $json->name = $roleRenamed->getName()->toNative();

        $this->repository->save($document->withBody($json));
    }

    /**
     * @param RoleDeleted $roleDeleted
     */
    protected function applyRoleDeleted(RoleDeleted $roleDeleted)
    {
        $this->repository->remove($roleDeleted->getUuid());
    }

    /**
     * @param ConstraintAdded $constraintAdded
     */
    protected function applyConstraintAdded(

This method seems to be duplicated in your project.

        ConstraintAdded $constraintAdded
    ) {
        $document = $this->loadDocumentFromRepositoryByUuid(
            $constraintAdded->getUuid()->toNative()
        );

        $json = $document->getBody();
        $json->constraint = $constraintAdded->getQuery()->toNative();

        $json->constraints = new \stdClass();
        $json->constraints->{$constraintAdded->getSapiVersion()->toNative()} = $constraintAdded->getQuery()->toNative();

        $this->repository->save($document->withBody($json));
    }

    /**
     * @param ConstraintUpdated $constraintUpdated
     */
    protected function applyConstraintUpdated(

This method seems to be duplicated in your project.

        ConstraintUpdated $constraintUpdated
    ) {
        $document = $this->loadDocumentFromRepositoryByUuid(
            $constraintUpdated->getUuid()->toNative()
        );

        $json = $document->getBody();
        $json->constraint = $constraintUpdated->getQuery()->toNative();
        $json->constraints->{$constraintUpdated->getSapiVersion()->toNative()} = $constraintUpdated->getQuery()->toNative();

        $this->repository->save($document->withBody($json));
    }

    /**
     * @param ConstraintRemoved $constraintRemoved
     */
    protected function applyConstraintRemoved(
        ConstraintRemoved $constraintRemoved
    ) {
        $document = $this->loadDocumentFromRepositoryByUuid(
            $constraintRemoved->getUuid()->toNative()
        );

        $json = $document->getBody();
        $json->constraint = null;
        $json->constraints->{$constraintRemoved->getSapiVersion()->toNative()} = null;

        $this->repository->save($document->withBody($json));
    }

    /**
     * @param PermissionAdded $permissionAdded
     */
    public function applyPermissionAdded(PermissionAdded $permissionAdded)
    {
        $document = $this->loadDocumentFromRepositoryByUuid(
            $permissionAdded->getUuid()->toNative()
        );

        $permission = $permissionAdded->getPermission();

        $json = $document->getBody();

        $permissions = property_exists($json, 'permissions') ? $json->permissions : [];
        array_push($permissions, $permission->getName());

        $json->permissions = array_unique($permissions);

        $this->repository->save($document->withBody($json));
    }

    /**
     * @param PermissionRemoved $permissionRemoved
     */
    public function applyPermissionRemoved(PermissionRemoved $permissionRemoved)
    {
        $document = $this->loadDocumentFromRepositoryByUuid(
            $permissionRemoved->getUuid()->toNative()
        );

        $permission = $permissionRemoved->getPermission();
        $permissionName = $permission->getName();

        $json = $document->getBody();
        $json->permissions = array_values(
            array_filter(
                $json->permissions,
                function ($item) use ($permissionName) {
                    return $item !== $permissionName;
                }
            )
        );

        $this->repository->save($document->withBody($json));
    }
}