Pz\Doctrine\Rest\Action\UpdateAction

Complexity

Total Complexity

12

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	34	4
A	afterUpdate()	0	4	1
A	hasEvents()	0	3	2
A	beforeUpdate()	0	4	1
A	callBeforeUpdate()	0	4	2
A	callAfterUpdate()	0	4	2

<?php namespace Pz\Doctrine\Rest\Action;

use Pz\Doctrine\Rest\Resource\Item;
use Pz\Doctrine\Rest\RestResponseFactory;
use Pz\Doctrine\Rest\Traits\CanHydrate;
use Pz\Doctrine\Rest\RestAction;
use Pz\Doctrine\Rest\Contracts\RestRequestContract;
use Pz\Doctrine\Rest\RestResponse;
use Pz\Doctrine\Rest\Traits\CanValidate;

class UpdateAction extends RestAction
{
    use CanHydrate;

The trait Pz\Doctrine\Rest\Traits\CanHydrate requires some properties which are not provided by Pz\Doctrine\Rest\Action\UpdateAction: $reflFields, $associationMappings

    use CanValidate;

    /** @var array */
    protected $beforeUpdate = [];

    /** @var array */
    protected $afterUpdate = [];

    /**
     * @param RestRequestContract $request
     * @return RestResponse
     *
     * @throws \Doctrine\ORM\ORMException
     * @throws \Doctrine\ORM\OptimisticLockException
     * @throws \Pz\Doctrine\Rest\Exceptions\RestException
     */
    public function handle($request)
    {
        $entity = $this->repository()->findById($request->getId());

        $this->authorize($request, $entity);
        $this->hydrateEntity($entity, $request->getData());
        $this->validateEntity($entity);

        if ($this->hasEvents()) {
            $this->repository()
                ->getEntityManager()
                ->getUnitOfWork()
                ->computeChangeSets();

            $changeSet = $this->repository()
                ->getEntityManager()
                ->getUnitOfWork()
                ->getEntityChangeSet($entity);
        }

        if (isset($changeSet)) {
            $this->callBeforeUpdate($entity, $changeSet);
        }

        $this->repository()
            ->getEntityManager()
            ->flush();

        if (isset($changeSet)) {
            $this->callAfterUpdate($entity, $changeSet);
        }

        return RestResponseFactory::resource($request,
            new Item($entity, $this->transformer())
        );
    }

    /**
     * @param callable $cb
     * @return $this
     */
    public function beforeUpdate(callable $cb)
    {
        $this->beforeUpdate[] = $cb;
        return $this;
    }

    /**
     * @param callable $cb
     * @return $this
     */
    public function afterUpdate(callable $cb)
    {
        $this->afterUpdate[] = $cb;
        return $this;
    }

    /**
     * @return bool
     */
    protected function hasEvents()
    {
        return !empty($this->beforeUpdate) || !empty($this->afterUpdate);
    }

    /**
     * @param object $entity
     * @param array $changeSet
     */
    protected function callBeforeUpdate($entity, array $changeSet)
    {
        foreach ($this->beforeUpdate as $beforeUpdate) {
            $beforeUpdate($entity, $changeSet);
        }
    }

    /**
     * @param object $entity
     * @param array $changeSet
     */
    protected function callAfterUpdate($entity, array $changeSet)
    {
        foreach ($this->afterUpdate as $afterUpdate) {
            $afterUpdate($entity, $changeSet);
        }
    }
}