146 lines
3.1 KiB
PHP
146 lines
3.1 KiB
PHP
<?php
|
|
/**
|
|
* Update to 5.1.0
|
|
*
|
|
* - use `date-desc` sorting for existing `shop.products` variables
|
|
*/
|
|
|
|
namespace AutomateWoo\DatabaseUpdates;
|
|
|
|
use AutomateWoo\Replace_Helper;
|
|
use AutomateWoo\Variables_Processor;
|
|
use AutomateWoo\Workflow;
|
|
use AutomateWoo\Workflows\Factory;
|
|
use AutomateWoo\Workflows\VariableParsing\ParsedVariable;
|
|
|
|
if ( ! defined( 'ABSPATH' ) ) {
|
|
exit;
|
|
}
|
|
|
|
/**
|
|
* Class Database_Update_5_1_0
|
|
*
|
|
* @package AutomateWoo\DatabaseUpdates
|
|
*/
|
|
class Database_Update_5_1_0 extends AbstractDatabaseUpdate {
|
|
|
|
const UPDATE_ITEMS_OPTIONS_KEY = 'automatewoo_update_items';
|
|
|
|
/** @var string */
|
|
protected $version = '5.1.0';
|
|
|
|
/**
|
|
* Runs immediately before a database update begins.
|
|
*/
|
|
protected function start() {
|
|
parent::start();
|
|
|
|
// get list of workflows to update
|
|
$workflows = $this->get_all_workflow_ids();
|
|
|
|
update_option( self::UPDATE_ITEMS_OPTIONS_KEY, $workflows );
|
|
}
|
|
|
|
/**
|
|
* Called immediately after database update is completed.
|
|
*/
|
|
protected function finish() {
|
|
parent::finish();
|
|
|
|
delete_option( self::UPDATE_ITEMS_OPTIONS_KEY );
|
|
}
|
|
|
|
/**
|
|
* @return bool
|
|
*/
|
|
protected function process() {
|
|
$items = get_option( self::UPDATE_ITEMS_OPTIONS_KEY );
|
|
|
|
if ( empty( $items ) ) {
|
|
return true; // no more items to process, return complete
|
|
}
|
|
|
|
$batch = array_splice( $items, 0, 5 );
|
|
|
|
foreach ( $batch as $item ) {
|
|
$workflow = Factory::get( $item );
|
|
$this->update_shop_products_variables( $workflow );
|
|
|
|
++$this->items_processed;
|
|
}
|
|
|
|
update_option( self::UPDATE_ITEMS_OPTIONS_KEY, $items );
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* @return bool|int
|
|
*/
|
|
public function get_items_to_process_count() {
|
|
if ( ! get_option( self::UPDATE_ITEMS_OPTIONS_KEY ) ) {
|
|
$workflows_to_update = $this->get_all_workflow_ids();
|
|
} else {
|
|
$workflows_to_update = get_option( self::UPDATE_ITEMS_OPTIONS_KEY );
|
|
}
|
|
|
|
return count( $workflows_to_update );
|
|
}
|
|
|
|
/**
|
|
* @param Workflow $workflow
|
|
*/
|
|
private function update_shop_products_variables( $workflow ) {
|
|
$actions = $workflow->get_meta( 'actions' );
|
|
|
|
if ( ! $actions ) {
|
|
return;
|
|
}
|
|
|
|
foreach ( $actions as &$action ) {
|
|
foreach ( $action as $field_name => &$field_value ) {
|
|
if ( 'action_name' === $field_name ) {
|
|
continue;
|
|
}
|
|
|
|
$replacer = new Replace_Helper(
|
|
$field_value,
|
|
function ( $value ) {
|
|
$variable = Variables_Processor::parse_variable( $value );
|
|
if ( ! $variable instanceof ParsedVariable ) {
|
|
return false;
|
|
}
|
|
|
|
if ( 'shop' === $variable->type && 'products' === $variable->field && ! array_key_exists( 'sort', $variable->parameters ) ) {
|
|
$value .= ", sort: 'date-desc'";
|
|
}
|
|
|
|
return "{{ $value }}";
|
|
},
|
|
'variables'
|
|
);
|
|
|
|
$field_value = $replacer->process();
|
|
}
|
|
}
|
|
|
|
$workflow->update_meta( 'actions', $actions );
|
|
}
|
|
|
|
/**
|
|
* Return the list of IDs of all the workflows in the database
|
|
*
|
|
* @return int[]
|
|
*/
|
|
private function get_all_workflow_ids() {
|
|
return get_posts(
|
|
[
|
|
'post_type' => 'aw_workflow',
|
|
'post_status' => 'any',
|
|
'posts_per_page' => -1,
|
|
'fields' => 'ids',
|
|
]
|
|
);
|
|
}
|
|
}
|
|
|
|
return new Database_Update_5_1_0();
|
