learnpress / inc / rest-api / v1 / frontend / class-lp-rest-gateway-webhook-controller.php

class-lp-rest-gateway-webhook-controller.php in LearnPress – WordPress LMS Plugin for Create and Sell Online Courses 4.4.5, at inc/rest-api/v1/frontend/class-lp-rest-gateway-webhook-controller.php

136 lines 3.6 KB

Raw Download Zip

1	<?php
2	use LearnPress\Helpers\Response;
3
4	defined( 'ABSPATH' ) \|\| exit();
5
6	if ( ! class_exists( 'LP_REST_Gateway_Webhook_Controller' ) ) {
7	/**
8	* REST API endpoint for gateway subscription webhooks.
9	*
10	* @since 4.3.7
11	* @version 1.0.0
12	*/
13	class LP_REST_Gateway_Webhook_Controller extends LP_Abstract_REST_Controller {
14	/**
15	* Configure REST namespace/base for gateway webhook routes.
16	*
17	* @return void
18	*/
19	public function __construct() {
20	$this->namespace = 'lp/v1';
21	$this->rest_base = 'gateways';
22
23	parent::__construct();
24	}
25
26	/**
27	* Register public subscription webhook route.
28	*
29	* Path pattern: /lp/v1/gateways/{gateway}/subscription-webhook
30	*
31	* @return void
32	*/
33	public function register_routes() {
34	$this->routes = array(
35	'(?P<gateway>[a-zA-Z0-9_-]+)/subscription-webhook' => array(
36	array(
37	'methods' => WP_REST_Server::ALLMETHODS,
38	'callback' => array( $this, 'listen_subscription_webhook' ),
39	'permission_callback' => '__return_true',
40	),
41	),
42	);
43
44	parent::register_routes();
45	}
46
47	/**
48	* Dispatch provider subscription webhook to gateway implementation.
49	*
50	* This is the centralized entrypoint used by Stripe/PayPal webhook calls.
51	*
52	* @param WP_REST_Request $request
53	*
54	* @return Response
55	* @since 4.3.7
56	* @version 1.0.1
57	*/
58	public function listen_subscription_webhook( WP_REST_Request $request ): Response {
59	$response = new Response();
60	$gateway_id = sanitize_key( (string) $request->get_param( 'gateway' ) );
61
62	try {
63	if ( empty( $gateway_id ) ) {
64	throw new Exception( __( 'Gateway is required.', 'learnpress' ), 400 );
65	}
66
67	$gateway = LP_Gateways::instance()->get_gateway( $gateway_id );
68	if ( ! $gateway instanceof LP_Gateway_Abstract ) {
69	throw new Exception( __( 'Gateway not found.', 'learnpress' ), 404 );
70	}
71
72	if ( ! $gateway->is_enabled() ) {
73	throw new Exception( __( 'Gateway is not enable.', 'learnpress' ), 404 );
74	}
75
76	//LP_Debug::log_to_comment( 'Webhook payload: ' . json_encode( $request->get_body(), JSON_UNESCAPED_UNICODE ) );
77
78	/**
79	* @var LP_Gateway_Paypal\|LP_Gateway_Stripe $gateway
80	*/
81	$gateway->capture_subscription_webhook( $request );
82	} catch ( Throwable $e ) {
83	LP_Debug::log_to_comment( 'Webhook error: ' . $gateway_id . ' - ' . $e->getMessage() );
84	LP_Debug::error_log( $e );
85	$response->message = $e->getMessage();
86	}
87
88	return $response;
89	}
90
91	/**
92	* Build sanitized REST error response for public webhook endpoint.
93	*
94	* Internal provider error details are logged server-side, while API
95	* response returns a generic/safe message by status class.
96	*
97	* @param Throwable $error
98	*
99	* @return WP_REST_Response
100	*/
101	protected function build_error_response( Throwable $error ): WP_REST_Response {
102	$status = absint( $error->getCode() );
103	if ( $status < 100 \|\| $status > 599 ) {
104	$status = 400;
105	}
106
107	$error_code = 'lp_subscription_webhook_error';
108	$private_message = (string) $error->getMessage();
109	$public_message = __( 'Invalid webhook request.', 'learnpress' );
110
111	if ( 429 === $status ) {
112	$public_message = __( 'Too many webhook requests.', 'learnpress' );
113	} elseif ( 413 === $status ) {
114	$public_message = __( 'Webhook payload too large.', 'learnpress' );
115	}
116
117	error_log(
118	sprintf(
119	'LP subscription webhook error [%s]: %s',
120	$error_code,
121	$private_message
122	)
123	);
124
125	return new WP_REST_Response(
126	array(
127	'status' => 'error',
128	'code' => $error_code,
129	'message' => $public_message,
130	),
131	$status
132	);
133	}
134	}
135	}
136