hazza/woocommerce-subscriptions
1
0
Fork 0
mirror of https://github.com/pronamic/woocommerce-subscriptions.git synced 2025-10-17 06:42:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

2.0.17

Browse Source
This commit is contained in:
Prospress Inc
2016-07-08 15:02:27 +02:00
committed by I
parent 183dce9069
commit 4733fa00c6
208 changed files with 57323 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
includes/libraries/action-scheduler/classes/ActionScheduler_QueueCleaner.php Normal file
View File

@@ -0,0 +1,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 );
}
}
}