App\Repository\UserRepository

Complexity

Total Complexity

9

Size/Duplication

Total Lines	116
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	4	4	1
A	checkUser()	12	12	2
A	getUsers()	7	7	1
A	searchUsers()	13	13	2
A	createUser()	10	10	1
A	updateUser()	11	11	1
A	deleteUser()	8	8	1

<?php

namespace App\Repository;

use App\Message\UserMessage;
use App\Exception\UserException;
use App\Repository\Query\UserQuery;

/**
 * Users Repository.
 */
class UserRepository extends BaseRepository

This class seems to be duplicated in your project.

{
    /**
     * @param object $database
     */
    public function __construct(\PDO $database = null)
    {
        $this->database = $database;
    }

    /**
     * Check if the user exists.
     *
     * @param int $userId
     * @return array $user
     * @throws \Exception
     */
    public function checkUser($userId)
    {
        $statement = $this->database->prepare(UserQuery::GET_USER_QUERY);
        $statement->bindParam('id', $userId);
        $statement->execute();
        $user = $statement->fetchObject();
        if (empty($user)) {
            throw new UserException(UserException::USER_NOT_FOUND, 404);
        }

        return $user;
    }

    /**
     * Get all users.
     *
     * @return array
     */
    public function getUsers()
    {
        $statement = $this->database->prepare(UserQuery::GET_USERS_QUERY);
        $statement->execute();

        return $statement->fetchAll();
    }

    /**
     * Search users by name.
     *
     * @param string $usersName
     * @return array
     * @throws \Exception
     */
    public function searchUsers($usersName)
    {
        $statement = $this->database->prepare(UserQuery::SEARCH_USERS_QUERY);
        $query = '%' . $usersName . '%';
        $statement->bindParam('query', $query);
        $statement->execute();
        $users = $statement->fetchAll();
        if (!$users) {
            throw new UserException(UserException::USER_NOT_FOUND, 404);
        }

        return $users;
    }

    /**
     * Create a user.
     *
     * @param array $data
     * @return array
     * @throws \Exception
     */
    public function createUser($data)
    {
        $statement = $this->database->prepare(UserQuery::CREATE_USER_QUERY);
        $statement->bindParam('name', $data['name']);
        $statement->bindParam('email', $data['email']);
        $statement->execute();
        $user = $this->checkUser($this->database->lastInsertId());

        return $user;
    }

    /**
     * Update a user.
     *
     * @param array $data
     * @param int $userId
     * @return array
     */
    public function updateUser($data, $userId)
    {
        $statement = $this->database->prepare(UserQuery::UPDATE_USER_QUERY);
        $statement->bindParam('id', $userId);
        $statement->bindParam('name', $data['name']);
        $statement->bindParam('email', $data['email']);
        $statement->execute();
        $user = $this->checkUser($userId);

        return $user;
    }

    /**
     * Delete a user.
     *
     * @param int $userId
     * @return string
     */
    public function deleteUser($userId)
    {
        $statement = $this->database->prepare(UserQuery::DELETE_USER_QUERY);
        $statement->bindParam('id', $userId);
        $statement->execute();

        return UserMessage::USER_DELETED;
    }
}