OCA\Analytics\Service\ThresholdService

Complexity

Total Complexity

14

Size/Duplication

Total Lines	120
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	4	1
A	floatvalue()	0	9	2
A	read()	0	6	1
A	readRaw()	0	3	1
B	validate()	0	18	7
A	__construct()	0	15	1
A	create()	0	4	1

<?php
/**
 * Analytics
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the LICENSE.md file.
 *
 * @author Marcel Scherello <analytics@scherello.de>
 * @copyright 2019-2022 Marcel Scherello
 */

namespace OCA\Analytics\Service;

use OCA\Analytics\Db\ReportMapper;
use OCA\Analytics\Db\ThresholdMapper;
use OCA\Analytics\Notification\NotificationManager;
use Psr\Log\LoggerInterface;
use OCP\IL10N;

class ThresholdService
{
    private $logger;
    private $ThresholdMapper;
    private $ReportMapper;
    private $NotificationManager;
    private $VariableService;
    private $l10n;

    public function __construct(
        LoggerInterface $logger,
        ThresholdMapper $ThresholdMapper,
        NotificationManager $NotificationManager,
        ReportMapper $ReportMapper,
        VariableService $VariableService,
        IL10N $l10n
   )
    {
        $this->logger = $logger;
        $this->ThresholdMapper = $ThresholdMapper;
        $this->NotificationManager = $NotificationManager;
        $this->ReportMapper = $ReportMapper;
        $this->VariableService = $VariableService;
        $this->l10n = $l10n;
    }

    /**
     * read all thresholds for a dataset
     *
     * @param int $reportId
     * @return array
     */
    public function read(int $reportId)
    {
        $thresholds = $this->ThresholdMapper->getThresholdsByReport($reportId);
        $thresholdsParsed = $this->VariableService->replaceThresholdsVariables($thresholds);

        return $thresholdsParsed;
    }

    /**
     * read all thresholds for a dataset without any replaced text variables
     *
     * @param int $reportId
     * @return array
     */
    public function readRaw(int $reportId)
    {
        return $this->ThresholdMapper->getThresholdsByReport($reportId);
    }

    /**
     * create new threshold for dataset
     *
     * @param int $reportId
     * @param $dimension1
     * @param $option
     * @param $value
     * @param int $severity
     * @return int
     */
    public function create(int $reportId, $dimension1, $option, $value, int $severity)
    {
        $value = $this->floatvalue($value);
        return $this->ThresholdMapper->create($reportId, $dimension1, $value, $option, $severity);
    }

    private function floatvalue($val)
    {
        $val = str_replace(",", ".", $val);
        $val = preg_replace('/\.(?=.*\.)/', '', $val);
        $val = preg_replace('/[^0-9-.]+/', '', $val);
        if (is_numeric($val)) {
            return number_format(floatval($val), 2, '.', '');
        } else {
            return false;
        }
    }

    /**
     * Delete threshold
     *
     * @param int $thresholdId
     * @return bool
     */
    public function delete(int $thresholdId)
    {
        $this->ThresholdMapper->deleteThreshold($thresholdId);
        return true;
    }

    /**
     * validate notification thresholds per report
     *
     * @param int $reportId
     * @param $dimension1
     * @param $dimension2
     * @param $value
     * @param int $insert
     * @return string
     * @throws \Exception
     */
    public function validate(int $reportId, $dimension1, $dimension2, $value, int $insert = 0)

The parameter $dimension2 is not used and could be removed.

    {
        $result = '';
        $thresholds = $this->ThresholdMapper->getSevOneThresholdsByReport($reportId);
        $datasetMetadata = $this->ReportMapper->read($reportId);

        foreach ($thresholds as $threshold) {
            if ($threshold['dimension1'] === $dimension1 or $threshold['dimension1'] === '*') {
                if (version_compare($value, $threshold['value'], $threshold['option'])) {
                    $this->NotificationManager->triggerNotification(NotificationManager::SUBJECT_THRESHOLD, $reportId, $threshold['id'], ['report' => $datasetMetadata['name'], 'subject' => $dimension1, 'rule' => $threshold['option'], 'value' => $threshold['value']], $threshold['user_id']);
                    $result = 'Threshold value met';
                } elseif ($threshold['option'] === 'new' && $insert != 0) {
                    $this->NotificationManager->triggerNotification(NotificationManager::SUBJECT_THRESHOLD, $reportId, $threshold['id'], ['report' => $datasetMetadata['name'], 'subject' => $dimension1, 'rule' => $this->l10n->t('new record'), 'value' => ''], $threshold['user_id']);
                    $result = 'Threshold value met';
                }
            }
        }
        return $result;
    }
}