# fluent-boards/2.0.12/app/Hooks/Handlers/NotificationHandler.php

FluentBoards – Project Management, Task Management, Goal Tracking, Kanban Board, and, Team Collaboration, version 2.0.12. 240 lines.

- Page: https://pluginprobe.com/plugins/fluent-boards/2.0.12/code/app/Hooks/Handlers/NotificationHandler.php
- Raw: https://pluginprobe.com/plugins/fluent-boards/2.0.12/raw/app/Hooks/Handlers/NotificationHandler.php
- Modified: 2026-07-31T13:53:12+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/fluent-boards/2.0.12/code/app/Hooks/Handlers/NotificationHandler.php#L10-L20`.

```php
<?php

namespace FluentBoards\App\Hooks\Handlers;

use FluentBoards\App\Models\Task;
use FluentBoards\App\Models\User;
use FluentBoards\App\Models\Board;
use FluentBoards\App\Models\Notification;
use FluentBoards\App\Services\Constant;

class NotificationHandler
{
    /**
     * Add a generic comment notification for watchers who were not explicitly mentioned.
     *
     * Mentioned users receive the higher-priority mention notification separately, so they
     * should not also receive a generic comment notification for the same comment.
     *
     * @param \FluentBoards\App\Models\Comment $comment
     * @return void
     */
    public function addCommentNotification($comment)
    {
        if($comment->task_id){
            $task = Task::findOrFail($comment->task_id);
            $mentionedUserIds = $this->getMentionedUserIdsFromComment($comment);
            $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
            $userIdsWhoGetNotification = $this->excludeMentionedUsersFromNotificationRecipients($userIdsWhoGetNotification, $mentionedUserIds);
            if(count($userIdsWhoGetNotification) > 0){
                $plainDescription = wp_strip_all_tags($comment->description);
                $action = $comment->parent_id ? 'task_reply_added' : 'comment_created';
                $message = $plainDescription;
                $settings = [ 'comment_id' => $comment->parent_id ?? $comment->id ];
                $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message, $settings);
                $notification->users()->attach($userIdsWhoGetNotification);
            }
        }
    }

    /**
     * Get normalized mentioned user IDs from a comment's stored settings.
     *
     * @param \FluentBoards\App\Models\Comment $comment
     * @return array
     */
    private function getMentionedUserIdsFromComment($comment)
    {
        $settings = $comment->settings;

        if (!is_array($settings) || empty($settings['mentioned_id']) || !is_array($settings['mentioned_id'])) {
            return [];
        }

        return array_values(array_filter(array_map('intval', $settings['mentioned_id'])));
    }

    /**
     * Remove mentioned users from generic notification recipients.
     *
     * @param array $recipientIds
     * @param array $mentionedUserIds
     * @return array
     */
    private function excludeMentionedUsersFromNotificationRecipients($recipientIds, $mentionedUserIds)
    {
        $mentionedUserIds = array_filter(array_map('intval', $mentionedUserIds));

        if (!$mentionedUserIds) {
            return array_values($recipientIds);
        }

        return array_values(array_filter($recipientIds, function ($recipientId) use ($mentionedUserIds) {
            return !in_array((int) $recipientId, $mentionedUserIds, true);
        }));
    }

    public function mentionInCommentNotification($comment, $mentionIds)
    {
        if($comment){
            $task = Task::findOrFail($comment->task_id);
            $plainDescription = wp_strip_all_tags($comment->description);
            $action = 'task_comment_mentioned';
            $message = $plainDescription;
            $settings = [ 'comment_id' => $comment->parent_id ?? $comment->id ];
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message, $settings);
            $notification->users()->attach($mentionIds);
        }
    }

    public function addSubtaskNotification($parentTask, $subTask)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($parentTask);
        if(count($userIdsWhoGetNotification) > 0){
            $board_id = $subTask->board_id;
            $action = 'subtask_added';
            $message = $subTask->title ;
            $notification = $this->createNotification($parentTask, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function changeDueDateNotification($task, $oldDate)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            $action = 'task_due_date_changed';
            $message = date_i18n('F j, Y, g:i a', strtotime($task->due_at));
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function changeStartDateNotification($task, $oldDate)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            $action = 'task_start_date_changed';
            $message = date_i18n('F j, Y, g:i a', strtotime($task->started_at));
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function changeStageNotification($task, $oldStageId)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            $action = 'task_moved_to_new_stage';
            $message = $task->stage->title;
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function changePriorityNotification($task, $oldPriority)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            $action = 'task_priority_changed';
            $message = $task->priority;
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function taskArchiveNotification($task)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            if ($task->archived_at) {
                $action = 'board_task_archived';
                $message = $task->title;
            } else {
                $action = 'board_task_restored';
                $message = $task->title;
            }
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function changeTitleNotification($task, $col, $oldTask)
    {
        if ($col !== 'title') {
            return;
        }

        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            $action = 'task_title_updated';
            $message = $task->title;
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function changeBoardNotification($task, $oldBoardId)
    {
        $userIdsWhoGetNotification = $this->findUsersWhoWillGetNotification($task);
        if(count($userIdsWhoGetNotification) > 0){
            $new_board_id = Task::findOrFail($task->board_id)->board_id;
            $new_board_title = Board::findOrFail($new_board_id)->title;
            // translators: %1$s is the task title, %2$s is the board title
            $message = sprintf(__('moved %1$s task to %2$s board.','fluent-boards'), $task->title, $new_board_title);
            $notification = $this->createNotification($oldBoardId, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $message);
            $notification->users()->attach($userIdsWhoGetNotification);
        }
    }

    public function assigneeAddedNotification($task, $newAssigneeId)
    {
        if($newAssigneeId != get_current_user_id()){
            $action = 'task_assignee_changed';
            $message = __('has added you as an assignee.','fluent-boards');
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($newAssigneeId);
        }
    }

    public function assigneeRemovedNotification($task, $newAssigneeId)
    {
        if($newAssigneeId != get_current_user_id()){
            $action = 'task_assignee_changed';
            $message = __('has removed you as an assignee.','fluent-boards');
            $notification = $this->createNotification($task, Constant::OBJECT_TYPE_BOARD_NOTIFICATION, $action, $message);
            $notification->users()->attach($newAssigneeId);
        }
    }

    public function createNotification($task, $objectType, $action, $description, $settings = null)
    {
        $data = [
            'object_id' => $task->board_id,
            'object_type' => $objectType,
            'task_id' => $task->id,
            'action' => $action,
            'description' => $description,
            'settings' => $settings
        ];
        $currentUser = get_current_user_id();
        if($currentUser == 0) {
            $data['activity_by'] = $task->created_by;
        }
        return Notification::create($data);
    }

    public function findUsersWhoWillGetNotification($task)
    {
        $currentUserId = get_current_user_id();
        $watchersOfTask = $task->watchers;
        $watchersExceptCurrentUser = [];
        foreach($watchersOfTask as $watcher){
            if($watcher->ID != $currentUserId){
                $watchersExceptCurrentUser[] = $watcher->ID;
            }
        }
        return $watchersExceptCurrentUser;
    }
}

```