SendMessages::getMessageDataForAssignIssue() - Code Metrics - Inspection of "Misc: increment version & update changes doc" - satrun77/tinyissue - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 195b94...7a36f1 )

by Mohamed

created 2016-08-19 09:32 UTC

SendMessages::getMessageDataForAssignIssue() A

↳ Parent: SendMessages

Complexity

Conditions	2
Paths	2

Size

Total Lines	13
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	1	Features	0

Metric	Value
dl	0
loc	13
rs	9.4285
c	2
b	1
f	0
cc	2
eloc	8
nc	2
nop	2

<?php

/*
 * This file is part of the Tinyissue package.
 *
 * (c) Mohamed Alsharaf <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Tinyissue\Model\Project\Issue;

use Illuminate\Database\Eloquent\Collection;
use Tinyissue\Model\Message\Queue;
use Tinyissue\Model\Project;
use Tinyissue\Model\Project\Issue as ProjectIssue;
use Tinyissue\Model\Tag;
use Tinyissue\Model\User;
use Tinyissue\Services\SendMessagesAbstract;

/**
 * SendMessages is a class to manage & process of sending messages about issue changes.
 *
 * @author Mohamed Alsharaf <[email protected]>
 */
class SendMessages extends SendMessagesAbstract
{
    protected $template = 'update_issue';

    /**
     * Collection of tags.
     *
     * @var Collection
     */
    protected $tags;

    /**
     * Returns an instance of Issue.
     *
     * @return ProjectIssue
     */
    protected function getIssue()
    {
        if (null === $this->issue) {
            $this->issue = $this->getModel();
        }

        return $this->issue;
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
    }

    /**
     * Returns an instance of Project.
     *
     * @return Project
     */
    protected function getProject()
    {
        return $this->getIssue()->project;
    }

    /**
     * Returns the project id.
     *
     * @return int
     */
    protected function getProjectId()
    {
        return $this->getIssue()->project_id;
    }

    /**
     * Returns message data belongs to adding an issue.
     *
     * @param Queue $queue
     *
     * @return array
     */
    protected function getMessageDataForAddIssue(Queue $queue)
    {
        $messageData                    = ['changes' => []];
        $messageData['changeByHeading'] = $queue->changeBy->fullname . ' created a new issue';
        if ($this->issue->assigned) {
            $messageData['changes']['assignee'] = $this->issue->assigned->fullname;
        }

        $tags = $this->issue->tags()->with('parent')->get();
        foreach ($tags as $tag) {
            $tagArray                                   = $tag->toShortArray();
            $tagArray['now']                            = $tagArray['name'];
            $messageData['changes'][$tag->parent->name] = $tagArray;
        }

        if ($this->issue->time_quote && !$this->issue->isQuoteLocked()) {
            $messageData['changes']['time_quote'] = \Html::duration($this->issue->time_quote);
        }

        return $messageData;
    }

    /**
     * Returns message data belongs to updating an issue.
     *
     * @param Queue $queue
     *
     * @return array
     */
    protected function getMessageDataForUpdateIssue(Queue $queue)
    {
        $messageData                    = [];
        $messageData['changeByHeading'] = $queue->changeBy->fullname . ' updated an issue';
        $whiteListFields                = ['change_by', 'title', 'body', 'assignee', 'status', 'type', 'resolution', 'time_quote'];

        foreach ($queue->payload['dirty'] as $field => $value) {
            // Skip fields that not part of the white list or quote is locked
            if (!in_array($field, $whiteListFields) || ($field == 'time_quote' && $this->issue->isQuoteLocked())) {
                continue;
            }

            // Format quote to readable time
            $value                          = $field === 'time_quote' ? \Html::duration($value) : $value;
            $value                          = $field === 'body' ? \Html::format($value) : $value;
            $messageData['changes'][$field] = [
                'now' => $value,
                'was' => $queue->getDataFromPayload('origin.' . $field),
            ];
        }

        return $messageData;
    }

    /**
     * Returns message data belongs to reopening an issue.
     *
     * @param Queue $queue
     *
     * @return array
     */
    protected function getMessageDataForReopenIssue(Queue $queue)
    {
        $messageData                    = [];
        $messageData['changeByHeading'] = $queue->changeBy->fullname . ' reopened an issue';
        $statusNow                      = $this->issue
            ->tags()->with('parent')->get()->where('parent.name', Tag::GROUP_STATUS)->last();
        $messageData['changes']['status'] = [
            'was' => trans('tinyissue.closed'),
            'now' => ($statusNow ? $statusNow->fullname : ''),
            'id'  => ($statusNow ? $statusNow->id : ''),
        ];

        return $messageData;
    }

    /**
     * Returns message data belongs to closing an issue.
     *
     * @param Queue $queue
     *
     * @return array
     */
    protected function getMessageDataForCloseIssue(Queue $queue)
    {
        $messageData                    = [];
        $messageData['changeByHeading'] = $queue->changeBy->fullname . ' closed an issue';
        $statusWas                      = $this->issue
            ->tags()->with('parent')->get()->where('parent.name', Tag::GROUP_STATUS)->last();
        $messageData['changes']['status'] = [
            'was' => ($statusWas ? $statusWas->fullname : ''),
            'now' => trans('tinyissue.closed'),
        ];

        return $messageData;
    }

    /**
     * Returns message data belongs to assigning an issue to a user.
     *
     * @param Queue $queue
     * @param array $extraData
     *
     * @return array
     */
    protected function getMessageDataForAssignIssue(Queue $queue, array $extraData)
    {
        $messageData = [];
        if (!array_key_exists('now', $extraData)) {
            $assignTo  = $this->getUserById($queue->getDataFromPayload('dirty.assigned_to'));
            $extraData = ['now' => $assignTo->fullname];
        }

        $messageData['changes']['assignee'] = $extraData;
        $messageData['changeByHeading']     = $queue->changeBy->fullname . ' assigned an issue to ' . $extraData['now'];

        return $messageData;
    }

    /**
     * Returns message data belongs to changing an issue tags.
     *
     * @param Queue $queue
     *
     * @return array
     */
    protected function getMessageDataForChangeTagIssue(Queue $queue)
    {
        $messageData                    = [];
        $messageData['changeByHeading'] = $queue->changeBy->fullname . ' changed an issue tag';

        foreach ($queue->payload['added'] as $tag) {
            $group                          = strtolower($tag['group']);
            $messageData['changes'][$group] = [
                'now'           => $tag['name'],
                'id'            => $tag['id'],
                'message_limit' => $tag['message_limit'],
            ];
        }

        foreach ($queue->payload['removed'] as $tag) {
            $group                                 = strtolower($tag['group']);
            $messageData['changes'][$group]['was'] = $tag['name'];
        }

        return $messageData;
    }

    /**
     * Check that the issue is load.
     *
     * @return bool
     */
    protected function validateData()
    {
        // if issue closed and last issue not closed, then something is wrong skip
        if (!$this->issue->isOpen() && $this->latestMessage->event !== Queue::CLOSE_ISSUE) {
            return false;
        }

        return true;
    }

    /**
     * Populate assigned relation in the current issue.
     *
     * @return void
     */
    protected function populateData()

    {
        $this->issue->setRelation('assigned', $this->getUserById($this->issue->assigned_to));
        $creator = $this->getUserById($this->issue->created_by);
        if ($creator) {
            $this->issue->setRelation('user', $creator);
        }
        $this->loadIssueCreatorToProjectUsers();
    }

    /**
     * Check if the latest message is about closing or reopening an issue.
     *
     * @return bool
     */
    public function isStatusMessage()
    {
        return ((!$this->issue->isOpen() && $this->latestMessage->event === Queue::CLOSE_ISSUE)
            || ($this->issue->isOpen() && $this->latestMessage->event === Queue::REOPEN_ISSUE));
    }

    /**
     * Process assign to user message. Send direct message to new and previous users and full subscribers.
     *
     * @return void
     */
    protected function processDirectMessages()
    {
        // Stop if issue is closed
        if (!$this->getIssue()->isOpen()) {
            return;
        }

        // Fetch all of the assign issue changes
        $assignMessages = $this->allMessages->where('event', Queue::ASSIGN_ISSUE);

        // Skip if no changes
        if ($assignMessages->isEmpty()) {
            return;
        }

        // Fetch the latest assignee
        /** @var Queue $assignMessage */
        $assignMessage = $assignMessages->first();

        // Fetch the user details of the new assignee & previous assignee if this isn't new issue
        $assigns        = [];
        $assigns['new'] = (int) $assignMessage->getDataFromPayload('dirty.assigned_to');
        if (!$this->addMessage) {
            $previousAssignMessage = $assignMessages->last();
            $assigns['old']        = (int) $previousAssignMessage->getDataFromPayload('origin.assigned_to');
        }

        // Fetch users objects for old and new assignee
        /** @var \Illuminate\Database\Eloquent\Collection $assignObjects */
        $assignObjects = (new User())->whereIn('id', $assigns)->get();
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }

        // If for what ever reason the user does not exists, skip this change
        // or if there is only one user and is not matching the new assignee.
        // then skip this message
        if ($assignObjects->count() === 0
            || ($assignObjects->count() === 1 && (int) $assignObjects->first()->id !== $assigns['new'])
        ) {
            return;
        }

        // Get the object of the new assignee
        $assignTo = $assignObjects->where('id', $assigns['new'], false)->first();
        $users    = collect([$this->createProjectUserObject($assignTo)]);

        // Exclude the user from any other message for this issue
        $this->addToExcludeUsers($assignTo);

        // Data about new and previous assignee
        $extraMessageData = [
            'now' => $assignTo->fullname,
        ];

        // Make sure that the previous assignee was not the same as the new user
        if (array_key_exists('old', $assigns) && $assigns['old'] > 0 && $assigns['new'] !== $assigns['old']) {
            $previousAssign = $assignObjects->where('id', $assigns['old'], false)->first();
            if ($previousAssign) {
                $extraMessageData['was'] = $previousAssign->fullname;
                $users->push($this->createProjectUserObject($previousAssign));
            }
        }

        // Get message data needed for the message & send
        $messageData = $this->getMessageData($assignMessage, $extraMessageData);
        $this->sendMessages($users, $messageData);
    }

    /**
     * Create user project object for a user.
     *
     * @param User $user
     *
     * @return Project\User
     */
    protected function createProjectUserObject(User $user)
    {
        $userProject = new Project\User([
            'user_id'    => $user->id,
            'project_id' => $this->getProjectId(),
        ]);
        $userProject->setRelation('user', $user);
        $userProject->setRelation('project', $this->getProject());

        return $userProject;
    }

    /**
     * Get collection of tags or one by ID.
     *
     * @param int $tagId
     *
     * @return Tag
     */
    protected function getTag($tagId)
    {
        if (null === $this->tags) {
            $this->tags = collect([]);
        }

        // Load & extract tag by ID
        $tag = $this->tags->where('id', $tagId, false)->first();
        if (!$tag) {
            $tag = (new Tag())->find($tagId);
class ParentClass {
    private $data = array();

    public function __call($method, array $args) {
        if (0 === strpos($method, 'get')) {
            return $this->data[strtolower(substr($method, 3))];
        }

        throw new \LogicException(sprintf('Unsupported method: %s', $method));
    }
}

/**
 * If this class knows which fields exist, you can specify the methods here:
 *
 * @method string getName()
 */
class SomeClass extends ParentClass { }
            $this->tags->push($tag);
        }

        return $tag;
    }

    /**
     * Whether or not the user wants to receive the message.
     *
     * @param Project\User $user
     * @param array        $data
     *
     * @return bool
     */
    protected function wantToReceiveMessage(Project\User $user, array $data)
    {
        $status = parent::wantToReceiveMessage($user, $data);

        if (!$status) {
            return false;
        }

        // Search for tag changes and verify if the user can receive messages
        foreach ($data['changes'] as $label => $change) {
            // Skip other changes that are not related to tag
            if (!in_array($label, Tag::getCoreGroups())) {
                continue;
            }

            // If the change was only remove a tag
            if (!array_key_exists('now', $change) && array_key_exists('was', $change)) {
                return true;
            }

            // If tag id not found
            if (!array_key_exists('id', $change)) {
                return true;
            }

            // Fetch tag details
            $tag = $this->getTag($change['id']);

            // Check if user allowed to receive the message
            if (!$tag->allowMessagesToUser($user->user)) {
                return false;
            }
        }

        return true;
    }
}


1			<?php
2
3			/*
4			* This file is part of the Tinyissue package.
5			*
6			* (c) Mohamed Alsharaf <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace Tinyissue\Model\Project\Issue;
13
14			use Illuminate\Database\Eloquent\Collection;
15			use Tinyissue\Model\Message\Queue;
16			use Tinyissue\Model\Project;
17			use Tinyissue\Model\Project\Issue as ProjectIssue;
18			use Tinyissue\Model\Tag;
19			use Tinyissue\Model\User;
20			use Tinyissue\Services\SendMessagesAbstract;
21
22			/**
23			* SendMessages is a class to manage & process of sending messages about issue changes.
24			*
25			* @author Mohamed Alsharaf <[email protected]>
26			*/
27			class SendMessages extends SendMessagesAbstract
28			{
29			protected $template = 'update_issue';
30
31			/**
32			* Collection of tags.
33			*
34			* @var Collection
35			*/
36			protected $tags;
37
38			/**
39			* Returns an instance of Issue.
40			*
41			* @return ProjectIssue
42			*/
43			protected function getIssue()
44			{
45			if (null === $this->issue) {
46			$this->issue = $this->getModel();
47			}
48
49			return $this->issue;
			0 ignored issues – show Bug Best Practice introduced 2016-08-08 06:29 UTC by Report Bug Copy Issue Report The return type of `return $this->issue;` (`Tinyissue\Model\Project\...Tinyissue\Model\Project`) is incompatible with the return type declared by the abstract method `Tinyissue\Services\SendMessagesAbstract::getIssue` of type `Tinyissue\Model\Project\Issue`. If you return a value from a function or method, it should be a sub-type of the type that is given by the parent type f.e. an interface, or abstract method. This is more formally defined by the Lizkov substitution principle, and guarantees that classes that depend on the parent type can use any instance of a child type interchangably. This principle also belongs to the SOLID principles for object oriented design. Let’s take a look at an example: class Author { private $name; public function __construct($name) { $this->name = $name; } public function getName() { return $this->name; } } abstract class Post { public function getAuthor() { return 'Johannes'; } } class BlogPost extends Post { public function getAuthor() { return new Author('Johannes'); } } class ForumPost extends Post { /* ... */ } function my_function(Post $post) { echo strtoupper($post->getAuthor()); } Our function `my_function` expects a `Post` object, and outputs the author of the post. The base class `Post` returns a simple string and outputting a simple string will work just fine. However, the child class `BlogPost` which is a sub-type of `Post` instead decided to return an `object`, and is therefore violating the SOLID principles. If a `BlogPost` were passed to `my_function`, PHP would not complain, but ultimately fail when executing the `strtoupper` call in its body. Loading history...
50			}
51
52			/**
53			* Returns an instance of Project.
54			*
55			* @return Project
56			*/
57			protected function getProject()
58			{
59			return $this->getIssue()->project;
60			}
61
62			/**
63			* Returns the project id.
64			*
65			* @return int
66			*/
67			protected function getProjectId()
68			{
69			return $this->getIssue()->project_id;
70			}
71
72			/**
73			* Returns message data belongs to adding an issue.
74			*
75			* @param Queue $queue
76			*
77			* @return array
78			*/
79			protected function getMessageDataForAddIssue(Queue $queue)
80			{
81			$messageData = ['changes' => []];
82			$messageData['changeByHeading'] = $queue->changeBy->fullname . ' created a new issue';
83			if ($this->issue->assigned) {
84			$messageData['changes']['assignee'] = $this->issue->assigned->fullname;
85			}
86
87			$tags = $this->issue->tags()->with('parent')->get();
88			foreach ($tags as $tag) {
89			$tagArray = $tag->toShortArray();
90			$tagArray['now'] = $tagArray['name'];
91			$messageData['changes'][$tag->parent->name] = $tagArray;
92			}
93
94			if ($this->issue->time_quote && !$this->issue->isQuoteLocked()) {
95			$messageData['changes']['time_quote'] = \Html::duration($this->issue->time_quote);
96			}
97
98			return $messageData;
99			}
100
101			/**
102			* Returns message data belongs to updating an issue.
103			*
104			* @param Queue $queue
105			*
106			* @return array
107			*/
108			protected function getMessageDataForUpdateIssue(Queue $queue)
109			{
110			$messageData = [];
111			$messageData['changeByHeading'] = $queue->changeBy->fullname . ' updated an issue';
112			$whiteListFields = ['change_by', 'title', 'body', 'assignee', 'status', 'type', 'resolution', 'time_quote'];
113
114			foreach ($queue->payload['dirty'] as $field => $value) {
115			// Skip fields that not part of the white list or quote is locked
116			if (!in_array($field, $whiteListFields) \|\| ($field == 'time_quote' && $this->issue->isQuoteLocked())) {
117			continue;
118			}
119
120			// Format quote to readable time
121			$value = $field === 'time_quote' ? \Html::duration($value) : $value;
122			$value = $field === 'body' ? \Html::format($value) : $value;
123			$messageData['changes'][$field] = [
124			'now' => $value,
125			'was' => $queue->getDataFromPayload('origin.' . $field),
126			];
127			}
128
129			return $messageData;
130			}
131
132			/**
133			* Returns message data belongs to reopening an issue.
134			*
135			* @param Queue $queue
136			*
137			* @return array
138			*/
139			protected function getMessageDataForReopenIssue(Queue $queue)
140			{
141			$messageData = [];
142			$messageData['changeByHeading'] = $queue->changeBy->fullname . ' reopened an issue';
143			$statusNow = $this->issue
144			->tags()->with('parent')->get()->where('parent.name', Tag::GROUP_STATUS)->last();
145			$messageData['changes']['status'] = [
146			'was' => trans('tinyissue.closed'),
147			'now' => ($statusNow ? $statusNow->fullname : ''),
148			'id' => ($statusNow ? $statusNow->id : ''),
149			];
150
151			return $messageData;
152			}
153
154			/**
155			* Returns message data belongs to closing an issue.
156			*
157			* @param Queue $queue
158			*
159			* @return array
160			*/
161			protected function getMessageDataForCloseIssue(Queue $queue)
162			{
163			$messageData = [];
164			$messageData['changeByHeading'] = $queue->changeBy->fullname . ' closed an issue';
165			$statusWas = $this->issue
166			->tags()->with('parent')->get()->where('parent.name', Tag::GROUP_STATUS)->last();
167			$messageData['changes']['status'] = [
168			'was' => ($statusWas ? $statusWas->fullname : ''),
169			'now' => trans('tinyissue.closed'),
170			];
171
172			return $messageData;
173			}
174
175			/**
176			* Returns message data belongs to assigning an issue to a user.
177			*
178			* @param Queue $queue
179			* @param array $extraData
180			*
181			* @return array
182			*/
183			protected function getMessageDataForAssignIssue(Queue $queue, array $extraData)
184			{
185			$messageData = [];
186			if (!array_key_exists('now', $extraData)) {
187			$assignTo = $this->getUserById($queue->getDataFromPayload('dirty.assigned_to'));
188			$extraData = ['now' => $assignTo->fullname];
189			}
190
191			$messageData['changes']['assignee'] = $extraData;
192			$messageData['changeByHeading'] = $queue->changeBy->fullname . ' assigned an issue to ' . $extraData['now'];
193
194			return $messageData;
195			}
196
197			/**
198			* Returns message data belongs to changing an issue tags.
199			*
200			* @param Queue $queue
201			*
202			* @return array
203			*/
204			protected function getMessageDataForChangeTagIssue(Queue $queue)
205			{
206			$messageData = [];
207			$messageData['changeByHeading'] = $queue->changeBy->fullname . ' changed an issue tag';
208
209			foreach ($queue->payload['added'] as $tag) {
210			$group = strtolower($tag['group']);
211			$messageData['changes'][$group] = [
212			'now' => $tag['name'],
213			'id' => $tag['id'],
214			'message_limit' => $tag['message_limit'],
215			];
216			}
217
218			foreach ($queue->payload['removed'] as $tag) {
219			$group = strtolower($tag['group']);
220			$messageData['changes'][$group]['was'] = $tag['name'];
221			}
222
223			return $messageData;
224			}
225
226			/**
227			* Check that the issue is load.
228			*
229			* @return bool
230			*/
231			protected function validateData()
232			{
233			// if issue closed and last issue not closed, then something is wrong skip
234			if (!$this->issue->isOpen() && $this->latestMessage->event !== Queue::CLOSE_ISSUE) {
235			return false;
236			}
237
238			return true;
239			}
240
241			/**
242			* Populate assigned relation in the current issue.
243			*
244			* @return void
245			*/
246			protected function populateData()
			1 ignored issue – show Duplication introduced 2016-06-06 00:05 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
247			{
248			$this->issue->setRelation('assigned', $this->getUserById($this->issue->assigned_to));
249			$creator = $this->getUserById($this->issue->created_by);
250			if ($creator) {
251			$this->issue->setRelation('user', $creator);
252			}
253			$this->loadIssueCreatorToProjectUsers();
254			}
255
256			/**
257			* Check if the latest message is about closing or reopening an issue.
258			*
259			* @return bool
260			*/
261			public function isStatusMessage()
262			{
263			return ((!$this->issue->isOpen() && $this->latestMessage->event === Queue::CLOSE_ISSUE)
264			\|\| ($this->issue->isOpen() && $this->latestMessage->event === Queue::REOPEN_ISSUE));
265			}
266
267			/**
268			* Process assign to user message. Send direct message to new and previous users and full subscribers.
269			*
270			* @return void
271			*/
272			protected function processDirectMessages()
273			{
274			// Stop if issue is closed
275			if (!$this->getIssue()->isOpen()) {
276			return;
277			}
278
279			// Fetch all of the assign issue changes
280			$assignMessages = $this->allMessages->where('event', Queue::ASSIGN_ISSUE);
281
282			// Skip if no changes
283			if ($assignMessages->isEmpty()) {
284			return;
285			}
286
287			// Fetch the latest assignee
288			/** @var Queue $assignMessage */
289			$assignMessage = $assignMessages->first();
290
291			// Fetch the user details of the new assignee & previous assignee if this isn't new issue
292			$assigns = [];
293			$assigns['new'] = (int) $assignMessage->getDataFromPayload('dirty.assigned_to');
294			if (!$this->addMessage) {
295			$previousAssignMessage = $assignMessages->last();
296			$assigns['old'] = (int) $previousAssignMessage->getDataFromPayload('origin.assigned_to');
297			}
298
299			// Fetch users objects for old and new assignee
300			/** @var \Illuminate\Database\Eloquent\Collection $assignObjects */
301			$assignObjects = (new User())->whereIn('id', $assigns)->get();
			0 ignored issues – show Documentation Bug introduced 2016-06-06 00:05 UTC by Report Bug Copy Issue Report The method `whereIn` does not exist on `object<Tinyissue\Model\User>`? Since you implemented `__call`, maybe consider adding a @method annotation. If you implement `__call` and you know which methods are available, you can improve IDE auto-completion and static analysis by adding a @method annotation to the class. This is often the case, when `__call` is implemented by a parent class and only the child class knows which methods exist: class ParentClass { private $data = array(); public function __call($method, array $args) { if (0 === strpos($method, 'get')) { return $this->data[strtolower(substr($method, 3))]; } throw new \LogicException(sprintf('Unsupported method: %s', $method)); } } /** * If this class knows which fields exist, you can specify the methods here: * * @method string getName() */ class SomeClass extends ParentClass { } Loading history...
302
303			// If for what ever reason the user does not exists, skip this change
304			// or if there is only one user and is not matching the new assignee.
305			// then skip this message
306			if ($assignObjects->count() === 0
307			\|\| ($assignObjects->count() === 1 && (int) $assignObjects->first()->id !== $assigns['new'])
308			) {
309			return;
310			}
311
312			// Get the object of the new assignee
313			$assignTo = $assignObjects->where('id', $assigns['new'], false)->first();
314			$users = collect([$this->createProjectUserObject($assignTo)]);
315
316			// Exclude the user from any other message for this issue
317			$this->addToExcludeUsers($assignTo);
318
319			// Data about new and previous assignee
320			$extraMessageData = [
321			'now' => $assignTo->fullname,
322			];
323
324			// Make sure that the previous assignee was not the same as the new user
325			if (array_key_exists('old', $assigns) && $assigns['old'] > 0 && $assigns['new'] !== $assigns['old']) {
326			$previousAssign = $assignObjects->where('id', $assigns['old'], false)->first();
327			if ($previousAssign) {
328			$extraMessageData['was'] = $previousAssign->fullname;
329			$users->push($this->createProjectUserObject($previousAssign));
330			}
331			}
332
333			// Get message data needed for the message & send
334			$messageData = $this->getMessageData($assignMessage, $extraMessageData);
335			$this->sendMessages($users, $messageData);
336			}
337
338			/**
339			* Create user project object for a user.
340			*
341			* @param User $user
342			*
343			* @return Project\User
344			*/
345			protected function createProjectUserObject(User $user)
346			{
347			$userProject = new Project\User([
348			'user_id' => $user->id,
349			'project_id' => $this->getProjectId(),
350			]);
351			$userProject->setRelation('user', $user);
352			$userProject->setRelation('project', $this->getProject());
353
354			return $userProject;
355			}
356
357			/**
358			* Get collection of tags or one by ID.
359			*
360			* @param int $tagId
361			*
362			* @return Tag
363			*/
364			protected function getTag($tagId)
365			{
366			if (null === $this->tags) {
367			$this->tags = collect([]);
368			}
369
370			// Load & extract tag by ID
371			$tag = $this->tags->where('id', $tagId, false)->first();
372			if (!$tag) {
373			$tag = (new Tag())->find($tagId);
			0 ignored issues – show Documentation Bug introduced 2016-06-06 00:05 UTC by Report Bug Copy Issue Report The method `find` does not exist on `object<Tinyissue\Model\Tag>`? Since you implemented `__call`, maybe consider adding a @method annotation. If you implement `__call` and you know which methods are available, you can improve IDE auto-completion and static analysis by adding a @method annotation to the class. This is often the case, when `__call` is implemented by a parent class and only the child class knows which methods exist: class ParentClass { private $data = array(); public function __call($method, array $args) { if (0 === strpos($method, 'get')) { return $this->data[strtolower(substr($method, 3))]; } throw new \LogicException(sprintf('Unsupported method: %s', $method)); } } /** * If this class knows which fields exist, you can specify the methods here: * * @method string getName() */ class SomeClass extends ParentClass { } Loading history...
374			$this->tags->push($tag);
375			}
376
377			return $tag;
378			}
379
380			/**
381			* Whether or not the user wants to receive the message.
382			*
383			* @param Project\User $user
384			* @param array $data
385			*
386			* @return bool
387			*/
388			protected function wantToReceiveMessage(Project\User $user, array $data)
389			{
390			$status = parent::wantToReceiveMessage($user, $data);
391
392			if (!$status) {
393			return false;
394			}
395
396			// Search for tag changes and verify if the user can receive messages
397			foreach ($data['changes'] as $label => $change) {
398			// Skip other changes that are not related to tag
399			if (!in_array($label, Tag::getCoreGroups())) {
400			continue;
401			}
402
403			// If the change was only remove a tag
404			if (!array_key_exists('now', $change) && array_key_exists('was', $change)) {
405			return true;
406			}
407
408			// If tag id not found
409			if (!array_key_exists('id', $change)) {
410			return true;
411			}
412
413			// Fetch tag details
414			$tag = $this->getTag($change['id']);
415
416			// Check if user allowed to receive the message
417			if (!$tag->allowMessagesToUser($user->user)) {
418			return false;
419			}
420			}
421
422			return true;
423			}
424			}
425

satrun77 / tinyissue

Push — master ( 195b94...7a36f1 )

SendMessages::getMessageDataForAssignIssue() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like