Display error message if update_merchant_product_statuses job throws an error

js/src/hooks/useMCProductStatistics.js

@@ -8,6 +8,7 @@ import { useEffect } from '@wordpress/element';
  */
 import useAppSelectDispatch from './useAppSelectDispatch';
 import useCountdown from './useCountdown';
+import useApiFetchCallback from '.~/hooks/useApiFetchCallback';
 import { useAppDispatch } from '.~/data';
 
 /**
@@ -27,6 +28,16 @@ const useMCProductStatistics = () => {
 		hasFinishedResolution && data?.loading ? true : false;
 	const hasStats = hasFinishedResolution && data?.statistics ? true : false;
 
+	const [ refreshProductStats ] = useApiFetchCallback( {
+		path: `/wc/gla/mc/product-statistics/refresh`,
+		method: 'GET',
+	} );
+
+	const refreshStats = async () => {
+		await refreshProductStats();
+		invalidateResolution();
+	};
+
 	useEffect( () => {
 		// If the job is still processing the data, start the countdown.
 		if ( isCalculatingStats && second === 0 ) {
@@ -57,6 +68,7 @@ const useMCProductStatistics = () => {
 		data,
 		invalidateResolution,
 		hasFinishedResolution,
+		refreshStats,
 		...rest,
 	};
 };

js/src/hooks/useMCProductStatistics.test.js

@@ -10,10 +10,17 @@ import useMCProductStatistics from '.~/hooks/useMCProductStatistics';
 import useCountdown from '.~/hooks/useCountdown';
 import useAppSelectDispatch from '.~/hooks/useAppSelectDispatch';
 import { useAppDispatch } from '.~/data';
+import useApiFetchCallback from '.~/hooks/useApiFetchCallback';
 
 jest.mock( '.~/hooks/useAppSelectDispatch' );
 jest.mock( '.~/hooks/useCountdown' );
 jest.mock( '.~/data' );
+jest.mock( '.~/hooks/useApiFetchCallback', () => ( {
+	__esModule: true,
+	default: jest.fn().mockImplementation( () => {
+		return [ jest.fn(), null ];
+	} ),
+} ) );
 
 describe( 'useMCProductStatistics', () => {
 	const startCountdown = jest.fn();
@@ -139,4 +146,38 @@ describe( 'useMCProductStatistics', () => {
 			);
 		} );
 	} );
+	describe( 'Refresh the product statistics', () => {
+		beforeAll( () => {
+			jest.clearAllMocks();
+		} );
+		it( 'The user clicks the refresh button', async () => {
+			const refreshProductStats = jest.fn();
+			useCountdown.mockImplementation( () => {
+				return {
+					second: 0,
+					callCount: 0,
+					startCountdown,
+				};
+			} );
+
+			useAppSelectDispatch.mockImplementation( () => {
+				return {
+					hasFinishedResolution: true,
+					invalidateResolution,
+					data: statsData,
+				};
+			} );
+
+			useApiFetchCallback.mockImplementation( () => {
+				return [ refreshProductStats, null ];
+			} );
+
+			const { result } = renderHook( () => useMCProductStatistics() );
+
+			await result.current.refreshStats();
+
+			expect( refreshProductStats ).toHaveBeenCalledTimes( 1 );
+			expect( invalidateResolution ).toHaveBeenCalledTimes( 1 );
+		} );
+	} );
 } );

js/src/product-feed/product-statistics/index.js

@@ -22,14 +22,16 @@ import {
 import useMCProductStatistics from '.~/hooks/useMCProductStatistics';
 import ProductStatusHelpPopover from './product-status-help-popover';
 import SyncStatus from '.~/product-feed/product-statistics/status-box/sync-status';
+import SyncProductStatistics from '.~/product-feed/product-statistics/status-box/sync-product-statistics';
 import FeedStatus from '.~/product-feed/product-statistics/status-box/feed-status';
 import AccountStatus from '.~/product-feed/product-statistics/status-box/account-status';
 import Text from '.~/components/app-text';
 import AppSpinner from '.~/components/app-spinner';
 import './index.scss';
 
 const ProductStatistics = () => {
-	const { hasFinishedResolution, data } = useMCProductStatistics();
+	const { hasFinishedResolution, data, refreshStats } =
+		useMCProductStatistics();
 
 	if ( hasFinishedResolution && ! data ) {
 		return __(
@@ -135,6 +137,12 @@ const ProductStatistics = () => {
 				<FeedStatus />
 				<SyncStatus />
 				<AccountStatus />
+				{ hasFinishedResolution && data?.error && (
+					<SyncProductStatistics
+						refreshStats={ refreshStats }
+						error={ data.error }
+					/>
+				) }
 			</CardFooter>
 		</Card>
 	);

js/src/product-feed/product-statistics/index.scss

@@ -93,5 +93,11 @@
 		.gridicons-sync {
 			transform: rotateZ(90deg);
 		}
+
+		.overview-stats-error-button {
+			height: auto;
+			padding-top: 0;
+			padding-left: 0;
+		}
 	}
 }

js/src/product-feed/product-statistics/index.test.js

@@ -119,4 +119,33 @@ describe( 'Product Statistics', () => {
 			} );
 		} );
 	} );
+	describe( `When there is an error`, () => {
+		it( 'Should render the error', () => {
+			useMCProductStatistics.mockImplementation( () => {
+				return {
+					hasFinishedResolution: true,
+					data: {
+						loading: false,
+						statistics: null,
+						error: 'Error loading stats!',
+					},
+				};
+			} );
+
+			const { getByText, container } = render( <ProductStatistics /> );
+
+			const notAvailableStats = container.querySelectorAll(
+				'.woocommerce-summary__item-value'
+			);
+
+			expect( notAvailableStats.length ).toBe( 5 );
+
+			for ( let i = 0; i < notAvailableStats.length; i++ ) {
+				expect( notAvailableStats[ i ].textContent ).toBe( 'N/A' );
+			}
+
+			expect( getByText( 'Overview Stats:' ) ).toBeInTheDocument();
+			expect( getByText( 'Error loading stats!' ) ).toBeInTheDocument();
+		} );
+	} );
 } );

js/src/product-feed/product-statistics/status-box/sync-product-statistics.js

@@ -0,0 +1,47 @@
+/**
+ * External dependencies
+ */
+import { __ } from '@wordpress/i18n';
+import { Button } from '@wordpress/components';
+
+/**
+ * Internal dependencies
+ */
+import Status from '.~/product-feed/product-statistics/status-box/status';
+import ErrorIcon from '.~/components/error-icon';
+
+/**
+ * @typedef {import('.~/data/actions').ProductStatistics } ProductStatistics
+ */
+
+/**
+ * Renders status information for the Product Sync
+ *
+ * @param {Object} props The component props
+ * @param {Function} props.refreshStats
+ * @param {string} props.error
+ * @return {JSX.Element} The status for the Product Sync
+ */
+function SyncProductStatistics( { refreshStats, error } ) {
+	return (
+		<Status
+			title={ __( 'Overview Stats:', 'google-listings-and-ads' ) }
+			icon={ <ErrorIcon size={ 24 } /> }
+			label={
+				<Button
+					aria-label={ error }
+					onClick={ refreshStats }
+					className="overview-stats-error-button"
+				>
+					{ __(
+						'There was an error loading the Overview Stats. Click to retry.',
+						'google-listings-and-ads'
+					) }
+				</Button>
+			}
+			description={ error }
+		/>
+	);
+}
+
+export default SyncProductStatistics;

src/Jobs/UpdateMerchantProductStatuses.php

@@ -128,4 +128,17 @@ public function is_scheduled(): bool {
 		// We set 'args' to null so it matches any arguments. This is because it's possible to have multiple instances of the job running with different page tokens
 		return $this->is_running( null );
 	}
+
+	/**
+	 * Validate the failure rate of the job.
+	 *
+	 * @return string|void Returns an error message if the failure rate is too high, otherwise null.
+	 */
+	public function get_failure_rate_message() {
+		try {
+			$this->monitor->validate_failure_rate( $this, $this->get_process_item_hook() );
+		} catch ( JobException $e ) {
+			return $e->getMessage();
+		}
+	}
 }

src/MerchantCenter/MerchantStatuses.php

@@ -136,8 +136,19 @@ public function __construct() {
 	 */
 	public function get_product_statistics( bool $force_refresh = false ): array {
 		$job               = $this->maybe_refresh_status_data( $force_refresh );
+		$failure_rate_msg  = $job->get_failure_rate_message();
 		$this->mc_statuses = $this->container->get( TransientsInterface::class )->get( Transients::MC_STATUSES );
 
+		// If the failure rate is too high, return an error message so the UI can stop polling.
+		if ( $failure_rate_msg && null === $this->mc_statuses ) {
+			return [
+				'timestamp'  => $this->cache_created_time->getTimestamp(),
+				'statistics' => null,
+				'loading'    => false,
+				'error'      => $failure_rate_msg,
+			];
+		}
+
 		if ( $job->is_scheduled() || null === $this->mc_statuses ) {
 			return [
 				'timestamp'  => $this->cache_created_time->getTimestamp(),
@@ -278,7 +289,9 @@ public function maybe_refresh_status_data( bool $force_refresh = false ): Update
 
 		// If force_refresh is true or if not transient, return empty array and scheduled the job to update the statuses.
 		if ( ! $job->is_scheduled() && ( $force_refresh || ( ! $force_refresh && null === $this->mc_statuses ) ) ) {
-			// Schedule job to update the statuses.
+			// Delete the transient before scheduling the job because some errors, like the failure rate message, can occur before the job is executed.
+			$this->clear_cache();
+			// Schedule job to update the statuses. If the failure rate is too high, the job will not be scheduled.
 			$job->schedule();
 		}
 

tests/Unit/Jobs/UpdateMerchantProductStatusesTest.php

@@ -248,4 +248,23 @@ public function test_update_merchant_product_statuses_when_view_report_throws_ex
 
 		do_action( self::PROCESS_ITEM_HOOK, [] );
 	}
+
+	public function test_get_failure_rate_message() {
+		$this->merchant_center_service->method( 'is_connected' )
+		->willReturn( true );
+
+		$this->monitor->expects( $this->exactly( 1 ) )->method( 'validate_failure_rate' )
+		->willThrowException( new JobException( 'The "update_merchant_product_statuses" job was stopped because its failure rate is above the allowed threshold.' ) );
+
+		$this->assertEquals( 'The "update_merchant_product_statuses" job was stopped because its failure rate is above the allowed threshold.', $this->job->get_failure_rate_message() );
+	}
+
+	public function test_get_with_no_failure_rate_message() {
+		$this->merchant_center_service->method( 'is_connected' )
+		->willReturn( true );
+
+		$this->monitor->expects( $this->exactly( 1 ) )->method( 'validate_failure_rate' );
+
+		$this->assertNull( $this->job->get_failure_rate_message() );
+	}
 }

tests/Unit/MerchantCenter/MerchantStatusesTest.php

@@ -334,6 +334,18 @@ public function test_get_product_statistics_without_transient() {
 		$this->update_merchant_product_statuses_job->expects( $this->exactly( 1 ) )
 		->method( 'schedule' );
 
+		$this->update_all_product_job->expects( $this->exactly( 1 ) )
+		->method( 'can_schedule' )
+		->with( null )
+		->willReturn( true );
+
+		$this->delete_all_product_job->expects( $this->exactly( 1 ) )
+		->method( 'can_schedule' )
+		->with( null )
+		->willReturn( true );
+
+		$this->transients->expects( $this->exactly( 1 ) )->method( 'delete' )->with( Transients::MC_STATUSES );
+
 		$this->update_merchant_product_statuses_job->expects( $this->exactly( 2 ) )
 		->method( 'is_scheduled' );
 
@@ -432,6 +444,44 @@ public function test_get_product_statistics_with_force_refresh() {
 		);
 	}
 
+	public function test_get_product_statistics_with_failure_rate() {
+		$this->merchant_center_service->expects( $this->once() )
+		->method( 'is_connected' )
+		->willReturn( true );
+
+		$this->transients->expects( $this->exactly( 2 ) )
+		->method( 'get' )
+		->willReturn(
+			null
+		);
+
+		$this->update_merchant_product_statuses_job->expects( $this->exactly( 1 ) )
+		->method( 'get_failure_rate_message' )->willReturn( 'Failure rate!' );
+
+		$this->update_merchant_product_statuses_job->expects( $this->exactly( 1 ) )
+		->method( 'schedule' );
+
+		$this->update_merchant_product_statuses_job->expects( $this->exactly( 1 ) )
+		->method( 'is_scheduled' )->willReturn( false );
+
+		$product_statistics = $this->merchant_statuses->get_product_statistics();
+
+		$this->assertEquals(
+			null,
+			$product_statistics['statistics']
+		);
+
+		$this->assertEquals(
+			false,
+			$product_statistics['loading']
+		);
+
+		$this->assertEquals(
+			'Failure rate!',
+			$product_statistics['error']
+		);
+	}
+
 	public function test_process_product_statuses() {
 		$product_1        = WC_Helper_Product::create_simple_product();
 		$product_2        = WC_Helper_Product::create_simple_product();