Tinyissue\Repository\Project\Issue\MessageQueuer

Complexity

Total Complexity

14

Size/Duplication

Total Lines	113
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	queueUpdate()	0	14	1
A	queueUpdateIssue()	0	9	3
A	queueClosedIssue()	0	6	2
A	queueReopenedIssue()	0	6	2
A	queueAdd()	0	4	1
A	queueAssign()	0	14	4
A	queueChangeTags()	0	4	1

<?php

/*
 * This file is part of the Tinyissue package.
 *
 * (c) Mohamed Alsharaf <mohamed.alsharaf@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Tinyissue\Repository\Project\Issue;

use Tinyissue\Model\Message\Queue;
use Tinyissue\Model\Project;
use Tinyissue\Model\User;

trait MessageQueuer
{
    /**
     * Insert update issue to message queue.
     *
     * @param Project\Issue $issue
     * @param User          $changeBy
     *
     * @return void
     */
    public function queueUpdate(Project\Issue $issue, User $changeBy)
    {
        // is Closed?
        $this->queueClosedIssue($issue, $changeBy);

        // is Reopened?
        $this->queueReopenedIssue($issue, $changeBy);

        // If the assignee has changed and it is not the logged in user who made the action
        $noMessageForMe = $this->queueAssign($issue, $changeBy);

        // If the update was just for assigning user, then skip update issue
        $this->queueUpdateIssue($issue, $changeBy, $noMessageForMe);
    }

    /**
     * @param Project\Issue $issue
     * @param User          $changeBy
     * @param bool|int      $noMessageForMe
     */
    protected function queueUpdateIssue(Project\Issue $issue, User $changeBy, $noMessageForMe = false)
    {
        // Number of changed attributes
        $countChanges = count($issue->getDirty());

        if (!($countChanges === 1 && $noMessageForMe !== false)) {
            return (new Queue())->updater($changeBy)->queue(Queue::UPDATE_ISSUE, $issue, $changeBy);
        }
    }

    /**
     * @param Project\Issue $issue
     * @param User          $changeBy
     */
    protected function queueClosedIssue(Project\Issue $issue, User $changeBy)
    {
        if (!$issue->isOpen()) {
            (new Queue())->updater($changeBy)->queue(Queue::CLOSE_ISSUE, $issue, $changeBy);
        }
    }

    /**
     * @param Project\Issue $issue
     * @param User          $changeBy
     */
    protected function queueReopenedIssue(Project\Issue $issue, User $changeBy)
    {
        if ((int) $issue->getOriginal('status') === Project\Issue::STATUS_CLOSED) {
            (new Queue())->updater($changeBy)->queue(Queue::REOPEN_ISSUE, $issue, $changeBy);
        }
    }

    /**
     * Insert add issue to message queue.
     *
     * @param Project\Issue $issue
     * @param User          $changeBy
     *
     * @return void
     */
    public function queueAdd(Project\Issue $issue, User $changeBy)
    {
        return (new Queue())->updater($changeBy)->queue(Queue::ADD_ISSUE, $issue, $changeBy);
    }

    /**
     * Insert assign issue to message queue.
     *
     * @param Project\Issue $issue
     * @param User          $changeBy
     *
     * @return bool|int
     */
    public function queueAssign(Project\Issue $issue, User $changeBy)
    {
        // Whether or not the assignee has changed
        $return = false;

        // If the assignee has changed and it is not the logged in user who made the action
        if ($issue->assigned_to > 0 && $changeBy->id !== $issue->assigned_to && $issue->assigned_to !== $issue->getOriginal('assigned_to', $issue->assigned_to)) {
            (new Queue())->updater($changeBy)->queue(Queue::ASSIGN_ISSUE, $issue, $changeBy);

            $return = $issue->assigned_to;
        }

        return $return;
    }

    /**
     * Insert issue tag changes to message queue.
     *
     * @param Project\Issue $issue
     * @param array         $addedTags
     * @param array         $removedTags
     * @param User          $changeBy
     *
     * @return mixed
     */
    public function queueChangeTags(Project\Issue $issue, array $addedTags, array $removedTags, User $changeBy)
    {
        return (new Queue())->updater($changeBy)->queueIssueTagChanges($issue, $addedTags, $removedTags, $changeBy);
    }
}