Cron::execute() - Code Metrics - Inspection of "Simplify Cron and increase reliability" - Schlaefer/Saito - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Branch — hotfix/5.4.1 (9732a4)

by Schlaefer

created 2019-10-20 10:45 UTC

Cron::execute() A

↳ Parent: Cron

Complexity

Conditions	5
Paths	8

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	5
nc	8
nop	0
dl	0
loc	20
rs	9.2888
c	0
b	0
f	0

<?php

declare(strict_types=1);

/**
 * Saito - The Threaded Web Forum
 *
 * @copyright Copyright (c) the Saito Project Developers
 * @link https://github.com/Schlaefer/Saito
 * @license http://opensource.org/licenses/MIT
 */

namespace Cron\Lib;

use Cake\Cache\Cache;

class Cron
{
    /** @var array */
    protected $jobs = [];

    /** @var int */
    protected $now;

    /** @var array|null Null if not intialized */
    private $lastRuns = null;

    /**
     * Constructor
     */
    public function __construct()
    {
        $this->now = time();
    }

    /**
     * Add cron job
     *
     * @param string $id unique ID for cron job
     * @param string $due due intervall
     * @param callable $func cron job
     * @return self
     */
    public function addCronJob(string $id, string $due, callable $func): self
    {
        $this->jobs[$id] = new CronJob($id, $due, $func);

        return $this;
    }

    /**
     * Run cron jobs
     *
     * @return void
     */
    public function execute()
    {
        $this->lastRuns = $this->getLastRuns();
        $jobsExecuted = false;
        foreach ($this->jobs as $job) {
            $uid = $job->getUid();
            $due = $job->getDue();
            if (!empty($this->lastRuns[$uid])) {
                if ($this->now < $this->lastRuns[$uid]) {
                    continue;
                }
            }
            $job->execute();
            $jobsExecuted = true;
            $this->lastRuns[$uid] = $due;
        }
        if ($jobsExecuted) {
            $this->saveLastRuns();
        }
    }

    /**
     * Clear history
     *
     * @return void
     */
    public function clearHistory()
    {
        $this->now = time();
        $this->lastRuns = [];
        $this->saveLastRuns();
    }

    /**
     * Get last cron runs
     *
     * @return array
     */
    protected function getLastRuns(): array
    {
        if ($this->lastRuns === null) {
            $this->lastRuns = Cache::read('Plugin.Cron.lastRuns', 'long') ?: [];
        }

        return $this->lastRuns;
    }

    /**
     * Create new cache data
     *
     * @return void
     */
    protected function saveLastRuns(): void
    {
        Cache::write('Plugin.Cron.lastRuns', $this->lastRuns, 'long');
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			/**
6			* Saito - The Threaded Web Forum
7			*
8			* @copyright Copyright (c) the Saito Project Developers
9			* @link https://github.com/Schlaefer/Saito
10			* @license http://opensource.org/licenses/MIT
11			*/
12
13			namespace Cron\Lib;
14
15			use Cake\Cache\Cache;
16
17			class Cron
18			{
19			/** @var array */
20			protected $jobs = [];
21
22			/** @var int */
23			protected $now;
24
25			/** @var array\|null Null if not intialized */
26			private $lastRuns = null;
27
28			/**
29			* Constructor
30			*/
31			public function __construct()
32			{
33			$this->now = time();
34			}
35
36			/**
37			* Add cron job
38			*
39			* @param string $id unique ID for cron job
40			* @param string $due due intervall
41			* @param callable $func cron job
42			* @return self
43			*/
44			public function addCronJob(string $id, string $due, callable $func): self
45			{
46			$this->jobs[$id] = new CronJob($id, $due, $func);
47
48			return $this;
49			}
50
51			/**
52			* Run cron jobs
53			*
54			* @return void
55			*/
56			public function execute()
57			{
58			$this->lastRuns = $this->getLastRuns();
59			$jobsExecuted = false;
60			foreach ($this->jobs as $job) {
61			$uid = $job->getUid();
62			$due = $job->getDue();
63			if (!empty($this->lastRuns[$uid])) {
64			if ($this->now < $this->lastRuns[$uid]) {
65			continue;
66			}
67			}
68			$job->execute();
69			$jobsExecuted = true;
70			$this->lastRuns[$uid] = $due;
71			}
72			if ($jobsExecuted) {
73			$this->saveLastRuns();
74			}
75			}
76
77			/**
78			* Clear history
79			*
80			* @return void
81			*/
82			public function clearHistory()
83			{
84			$this->now = time();
85			$this->lastRuns = [];
86			$this->saveLastRuns();
87			}
88
89			/**
90			* Get last cron runs
91			*
92			* @return array
93			*/
94			protected function getLastRuns(): array
95			{
96			if ($this->lastRuns === null) {
97			$this->lastRuns = Cache::read('Plugin.Cron.lastRuns', 'long') ?: [];
98			}
99
100			return $this->lastRuns;
101			}
102
103			/**
104			* Create new cache data
105			*
106			* @return void
107			*/
108			protected function saveLastRuns(): void
109			{
110			Cache::write('Plugin.Cron.lastRuns', $this->lastRuns, 'long');
111			}
112			}
113

Schlaefer / Saito

Branch — hotfix/5.4.1 (9732a4)

Cron::execute() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like