Merge pull request #1239 from woocommerce/PCP-1481-webhook-storage

Fix webhook issues when switching sandbox, and delete all webhooks when unsubscribing

modules/ppcp-webhooks/resources/js/status-page.js

@@ -1,3 +1,5 @@
+import {setVisibleByClass} from "../../../ppcp-button/resources/js/modules/Helper/Hiding"
+
 document.addEventListener(
     'DOMContentLoaded',
     () => {
@@ -147,5 +149,25 @@ document.addEventListener(
                 simulateBtn.prop('disabled', false);
             }
         });
+
+        const sandboxCheckbox = document.querySelector('#ppcp-sandbox_on');
+        if (sandboxCheckbox) {
+            const setWebhooksVisibility = (show) => {
+                [
+                    '#field-webhook_status_heading',
+                    '#field-webhooks_list',
+                    '#field-webhooks_resubscribe',
+                    '#field-webhooks_simulate',
+                ].forEach(selector => {
+                    setVisibleByClass(selector, show, 'hide');
+                });
+            };
+
+            const serverSandboxState = PayPalCommerceGatewayWebhooksStatus.environment === 'sandbox';
+            setWebhooksVisibility(serverSandboxState === sandboxCheckbox.checked);
+            sandboxCheckbox.addEventListener('click', () => {
+                setWebhooksVisibility(serverSandboxState === sandboxCheckbox.checked);
+            });
+        }
     }
 );

modules/ppcp-webhooks/services.php

@@ -167,7 +167,8 @@ return array(
 	'webhook.status.assets'                   => function( ContainerInterface $container ) : WebhooksStatusPageAssets {
 		return new WebhooksStatusPageAssets(
 			$container->get( 'webhook.module-url' ),
-			$container->get( 'ppcp.asset-version' )
+			$container->get( 'ppcp.asset-version' ),
+			$container->get( 'onboarding.environment' )
 		);
 	},
 
@@ -198,8 +199,8 @@ return array(
 		);
 	},
 
-	'webhook.last-webhook-storage'            => static function ( ContainerInterface $container ): WebhookInfoStorage {
-		return new WebhookInfoStorage( $container->get( 'webhook.last-webhook-storage.key' ) );
+	'webhook.last-webhook-storage'            => static function ( ContainerInterface $container ): WebhookEventStorage {
+		return new WebhookEventStorage( $container->get( 'webhook.last-webhook-storage.key' ) );
 	},
 	'webhook.last-webhook-storage.key'        => static function ( ContainerInterface $container ): string {
 		return 'ppcp-last-webhook';

modules/ppcp-webhooks/src/Endpoint/ResubscribeEndpoint.php

@@ -62,8 +62,6 @@ class ResubscribeEndpoint {
 			// Validate nonce.
 			$this->request_data->read_request( $this->nonce() );
 
-			$this->registrar->unregister();
-
 			if ( ! $this->registrar->register() ) {
 				wp_send_json_error( 'Webhook subscription failed.', 500 );
 				return false;

modules/ppcp-webhooks/src/IncomingWebhookEndpoint.php

@@ -77,11 +77,11 @@ class IncomingWebhookEndpoint {
 	private $simulation;
 
 	/**
-	 * The last webhook info storage.
+	 * The last webhook event storage.
 	 *
-	 * @var WebhookInfoStorage
+	 * @var WebhookEventStorage
 	 */
-	private $last_webhook_storage;
+	private $last_webhook_event_storage;
 
 	/**
 	 * IncomingWebhookEndpoint constructor.
@@ -92,7 +92,7 @@ class IncomingWebhookEndpoint {
 	 * @param bool                $verify_request Whether requests need to be verified or not.
 	 * @param WebhookEventFactory $webhook_event_factory The webhook event factory.
 	 * @param WebhookSimulation   $simulation The simulation handler.
-	 * @param WebhookInfoStorage  $last_webhook_storage The last webhook info storage.
+	 * @param WebhookEventStorage $last_webhook_event_storage The last webhook event storage.
 	 * @param RequestHandler      ...$handlers The handlers, which process a request in the end.
 	 */
 	public function __construct(
@@ -102,18 +102,18 @@ class IncomingWebhookEndpoint {
 		bool $verify_request,
 		WebhookEventFactory $webhook_event_factory,
 		WebhookSimulation $simulation,
-		WebhookInfoStorage $last_webhook_storage,
+		WebhookEventStorage $last_webhook_event_storage,
 		RequestHandler ...$handlers
 	) {
 
-		$this->webhook_endpoint      = $webhook_endpoint;
-		$this->webhook               = $webhook;
-		$this->handlers              = $handlers;
-		$this->logger                = $logger;
-		$this->verify_request        = $verify_request;
-		$this->webhook_event_factory = $webhook_event_factory;
-		$this->last_webhook_storage  = $last_webhook_storage;
-		$this->simulation            = $simulation;
+		$this->webhook_endpoint           = $webhook_endpoint;
+		$this->webhook                    = $webhook;
+		$this->handlers                   = $handlers;
+		$this->logger                     = $logger;
+		$this->verify_request             = $verify_request;
+		$this->webhook_event_factory      = $webhook_event_factory;
+		$this->last_webhook_event_storage = $last_webhook_event_storage;
+		$this->simulation                 = $simulation;
 	}
 
 	/**
@@ -186,7 +186,7 @@ class IncomingWebhookEndpoint {
 	public function handle_request( \WP_REST_Request $request ): \WP_REST_Response {
 		$event = $this->event_from_request( $request );
 
-		$this->last_webhook_storage->save( $event );
+		$this->last_webhook_event_storage->save( $event );
 
 		if ( $this->simulation->is_simulation_event( $event ) ) {
 			$this->logger->info( 'Received simulated webhook.' );

modules/ppcp-webhooks/src/Status/Assets/WebhooksStatusPageAssets.php

@@ -9,6 +9,7 @@ declare(strict_types=1);
 
 namespace WooCommerce\PayPalCommerce\Webhooks\Status\Assets;
 
+use WooCommerce\PayPalCommerce\Onboarding\Environment;
 use WooCommerce\PayPalCommerce\Webhooks\Endpoint\ResubscribeEndpoint;
 use WooCommerce\PayPalCommerce\Webhooks\Endpoint\SimulateEndpoint;
 use WooCommerce\PayPalCommerce\Webhooks\Endpoint\SimulationStateEndpoint;
@@ -33,18 +34,28 @@ class WebhooksStatusPageAssets {
 	 */
 	private $version;
 
+	/**
+	 * The environment object.
+	 *
+	 * @var Environment
+	 */
+	private $environment;
+
 	/**
 	 * WebhooksStatusPageAssets constructor.
 	 *
-	 * @param string $module_url                         The URL to the module.
-	 * @param string $version                            The assets version.
+	 * @param string      $module_url  The URL to the module.
+	 * @param string      $version     The assets version.
+	 * @param Environment $environment The environment object.
 	 */
 	public function __construct(
 		string $module_url,
-		string $version
+		string $version,
+		Environment $environment
 	) {
-		$this->module_url = untrailingslashit( $module_url );
-		$this->version    = $version;
+		$this->module_url  = untrailingslashit( $module_url );
+		$this->version     = $version;
+		$this->environment = $environment;
 	}
 
 	/**
@@ -103,6 +114,7 @@ class WebhooksStatusPageAssets {
 					'tooLongDelayMessage' => __( 'Looks like the webhook cannot be received. Check that your website is accessible from the internet.', 'woocommerce-paypal-payments' ),
 				),
 			),
+			'environment' => $this->environment->current_environment(),
 		);
 	}
 

modules/ppcp-webhooks/src/WebhookEventStorage.php

@@ -12,9 +12,9 @@ namespace WooCommerce\PayPalCommerce\Webhooks;
 use WooCommerce\PayPalCommerce\ApiClient\Entity\WebhookEvent;
 
 /**
- * Class WebhookInfoStorage
+ * Class WebhookEventStorage
  */
-class WebhookInfoStorage {
+class WebhookEventStorage {
 
 	/**
 	 * The WP option key.

modules/ppcp-webhooks/src/WebhookModule.php

@@ -152,7 +152,6 @@ class WebhookModule implements ModuleInterface {
 				add_action(
 					'init',
 					function () use ( $registrar ) {
-						$registrar->unregister();
 						$registrar->register();
 					}
 				);

modules/ppcp-webhooks/src/WebhookRegistrar.php

@@ -45,11 +45,11 @@ class WebhookRegistrar {
 	private $rest_endpoint;
 
 	/**
-	 * The last webhook info storage.
+	 * The last webhook event storage.
 	 *
-	 * @var WebhookInfoStorage
+	 * @var WebhookEventStorage
 	 */
-	private $last_webhook_storage;
+	private $last_webhook_event_storage;
 
 	/**
 	 * The logger.
@@ -64,22 +64,22 @@ class WebhookRegistrar {
 	 * @param WebhookFactory          $webhook_factory The Webhook factory.
 	 * @param WebhookEndpoint         $endpoint The Webhook endpoint.
 	 * @param IncomingWebhookEndpoint $rest_endpoint The WordPress Rest API endpoint.
-	 * @param WebhookInfoStorage      $last_webhook_storage The last webhook info storage.
+	 * @param WebhookEventStorage     $last_webhook_event_storage The last webhook event storage.
 	 * @param LoggerInterface         $logger The logger.
 	 */
 	public function __construct(
 		WebhookFactory $webhook_factory,
 		WebhookEndpoint $endpoint,
 		IncomingWebhookEndpoint $rest_endpoint,
-		WebhookInfoStorage $last_webhook_storage,
+		WebhookEventStorage $last_webhook_event_storage,
 		LoggerInterface $logger
 	) {
 
-		$this->webhook_factory      = $webhook_factory;
-		$this->endpoint             = $endpoint;
-		$this->rest_endpoint        = $rest_endpoint;
-		$this->last_webhook_storage = $last_webhook_storage;
-		$this->logger               = $logger;
+		$this->webhook_factory            = $webhook_factory;
+		$this->endpoint                   = $endpoint;
+		$this->rest_endpoint              = $rest_endpoint;
+		$this->last_webhook_event_storage = $last_webhook_event_storage;
+		$this->logger                     = $logger;
 	}
 
 	/**
@@ -88,6 +88,8 @@ class WebhookRegistrar {
 	 * @return bool
 	 */
 	public function register(): bool {
+		$this->unregister();
+
 		$webhook = $this->webhook_factory->for_url_and_events(
 			$this->rest_endpoint->url(),
 			$this->rest_endpoint->handled_event_types()
@@ -102,7 +104,7 @@ class WebhookRegistrar {
 				self::KEY,
 				$created->to_array()
 			);
-			$this->last_webhook_storage->clear();
+			$this->last_webhook_event_storage->clear();
 			$this->logger->info( 'Webhooks subscribed.' );
 			return true;
 		} catch ( RuntimeException $error ) {
@@ -113,27 +115,23 @@ class WebhookRegistrar {
 
 	/**
 	 * Unregister webhooks with PayPal.
-	 *
-	 * @return bool
 	 */
-	public function unregister(): bool {
-		$data = (array) get_option( self::KEY, array() );
-		if ( ! $data ) {
-			return false;
-		}
+	public function unregister(): void {
 		try {
-			$webhook = $this->webhook_factory->from_array( $data );
-			$success = $this->endpoint->delete( $webhook );
+			$webhooks = $this->endpoint->list();
+			foreach ( $webhooks as $webhook ) {
+				try {
+					$this->endpoint->delete( $webhook );
+				} catch ( RuntimeException $deletion_error ) {
+					$this->logger->error( "Failed to delete webhook {$webhook->id()}: {$deletion_error->getMessage()}" );
+				}
+			}
 		} catch ( RuntimeException $error ) {
 			$this->logger->error( 'Failed to delete webhooks: ' . $error->getMessage() );
-			return false;
 		}
 
-		if ( $success ) {
-			delete_option( self::KEY );
-			$this->last_webhook_storage->clear();
-			$this->logger->info( 'Webhooks deleted.' );
-		}
-		return $success;
+		delete_option( self::KEY );
+		$this->last_webhook_event_storage->clear();
+		$this->logger->info( 'Webhooks deleted.' );
 	}
 }