App\Repository\TaskRepository

Complexity

Total Complexity

15

Size/Duplication

Total Lines	155
Duplicated Lines	9.03 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	checkTask()	0	13	2
A	getTasks()	0	8	1
A	searchTasks()	14	14	2
A	createTask()	0	11	1
A	updateTask()	0	12	1
A	deleteTask()	0	7	1
A	getTaskQuery()	0	4	1
A	getTasksQuery()	0	4	1
A	searchTasksQuery()	0	4	1
A	createTaskQuery()	0	4	1
A	updateTaskQuery()	0	4	1
A	deleteTaskQuery()	0	4	1

<?php

namespace App\Repository;

use App\Service\MessageService;

/**
 * Tasks Repository.
 */
class TaskRepository extends BaseRepository
{
    /**
     * @param object $database
     */
    public function __construct(\PDO $database = null)
    {
        $this->database = $database;
    }

    /**
     * Check if the task exists.
     *
     * @param int $taskId
     * @return array $task
     * @throws \Exception
     */
    public function checkTask($taskId)
    {
        $query = $this->getTaskQuery();
        $statement = $this->database->prepare($query);
        $statement->bindParam('id', $taskId);
        $statement->execute();
        $task = $statement->fetchObject();
        if (empty($task)) {
            throw new \Exception(MessageService::TASK_NOT_FOUND, 404);
        }

        return $task;
    }

    /**
     * Get all tasks.
     *
     * @return array
     */
    public function getTasks()
    {
        $query = $this->getTasksQuery();
        $statement = $this->database->prepare($query);
        $statement->execute();

        return $statement->fetchAll();
    }

    /**
     * Search tasks by name.
     *
     * @param string $tasksName
     * @return array
     * @throws \Exception
     */
    public function searchTasks($tasksName)
    {
        $query = $this->searchTasksQuery();
        $statement = $this->database->prepare($query);
        $query = '%' . $tasksName . '%';
        $statement->bindParam('query', $query);
        $statement->execute();
        $tasks = $statement->fetchAll();
        if (!$tasks) {
            throw new \Exception(MessageService::TASK_NOT_FOUND, 404);
        }

        return $tasks;
    }

    /**
     * Create a task.
     *
     * @param array $data
     * @return array
     * @throws \Exception
     */
    public function createTask($data)
    {
        $query = $this->createTaskQuery();
        $statement = $this->database->prepare($query);
        $statement->bindParam('task', $data['task']);
        $statement->bindParam('status', $data['status']);
        $statement->execute();
        $task = $this->checkTask($this->database->lastInsertId());

        return $task;
    }

    /**
     * Update a task.
     *
     * @param array $data
     * @param int $taskId
     * @return array
     */
    public function updateTask($data, $taskId)
    {
        $query = $this->updateTaskQuery();
        $statement = $this->database->prepare($query);
        $statement->bindParam('id', $taskId);
        $statement->bindParam('task', $data['task']);
        $statement->bindParam('status', $data['status']);
        $statement->execute();
        $task = $this->checkTask($taskId);

        return $task;
    }

    /**
     * Delete a task.
     *
     * @param int $taskId
     * @return void
     */
    public function deleteTask($taskId)
    {
        $query = $this->deleteTaskQuery();
        $statement = $this->database->prepare($query);
        $statement->bindParam('id', $taskId);
        $statement->execute();
    }

    /**
     * Get Task Sql Query.
     *
     * @return string
     */
    public function getTaskQuery()
    {
        return 'SELECT * FROM tasks WHERE id=:id';
    }

    public function getTasksQuery()
    {
        return 'SELECT * FROM tasks ORDER BY task';
    }

    public function searchTasksQuery()
    {
        return 'SELECT * FROM tasks WHERE UPPER(task) LIKE :query ORDER BY task';
    }

    public function createTaskQuery()
    {
        return 'INSERT INTO tasks (task, status) VALUES (:task, :status)';
    }

    public function updateTaskQuery()
    {
        return 'UPDATE tasks SET task=:task, status=:status WHERE id=:id';
    }

    public function deleteTaskQuery()
    {
        return 'DELETE FROM tasks WHERE id=:id';
    }
}