Xervice\User\Business\Writer\UserWriter

Complexity

Total Complexity

11

Size/Duplication

Total Lines	136
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	createUser()	0	6	1
A	hydrateEntityFromDataProvider()	0	12	3
A	persistUserFromDataProvider()	0	9	1
A	updateUser()	0	6	1
A	deleteUser()	0	5	1
A	getUserLoginEntity()	0	12	2
A	__construct()	0	6	1
A	getUserCredentialsEntity()	0	5	1

<?php


namespace Xervice\User\Business\Writer;


use DataProvider\UserDataProvider;
use DataProvider\UserLoginDataProvider;
use Orm\Xervice\User\Persistence\User;

The type Orm\Xervice\User\Persistence\User was not found. Maybe you did not declare it correctly or list all dependencies?

use Orm\Xervice\User\Persistence\UserCredential;

The type Orm\Xervice\User\Persistence\UserCredential was not found. Maybe you did not declare it correctly or list all dependencies?

use Orm\Xervice\User\Persistence\UserLogin;

The type Orm\Xervice\User\Persistence\UserLogin was not found. Maybe you did not declare it correctly or list all dependencies?

use Xervice\User\Business\Exception\UserException;
use Xervice\User\Business\Validator\UserValidatorInterface;
use Xervice\User\UserQueryContainerInterface;

class UserWriter implements UserWriterInterface
{
    /**
     * @var \Xervice\User\Business\Validator\UserValidatorInterface
     */
    private $validator;

    /**
     * @var \Xervice\User\UserQueryContainerInterface
     */
    private $queryContainer;

    /**
     * UserWriter constructor.
     *
     * @param \Xervice\User\Business\Validator\UserValidatorInterface $validator
     * @param \Xervice\User\UserQueryContainerInterface $queryContainer
     */
    public function __construct(
        UserValidatorInterface $validator,
        UserQueryContainerInterface $queryContainer
    ) {
        $this->validator = $validator;
        $this->queryContainer = $queryContainer;
    }

    /**
     * @param \DataProvider\UserDataProvider $userDataProvider
     *
     * @return \DataProvider\UserDataProvider
     * @throws \Propel\Runtime\Exception\PropelException
     * @throws \Xervice\User\Business\Exception\UserException
     */
    public function createUser(UserDataProvider $userDataProvider): UserDataProvider
    {
        $this->validator->validateUser($userDataProvider);

        $user = new User();
        return $this->persistUserFromDataProvider($userDataProvider, $user);
    }

    /**
     * @param \DataProvider\UserDataProvider $userDataProvider
     *
     * @return \DataProvider\UserDataProvider
     * @throws \Propel\Runtime\Exception\PropelException
     * @throws \Xervice\User\Business\Exception\UserException
     */
    public function updateUser(UserDataProvider $userDataProvider): UserDataProvider
    {
        $this->validator->validateUser($userDataProvider);

        $user = $this->queryContainer->getUserQuery()->findOneByUserId($userDataProvider->getUserId());
        return $this->persistUserFromDataProvider($userDataProvider, $user);
    }

    /**
     * @param \DataProvider\UserDataProvider $userDataProvider
     *
     * @throws \Propel\Runtime\Exception\PropelException
     */
    public function deleteUser(UserDataProvider $userDataProvider): void
    {
        $user = new User();
        $user->setUserId($userDataProvider->getUserId());
        $user->delete();
    }

    /**
     * @param \Orm\Xervice\User\Persistence\User $user
     * @param \DataProvider\UserDataProvider $userDataProvider
     *
     * @return \Orm\Xervice\User\Persistence\User
     */
    private function hydrateEntityFromDataProvider(User $user, UserDataProvider $userDataProvider): User
    {
        $user->fromArray($userDataProvider->toArray());

        if ($userDataProvider->hasUserLogins()) {
            foreach ($userDataProvider->getUserLogins() as $loginDataProvider) {
                $userLoginEntity = $this->getUserLoginEntity($loginDataProvider);
                $user->addUserLogin($userLoginEntity);
            }
        }

        return $user;
    }

    /**
     * @param \DataProvider\UserLoginDataProvider $loginDataProvider
     *
     * @return \Orm\Xervice\User\Persistence\UserLogin
     * @throws \Propel\Runtime\Exception\PropelException
     */
    private function getUserLoginEntity(UserLoginDataProvider $loginDataProvider): UserLogin
    {
        $userLoginEntity = new UserLogin();
        $userLoginEntity->fromArray($loginDataProvider->toArray());

        if ($loginDataProvider->hasUserCredential()) {
            $userLoginEntity->setUserCredential(
                $this->getUserCredentialsEntity($loginDataProvider->getUserCredential())
            );
        }

        return $userLoginEntity;
    }

    /**
     * @param $credentialDataProvider
     *
     * @return \Orm\Xervice\User\Persistence\UserCredential
     */
    private function getUserCredentialsEntity($credentialDataProvider): UserCredential
    {
        $userCredentialEntity = new UserCredential();
        $userCredentialEntity->fromArray($credentialDataProvider->toArray());
        return $userCredentialEntity;
    }

    /**
     * @param \DataProvider\UserDataProvider $userDataProvider
     * @param $user
     *
     * @return \DataProvider\UserDataProvider
     * @throws \Propel\Runtime\Exception\PropelException
     */
    private function persistUserFromDataProvider(
        UserDataProvider $userDataProvider,
        User $user
    ): \DataProvider\UserDataProvider {

        $user = $this->hydrateEntityFromDataProvider($user, $userDataProvider);
        $user->save();

        return $userDataProvider->setUserId($user->getUserId());
    }
}