Code Coverage
 
Lines
Functions and Methods
Classes and Traits
Total
69.05% covered (warning)
69.05%
29 / 42
50.00% covered (danger)
50.00%
2 / 4
 CRAP
0.00% covered (danger)
0.00%
0 / 1
FlushUtterancesFromStoreByExpirationJobQueue
69.05% covered (warning)
69.05%
29 / 42
50.00% covered (danger)
50.00%
2 / 4
 8.45
0.00% covered (danger)
0.00%
0 / 1
 __construct
100.00% covered (success)
100.00%
12 / 12
100.00% covered (success)
100.00%
1 / 1
 1
 maybeQueueJob
0.00% covered (danger)
0.00%
0 / 4
0.00% covered (danger)
0.00%
0 / 1
 6
 queueJob
0.00% covered (danger)
0.00%
0 / 9
0.00% covered (danger)
0.00%
0 / 1
 2
 isTimeToQueueJob
100.00% covered (success)
100.00%
17 / 17
100.00% covered (success)
100.00%
1 / 1
 3
1<?php
2
3namespace MediaWiki\Wikispeech\Utterance;
4
5/**
6 * @file
7 * @ingroup Extensions
8 * @license GPL-2.0-or-later
9 */
10
11use DateTime;
12use MediaWiki\Logger\LoggerFactory;
13use MediaWiki\MediaWikiServices;
14use Mediawiki\Title\Title;
15use Psr\Log\LoggerInterface;
16use WANObjectCache;
17
18/**
19 * Periodically flushes out old utterances from the utterance store.
20 *
21 * This is an important part of the extension architecture, making sure
22 * that utterance audio files and synthesis metadata files are updated
23 * when underlying voice synthesis is improved.
24 *
25 * The job is currently queued at the same time as utterances are created,
26 * with a configurable minimum amount of minutes delay between queues by
27 * executing {@link FlushUtterancesFromStoreByExpirationJob::maybeQueueJob()}.
28 *
29 * This is more or less equivalent to a semi dysfunctional cron tab. It might
30 * make sense to consider implement queuing the job periodically using a real
31 * cron tab, but that would also require more manual non standard work when
32 * setting up Wikispeech. It might also cause problems with future upgrades.
33 *
34 * One downside to the current approach is, that in a highly distributed
35 * environment with many active users there might be multiple jobs queued
36 * before the WAN cache is synchronized. Executing this job multiple times
37 * is however not a problem in it self more than being a bit of waste of
38 * resources. In the case where Wikispeech is configured to only flush a
39 * limited batch of utterances in each job, it might actually be a good
40 * thing that multiple jobs are queued.
41 *
42 * @see UtteranceStore::flushUtterancesByExpirationDate()
43 * @see FlushUtterancesFromStoreByExpirationJob
44 *
45 * @since 0.1.7
46 */
47class FlushUtterancesFromStoreByExpirationJobQueue {
48
49    /** @var LoggerInterface */
50    private $logger;
51
52    /** @var WANObjectCache */
53    private $cache;
54
55    /** @var string */
56    private $cacheKey;
57
58    /** @var string WAN cache key class namespace */
59    public static $cacheKeyClass = 'Wikispeech.flushUtterancesFromStoreByExpirationJob';
60
61    /** @var string WAN cache key component used by pseudo-crontab */
62    public static $cacheKeyComponentPreviousDateTimeQueued = 'previousDateTimeQueued';
63
64    /** @var int */
65    private $minimumMinutesBetweenFlushExpiredUtterancesJobs;
66
67    /**
68     * @since 0.1.7
69     */
70    public function __construct() {
71        $this->logger = LoggerFactory::getInstance( 'Wikispeech' );
72        $config = MediaWikiServices::getInstance()
73            ->getConfigFactory()
74            ->makeConfig( 'wikispeech' );
75        $this->minimumMinutesBetweenFlushExpiredUtterancesJobs = intval(
76            $config->get( 'WikispeechMinimumMinutesBetweenFlushExpiredUtterancesJobs' )
77        );
78        $this->cache = MediaWikiServices::getInstance()->getMainWANObjectCache();
79        $this->cacheKey = $this->cache->makeKey(
80            self::$cacheKeyClass,
81            self::$cacheKeyComponentPreviousDateTimeQueued
82        );
83    }
84
85    /**
86     * Queues a job if criteria to do so has been met.
87     *
88     * Convenience method that calls {@link queueJob()}
89     * if {@link isTimeToQueueJob()} returns true.
90     *
91     * @since 0.1.7
92     * @return bool Whether or not job was queued.
93     */
94    public function maybeQueueJob() {
95        if ( $this->isTimeToQueueJob() ) {
96            $this->queueJob();
97            return true;
98        }
99        return false;
100    }
101
102    /**
103     * Queues a job.
104     *
105     * @since 0.1.7
106     */
107    public function queueJob() {
108        $this->cache->set( $this->cacheKey, new DateTime() );
109        $jobQueueGroup = MediaWikiServices::getInstance()->getJobQueueGroup();
110        $jobQueueGroup->push(
111            new FlushUtterancesFromStoreByExpirationJob(
112                Title::newMainPage(),
113                [],
114                MediaWikiServices::getInstance()->getService( 'Wikispeech.UtteranceStore' )
115            )
116        );
117    }
118
119    /**
120     * Evaluates if the criteria has been met to queue a job.
121     * Currently that means that at least as many minutes as defined in config
122     * has past since previous queueing of the job.
123     *
124     * @since 0.1.7
125     * @return bool Whether or not it's time to queue the flush job
126     */
127    public function isTimeToQueueJob() {
128        if ( !$this->minimumMinutesBetweenFlushExpiredUtterancesJobs ) {
129            return false;
130        }
131        $previousDateTimeQueued = $this->cache->get( $this->cacheKey );
132        $this->logger->debug( __METHOD__ . ': ' .
133            'previousDateTimeQueued {previousDateTimeQueued}',
134            [ 'previousDateTimeQueued' => $previousDateTimeQueued ]
135        );
136        if ( !$previousDateTimeQueued ) {
137            // Either the cached value was never set or the cache is offline.
138            // In case of the latter, avoid queuing jobs on each request
139            // by requiring a cached value. This will set the initial cached value.
140            $this->cache->set( $this->cacheKey, new DateTime() );
141            return false;
142        }
143        $nextPossibleJobQueueTimestamp = date_add(
144            $previousDateTimeQueued,
145            date_interval_create_from_date_string(
146                $this->minimumMinutesBetweenFlushExpiredUtterancesJobs . ' minutes'
147            )
148        );
149        return new DateTime() >= $nextPossibleJobQueueTimestamp;
150    }
151}