@@ -19,7 +19,7 @@ discard block |
||
| 19 | 19 | use Wordlift\Task\Single_Call_Task; |
| 20 | 20 | |
| 21 | 21 | if ( ! defined( 'ABSPATH' ) ) { |
| 22 | - exit; |
|
| 22 | + exit; |
|
| 23 | 23 | } |
| 24 | 24 | |
| 25 | 25 | define( 'WL_FOOD_KG_FILE', __FILE__ ); |
@@ -27,86 +27,86 @@ discard block |
||
| 27 | 27 | |
| 28 | 28 | function __wl_foodkg__load() { |
| 29 | 29 | |
| 30 | - // Autoloader for plugin itself. |
|
| 31 | - if ( file_exists( __DIR__ . '/vendor/autoload.php' ) ) { |
|
| 32 | - require __DIR__ . '/vendor/autoload.php'; |
|
| 33 | - } |
|
| 34 | - |
|
| 35 | - $container_builder = new ContainerBuilder(); |
|
| 36 | - $loader = new YamlFileLoader( $container_builder, new FileLocator( __DIR__ ) ); |
|
| 37 | - $loader->load( 'services.yml' ); |
|
| 38 | - $container_builder->compile(); |
|
| 39 | - |
|
| 40 | - $notices = $container_builder->get( 'Wordlift\Modules\Food_Kg\Notices' ); |
|
| 41 | - $notices->register_hooks(); |
|
| 42 | - |
|
| 43 | - /** |
|
| 44 | - * @var Preconditions $preconditions |
|
| 45 | - */ |
|
| 46 | - $preconditions = $container_builder->get( 'Wordlift\Modules\Food_Kg\Preconditions' ); |
|
| 47 | - if ( ! $preconditions->pass() ) { |
|
| 48 | - return; |
|
| 49 | - } |
|
| 50 | - |
|
| 51 | - // Meta Box. |
|
| 52 | - $meta_box = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Meta_Box' ); |
|
| 53 | - $meta_box->register_hooks(); |
|
| 54 | - |
|
| 55 | - $module = $container_builder->get( 'Wordlift\Modules\Food_Kg\Module' ); |
|
| 56 | - $module->register_hooks(); |
|
| 57 | - |
|
| 58 | - /** @var Jsonld $jsonld */ |
|
| 59 | - $jsonld = $container_builder->get( 'Wordlift\Modules\Food_Kg\Jsonld' ); |
|
| 60 | - $jsonld->register_hooks(); |
|
| 61 | - |
|
| 62 | - /** |
|
| 63 | - * Ingredients API. |
|
| 64 | - */ |
|
| 65 | - $ingredients_api = $container_builder->get( 'Wordlift\Modules\Food_Kg\Ingredients_API' ); |
|
| 66 | - $ingredients_api->register_hooks(); |
|
| 67 | - |
|
| 68 | - /** @var Main_Ingredient_Jsonld $jsonld */ |
|
| 69 | - $main_ingredient_jsonld = $container_builder->get( 'Wordlift\Modules\Food_Kg\Main_Ingredient_Jsonld' ); |
|
| 70 | - $main_ingredient_jsonld->register_hooks(); |
|
| 71 | - |
|
| 72 | - // Main Ingredient Background Task. |
|
| 73 | - $main_ingredient_recipe_lift = $container_builder->get( 'Wordlift\Modules\Food_Kg\Main_Ingredient_Recipe_Lift_Strategy' ); |
|
| 74 | - Background_Task_Factory::create_action_scheduler_task( |
|
| 75 | - 'wl_main_ingredient_sync', |
|
| 76 | - 'wordlift', |
|
| 77 | - new All_Posts_Task( |
|
| 78 | - array( $main_ingredient_recipe_lift, 'process' ), |
|
| 79 | - 'wprm_recipe', |
|
| 80 | - 'sync-main-ingredient' |
|
| 81 | - ), |
|
| 82 | - '/main-ingredient', |
|
| 83 | - 'sync-main-ingredient', |
|
| 84 | - __( 'Synchronize Main Ingredient', 'wordlift' ) |
|
| 85 | - ); |
|
| 86 | - |
|
| 87 | - // Ingredients Taxonomy Background Task. |
|
| 88 | - $ingredients_taxonomy_recipe_lift = $container_builder->get( 'Wordlift\Modules\Food_Kg\Ingredients_Taxonomy_Recipe_Lift_Strategy' ); |
|
| 89 | - Background_Task_Factory::create( |
|
| 90 | - new Single_Call_Task( |
|
| 91 | - array( $ingredients_taxonomy_recipe_lift, 'run' ), |
|
| 92 | - 'sync-ingredients-taxonomy' |
|
| 93 | - ), |
|
| 94 | - '/sync-ingredients-taxonomy', |
|
| 95 | - 'sync-ingredients-taxonomy', |
|
| 96 | - __( 'Synchronize Ingredients Taxonomy', 'wordlift' ) |
|
| 97 | - ); |
|
| 98 | - |
|
| 99 | - if ( is_admin() ) { |
|
| 100 | - $page = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Page' ); |
|
| 101 | - $page->register_hooks(); |
|
| 102 | - |
|
| 103 | - $page = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Ingredients_Taxonomy_Page' ); |
|
| 104 | - $page->register_hooks(); |
|
| 105 | - |
|
| 106 | - // Download Ingredients Data. |
|
| 107 | - $download_ingredients_data = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Download_Ingredients_Data' ); |
|
| 108 | - $download_ingredients_data->register_hooks(); |
|
| 109 | - } |
|
| 30 | + // Autoloader for plugin itself. |
|
| 31 | + if ( file_exists( __DIR__ . '/vendor/autoload.php' ) ) { |
|
| 32 | + require __DIR__ . '/vendor/autoload.php'; |
|
| 33 | + } |
|
| 34 | + |
|
| 35 | + $container_builder = new ContainerBuilder(); |
|
| 36 | + $loader = new YamlFileLoader( $container_builder, new FileLocator( __DIR__ ) ); |
|
| 37 | + $loader->load( 'services.yml' ); |
|
| 38 | + $container_builder->compile(); |
|
| 39 | + |
|
| 40 | + $notices = $container_builder->get( 'Wordlift\Modules\Food_Kg\Notices' ); |
|
| 41 | + $notices->register_hooks(); |
|
| 42 | + |
|
| 43 | + /** |
|
| 44 | + * @var Preconditions $preconditions |
|
| 45 | + */ |
|
| 46 | + $preconditions = $container_builder->get( 'Wordlift\Modules\Food_Kg\Preconditions' ); |
|
| 47 | + if ( ! $preconditions->pass() ) { |
|
| 48 | + return; |
|
| 49 | + } |
|
| 50 | + |
|
| 51 | + // Meta Box. |
|
| 52 | + $meta_box = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Meta_Box' ); |
|
| 53 | + $meta_box->register_hooks(); |
|
| 54 | + |
|
| 55 | + $module = $container_builder->get( 'Wordlift\Modules\Food_Kg\Module' ); |
|
| 56 | + $module->register_hooks(); |
|
| 57 | + |
|
| 58 | + /** @var Jsonld $jsonld */ |
|
| 59 | + $jsonld = $container_builder->get( 'Wordlift\Modules\Food_Kg\Jsonld' ); |
|
| 60 | + $jsonld->register_hooks(); |
|
| 61 | + |
|
| 62 | + /** |
|
| 63 | + * Ingredients API. |
|
| 64 | + */ |
|
| 65 | + $ingredients_api = $container_builder->get( 'Wordlift\Modules\Food_Kg\Ingredients_API' ); |
|
| 66 | + $ingredients_api->register_hooks(); |
|
| 67 | + |
|
| 68 | + /** @var Main_Ingredient_Jsonld $jsonld */ |
|
| 69 | + $main_ingredient_jsonld = $container_builder->get( 'Wordlift\Modules\Food_Kg\Main_Ingredient_Jsonld' ); |
|
| 70 | + $main_ingredient_jsonld->register_hooks(); |
|
| 71 | + |
|
| 72 | + // Main Ingredient Background Task. |
|
| 73 | + $main_ingredient_recipe_lift = $container_builder->get( 'Wordlift\Modules\Food_Kg\Main_Ingredient_Recipe_Lift_Strategy' ); |
|
| 74 | + Background_Task_Factory::create_action_scheduler_task( |
|
| 75 | + 'wl_main_ingredient_sync', |
|
| 76 | + 'wordlift', |
|
| 77 | + new All_Posts_Task( |
|
| 78 | + array( $main_ingredient_recipe_lift, 'process' ), |
|
| 79 | + 'wprm_recipe', |
|
| 80 | + 'sync-main-ingredient' |
|
| 81 | + ), |
|
| 82 | + '/main-ingredient', |
|
| 83 | + 'sync-main-ingredient', |
|
| 84 | + __( 'Synchronize Main Ingredient', 'wordlift' ) |
|
| 85 | + ); |
|
| 86 | + |
|
| 87 | + // Ingredients Taxonomy Background Task. |
|
| 88 | + $ingredients_taxonomy_recipe_lift = $container_builder->get( 'Wordlift\Modules\Food_Kg\Ingredients_Taxonomy_Recipe_Lift_Strategy' ); |
|
| 89 | + Background_Task_Factory::create( |
|
| 90 | + new Single_Call_Task( |
|
| 91 | + array( $ingredients_taxonomy_recipe_lift, 'run' ), |
|
| 92 | + 'sync-ingredients-taxonomy' |
|
| 93 | + ), |
|
| 94 | + '/sync-ingredients-taxonomy', |
|
| 95 | + 'sync-ingredients-taxonomy', |
|
| 96 | + __( 'Synchronize Ingredients Taxonomy', 'wordlift' ) |
|
| 97 | + ); |
|
| 98 | + |
|
| 99 | + if ( is_admin() ) { |
|
| 100 | + $page = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Page' ); |
|
| 101 | + $page->register_hooks(); |
|
| 102 | + |
|
| 103 | + $page = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Ingredients_Taxonomy_Page' ); |
|
| 104 | + $page->register_hooks(); |
|
| 105 | + |
|
| 106 | + // Download Ingredients Data. |
|
| 107 | + $download_ingredients_data = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Download_Ingredients_Data' ); |
|
| 108 | + $download_ingredients_data->register_hooks(); |
|
| 109 | + } |
|
| 110 | 110 | } |
| 111 | 111 | |
| 112 | 112 | add_action( 'plugins_loaded', '__wl_foodkg__load' ); |
@@ -18,96 +18,96 @@ |
||
| 18 | 18 | use Wordlift\Task\Background\Background_Task_Factory; |
| 19 | 19 | use Wordlift\Task\Single_Call_Task; |
| 20 | 20 | |
| 21 | -if ( ! defined( 'ABSPATH' ) ) { |
|
| 21 | +if ( ! defined('ABSPATH')) { |
|
| 22 | 22 | exit; |
| 23 | 23 | } |
| 24 | 24 | |
| 25 | -define( 'WL_FOOD_KG_FILE', __FILE__ ); |
|
| 26 | -define( 'WL_FOOD_KG_DIR_PATH', dirname( WL_FOOD_KG_FILE ) ); |
|
| 25 | +define('WL_FOOD_KG_FILE', __FILE__); |
|
| 26 | +define('WL_FOOD_KG_DIR_PATH', dirname(WL_FOOD_KG_FILE)); |
|
| 27 | 27 | |
| 28 | 28 | function __wl_foodkg__load() { |
| 29 | 29 | |
| 30 | 30 | // Autoloader for plugin itself. |
| 31 | - if ( file_exists( __DIR__ . '/vendor/autoload.php' ) ) { |
|
| 32 | - require __DIR__ . '/vendor/autoload.php'; |
|
| 31 | + if (file_exists(__DIR__.'/vendor/autoload.php')) { |
|
| 32 | + require __DIR__.'/vendor/autoload.php'; |
|
| 33 | 33 | } |
| 34 | 34 | |
| 35 | 35 | $container_builder = new ContainerBuilder(); |
| 36 | - $loader = new YamlFileLoader( $container_builder, new FileLocator( __DIR__ ) ); |
|
| 37 | - $loader->load( 'services.yml' ); |
|
| 36 | + $loader = new YamlFileLoader($container_builder, new FileLocator(__DIR__)); |
|
| 37 | + $loader->load('services.yml'); |
|
| 38 | 38 | $container_builder->compile(); |
| 39 | 39 | |
| 40 | - $notices = $container_builder->get( 'Wordlift\Modules\Food_Kg\Notices' ); |
|
| 40 | + $notices = $container_builder->get('Wordlift\Modules\Food_Kg\Notices'); |
|
| 41 | 41 | $notices->register_hooks(); |
| 42 | 42 | |
| 43 | 43 | /** |
| 44 | 44 | * @var Preconditions $preconditions |
| 45 | 45 | */ |
| 46 | - $preconditions = $container_builder->get( 'Wordlift\Modules\Food_Kg\Preconditions' ); |
|
| 47 | - if ( ! $preconditions->pass() ) { |
|
| 46 | + $preconditions = $container_builder->get('Wordlift\Modules\Food_Kg\Preconditions'); |
|
| 47 | + if ( ! $preconditions->pass()) { |
|
| 48 | 48 | return; |
| 49 | 49 | } |
| 50 | 50 | |
| 51 | 51 | // Meta Box. |
| 52 | - $meta_box = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Meta_Box' ); |
|
| 52 | + $meta_box = $container_builder->get('Wordlift\Modules\Food_Kg\Admin\Meta_Box'); |
|
| 53 | 53 | $meta_box->register_hooks(); |
| 54 | 54 | |
| 55 | - $module = $container_builder->get( 'Wordlift\Modules\Food_Kg\Module' ); |
|
| 55 | + $module = $container_builder->get('Wordlift\Modules\Food_Kg\Module'); |
|
| 56 | 56 | $module->register_hooks(); |
| 57 | 57 | |
| 58 | 58 | /** @var Jsonld $jsonld */ |
| 59 | - $jsonld = $container_builder->get( 'Wordlift\Modules\Food_Kg\Jsonld' ); |
|
| 59 | + $jsonld = $container_builder->get('Wordlift\Modules\Food_Kg\Jsonld'); |
|
| 60 | 60 | $jsonld->register_hooks(); |
| 61 | 61 | |
| 62 | 62 | /** |
| 63 | 63 | * Ingredients API. |
| 64 | 64 | */ |
| 65 | - $ingredients_api = $container_builder->get( 'Wordlift\Modules\Food_Kg\Ingredients_API' ); |
|
| 65 | + $ingredients_api = $container_builder->get('Wordlift\Modules\Food_Kg\Ingredients_API'); |
|
| 66 | 66 | $ingredients_api->register_hooks(); |
| 67 | 67 | |
| 68 | 68 | /** @var Main_Ingredient_Jsonld $jsonld */ |
| 69 | - $main_ingredient_jsonld = $container_builder->get( 'Wordlift\Modules\Food_Kg\Main_Ingredient_Jsonld' ); |
|
| 69 | + $main_ingredient_jsonld = $container_builder->get('Wordlift\Modules\Food_Kg\Main_Ingredient_Jsonld'); |
|
| 70 | 70 | $main_ingredient_jsonld->register_hooks(); |
| 71 | 71 | |
| 72 | 72 | // Main Ingredient Background Task. |
| 73 | - $main_ingredient_recipe_lift = $container_builder->get( 'Wordlift\Modules\Food_Kg\Main_Ingredient_Recipe_Lift_Strategy' ); |
|
| 73 | + $main_ingredient_recipe_lift = $container_builder->get('Wordlift\Modules\Food_Kg\Main_Ingredient_Recipe_Lift_Strategy'); |
|
| 74 | 74 | Background_Task_Factory::create_action_scheduler_task( |
| 75 | 75 | 'wl_main_ingredient_sync', |
| 76 | 76 | 'wordlift', |
| 77 | 77 | new All_Posts_Task( |
| 78 | - array( $main_ingredient_recipe_lift, 'process' ), |
|
| 78 | + array($main_ingredient_recipe_lift, 'process'), |
|
| 79 | 79 | 'wprm_recipe', |
| 80 | 80 | 'sync-main-ingredient' |
| 81 | 81 | ), |
| 82 | 82 | '/main-ingredient', |
| 83 | 83 | 'sync-main-ingredient', |
| 84 | - __( 'Synchronize Main Ingredient', 'wordlift' ) |
|
| 84 | + __('Synchronize Main Ingredient', 'wordlift') |
|
| 85 | 85 | ); |
| 86 | 86 | |
| 87 | 87 | // Ingredients Taxonomy Background Task. |
| 88 | - $ingredients_taxonomy_recipe_lift = $container_builder->get( 'Wordlift\Modules\Food_Kg\Ingredients_Taxonomy_Recipe_Lift_Strategy' ); |
|
| 88 | + $ingredients_taxonomy_recipe_lift = $container_builder->get('Wordlift\Modules\Food_Kg\Ingredients_Taxonomy_Recipe_Lift_Strategy'); |
|
| 89 | 89 | Background_Task_Factory::create( |
| 90 | 90 | new Single_Call_Task( |
| 91 | - array( $ingredients_taxonomy_recipe_lift, 'run' ), |
|
| 91 | + array($ingredients_taxonomy_recipe_lift, 'run'), |
|
| 92 | 92 | 'sync-ingredients-taxonomy' |
| 93 | 93 | ), |
| 94 | 94 | '/sync-ingredients-taxonomy', |
| 95 | 95 | 'sync-ingredients-taxonomy', |
| 96 | - __( 'Synchronize Ingredients Taxonomy', 'wordlift' ) |
|
| 96 | + __('Synchronize Ingredients Taxonomy', 'wordlift') |
|
| 97 | 97 | ); |
| 98 | 98 | |
| 99 | - if ( is_admin() ) { |
|
| 100 | - $page = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Page' ); |
|
| 99 | + if (is_admin()) { |
|
| 100 | + $page = $container_builder->get('Wordlift\Modules\Food_Kg\Admin\Page'); |
|
| 101 | 101 | $page->register_hooks(); |
| 102 | 102 | |
| 103 | - $page = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Ingredients_Taxonomy_Page' ); |
|
| 103 | + $page = $container_builder->get('Wordlift\Modules\Food_Kg\Admin\Ingredients_Taxonomy_Page'); |
|
| 104 | 104 | $page->register_hooks(); |
| 105 | 105 | |
| 106 | 106 | // Download Ingredients Data. |
| 107 | - $download_ingredients_data = $container_builder->get( 'Wordlift\Modules\Food_Kg\Admin\Download_Ingredients_Data' ); |
|
| 107 | + $download_ingredients_data = $container_builder->get('Wordlift\Modules\Food_Kg\Admin\Download_Ingredients_Data'); |
|
| 108 | 108 | $download_ingredients_data->register_hooks(); |
| 109 | 109 | } |
| 110 | 110 | } |
| 111 | 111 | |
| 112 | -add_action( 'plugins_loaded', '__wl_foodkg__load' ); |
|
| 112 | +add_action('plugins_loaded', '__wl_foodkg__load'); |
|
| 113 | 113 | |
@@ -4,122 +4,122 @@ |
||
| 4 | 4 | |
| 5 | 5 | class Context { |
| 6 | 6 | |
| 7 | - private $count; |
|
| 8 | - private $offset; |
|
| 9 | - private $started; |
|
| 10 | - private $updated; |
|
| 11 | - |
|
| 12 | - /** |
|
| 13 | - * @param $count |
|
| 14 | - * @param $offset |
|
| 15 | - * @param $started |
|
| 16 | - * @param $updated |
|
| 17 | - */ |
|
| 18 | - public function __construct( $count, $offset, $started, $updated ) { |
|
| 19 | - $this->count = $count; |
|
| 20 | - $this->offset = $offset; |
|
| 21 | - $this->started = $started; |
|
| 22 | - $this->updated = $updated; |
|
| 23 | - } |
|
| 24 | - |
|
| 25 | - /** |
|
| 26 | - * @return int |
|
| 27 | - */ |
|
| 28 | - public function get_count() { |
|
| 29 | - return $this->count; |
|
| 30 | - } |
|
| 31 | - |
|
| 32 | - /** |
|
| 33 | - * @param int $count |
|
| 34 | - * |
|
| 35 | - * @return Context |
|
| 36 | - */ |
|
| 37 | - public function set_count( $count ) { |
|
| 38 | - $this->count = $count; |
|
| 39 | - |
|
| 40 | - return $this; |
|
| 41 | - } |
|
| 42 | - |
|
| 43 | - /** |
|
| 44 | - * @return int |
|
| 45 | - */ |
|
| 46 | - public function get_offset() { |
|
| 47 | - return $this->offset; |
|
| 48 | - } |
|
| 49 | - |
|
| 50 | - /** |
|
| 51 | - * @param int $offset |
|
| 52 | - * |
|
| 53 | - * @return Context |
|
| 54 | - */ |
|
| 55 | - public function set_offset( $offset ) { |
|
| 56 | - $this->offset = $offset; |
|
| 57 | - |
|
| 58 | - return $this; |
|
| 59 | - } |
|
| 60 | - |
|
| 61 | - /** |
|
| 62 | - * @return int |
|
| 63 | - */ |
|
| 64 | - public function get_started() { |
|
| 65 | - return $this->started; |
|
| 66 | - } |
|
| 67 | - |
|
| 68 | - /** |
|
| 69 | - * @param int $started |
|
| 70 | - * |
|
| 71 | - * @return Context |
|
| 72 | - */ |
|
| 73 | - public function set_started( $started ) { |
|
| 74 | - $this->started = $started; |
|
| 75 | - |
|
| 76 | - return $this; |
|
| 77 | - } |
|
| 78 | - |
|
| 79 | - /** |
|
| 80 | - * @return int |
|
| 81 | - */ |
|
| 82 | - public function get_updated() { |
|
| 83 | - return $this->updated; |
|
| 84 | - } |
|
| 85 | - |
|
| 86 | - /** |
|
| 87 | - * @param int $updated |
|
| 88 | - * |
|
| 89 | - * @return Context |
|
| 90 | - */ |
|
| 91 | - public function set_updated( $updated ) { |
|
| 92 | - $this->updated = $updated; |
|
| 93 | - |
|
| 94 | - return $this; |
|
| 95 | - } |
|
| 96 | - |
|
| 97 | - public function get_data() { |
|
| 98 | - return array( |
|
| 99 | - 'count' => $this->count, |
|
| 100 | - 'updated' => $this->updated, |
|
| 101 | - 'started' => $this->started, |
|
| 102 | - 'offset' => $this->offset, |
|
| 103 | - 'index' => $this->offset, |
|
| 104 | - ); |
|
| 105 | - } |
|
| 106 | - |
|
| 107 | - /** |
|
| 108 | - * @param $count int |
|
| 109 | - * |
|
| 110 | - * @return Context |
|
| 111 | - */ |
|
| 112 | - public static function from( $count ) { |
|
| 113 | - return new self( $count, 0, time(), time() ); |
|
| 114 | - } |
|
| 115 | - |
|
| 116 | - /** |
|
| 117 | - * @param $data array |
|
| 118 | - * |
|
| 119 | - * @return Context |
|
| 120 | - */ |
|
| 121 | - public static function from_data( $data ) { |
|
| 122 | - return new self( $data['count'], $data['offset'], $data['started'], $data['updated'] ); |
|
| 123 | - } |
|
| 7 | + private $count; |
|
| 8 | + private $offset; |
|
| 9 | + private $started; |
|
| 10 | + private $updated; |
|
| 11 | + |
|
| 12 | + /** |
|
| 13 | + * @param $count |
|
| 14 | + * @param $offset |
|
| 15 | + * @param $started |
|
| 16 | + * @param $updated |
|
| 17 | + */ |
|
| 18 | + public function __construct( $count, $offset, $started, $updated ) { |
|
| 19 | + $this->count = $count; |
|
| 20 | + $this->offset = $offset; |
|
| 21 | + $this->started = $started; |
|
| 22 | + $this->updated = $updated; |
|
| 23 | + } |
|
| 24 | + |
|
| 25 | + /** |
|
| 26 | + * @return int |
|
| 27 | + */ |
|
| 28 | + public function get_count() { |
|
| 29 | + return $this->count; |
|
| 30 | + } |
|
| 31 | + |
|
| 32 | + /** |
|
| 33 | + * @param int $count |
|
| 34 | + * |
|
| 35 | + * @return Context |
|
| 36 | + */ |
|
| 37 | + public function set_count( $count ) { |
|
| 38 | + $this->count = $count; |
|
| 39 | + |
|
| 40 | + return $this; |
|
| 41 | + } |
|
| 42 | + |
|
| 43 | + /** |
|
| 44 | + * @return int |
|
| 45 | + */ |
|
| 46 | + public function get_offset() { |
|
| 47 | + return $this->offset; |
|
| 48 | + } |
|
| 49 | + |
|
| 50 | + /** |
|
| 51 | + * @param int $offset |
|
| 52 | + * |
|
| 53 | + * @return Context |
|
| 54 | + */ |
|
| 55 | + public function set_offset( $offset ) { |
|
| 56 | + $this->offset = $offset; |
|
| 57 | + |
|
| 58 | + return $this; |
|
| 59 | + } |
|
| 60 | + |
|
| 61 | + /** |
|
| 62 | + * @return int |
|
| 63 | + */ |
|
| 64 | + public function get_started() { |
|
| 65 | + return $this->started; |
|
| 66 | + } |
|
| 67 | + |
|
| 68 | + /** |
|
| 69 | + * @param int $started |
|
| 70 | + * |
|
| 71 | + * @return Context |
|
| 72 | + */ |
|
| 73 | + public function set_started( $started ) { |
|
| 74 | + $this->started = $started; |
|
| 75 | + |
|
| 76 | + return $this; |
|
| 77 | + } |
|
| 78 | + |
|
| 79 | + /** |
|
| 80 | + * @return int |
|
| 81 | + */ |
|
| 82 | + public function get_updated() { |
|
| 83 | + return $this->updated; |
|
| 84 | + } |
|
| 85 | + |
|
| 86 | + /** |
|
| 87 | + * @param int $updated |
|
| 88 | + * |
|
| 89 | + * @return Context |
|
| 90 | + */ |
|
| 91 | + public function set_updated( $updated ) { |
|
| 92 | + $this->updated = $updated; |
|
| 93 | + |
|
| 94 | + return $this; |
|
| 95 | + } |
|
| 96 | + |
|
| 97 | + public function get_data() { |
|
| 98 | + return array( |
|
| 99 | + 'count' => $this->count, |
|
| 100 | + 'updated' => $this->updated, |
|
| 101 | + 'started' => $this->started, |
|
| 102 | + 'offset' => $this->offset, |
|
| 103 | + 'index' => $this->offset, |
|
| 104 | + ); |
|
| 105 | + } |
|
| 106 | + |
|
| 107 | + /** |
|
| 108 | + * @param $count int |
|
| 109 | + * |
|
| 110 | + * @return Context |
|
| 111 | + */ |
|
| 112 | + public static function from( $count ) { |
|
| 113 | + return new self( $count, 0, time(), time() ); |
|
| 114 | + } |
|
| 115 | + |
|
| 116 | + /** |
|
| 117 | + * @param $data array |
|
| 118 | + * |
|
| 119 | + * @return Context |
|
| 120 | + */ |
|
| 121 | + public static function from_data( $data ) { |
|
| 122 | + return new self( $data['count'], $data['offset'], $data['started'], $data['updated'] ); |
|
| 123 | + } |
|
| 124 | 124 | |
| 125 | 125 | } |
@@ -15,7 +15,7 @@ discard block |
||
| 15 | 15 | * @param $started |
| 16 | 16 | * @param $updated |
| 17 | 17 | */ |
| 18 | - public function __construct( $count, $offset, $started, $updated ) { |
|
| 18 | + public function __construct($count, $offset, $started, $updated) { |
|
| 19 | 19 | $this->count = $count; |
| 20 | 20 | $this->offset = $offset; |
| 21 | 21 | $this->started = $started; |
@@ -34,7 +34,7 @@ discard block |
||
| 34 | 34 | * |
| 35 | 35 | * @return Context |
| 36 | 36 | */ |
| 37 | - public function set_count( $count ) { |
|
| 37 | + public function set_count($count) { |
|
| 38 | 38 | $this->count = $count; |
| 39 | 39 | |
| 40 | 40 | return $this; |
@@ -52,7 +52,7 @@ discard block |
||
| 52 | 52 | * |
| 53 | 53 | * @return Context |
| 54 | 54 | */ |
| 55 | - public function set_offset( $offset ) { |
|
| 55 | + public function set_offset($offset) { |
|
| 56 | 56 | $this->offset = $offset; |
| 57 | 57 | |
| 58 | 58 | return $this; |
@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | * |
| 71 | 71 | * @return Context |
| 72 | 72 | */ |
| 73 | - public function set_started( $started ) { |
|
| 73 | + public function set_started($started) { |
|
| 74 | 74 | $this->started = $started; |
| 75 | 75 | |
| 76 | 76 | return $this; |
@@ -88,7 +88,7 @@ discard block |
||
| 88 | 88 | * |
| 89 | 89 | * @return Context |
| 90 | 90 | */ |
| 91 | - public function set_updated( $updated ) { |
|
| 91 | + public function set_updated($updated) { |
|
| 92 | 92 | $this->updated = $updated; |
| 93 | 93 | |
| 94 | 94 | return $this; |
@@ -109,8 +109,8 @@ discard block |
||
| 109 | 109 | * |
| 110 | 110 | * @return Context |
| 111 | 111 | */ |
| 112 | - public static function from( $count ) { |
|
| 113 | - return new self( $count, 0, time(), time() ); |
|
| 112 | + public static function from($count) { |
|
| 113 | + return new self($count, 0, time(), time()); |
|
| 114 | 114 | } |
| 115 | 115 | |
| 116 | 116 | /** |
@@ -118,8 +118,8 @@ discard block |
||
| 118 | 118 | * |
| 119 | 119 | * @return Context |
| 120 | 120 | */ |
| 121 | - public static function from_data( $data ) { |
|
| 122 | - return new self( $data['count'], $data['offset'], $data['started'], $data['updated'] ); |
|
| 121 | + public static function from_data($data) { |
|
| 122 | + return new self($data['count'], $data['offset'], $data['started'], $data['updated']); |
|
| 123 | 123 | } |
| 124 | 124 | |
| 125 | 125 | } |
@@ -8,95 +8,95 @@ |
||
| 8 | 8 | |
| 9 | 9 | class Background_Task_Route { |
| 10 | 10 | |
| 11 | - const VERSION_STRING = 'wordlift/v1'; |
|
| 12 | - |
|
| 13 | - /** |
|
| 14 | - * @var Background_Route_Task |
|
| 15 | - */ |
|
| 16 | - private $background_task; |
|
| 17 | - |
|
| 18 | - /** |
|
| 19 | - * @var string |
|
| 20 | - */ |
|
| 21 | - private $route_name; |
|
| 22 | - |
|
| 23 | - public function __construct( $background_task, $route_name ) { |
|
| 24 | - $this->background_task = $background_task; |
|
| 25 | - $this->route_name = $route_name; |
|
| 26 | - } |
|
| 27 | - |
|
| 28 | - public static function create( $task, $route_name ) { |
|
| 29 | - $route = new self( $task, $route_name ); |
|
| 30 | - |
|
| 31 | - add_action( 'rest_api_init', array( $route, 'register' ) ); |
|
| 32 | - |
|
| 33 | - return $route; |
|
| 34 | - } |
|
| 35 | - |
|
| 36 | - /** |
|
| 37 | - * @throws Exception if the input value is invalid. |
|
| 38 | - */ |
|
| 39 | - public function register() { |
|
| 40 | - Assertions::starts_with( $this->route_name, '/', 'The route name must start with a slash.' ); |
|
| 41 | - |
|
| 42 | - register_rest_route( |
|
| 43 | - self::VERSION_STRING, |
|
| 44 | - $this->route_name, |
|
| 45 | - array( |
|
| 46 | - 'methods' => WP_REST_Server::CREATABLE, |
|
| 47 | - 'callback' => function () { |
|
| 48 | - return $this->background_task->start(); |
|
| 49 | - }, |
|
| 50 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 51 | - ) |
|
| 52 | - ); |
|
| 53 | - |
|
| 54 | - register_rest_route( |
|
| 55 | - self::VERSION_STRING, |
|
| 56 | - $this->route_name, |
|
| 57 | - array( |
|
| 58 | - 'methods' => WP_REST_Server::READABLE, |
|
| 59 | - 'callback' => function () { |
|
| 60 | - return $this->background_task->get_info(); |
|
| 61 | - }, |
|
| 62 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 63 | - ) |
|
| 64 | - ); |
|
| 65 | - |
|
| 66 | - register_rest_route( |
|
| 67 | - self::VERSION_STRING, |
|
| 68 | - $this->route_name, |
|
| 69 | - array( |
|
| 70 | - 'methods' => WP_REST_Server::DELETABLE, |
|
| 71 | - 'callback' => function () { |
|
| 72 | - return $this->background_task->stop(); |
|
| 73 | - }, |
|
| 74 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 75 | - ) |
|
| 76 | - ); |
|
| 77 | - |
|
| 78 | - register_rest_route( |
|
| 79 | - self::VERSION_STRING, |
|
| 80 | - $this->route_name, |
|
| 81 | - array( |
|
| 82 | - 'methods' => 'PUT', |
|
| 83 | - 'callback' => function () { |
|
| 84 | - return $this->background_task->resume(); |
|
| 85 | - }, |
|
| 86 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 87 | - ) |
|
| 88 | - ); |
|
| 89 | - |
|
| 90 | - } |
|
| 91 | - |
|
| 92 | - public function permission_callback() { |
|
| 93 | - $user = wp_get_current_user(); |
|
| 94 | - |
|
| 95 | - return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true ); |
|
| 96 | - } |
|
| 97 | - |
|
| 98 | - public function get_rest_path() { |
|
| 99 | - return self::VERSION_STRING . $this->route_name; |
|
| 100 | - } |
|
| 11 | + const VERSION_STRING = 'wordlift/v1'; |
|
| 12 | + |
|
| 13 | + /** |
|
| 14 | + * @var Background_Route_Task |
|
| 15 | + */ |
|
| 16 | + private $background_task; |
|
| 17 | + |
|
| 18 | + /** |
|
| 19 | + * @var string |
|
| 20 | + */ |
|
| 21 | + private $route_name; |
|
| 22 | + |
|
| 23 | + public function __construct( $background_task, $route_name ) { |
|
| 24 | + $this->background_task = $background_task; |
|
| 25 | + $this->route_name = $route_name; |
|
| 26 | + } |
|
| 27 | + |
|
| 28 | + public static function create( $task, $route_name ) { |
|
| 29 | + $route = new self( $task, $route_name ); |
|
| 30 | + |
|
| 31 | + add_action( 'rest_api_init', array( $route, 'register' ) ); |
|
| 32 | + |
|
| 33 | + return $route; |
|
| 34 | + } |
|
| 35 | + |
|
| 36 | + /** |
|
| 37 | + * @throws Exception if the input value is invalid. |
|
| 38 | + */ |
|
| 39 | + public function register() { |
|
| 40 | + Assertions::starts_with( $this->route_name, '/', 'The route name must start with a slash.' ); |
|
| 41 | + |
|
| 42 | + register_rest_route( |
|
| 43 | + self::VERSION_STRING, |
|
| 44 | + $this->route_name, |
|
| 45 | + array( |
|
| 46 | + 'methods' => WP_REST_Server::CREATABLE, |
|
| 47 | + 'callback' => function () { |
|
| 48 | + return $this->background_task->start(); |
|
| 49 | + }, |
|
| 50 | + 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 51 | + ) |
|
| 52 | + ); |
|
| 53 | + |
|
| 54 | + register_rest_route( |
|
| 55 | + self::VERSION_STRING, |
|
| 56 | + $this->route_name, |
|
| 57 | + array( |
|
| 58 | + 'methods' => WP_REST_Server::READABLE, |
|
| 59 | + 'callback' => function () { |
|
| 60 | + return $this->background_task->get_info(); |
|
| 61 | + }, |
|
| 62 | + 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 63 | + ) |
|
| 64 | + ); |
|
| 65 | + |
|
| 66 | + register_rest_route( |
|
| 67 | + self::VERSION_STRING, |
|
| 68 | + $this->route_name, |
|
| 69 | + array( |
|
| 70 | + 'methods' => WP_REST_Server::DELETABLE, |
|
| 71 | + 'callback' => function () { |
|
| 72 | + return $this->background_task->stop(); |
|
| 73 | + }, |
|
| 74 | + 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 75 | + ) |
|
| 76 | + ); |
|
| 77 | + |
|
| 78 | + register_rest_route( |
|
| 79 | + self::VERSION_STRING, |
|
| 80 | + $this->route_name, |
|
| 81 | + array( |
|
| 82 | + 'methods' => 'PUT', |
|
| 83 | + 'callback' => function () { |
|
| 84 | + return $this->background_task->resume(); |
|
| 85 | + }, |
|
| 86 | + 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 87 | + ) |
|
| 88 | + ); |
|
| 89 | + |
|
| 90 | + } |
|
| 91 | + |
|
| 92 | + public function permission_callback() { |
|
| 93 | + $user = wp_get_current_user(); |
|
| 94 | + |
|
| 95 | + return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true ); |
|
| 96 | + } |
|
| 97 | + |
|
| 98 | + public function get_rest_path() { |
|
| 99 | + return self::VERSION_STRING . $this->route_name; |
|
| 100 | + } |
|
| 101 | 101 | |
| 102 | 102 | } |
@@ -20,15 +20,15 @@ discard block |
||
| 20 | 20 | */ |
| 21 | 21 | private $route_name; |
| 22 | 22 | |
| 23 | - public function __construct( $background_task, $route_name ) { |
|
| 23 | + public function __construct($background_task, $route_name) { |
|
| 24 | 24 | $this->background_task = $background_task; |
| 25 | 25 | $this->route_name = $route_name; |
| 26 | 26 | } |
| 27 | 27 | |
| 28 | - public static function create( $task, $route_name ) { |
|
| 29 | - $route = new self( $task, $route_name ); |
|
| 28 | + public static function create($task, $route_name) { |
|
| 29 | + $route = new self($task, $route_name); |
|
| 30 | 30 | |
| 31 | - add_action( 'rest_api_init', array( $route, 'register' ) ); |
|
| 31 | + add_action('rest_api_init', array($route, 'register')); |
|
| 32 | 32 | |
| 33 | 33 | return $route; |
| 34 | 34 | } |
@@ -37,17 +37,17 @@ discard block |
||
| 37 | 37 | * @throws Exception if the input value is invalid. |
| 38 | 38 | */ |
| 39 | 39 | public function register() { |
| 40 | - Assertions::starts_with( $this->route_name, '/', 'The route name must start with a slash.' ); |
|
| 40 | + Assertions::starts_with($this->route_name, '/', 'The route name must start with a slash.'); |
|
| 41 | 41 | |
| 42 | 42 | register_rest_route( |
| 43 | 43 | self::VERSION_STRING, |
| 44 | 44 | $this->route_name, |
| 45 | 45 | array( |
| 46 | 46 | 'methods' => WP_REST_Server::CREATABLE, |
| 47 | - 'callback' => function () { |
|
| 47 | + 'callback' => function() { |
|
| 48 | 48 | return $this->background_task->start(); |
| 49 | 49 | }, |
| 50 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 50 | + 'permission_callback' => array($this, 'permission_callback'), |
|
| 51 | 51 | ) |
| 52 | 52 | ); |
| 53 | 53 | |
@@ -56,10 +56,10 @@ discard block |
||
| 56 | 56 | $this->route_name, |
| 57 | 57 | array( |
| 58 | 58 | 'methods' => WP_REST_Server::READABLE, |
| 59 | - 'callback' => function () { |
|
| 59 | + 'callback' => function() { |
|
| 60 | 60 | return $this->background_task->get_info(); |
| 61 | 61 | }, |
| 62 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 62 | + 'permission_callback' => array($this, 'permission_callback'), |
|
| 63 | 63 | ) |
| 64 | 64 | ); |
| 65 | 65 | |
@@ -68,10 +68,10 @@ discard block |
||
| 68 | 68 | $this->route_name, |
| 69 | 69 | array( |
| 70 | 70 | 'methods' => WP_REST_Server::DELETABLE, |
| 71 | - 'callback' => function () { |
|
| 71 | + 'callback' => function() { |
|
| 72 | 72 | return $this->background_task->stop(); |
| 73 | 73 | }, |
| 74 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 74 | + 'permission_callback' => array($this, 'permission_callback'), |
|
| 75 | 75 | ) |
| 76 | 76 | ); |
| 77 | 77 | |
@@ -80,10 +80,10 @@ discard block |
||
| 80 | 80 | $this->route_name, |
| 81 | 81 | array( |
| 82 | 82 | 'methods' => 'PUT', |
| 83 | - 'callback' => function () { |
|
| 83 | + 'callback' => function() { |
|
| 84 | 84 | return $this->background_task->resume(); |
| 85 | 85 | }, |
| 86 | - 'permission_callback' => array( $this, 'permission_callback' ), |
|
| 86 | + 'permission_callback' => array($this, 'permission_callback'), |
|
| 87 | 87 | ) |
| 88 | 88 | ); |
| 89 | 89 | |
@@ -92,11 +92,11 @@ discard block |
||
| 92 | 92 | public function permission_callback() { |
| 93 | 93 | $user = wp_get_current_user(); |
| 94 | 94 | |
| 95 | - return is_super_admin( $user->ID ) || in_array( 'administrator', (array) $user->roles, true ); |
|
| 95 | + return is_super_admin($user->ID) || in_array('administrator', (array) $user->roles, true); |
|
| 96 | 96 | } |
| 97 | 97 | |
| 98 | 98 | public function get_rest_path() { |
| 99 | - return self::VERSION_STRING . $this->route_name; |
|
| 99 | + return self::VERSION_STRING.$this->route_name; |
|
| 100 | 100 | } |
| 101 | 101 | |
| 102 | 102 | } |
@@ -7,119 +7,119 @@ |
||
| 7 | 7 | |
| 8 | 8 | class Background_Task extends Wordlift_Plugin_WP_Background_Process implements Background_Route_Task { |
| 9 | 9 | |
| 10 | - const STATE_STARTED = 'started'; |
|
| 11 | - const STATE_STOPPED = 'stopped'; |
|
| 12 | - |
|
| 13 | - /** |
|
| 14 | - * The current state of the task, started or stopped. |
|
| 15 | - * |
|
| 16 | - * @var Background_Task_State $state |
|
| 17 | - */ |
|
| 18 | - private $state; |
|
| 19 | - |
|
| 20 | - /** |
|
| 21 | - * The actual task. |
|
| 22 | - * |
|
| 23 | - * @var Task $task |
|
| 24 | - */ |
|
| 25 | - private $task; |
|
| 26 | - |
|
| 27 | - /** |
|
| 28 | - * The prefix to store the state and other information in WP's options table, determined at instantiation. |
|
| 29 | - * |
|
| 30 | - * @var string $option_prefix |
|
| 31 | - */ |
|
| 32 | - private $option_prefix; |
|
| 33 | - |
|
| 34 | - /** |
|
| 35 | - * @param Task $task |
|
| 36 | - */ |
|
| 37 | - public function __construct( $task ) { |
|
| 38 | - $this->action = $task->get_id(); |
|
| 39 | - $this->option_prefix = "_{$this->action}_"; |
|
| 40 | - |
|
| 41 | - parent::__construct(); |
|
| 42 | - |
|
| 43 | - // Set the current state. |
|
| 44 | - if ( self::STATE_STARTED === $this->get_state() ) { |
|
| 45 | - $this->state = new Background_Task_Started_State( $this, $task ); |
|
| 46 | - } else { |
|
| 47 | - $this->state = new Background_Task_Stopped_State( $this ); |
|
| 48 | - } |
|
| 49 | - |
|
| 50 | - $this->task = $task; |
|
| 51 | - } |
|
| 52 | - |
|
| 53 | - public static function create( $task ) { |
|
| 54 | - return new self( $task ); |
|
| 55 | - } |
|
| 56 | - |
|
| 57 | - public function get_option_prefix() { |
|
| 58 | - return $this->option_prefix; |
|
| 59 | - } |
|
| 60 | - |
|
| 61 | - /** |
|
| 62 | - * This function is called: |
|
| 63 | - * - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance. |
|
| 64 | - * - To synchronize a post, by passing a numeric ID. |
|
| 65 | - * |
|
| 66 | - * This function returns the parameter for the next call or NULL if there are no more posts to process. |
|
| 67 | - * |
|
| 68 | - * @param mixed $item Queue item to iterate over. |
|
| 69 | - * |
|
| 70 | - * @return int[]|false The next post IDs or false if there are no more. |
|
| 71 | - */ |
|
| 72 | - protected function task( $item ) { |
|
| 73 | - |
|
| 74 | - return $this->state->task( $item ); |
|
| 75 | - } |
|
| 76 | - |
|
| 77 | - /** |
|
| 78 | - * Transition to the started state. |
|
| 79 | - */ |
|
| 80 | - public function start() { |
|
| 81 | - $this->state->leave(); |
|
| 82 | - $this->state = new Background_Task_Started_State( $this, $this->task ); |
|
| 83 | - $this->state->enter(); |
|
| 84 | - } |
|
| 85 | - |
|
| 86 | - /** |
|
| 87 | - * Transition to the stopped state. |
|
| 88 | - */ |
|
| 89 | - public function stop() { |
|
| 90 | - $this->state->leave(); |
|
| 91 | - $this->state = new Background_Task_Stopped_State( $this ); |
|
| 92 | - $this->state->enter(); |
|
| 93 | - } |
|
| 94 | - |
|
| 95 | - public function resume() { |
|
| 96 | - $this->state->resume(); |
|
| 97 | - } |
|
| 98 | - |
|
| 99 | - /** |
|
| 100 | - * Get the current state. |
|
| 101 | - * |
|
| 102 | - * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default). |
|
| 103 | - */ |
|
| 104 | - public function get_state() { |
|
| 105 | - return get_option( $this->option_prefix . 'state', self::STATE_STOPPED ); |
|
| 106 | - } |
|
| 107 | - |
|
| 108 | - /** |
|
| 109 | - * Persist the current state. |
|
| 110 | - * |
|
| 111 | - * @param string $value |
|
| 112 | - * |
|
| 113 | - * @return bool |
|
| 114 | - */ |
|
| 115 | - public function set_state( $value ) { |
|
| 116 | - return null === $value |
|
| 117 | - ? delete_option( $this->option_prefix . 'state' ) |
|
| 118 | - : update_option( $this->option_prefix . 'state', $value, true ); |
|
| 119 | - } |
|
| 120 | - |
|
| 121 | - public function get_info() { |
|
| 122 | - return $this->state->get_info(); |
|
| 123 | - } |
|
| 10 | + const STATE_STARTED = 'started'; |
|
| 11 | + const STATE_STOPPED = 'stopped'; |
|
| 12 | + |
|
| 13 | + /** |
|
| 14 | + * The current state of the task, started or stopped. |
|
| 15 | + * |
|
| 16 | + * @var Background_Task_State $state |
|
| 17 | + */ |
|
| 18 | + private $state; |
|
| 19 | + |
|
| 20 | + /** |
|
| 21 | + * The actual task. |
|
| 22 | + * |
|
| 23 | + * @var Task $task |
|
| 24 | + */ |
|
| 25 | + private $task; |
|
| 26 | + |
|
| 27 | + /** |
|
| 28 | + * The prefix to store the state and other information in WP's options table, determined at instantiation. |
|
| 29 | + * |
|
| 30 | + * @var string $option_prefix |
|
| 31 | + */ |
|
| 32 | + private $option_prefix; |
|
| 33 | + |
|
| 34 | + /** |
|
| 35 | + * @param Task $task |
|
| 36 | + */ |
|
| 37 | + public function __construct( $task ) { |
|
| 38 | + $this->action = $task->get_id(); |
|
| 39 | + $this->option_prefix = "_{$this->action}_"; |
|
| 40 | + |
|
| 41 | + parent::__construct(); |
|
| 42 | + |
|
| 43 | + // Set the current state. |
|
| 44 | + if ( self::STATE_STARTED === $this->get_state() ) { |
|
| 45 | + $this->state = new Background_Task_Started_State( $this, $task ); |
|
| 46 | + } else { |
|
| 47 | + $this->state = new Background_Task_Stopped_State( $this ); |
|
| 48 | + } |
|
| 49 | + |
|
| 50 | + $this->task = $task; |
|
| 51 | + } |
|
| 52 | + |
|
| 53 | + public static function create( $task ) { |
|
| 54 | + return new self( $task ); |
|
| 55 | + } |
|
| 56 | + |
|
| 57 | + public function get_option_prefix() { |
|
| 58 | + return $this->option_prefix; |
|
| 59 | + } |
|
| 60 | + |
|
| 61 | + /** |
|
| 62 | + * This function is called: |
|
| 63 | + * - To start a new Synchronization, by passing a {@link Sync_Start_Message} instance. |
|
| 64 | + * - To synchronize a post, by passing a numeric ID. |
|
| 65 | + * |
|
| 66 | + * This function returns the parameter for the next call or NULL if there are no more posts to process. |
|
| 67 | + * |
|
| 68 | + * @param mixed $item Queue item to iterate over. |
|
| 69 | + * |
|
| 70 | + * @return int[]|false The next post IDs or false if there are no more. |
|
| 71 | + */ |
|
| 72 | + protected function task( $item ) { |
|
| 73 | + |
|
| 74 | + return $this->state->task( $item ); |
|
| 75 | + } |
|
| 76 | + |
|
| 77 | + /** |
|
| 78 | + * Transition to the started state. |
|
| 79 | + */ |
|
| 80 | + public function start() { |
|
| 81 | + $this->state->leave(); |
|
| 82 | + $this->state = new Background_Task_Started_State( $this, $this->task ); |
|
| 83 | + $this->state->enter(); |
|
| 84 | + } |
|
| 85 | + |
|
| 86 | + /** |
|
| 87 | + * Transition to the stopped state. |
|
| 88 | + */ |
|
| 89 | + public function stop() { |
|
| 90 | + $this->state->leave(); |
|
| 91 | + $this->state = new Background_Task_Stopped_State( $this ); |
|
| 92 | + $this->state->enter(); |
|
| 93 | + } |
|
| 94 | + |
|
| 95 | + public function resume() { |
|
| 96 | + $this->state->resume(); |
|
| 97 | + } |
|
| 98 | + |
|
| 99 | + /** |
|
| 100 | + * Get the current state. |
|
| 101 | + * |
|
| 102 | + * @return string Either self::STARTED_STATE or self::STOPPED_STATE (default). |
|
| 103 | + */ |
|
| 104 | + public function get_state() { |
|
| 105 | + return get_option( $this->option_prefix . 'state', self::STATE_STOPPED ); |
|
| 106 | + } |
|
| 107 | + |
|
| 108 | + /** |
|
| 109 | + * Persist the current state. |
|
| 110 | + * |
|
| 111 | + * @param string $value |
|
| 112 | + * |
|
| 113 | + * @return bool |
|
| 114 | + */ |
|
| 115 | + public function set_state( $value ) { |
|
| 116 | + return null === $value |
|
| 117 | + ? delete_option( $this->option_prefix . 'state' ) |
|
| 118 | + : update_option( $this->option_prefix . 'state', $value, true ); |
|
| 119 | + } |
|
| 120 | + |
|
| 121 | + public function get_info() { |
|
| 122 | + return $this->state->get_info(); |
|
| 123 | + } |
|
| 124 | 124 | |
| 125 | 125 | } |
@@ -3,18 +3,18 @@ |
||
| 3 | 3 | namespace Wordlift\Task\Background; |
| 4 | 4 | |
| 5 | 5 | interface Background_Route_Task { |
| 6 | - /** |
|
| 7 | - * Transition to the started state. |
|
| 8 | - */ |
|
| 9 | - public function start(); |
|
| 6 | + /** |
|
| 7 | + * Transition to the started state. |
|
| 8 | + */ |
|
| 9 | + public function start(); |
|
| 10 | 10 | |
| 11 | - /** |
|
| 12 | - * Transition to the stopped state. |
|
| 13 | - */ |
|
| 14 | - public function stop(); |
|
| 11 | + /** |
|
| 12 | + * Transition to the stopped state. |
|
| 13 | + */ |
|
| 14 | + public function stop(); |
|
| 15 | 15 | |
| 16 | - public function resume(); |
|
| 16 | + public function resume(); |
|
| 17 | 17 | |
| 18 | - public function get_info(); |
|
| 18 | + public function get_info(); |
|
| 19 | 19 | |
| 20 | 20 | } |
@@ -14,58 +14,58 @@ |
||
| 14 | 14 | */ |
| 15 | 15 | class Background_Task_Factory { |
| 16 | 16 | |
| 17 | - /** |
|
| 18 | - * Create a {@link Background_Task} given the provided task and route. |
|
| 19 | - * |
|
| 20 | - * @param Task $task The target task. |
|
| 21 | - * @param string $route The route name. |
|
| 22 | - * @param string $page_id The page id. |
|
| 23 | - * @param string $page_title The page title. |
|
| 24 | - * |
|
| 25 | - * @return void |
|
| 26 | - * @throws Exception in case of invalid arguments. |
|
| 27 | - */ |
|
| 28 | - public static function create( $task, $route, $page_id, $page_title ) { |
|
| 29 | - self::assertions( $task, $route ); |
|
| 30 | - $background_task = Background_Task::create( $task ); |
|
| 31 | - $background_task_route = Background_Task_Route::create( $background_task, $route ); |
|
| 32 | - Background_Task_Page::create( $page_title, $page_id, $background_task_route ); |
|
| 33 | - } |
|
| 17 | + /** |
|
| 18 | + * Create a {@link Background_Task} given the provided task and route. |
|
| 19 | + * |
|
| 20 | + * @param Task $task The target task. |
|
| 21 | + * @param string $route The route name. |
|
| 22 | + * @param string $page_id The page id. |
|
| 23 | + * @param string $page_title The page title. |
|
| 24 | + * |
|
| 25 | + * @return void |
|
| 26 | + * @throws Exception in case of invalid arguments. |
|
| 27 | + */ |
|
| 28 | + public static function create( $task, $route, $page_id, $page_title ) { |
|
| 29 | + self::assertions( $task, $route ); |
|
| 30 | + $background_task = Background_Task::create( $task ); |
|
| 31 | + $background_task_route = Background_Task_Route::create( $background_task, $route ); |
|
| 32 | + Background_Task_Page::create( $page_title, $page_id, $background_task_route ); |
|
| 33 | + } |
|
| 34 | 34 | |
| 35 | - /** |
|
| 36 | - * Create a {@link Background_Task} given the provided task and route. |
|
| 37 | - * |
|
| 38 | - * @param Task $task The target task. |
|
| 39 | - * @param string $route The route name. |
|
| 40 | - * @param string $page_id The page id. |
|
| 41 | - * @param string $page_title The page title. |
|
| 42 | - * |
|
| 43 | - * @return void |
|
| 44 | - * @throws Exception in case of invalid arguments. |
|
| 45 | - */ |
|
| 46 | - public static function create_action_scheduler_task( $hook, $group, $task, $route, $page_id, $page_title, $batch_size = 5 ) { |
|
| 47 | - self::assertions( $task, $route ); |
|
| 48 | - $background_task = new \Wordlift\Task\Action_Scheduler\Background_Task( |
|
| 49 | - $hook, |
|
| 50 | - $group, |
|
| 51 | - $task, |
|
| 52 | - "_{$hook}_", |
|
| 53 | - $batch_size |
|
| 54 | - ); |
|
| 55 | - $background_task_route = Background_Task_Route::create( $background_task, $route ); |
|
| 56 | - Background_Task_Page::create( $page_title, $page_id, $background_task_route ); |
|
| 57 | - } |
|
| 35 | + /** |
|
| 36 | + * Create a {@link Background_Task} given the provided task and route. |
|
| 37 | + * |
|
| 38 | + * @param Task $task The target task. |
|
| 39 | + * @param string $route The route name. |
|
| 40 | + * @param string $page_id The page id. |
|
| 41 | + * @param string $page_title The page title. |
|
| 42 | + * |
|
| 43 | + * @return void |
|
| 44 | + * @throws Exception in case of invalid arguments. |
|
| 45 | + */ |
|
| 46 | + public static function create_action_scheduler_task( $hook, $group, $task, $route, $page_id, $page_title, $batch_size = 5 ) { |
|
| 47 | + self::assertions( $task, $route ); |
|
| 48 | + $background_task = new \Wordlift\Task\Action_Scheduler\Background_Task( |
|
| 49 | + $hook, |
|
| 50 | + $group, |
|
| 51 | + $task, |
|
| 52 | + "_{$hook}_", |
|
| 53 | + $batch_size |
|
| 54 | + ); |
|
| 55 | + $background_task_route = Background_Task_Route::create( $background_task, $route ); |
|
| 56 | + Background_Task_Page::create( $page_title, $page_id, $background_task_route ); |
|
| 57 | + } |
|
| 58 | 58 | |
| 59 | - /** |
|
| 60 | - * @param Task $task |
|
| 61 | - * @param $route |
|
| 62 | - * |
|
| 63 | - * @return void |
|
| 64 | - * @throws Exception in case of invalid arguments. |
|
| 65 | - */ |
|
| 66 | - private static function assertions( Task $task, $route ) { |
|
| 67 | - Assertions::is_a( $task, 'Wordlift\Task\Task' ); |
|
| 68 | - Assertions::starts_with( $route, '/', __( 'The route must start with a slash.', 'wordlift' ) ); |
|
| 69 | - } |
|
| 59 | + /** |
|
| 60 | + * @param Task $task |
|
| 61 | + * @param $route |
|
| 62 | + * |
|
| 63 | + * @return void |
|
| 64 | + * @throws Exception in case of invalid arguments. |
|
| 65 | + */ |
|
| 66 | + private static function assertions( Task $task, $route ) { |
|
| 67 | + Assertions::is_a( $task, 'Wordlift\Task\Task' ); |
|
| 68 | + Assertions::starts_with( $route, '/', __( 'The route must start with a slash.', 'wordlift' ) ); |
|
| 69 | + } |
|
| 70 | 70 | |
| 71 | 71 | } |
@@ -25,11 +25,11 @@ discard block |
||
| 25 | 25 | * @return void |
| 26 | 26 | * @throws Exception in case of invalid arguments. |
| 27 | 27 | */ |
| 28 | - public static function create( $task, $route, $page_id, $page_title ) { |
|
| 29 | - self::assertions( $task, $route ); |
|
| 30 | - $background_task = Background_Task::create( $task ); |
|
| 31 | - $background_task_route = Background_Task_Route::create( $background_task, $route ); |
|
| 32 | - Background_Task_Page::create( $page_title, $page_id, $background_task_route ); |
|
| 28 | + public static function create($task, $route, $page_id, $page_title) { |
|
| 29 | + self::assertions($task, $route); |
|
| 30 | + $background_task = Background_Task::create($task); |
|
| 31 | + $background_task_route = Background_Task_Route::create($background_task, $route); |
|
| 32 | + Background_Task_Page::create($page_title, $page_id, $background_task_route); |
|
| 33 | 33 | } |
| 34 | 34 | |
| 35 | 35 | /** |
@@ -43,17 +43,17 @@ discard block |
||
| 43 | 43 | * @return void |
| 44 | 44 | * @throws Exception in case of invalid arguments. |
| 45 | 45 | */ |
| 46 | - public static function create_action_scheduler_task( $hook, $group, $task, $route, $page_id, $page_title, $batch_size = 5 ) { |
|
| 47 | - self::assertions( $task, $route ); |
|
| 48 | - $background_task = new \Wordlift\Task\Action_Scheduler\Background_Task( |
|
| 46 | + public static function create_action_scheduler_task($hook, $group, $task, $route, $page_id, $page_title, $batch_size = 5) { |
|
| 47 | + self::assertions($task, $route); |
|
| 48 | + $background_task = new \Wordlift\Task\Action_Scheduler\Background_Task( |
|
| 49 | 49 | $hook, |
| 50 | 50 | $group, |
| 51 | 51 | $task, |
| 52 | 52 | "_{$hook}_", |
| 53 | 53 | $batch_size |
| 54 | 54 | ); |
| 55 | - $background_task_route = Background_Task_Route::create( $background_task, $route ); |
|
| 56 | - Background_Task_Page::create( $page_title, $page_id, $background_task_route ); |
|
| 55 | + $background_task_route = Background_Task_Route::create($background_task, $route); |
|
| 56 | + Background_Task_Page::create($page_title, $page_id, $background_task_route); |
|
| 57 | 57 | } |
| 58 | 58 | |
| 59 | 59 | /** |
@@ -63,9 +63,9 @@ discard block |
||
| 63 | 63 | * @return void |
| 64 | 64 | * @throws Exception in case of invalid arguments. |
| 65 | 65 | */ |
| 66 | - private static function assertions( Task $task, $route ) { |
|
| 67 | - Assertions::is_a( $task, 'Wordlift\Task\Task' ); |
|
| 68 | - Assertions::starts_with( $route, '/', __( 'The route must start with a slash.', 'wordlift' ) ); |
|
| 66 | + private static function assertions(Task $task, $route) { |
|
| 67 | + Assertions::is_a($task, 'Wordlift\Task\Task'); |
|
| 68 | + Assertions::starts_with($route, '/', __('The route must start with a slash.', 'wordlift')); |
|
| 69 | 69 | } |
| 70 | 70 | |
| 71 | 71 | } |
@@ -8,101 +8,101 @@ |
||
| 8 | 8 | use Wordlift\Task\Task; |
| 9 | 9 | |
| 10 | 10 | class Background_Task extends Action_Scheduler_Background_Process implements Background_Route_Task { |
| 11 | - /** |
|
| 12 | - * The option prefix to store state. |
|
| 13 | - * |
|
| 14 | - * @var string $option_prefix |
|
| 15 | - */ |
|
| 16 | - private $option_prefix; |
|
| 17 | - /** |
|
| 18 | - * @var Task |
|
| 19 | - */ |
|
| 20 | - private $task; |
|
| 21 | - |
|
| 22 | - const STATE_STARTED = 'started'; |
|
| 23 | - const STATE_STOPPED = 'stopped'; |
|
| 24 | - /** |
|
| 25 | - * @var int |
|
| 26 | - */ |
|
| 27 | - private $batch_size; |
|
| 28 | - |
|
| 29 | - public function __construct( $hook, $group, $task, $option_prefix, $batch_size = 5 ) { |
|
| 30 | - parent::__construct( $hook, $group ); |
|
| 31 | - $this->task = $task; |
|
| 32 | - $this->option_prefix = $option_prefix; |
|
| 33 | - $this->batch_size = $batch_size; |
|
| 34 | - } |
|
| 35 | - |
|
| 36 | - // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable |
|
| 37 | - public function do_task( $args ) { |
|
| 38 | - if ( self::STATE_STOPPED === $this->get_process_state() ) { |
|
| 39 | - return State::complete(); |
|
| 40 | - } |
|
| 41 | - $context = $this->get_context(); |
|
| 42 | - $this->task->tick( null, $context->get_data() + array( 'batch_size' => $this->batch_size ) ); |
|
| 43 | - |
|
| 44 | - if ( ( $context->get_count() - $context->get_offset() ) >= 0 ) { |
|
| 45 | - $context->set_offset( $context->get_offset() + $this->batch_size )->set_updated( time() ); |
|
| 46 | - $this->set_info( $context ); |
|
| 47 | - return State::items_in_queue(); |
|
| 48 | - } else { |
|
| 49 | - $this->set_process_state( self::STATE_STOPPED ); |
|
| 50 | - return State::complete(); |
|
| 51 | - } |
|
| 52 | - |
|
| 53 | - } |
|
| 54 | - |
|
| 55 | - public function start() { |
|
| 56 | - $this->delete_info(); |
|
| 57 | - $this->set_process_state( self::STATE_STARTED ); |
|
| 58 | - $this->schedule(); |
|
| 59 | - } |
|
| 60 | - |
|
| 61 | - public function stop() { |
|
| 62 | - $this->set_process_state( self::STATE_STOPPED ); |
|
| 63 | - $this->unschedule(); |
|
| 64 | - } |
|
| 65 | - |
|
| 66 | - public function resume() { |
|
| 67 | - $this->set_process_state( self::STATE_STARTED ); |
|
| 68 | - $this->schedule(); |
|
| 69 | - } |
|
| 70 | - |
|
| 71 | - public function get_info() { |
|
| 72 | - return $this->get_context()->get_data() + array( 'state' => $this->get_process_state() ); |
|
| 73 | - } |
|
| 74 | - |
|
| 75 | - public function get_context() { |
|
| 76 | - $data = get_option( |
|
| 77 | - "{$this->option_prefix}_state", |
|
| 78 | - null |
|
| 79 | - ); |
|
| 80 | - |
|
| 81 | - if ( null === $data ) { |
|
| 82 | - return Context::from( (int) $this->task->starting() ); |
|
| 83 | - } |
|
| 84 | - |
|
| 85 | - return Context::from_data( $data ); |
|
| 86 | - } |
|
| 87 | - |
|
| 88 | - /** |
|
| 89 | - * @param $context Context |
|
| 90 | - * |
|
| 91 | - * @return void |
|
| 92 | - */ |
|
| 93 | - public function set_info( $context ) { |
|
| 94 | - update_option( "{$this->option_prefix}_state", $context->get_data() ); |
|
| 95 | - } |
|
| 96 | - |
|
| 97 | - private function delete_info() { |
|
| 98 | - delete_option( "{$this->option_prefix}_state" ); |
|
| 99 | - } |
|
| 100 | - |
|
| 101 | - private function get_process_state() { |
|
| 102 | - return get_option( "{$this->option_prefix}_action_scheduler_state", self::STATE_STOPPED ); |
|
| 103 | - } |
|
| 104 | - |
|
| 105 | - private function set_process_state( $state ) { |
|
| 106 | - update_option( "{$this->option_prefix}_action_scheduler_state", $state ); |
|
| 107 | - } |
|
| 11 | + /** |
|
| 12 | + * The option prefix to store state. |
|
| 13 | + * |
|
| 14 | + * @var string $option_prefix |
|
| 15 | + */ |
|
| 16 | + private $option_prefix; |
|
| 17 | + /** |
|
| 18 | + * @var Task |
|
| 19 | + */ |
|
| 20 | + private $task; |
|
| 21 | + |
|
| 22 | + const STATE_STARTED = 'started'; |
|
| 23 | + const STATE_STOPPED = 'stopped'; |
|
| 24 | + /** |
|
| 25 | + * @var int |
|
| 26 | + */ |
|
| 27 | + private $batch_size; |
|
| 28 | + |
|
| 29 | + public function __construct( $hook, $group, $task, $option_prefix, $batch_size = 5 ) { |
|
| 30 | + parent::__construct( $hook, $group ); |
|
| 31 | + $this->task = $task; |
|
| 32 | + $this->option_prefix = $option_prefix; |
|
| 33 | + $this->batch_size = $batch_size; |
|
| 34 | + } |
|
| 35 | + |
|
| 36 | + // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable |
|
| 37 | + public function do_task( $args ) { |
|
| 38 | + if ( self::STATE_STOPPED === $this->get_process_state() ) { |
|
| 39 | + return State::complete(); |
|
| 40 | + } |
|
| 41 | + $context = $this->get_context(); |
|
| 42 | + $this->task->tick( null, $context->get_data() + array( 'batch_size' => $this->batch_size ) ); |
|
| 43 | + |
|
| 44 | + if ( ( $context->get_count() - $context->get_offset() ) >= 0 ) { |
|
| 45 | + $context->set_offset( $context->get_offset() + $this->batch_size )->set_updated( time() ); |
|
| 46 | + $this->set_info( $context ); |
|
| 47 | + return State::items_in_queue(); |
|
| 48 | + } else { |
|
| 49 | + $this->set_process_state( self::STATE_STOPPED ); |
|
| 50 | + return State::complete(); |
|
| 51 | + } |
|
| 52 | + |
|
| 53 | + } |
|
| 54 | + |
|
| 55 | + public function start() { |
|
| 56 | + $this->delete_info(); |
|
| 57 | + $this->set_process_state( self::STATE_STARTED ); |
|
| 58 | + $this->schedule(); |
|
| 59 | + } |
|
| 60 | + |
|
| 61 | + public function stop() { |
|
| 62 | + $this->set_process_state( self::STATE_STOPPED ); |
|
| 63 | + $this->unschedule(); |
|
| 64 | + } |
|
| 65 | + |
|
| 66 | + public function resume() { |
|
| 67 | + $this->set_process_state( self::STATE_STARTED ); |
|
| 68 | + $this->schedule(); |
|
| 69 | + } |
|
| 70 | + |
|
| 71 | + public function get_info() { |
|
| 72 | + return $this->get_context()->get_data() + array( 'state' => $this->get_process_state() ); |
|
| 73 | + } |
|
| 74 | + |
|
| 75 | + public function get_context() { |
|
| 76 | + $data = get_option( |
|
| 77 | + "{$this->option_prefix}_state", |
|
| 78 | + null |
|
| 79 | + ); |
|
| 80 | + |
|
| 81 | + if ( null === $data ) { |
|
| 82 | + return Context::from( (int) $this->task->starting() ); |
|
| 83 | + } |
|
| 84 | + |
|
| 85 | + return Context::from_data( $data ); |
|
| 86 | + } |
|
| 87 | + |
|
| 88 | + /** |
|
| 89 | + * @param $context Context |
|
| 90 | + * |
|
| 91 | + * @return void |
|
| 92 | + */ |
|
| 93 | + public function set_info( $context ) { |
|
| 94 | + update_option( "{$this->option_prefix}_state", $context->get_data() ); |
|
| 95 | + } |
|
| 96 | + |
|
| 97 | + private function delete_info() { |
|
| 98 | + delete_option( "{$this->option_prefix}_state" ); |
|
| 99 | + } |
|
| 100 | + |
|
| 101 | + private function get_process_state() { |
|
| 102 | + return get_option( "{$this->option_prefix}_action_scheduler_state", self::STATE_STOPPED ); |
|
| 103 | + } |
|
| 104 | + |
|
| 105 | + private function set_process_state( $state ) { |
|
| 106 | + update_option( "{$this->option_prefix}_action_scheduler_state", $state ); |
|
| 107 | + } |
|
| 108 | 108 | } |
@@ -26,27 +26,27 @@ discard block |
||
| 26 | 26 | */ |
| 27 | 27 | private $batch_size; |
| 28 | 28 | |
| 29 | - public function __construct( $hook, $group, $task, $option_prefix, $batch_size = 5 ) { |
|
| 30 | - parent::__construct( $hook, $group ); |
|
| 29 | + public function __construct($hook, $group, $task, $option_prefix, $batch_size = 5) { |
|
| 30 | + parent::__construct($hook, $group); |
|
| 31 | 31 | $this->task = $task; |
| 32 | 32 | $this->option_prefix = $option_prefix; |
| 33 | 33 | $this->batch_size = $batch_size; |
| 34 | 34 | } |
| 35 | 35 | |
| 36 | 36 | // phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable |
| 37 | - public function do_task( $args ) { |
|
| 38 | - if ( self::STATE_STOPPED === $this->get_process_state() ) { |
|
| 37 | + public function do_task($args) { |
|
| 38 | + if (self::STATE_STOPPED === $this->get_process_state()) { |
|
| 39 | 39 | return State::complete(); |
| 40 | 40 | } |
| 41 | 41 | $context = $this->get_context(); |
| 42 | - $this->task->tick( null, $context->get_data() + array( 'batch_size' => $this->batch_size ) ); |
|
| 42 | + $this->task->tick(null, $context->get_data() + array('batch_size' => $this->batch_size)); |
|
| 43 | 43 | |
| 44 | - if ( ( $context->get_count() - $context->get_offset() ) >= 0 ) { |
|
| 45 | - $context->set_offset( $context->get_offset() + $this->batch_size )->set_updated( time() ); |
|
| 46 | - $this->set_info( $context ); |
|
| 44 | + if (($context->get_count() - $context->get_offset()) >= 0) { |
|
| 45 | + $context->set_offset($context->get_offset() + $this->batch_size)->set_updated(time()); |
|
| 46 | + $this->set_info($context); |
|
| 47 | 47 | return State::items_in_queue(); |
| 48 | 48 | } else { |
| 49 | - $this->set_process_state( self::STATE_STOPPED ); |
|
| 49 | + $this->set_process_state(self::STATE_STOPPED); |
|
| 50 | 50 | return State::complete(); |
| 51 | 51 | } |
| 52 | 52 | |
@@ -54,22 +54,22 @@ discard block |
||
| 54 | 54 | |
| 55 | 55 | public function start() { |
| 56 | 56 | $this->delete_info(); |
| 57 | - $this->set_process_state( self::STATE_STARTED ); |
|
| 57 | + $this->set_process_state(self::STATE_STARTED); |
|
| 58 | 58 | $this->schedule(); |
| 59 | 59 | } |
| 60 | 60 | |
| 61 | 61 | public function stop() { |
| 62 | - $this->set_process_state( self::STATE_STOPPED ); |
|
| 62 | + $this->set_process_state(self::STATE_STOPPED); |
|
| 63 | 63 | $this->unschedule(); |
| 64 | 64 | } |
| 65 | 65 | |
| 66 | 66 | public function resume() { |
| 67 | - $this->set_process_state( self::STATE_STARTED ); |
|
| 67 | + $this->set_process_state(self::STATE_STARTED); |
|
| 68 | 68 | $this->schedule(); |
| 69 | 69 | } |
| 70 | 70 | |
| 71 | 71 | public function get_info() { |
| 72 | - return $this->get_context()->get_data() + array( 'state' => $this->get_process_state() ); |
|
| 72 | + return $this->get_context()->get_data() + array('state' => $this->get_process_state()); |
|
| 73 | 73 | } |
| 74 | 74 | |
| 75 | 75 | public function get_context() { |
@@ -78,11 +78,11 @@ discard block |
||
| 78 | 78 | null |
| 79 | 79 | ); |
| 80 | 80 | |
| 81 | - if ( null === $data ) { |
|
| 82 | - return Context::from( (int) $this->task->starting() ); |
|
| 81 | + if (null === $data) { |
|
| 82 | + return Context::from((int) $this->task->starting()); |
|
| 83 | 83 | } |
| 84 | 84 | |
| 85 | - return Context::from_data( $data ); |
|
| 85 | + return Context::from_data($data); |
|
| 86 | 86 | } |
| 87 | 87 | |
| 88 | 88 | /** |
@@ -90,19 +90,19 @@ discard block |
||
| 90 | 90 | * |
| 91 | 91 | * @return void |
| 92 | 92 | */ |
| 93 | - public function set_info( $context ) { |
|
| 94 | - update_option( "{$this->option_prefix}_state", $context->get_data() ); |
|
| 93 | + public function set_info($context) { |
|
| 94 | + update_option("{$this->option_prefix}_state", $context->get_data()); |
|
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | private function delete_info() { |
| 98 | - delete_option( "{$this->option_prefix}_state" ); |
|
| 98 | + delete_option("{$this->option_prefix}_state"); |
|
| 99 | 99 | } |
| 100 | 100 | |
| 101 | 101 | private function get_process_state() { |
| 102 | - return get_option( "{$this->option_prefix}_action_scheduler_state", self::STATE_STOPPED ); |
|
| 102 | + return get_option("{$this->option_prefix}_action_scheduler_state", self::STATE_STOPPED); |
|
| 103 | 103 | } |
| 104 | 104 | |
| 105 | - private function set_process_state( $state ) { |
|
| 106 | - update_option( "{$this->option_prefix}_action_scheduler_state", $state ); |
|
| 105 | + private function set_process_state($state) { |
|
| 106 | + update_option("{$this->option_prefix}_action_scheduler_state", $state); |
|
| 107 | 107 | } |
| 108 | 108 | } |