ControleOnline\Controller\CreateUserAction

Complexity

Total Complexity

19

Size/Duplication

Total Lines	169
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getUsers()	0	17	2
B	addUser()	0	38	8
A	__invoke()	0	25	2
A	deleteUser()	0	32	6

<?php

namespace ControleOnline\Controller;

use Symfony\Component\HttpFoundation\Request;

The type Symfony\Component\HttpFoundation\Request was not found. Maybe you did not declare it correctly or list all dependencies?

use Doctrine\ORM\EntityManagerInterface;

The type Doctrine\ORM\EntityManagerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\HttpFoundation\JsonResponse;

The type Symfony\Component\HttpFoundation\JsonResponse was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Security\Core\Security;

The type Symfony\Component\Security\Core\Security was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;

The type Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use ControleOnline\Entity\People;

The type ControleOnline\Entity\People was not found. Maybe you did not declare it correctly or list all dependencies?

use ControleOnline\Entity\User;
use ControleOnline\Entity\Person;

The type ControleOnline\Entity\Person was not found. Maybe you did not declare it correctly or list all dependencies?

class CreateUserAction
{
    /**
     * Entity Manager
     *
     * @var EntityManagerInterface
     */
    private $manager = null;

    /**
     * Request
     *
     * @var Request
     */
    private $request  = null;

    /**
     * Security
     *
     * @var Security
     */
    private $security = null;

    /**
     * Current user
     *
     * @var \ControleOnline\Entity\User
     */
    private $currentUser = null;

    /**
     * Password encoder
     *
     * @var UserPasswordEncoderInterface
     */
    private $encoder = null;

    public function __construct(EntityManagerInterface $manager, Security $security, UserPasswordEncoderInterface $passwordEncoder)
    {
        $this->manager     = $manager;
        $this->security    = $security;
        $this->currentUser = $security->getUser();
        $this->encoder     = $passwordEncoder;
    }

    public function __invoke(Person $data, Request $request): JsonResponse
    {
        $this->request = $request;

        try {
            $payload   = json_decode($this->request->getContent(), true);
            $result    = $this->addUser($data, $payload);

            return new JsonResponse([
                'response' => [
                    'data'    => $result,
                    'count'   => 1,
                    'error'   => '',
                    'success' => true,
                ],
            ], 200);

        } catch (\Exception $e) {

            return new JsonResponse([
                'response' => [
                    'data'    => [],
                    'count'   => 0,
                    'error'   => $e->getMessage(),
                    'success' => false,
                ],
            ]);

        }
    }

    private function addUser(Person $person, array $payload): ?array
    {
        try {
            $this->manager->getConnection()->beginTransaction();

            if (!isset($payload['username']) || empty($payload['username'])) {
                throw new \InvalidArgumentException('Username param is not valid');
            }

            if (!isset($payload['password']) || empty($payload['password'])) {
                throw new \InvalidArgumentException('Password param is not valid');
            }

            $company = $this->manager->getRepository(People::class)->find($person->getId());
            $user    = $this->manager->getRepository(User::class)->findOneBy(['username' => $payload['username']]);
            if ($user instanceof User) {
                throw new \InvalidArgumentException('O username já esta em uso');
            }

            $user = new User();
            $user->setUsername($payload['username']);
            $user->setHash    ($this->encoder->encodePassword($user, $payload['password']));
            $user->setPeople  ($company);

            $this->manager->persist($user);

            $this->manager->flush();
            $this->manager->getConnection()->commit();

            return [
                'id' => $user->getId()
            ];

        } catch (\Exception $e) {
            if ($this->manager->getConnection()->isTransactionActive())
                $this->manager->getConnection()->rollBack();

            throw new \InvalidArgumentException($e->getMessage());
        }
    }

    private function deleteUser(Person $person, array $payload): bool

The method deleteUser() is not used, and could be removed.

    {
        try {
            $this->manager->getConnection()->beginTransaction();

            if (!isset($payload['id'])) {
                throw new \InvalidArgumentException('Document id is not defined');
            }

            $company = $this->manager->getRepository(People::class)->find($person->getId());
            $users   = $this->manager->getRepository(User::class)->findBy(['people' => $company]);
            if (count($users) == 1) {
                throw new \InvalidArgumentException('Deve existir pelo menos um usuário');
            }

            $user    = $this->manager->getRepository(User::class)->findOneBy(['id' => $payload['id'], 'people' => $company]);
            if (!$user instanceof User) {
                throw new \InvalidArgumentException('Person user was not found');
            }

            $this->manager->remove($user);

            $this->manager->flush();
            $this->manager->getConnection()->commit();

            return true;

        } catch (\Exception $e) {
            if ($this->manager->getConnection()->isTransactionActive())
                $this->manager->getConnection()->rollBack();

            throw new \InvalidArgumentException($e->getMessage());
        }
    }

    private function getUsers(Person $person, ?array $payload = null): array

The parameter $payload is not used and could be removed.

The method getUsers() is not used, and could be removed.

    {
        $members = [];
        $company = $this->manager->getRepository(People::class )->find($person->getId());
        $users   = $this->manager->getRepository(User::class)->findBy(['people' => $company]);

        foreach ($users as $user) {
            $members[] = [
                'id'       => $user->getId(),
                'username' => $user->getUsername(),
                'apiKey'   => $user->getApiKey(),
            ];
        }

        return [
            'members' => $members,
            'total'   => count($members),
        ];
    }
}