Get product stats using the Merchant Center report query

src/API/Google/MerchantReport.php

@@ -6,6 +6,7 @@
 use Automattic\WooCommerce\Admin\API\Reports\TimeInterval;
 use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Query\MerchantFreeListingReportQuery;
 use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Query\MerchantProductReportQuery;
+use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Query\MerchantProductViewReportQuery;
 use Automattic\WooCommerce\GoogleListingsAndAds\Exception\InvalidValue;
 use Automattic\WooCommerce\GoogleListingsAndAds\Options\OptionsAwareInterface;
 use Automattic\WooCommerce\GoogleListingsAndAds\Options\OptionsAwareTrait;
@@ -14,6 +15,7 @@
 use Automattic\WooCommerce\GoogleListingsAndAds\Vendor\Google\Service\ShoppingContent;
 use Automattic\WooCommerce\GoogleListingsAndAds\Vendor\Google\Service\ShoppingContent\ReportRow;
 use Automattic\WooCommerce\GoogleListingsAndAds\Vendor\Google\Service\ShoppingContent\Segments;
+use Automattic\WooCommerce\GoogleListingsAndAds\Vendor\Google\Service\ShoppingContent\SearchResponse;
 use DateTime;
 use Exception;
 
@@ -52,6 +54,28 @@ public function __construct( ShoppingContent $service, ProductHelper $product_he
 		$this->product_helper = $product_helper;
 	}
 
+	/**
+	 * Get ProductView Query response.
+	 *
+	 * @param string|null $next_page_token The next page token.
+	 * @return SearchResponse The response from the search call.
+	 *
+	 * @throws GoogleException If the search call fails.
+	 */
+	public function get_product_view_report( $next_page_token = null ): SearchResponse {
+			$query = new MerchantProductViewReportQuery(
+				[
+					'next_page' => $next_page_token,
+					'per_page'  => 1000,
+				]
+			);
+
+		return $query
+		->set_client( $this->service, $this->options->get_merchant_id() )
+		->get_results();
+	}
+
+
 	/**
 	 * Get report data for free listings.
 	 *

src/API/Google/Query/MerchantProductViewReportQuery.php

@@ -0,0 +1,54 @@
+<?php
+declare( strict_types=1 );
+
+namespace Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Query;
+
+defined( 'ABSPATH' ) || exit;
+
+/**
+ * Class MerchantProductViewReportQuery
+ *
+ * @package Automattic\WooCommerce\GoogleListingsAndAds\API\Google\Query
+ */
+class MerchantProductViewReportQuery extends MerchantQuery {
+
+	use ReportQueryTrait;
+
+	/**
+	 * Query constructor.
+	 *
+	 * @param array $args Query arguments.
+	 */
+	public function __construct( array $args ) {
+		parent::__construct( 'ProductView' );
+		$this->set_initial_columns();
+		$this->handle_query_args( $args );
+	}
+
+
+	/**
+	 * Filter the query by a list of ID's.
+	 *
+	 * @param array $ids list of ID's to filter by.
+	 *
+	 * @return $this
+	 */
+	public function filter( array $ids ): QueryInterface {
+		// No filtering used for product view report.
+		return $this;
+	}
+
+	/**
+	 * Set the initial columns for this query.
+	 */
+	protected function set_initial_columns() {
+		$this->columns(
+			[
+				'id'              => 'product_view.id',
+				'offer_id'        => 'product_view.offer_id',
+				'expiration_date' => 'product_view.expiration_date',
+				'status'          => 'product_view.aggregated_destination_status',
+			]
+		);
+	}
+}

src/API/Site/Controllers/MerchantCenter/ProductStatisticsController.php

@@ -7,6 +7,7 @@
 use Automattic\WooCommerce\GoogleListingsAndAds\API\TransportMethods;
 use Automattic\WooCommerce\GoogleListingsAndAds\Jobs\ProductSyncStats;
 use Automattic\WooCommerce\GoogleListingsAndAds\MerchantCenter\MerchantStatuses;
+use Automattic\WooCommerce\GoogleListingsAndAds\API\Google\MerchantReport;
 use WP_REST_Response as Response;
 use WP_REST_Request as Request;
 use Automattic\WooCommerce\GoogleListingsAndAds\Proxies\RESTServer;
@@ -35,18 +36,26 @@ class ProductStatisticsController extends BaseOptionsController {
 	 */
 	protected $sync_stats;
 
+	/**
+	 *  The MerchantReport object.
+	 *
+	 * @var MerchantReport $merchant_report
+	 */
+
 
 	/**
 	 * ProductStatisticsController constructor.
 	 *
 	 * @param RESTServer       $server
 	 * @param MerchantStatuses $merchant_statuses
 	 * @param ProductSyncStats $sync_stats
+	 * @param MerchantReport   $merchant_report
 	 */
-	public function __construct( RESTServer $server, MerchantStatuses $merchant_statuses, ProductSyncStats $sync_stats ) {
+	public function __construct( RESTServer $server, MerchantStatuses $merchant_statuses, ProductSyncStats $sync_stats, MerchantReport $merchant_report ) {
 		parent::__construct( $server );
 		$this->merchant_statuses = $merchant_statuses;
 		$this->sync_stats        = $sync_stats;
+		$this->merchant_report   = $merchant_report;
 	}
 
 	/**

src/Google/NotificationsService.php

@@ -0,0 +1,140 @@
+<?php
+declare( strict_types=1 );
+
+namespace Automattic\WooCommerce\GoogleListingsAndAds\Google;
+
+use Automattic\Jetpack\Connection\Client;
+use Automattic\WooCommerce\GoogleListingsAndAds\Infrastructure\Service;
+use Jetpack_Options;
+
+defined( 'ABSPATH' ) || exit;
+
+/**
+ * Class NotificationsService
+ * This class implements a service to Notify a partner about Shop Data Updates
+ *
+ * @since x.x.x
+ * @package Automattic\WooCommerce\GoogleListingsAndAds\Google
+ */
+class NotificationsService implements Service {
+
+	// List of Topics to be used.
+	public const TOPIC_PRODUCT_CREATED  = 'product.create';
+	public const TOPIC_PRODUCT_DELETED  = 'product.delete';
+	public const TOPIC_PRODUCT_UPDATED  = 'product.update';
+	public const TOPIC_COUPON_CREATED   = 'coupon.create';
+	public const TOPIC_COUPON_DELETED   = 'coupon.delete';
+	public const TOPIC_COUPON_UPDATED   = 'coupon.update';
+	public const TOPIC_SHIPPING_SAVED   = 'action.woocommerce_after_shipping_zone_object_save';
+	public const TOPIC_SHIPPING_DELETED = 'action.woocommerce_delete_shipping_zone';
+
+	/**
+	 * The url to send the notification
+	 *
+	 * @var string $notification_url
+	 */
+	private $notification_url;
+
+
+	/**
+	 * Class constructor
+	 */
+	public function __construct() {
+		$blog_id                = Jetpack_Options::get_option( 'id' );
+		$this->notification_url = "https://public-api.wordpress.com/wpcom/v2/sites/{$blog_id}/partners/google/notifications";
+	}
+
+	/**
+	 * Calls the Notification endpoint in WPCOM.
+	 * https://public-api.wordpress.com/wpcom/v2/sites/{site}/partners/google/notifications
+	 *
+	 * @param int    $item_id
+	 * @param string $topic
+	 * @return bool True is the notification is successful. False otherwise.
+	 */
+	public function notify( int $item_id, string $topic ): bool {
+		/**
+		 * Allow users to disable the notification request.
+		 *
+		 * @since x.x.x
+		 *
+		 * @param bool $value The current filter value. True by default.
+		 * @param int $item_id The item_id for the notification.
+		 * @param string $topic The topic for the notification.
+		 */
+		if ( ! apply_filters( 'woocommerce_gla_notify', true, $item_id, $topic ) ) {
+			return false;
+		}
+
+		do_action(
+			'woocommerce_gla_debug_message',
+			sprintf( 'Notification - Item ID: %d - Topic: %s', $item_id, $topic ),
+			__METHOD__
+		);
+
+		$remote_args = [
+			'method'  => 'POST',
+			'timeout' => 30,
+			'headers' => [
+				'x-woocommerce-topic' => $topic,
+			],
+			'body'    => [
+				'item_id' => $item_id,
+			],
+			'url'     => $this->get_notification_url(),
+		];
+
+		$response = $this->do_request( $remote_args );
+
+		if ( is_wp_error( $response ) || wp_remote_retrieve_response_code( $response ) >= 400 ) {
+			$error = is_wp_error( $response ) ? $response->get_error_message() : wp_remote_retrieve_body( $response );
+			$this->notification_error( $item_id, $topic, $error );
+			return false;
+		}
+
+		return true;
+	}
+
+	/**
+	 * Logs an error.
+	 *
+	 * @param int    $item_id
+	 * @param string $topic
+	 * @param string $error
+	 */
+	private function notification_error( int $item_id, string $topic, string $error ): void {
+		do_action(
+			'woocommerce_gla_error',
+			sprintf( 'Error sending notification for Item ID %d with topic %s. %s', $item_id, $topic, $error ),
+			__METHOD__
+		);
+	}
+
+	/**
+	 * Performs a Remote Request
+	 *
+	 * @param array $args
+	 * @return array|\WP_Error
+	 */
+	protected function do_request( array $args ) {
+		return Client::remote_request( $args, wp_json_encode( $args['body'] ) );
+	}
+
+	/**
+	 * Get the route
+	 *
+	 * @return string The route.
+	 */
+	public function get_notification_url(): string {
+		return $this->notification_url;
+	}
+
+	/**
+	 * If the Notifications are enabled
+	 *
+	 * @return bool
+	 */
+	public function is_enabled(): bool {
+		return apply_filters( 'woocommerce_gla_notifications_enabled', true );
+	}
+}