-
Notifications
You must be signed in to change notification settings - Fork 21
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #2202 from woocommerce/add/hooks-api-pull-metas
Scheduled notifications using meta handler
- Loading branch information
Showing
11 changed files
with
756 additions
and
88 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,133 @@ | ||
| <?php | ||
| declare(strict_types=1); | ||
|
|
||
| namespace Automattic\WooCommerce\GoogleListingsAndAds\Jobs\Notifications; | ||
|
|
||
| use Automattic\WooCommerce\GoogleListingsAndAds\ActionScheduler\ActionSchedulerInterface; | ||
| use Automattic\WooCommerce\GoogleListingsAndAds\Google\NotificationsService; | ||
| use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\AbstractActionSchedulerJob; | ||
| use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\ActionSchedulerJobMonitor; | ||
| use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\JobInterface; | ||
| use Automattic\WooCommerce\GoogleListingsAndAds\Product\ProductHelper; | ||
| use Automattic\WooCommerce\GoogleListingsAndAds\Value\NotificationStatus; | ||
|
|
||
|
|
||
| defined( 'ABSPATH' ) || exit; | ||
|
|
||
| /** | ||
| * Class ProductNotificationJob | ||
| * Class for all the Product Notifications Jobs | ||
| * | ||
| * @since x.x.x | ||
| * @package Automattic\WooCommerce\GoogleListingsAndAds\Jobs\Notifications | ||
| */ | ||
| class ProductNotificationJob extends AbstractActionSchedulerJob implements JobInterface { | ||
|
|
||
| /** | ||
| * @var NotificationsService $notifications_service | ||
| */ | ||
| protected $notifications_service; | ||
|
|
||
| /** | ||
| * @var ProductHelper $product_helper | ||
| */ | ||
| protected $product_helper; | ||
|
|
||
| /** | ||
| * Notifications Jobs constructor. | ||
| * | ||
| * @param ActionSchedulerInterface $action_scheduler | ||
| * @param ActionSchedulerJobMonitor $monitor | ||
| * @param NotificationsService $notifications_service | ||
| * @param ProductHelper $product_helper | ||
| */ | ||
| public function __construct( | ||
| ActionSchedulerInterface $action_scheduler, | ||
| ActionSchedulerJobMonitor $monitor, | ||
| NotificationsService $notifications_service, | ||
| ProductHelper $product_helper | ||
| ) { | ||
| $this->notifications_service = $notifications_service; | ||
| $this->product_helper = $product_helper; | ||
| parent::__construct( $action_scheduler, $monitor ); | ||
| } | ||
|
|
||
| /** | ||
| * Get the job name | ||
| * | ||
| * @return string | ||
| */ | ||
| public function get_name(): string { | ||
| return 'notifications/products'; | ||
| } | ||
|
|
||
|
|
||
| /** | ||
| * Logic when processing the items | ||
| * | ||
| * @param array $args Arguments with the item id and the topic | ||
| */ | ||
| protected function process_items( array $args ): void { | ||
| if ( ! isset( $args[0] ) || ! isset( $args[1] ) ) { | ||
| return; | ||
| } | ||
|
|
||
| $item = $args[0]; | ||
| $topic = $args[1]; | ||
|
|
||
| if ( $this->notifications_service->notify( $item, $topic ) ) { | ||
| $this->set_status( $item, $this->get_after_notification_status( $topic ) ); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Schedule the Product Notification Job | ||
| * | ||
| * @param array $args | ||
| */ | ||
| public function schedule( array $args = [] ): void { | ||
| /** | ||
| * Allow users to disable the notification job schedule. | ||
| * | ||
| * @since x.x.x | ||
| * | ||
| * @param bool $value The current filter value. By default, it is the result of `$this->can_schedule` function. | ||
| * @param array $args The arguments for the schedule function with the item id and the topic. | ||
| */ | ||
| $can_schedule = apply_filters( 'woocommerce_gla_product_notification_job_can_schedule', $this->can_schedule( [ $args ] ), $args ); | ||
|
|
||
| if ( $can_schedule ) { | ||
| $this->action_scheduler->schedule_immediate( | ||
| $this->get_process_item_hook(), | ||
| [ $args ] | ||
| ); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Set the notification status for a product. | ||
| * | ||
| * @param int $product_id | ||
| * @param string $status | ||
| */ | ||
| protected function set_status( int $product_id, string $status ): void { | ||
| $product = $this->product_helper->get_wc_product( $product_id ); | ||
| $this->product_helper->set_notification_status( $product, $status ); | ||
| } | ||
|
|
||
| /** | ||
| * Get the Notification Status after the notification happens | ||
| * | ||
| * @param string $topic | ||
| * @return string | ||
| */ | ||
| protected function get_after_notification_status( string $topic ): string { | ||
| if ( str_contains( $topic, '.create' ) ) { | ||
| return NotificationStatus::NOTIFICATION_CREATED; | ||
| } elseif ( str_contains( $topic, '.delete' ) ) { | ||
| return NotificationStatus::NOTIFICATION_DELETED; | ||
| } else { | ||
| return NotificationStatus::NOTIFICATION_UPDATED; | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.