fix: webhook handlers trigger correctly and with payloads

Author: theodesp

plugins/wp-graphql-headless-webhooks/src/Events/WebhookEventManager.php

@@ -57,13 +57,12 @@ public function register_hooks(): void {
 	 */
 	private function trigger_webhooks( string $event, array $payload ): void {
 		$allowed_events = $this->repository->get_allowed_events();
-
-		if ( ! in_array( $event, $allowed_events, true ) ) {
+		if ( ! array_key_exists( $event, $allowed_events ) ) {
+			error_log( 'Event ' . $event . ' is not allowed. Allowed events: ' . implode( ', ', $allowed_events ) );
 			return;
 		}
 
 		do_action( 'graphql_webhooks_before_trigger', $event, $payload );
-
 		foreach ( $this->repository->get_all() as $webhook ) {
 			if ( $webhook->event === $event ) {
 				$this->handler->handle( $webhook, $payload );

plugins/wp-graphql-headless-webhooks/src/Handlers/WebhookHandler.php

@@ -11,38 +11,34 @@
  */
 class WebhookHandler implements Handler {
 
-    /**
-     * Handle the event payload for a specific webhook.
-     *
-     * @param Webhook $webhook The Webhook entity instance.
-     * @param array   $payload The event payload data.
-     *
-     * @return void
-     */
-    public function handle( Webhook $webhook, array $payload ): void {
-        $args = [
-            'headers'  => $webhook->headers ?: [ 'Content-Type' => 'application/json' ],
-            'timeout'  => 5,
-            'blocking' => false,
-        ];
-
-        if ( strtoupper( $webhook->method ) === 'GET' ) {
-            $url = add_query_arg( $payload, $webhook->url );
-            $args['method'] = 'GET';
-        } else {
-            $url = $webhook->url;
-            $args['method'] = 'POST';
-            $args['body'] = wp_json_encode( $payload );
-            if ( empty( $args['headers']['Content-Type'] ) ) {
-                $args['headers']['Content-Type'] = 'application/json';
-            }
-        }
-
-        /**
-         * Filter the payload before sending.
-         */
+	/**
+	 * Handle the event payload for a specific webhook.
+	 *
+	 * @param Webhook $webhook The Webhook entity instance.
+	 * @param array   $payload The event payload data.
+	 *
+	 * @return void
+	 */
+	public function handle( Webhook $webhook, array $payload ): void {
+		$args = [ 
+			'headers' => $webhook->headers ?: [ 'Content-Type' => 'application/json' ],
+			'timeout' => 5,
+			'blocking' => false,
+		];
         $payload = apply_filters( 'graphql_webhooks_payload', $payload, $webhook );
-        wp_remote_request( $url, $args );
-        do_action( 'graphql_webhooks_sent', $webhook, $payload );
-    }
+
+		if ( strtoupper( $webhook->method ) === 'GET' ) {
+			$url = add_query_arg( $payload, $webhook->url );
+			$args['method'] = 'GET';
+		} else {
+			$url = $webhook->url;
+			$args['method'] = 'POST';
+			$args['body'] = wp_json_encode( $payload );
+			if ( empty( $args['headers']['Content-Type'] ) ) {
+				$args['headers']['Content-Type'] = 'application/json';
+			}
+		}
+		wp_remote_request( $url, $args );
+		do_action( 'graphql_webhooks_sent', $webhook, $payload );
+	}
 }

plugins/wp-graphql-headless-webhooks/src/Plugin.php

@@ -97,6 +97,17 @@ private function includes(): void {
 				require_once WPGRAPHQL_HEADLESS_WEBHOOKS_PLUGIN_DIR . 'vendor/autoload.php';
 			}
 		}
+		
+		/**
+		 * Get the webhook repository instance.
+		 *
+		 * Provides access to the WebhookRepository for managing webhook data.
+		 *
+		 * @return WebhookRepository The repository instance.
+		 */
+		public function get_repository(): WebhookRepository {
+			return $this->repository;
+		}
 
 		/**
 		 * Prevent cloning.