OCA\Analytics\Notification\NotificationManager

Complexity

Total Complexity

2

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	triggerNotification()	0	16	1
A	__construct()	0	7	1

<?php
/**
 * Analytics
 *
 * SPDX-FileCopyrightText: 2019-2022 Marcel Scherello
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

namespace OCA\Analytics\Notification;

use OCP\Notification\IManager as INotificationManager;

The type OCP\Notification\IManager was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Log\LoggerInterface;

The type Psr\Log\LoggerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

class NotificationManager
{
    const OBJECT_REPORT = 'analytics_report';
    const SUBJECT_THRESHOLD = 'data_threshold';
    const DATALOAD_ERROR = 'dataload_error';
    /** @var INotificationManager */
    protected $notificationManager;
    private $logger;

    public function __construct(
        LoggerInterface      $logger,
        INotificationManager $notificationManager
    )
    {
        $this->logger = $logger;
        $this->notificationManager = $notificationManager;
    }

    /**
     * @param string $object_type
     * @param int $object_id
     * @param $subject
     * @param array $subject_parameter
     * @param $user_id
     */
    public function triggerNotification($object_type, $object_id, $subject, $subject_parameter, $user_id)
    {
        $notification = $this->notificationManager->createNotification();
        $notification->setApp('analytics')
            ->setObject($object_type, $object_id)
            ->setSubject($subject)
            ->setUser($user_id);
        $this->notificationManager->markProcessed($notification);

        $notification = $this->notificationManager->createNotification();
        $notification->setApp('analytics')
            ->setDateTime(new \DateTime())
            ->setObject($object_type, $object_id)
            ->setSubject($subject, $subject_parameter)
            ->setUser($user_id);
        $this->notificationManager->notify($notification);
    }
}