surecart / app / src / Controllers / Web / WebhookController.php

WebhookController.php in SureCart – Ecommerce Made Easy For Selling Physical Products, Digital Downloads, Subscriptions, Donations, & Payments 4.2.3, at app/src/Controllers/Web/WebhookController.php

192 lines 4.9 KB

Raw Download Zip

1	<?php
2
3	namespace SureCart\Controllers\Web;
4
5	use SureCart\Models\IncomingWebhook;
6	use SureCart\Models\RegisteredWebhook;
7	use SureCartVendors\Psr\Http\Message\ResponseInterface;
8
9	/**
10	* Handles webhooks
11	*/
12	class WebhookController {
13	/**
14	* Create new webhook for this site.
15	*
16	* @param \SureCartCore\Requests\RequestInterface $request Request.
17	* @return ResponseInterface
18	*/
19	public function create( $request ) {
20	// We'll create a webhook for this site register the webhooks.
21	$registered = RegisteredWebhook::create();
22
23	// handle error and show notice to user.
24	if ( is_wp_error( $registered ) ) {
25	// show notice.
26	\SureCart::notices()->add(
27	[
28	'name' => 'webhooks_registration_error',
29	'type' => 'warning',
30	'title' => esc_html__( 'SureCart Webhook Creation Error', 'surecart' ),
31	'text' => sprintf( '<p>%s</p>', ( implode( '<br />', $registered->get_error_messages() ?? [] ) ) ),
32	]
33	);
34	}
35
36	// test it.
37	$registered->test();
38
39	return \SureCart::redirect()->to( esc_url_raw( admin_url( 'admin.php?page=sc-dashboard' ) ) );
40	}
41
42	/**
43	* Update the webhook.
44	*
45	* @param \SureCartCore\Requests\RequestInterface $request Request.
46	* @return ResponseInterface
47	*/
48	public function update( $request ) {
49	// Find the registered webhook.
50	$webhook = RegisteredWebhook::find();
51	if ( is_wp_error( $webhook ) ) {
52	wp_die( wp_kses_post( $webhook->get_error_message() ) );
53	}
54
55	// update webhook.
56	$updated = RegisteredWebhook::update();
57
58	// handle error.
59	if ( is_wp_error( $updated ) ) {
60	wp_die( wp_kses_post( $updated->get_error_message() ) );
61	}
62
63	return \SureCart::redirect()->to( esc_url_raw( admin_url( 'admin.php?page=sc-dashboard' ) ) );
64	}
65
66	/**
67	* This deletes and recreates the webhook
68	* in case the signing secret is invalid for some reason.
69	*
70	* @param \SureCartCore\Requests\RequestInterface $request Request.
71	* @return ResponseInterface
72	*/
73	public function resync( $request ) {
74	// Delete the registered webhook.
75	$webhook = RegisteredWebhook::registration()->delete();
76	if ( is_wp_error( $webhook ) ) {
77	wp_die( wp_kses_post( $webhook->get_error_message() ) );
78	}
79
80	// recreate.
81	return $this->create( $request );
82	}
83
84	/**
85	* Recieve webhook.
86	*
87	* @param \SureCartCore\Requests\RequestInterface $request Request.
88	* @return ResponseInterface
89	*/
90	public function receive( $request ) {
91	// get json if sent.
92	if ( 'application/json' === $request->getHeaderLine( 'Content-Type' ) ) {
93	$body = json_decode( $request->getBody(), true );
94	} else {
95	$body = $request->getParsedBody();
96	}
97
98	// validate body.
99	if ( empty( $body['type'] ) ) {
100	return new \WP_Error( 'missing_type', 'Missing type.' );
101	}
102	if ( empty( $body['data'] ) ) {
103	return new \WP_Error( 'missing_data', 'Missing data.' );
104	}
105	if ( empty( $body['id'] ) ) {
106	return new \WP_Error( 'missing_id', 'Missing id.' );
107	}
108
109	// make sure we don't have a duplicate webhook.
110	$webhook = IncomingWebhook::where( 'webhook_id', $body['id'] )->first();
111	if ( ! empty( $webhook->id ) ) {
112	return \SureCart::json(
113	[
114	'status' => 'already_handled',
115	]
116	)
117	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
118	->withStatus( 200 );
119	}
120
121	// create incoming webhook.
122	$incoming = IncomingWebhook::create(
123	[
124	'webhook_id' => $body['id'],
125	'data' => $body,
126	'source' => 'surecart',
127	]
128	);
129
130	if ( is_wp_error( $incoming ) ) {
131	return \SureCart::json(
132	[
133	'error' => $incoming->get_error_message(),
134	]
135	)
136	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
137	->withStatus( 500 );
138	}
139
140	if ( empty( $incoming->id ) ) {
141	return \SureCart::json(
142	[
143	'error' => 'Failed to create webhook.',
144	]
145	)
146	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
147	->withStatus( 400 );
148	}
149
150	// dispatch an async request.
151	\SureCart::async()->data(
152	[
153	'id' => $incoming->id,
154	]
155	)->dispatch();
156
157	// handle the response.
158	return $this->handleResponse( $incoming->id, $incoming->toArray() );
159	}
160
161	/**
162	* Handle the response back to the webhook.
163	*
164	* @param array\|\WP_Error $data Data.
165	* @return function
166	*/
167	public function handleResponse( $id, $data ) {
168	// handle the response.
169	if ( is_wp_error( $data ) ) {
170	return \SureCart::json( [ $data->get_error_code() => $data->get_error_message() ] )
171	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
172	->withStatus( 500 );
173	}
174
175	if ( empty( $data ) ) {
176	return \SureCart::json( [ 'failed' => true ] )
177	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
178	->withStatus( 400 );
179	}
180
181	return \SureCart::json(
182	[
183	'process_id' => $id,
184	'event_triggered' => $data['event'] ?? 'none',
185	'data' => $data,
186	]
187	)
188	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
189	->withStatus( 200 );
190	}
191	}
192