ActionScheduler_QueueCleaner.php
2.16 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
<?php
/**
* Class ActionScheduler_QueueCleaner
*/
class ActionScheduler_QueueCleaner {
/** @var ActionScheduler_Store */
private $store = NULL;
private $month_in_seconds = 2678400; // 31 days
private $five_minutes = 300;
public function __construct( ActionScheduler_Store $store = NULL ) {
$this->store = $store ? $store : ActionScheduler_Store::instance();
}
public function delete_old_actions() {
$lifespan = apply_filters( 'action_scheduler_retention_period', $this->month_in_seconds );
$cutoff = new DateTime($lifespan.' seconds ago');
$actions_to_delete = $this->store->query_actions( array(
'status' => ActionScheduler_Store::STATUS_COMPLETE,
'modified' => $cutoff,
'modified_compare' => '<=',
'per_page' => apply_filters( 'action_scheduler_cleanup_batch_size', 20 ),
) );
foreach ( $actions_to_delete as $action_id ) {
$this->store->delete_action( $action_id );
}
}
public function reset_timeouts() {
$timeout = apply_filters( 'action_scheduler_timeout_period', $this->five_minutes );
if ( $timeout < 0 ) {
return;
}
$cutoff = new DateTime($timeout.' seconds ago');
$actions_to_reset = $this->store->query_actions( array(
'status' => ActionScheduler_Store::STATUS_PENDING,
'modified' => $cutoff,
'modified_compare' => '<=',
'claimed' => TRUE,
'per_page' => apply_filters( 'action_scheduler_cleanup_batch_size', 20 ),
) );
foreach ( $actions_to_reset as $action_id ) {
$this->store->unclaim_action( $action_id );
do_action( 'action_scheduler_reset_action', $action_id );
}
}
public function mark_failures() {
$timeout = apply_filters( 'action_scheduler_failure_period', $this->five_minutes );
if ( $timeout < 0 ) {
return;
}
$cutoff = new DateTime($timeout.' seconds ago');
$actions_to_reset = $this->store->query_actions( array(
'status' => ActionScheduler_Store::STATUS_RUNNING,
'modified' => $cutoff,
'modified_compare' => '<=',
'per_page' => apply_filters( 'action_scheduler_cleanup_batch_size', 20 ),
) );
foreach ( $actions_to_reset as $action_id ) {
$this->store->mark_failure( $action_id );
do_action( 'action_scheduler_failed_action', $action_id, $timeout );
}
}
}