← All changes | app/src/Controllers/Web/WebhookController.php +101 -115 4.3.2 → 2.1.3 View file →

		@@ -1,11 +1,10 @@
1	1	<?php
2		-
3	2	namespace SureCart\Controllers\Web;
4	3
5		-use SureCart\Models\IncomingWebhook;
6		-use SureCart\Models\RegisteredWebhook;
7		-use SureCartVendors\Psr\Http\Message\ResponseInterface;
	4	+use SureCart\Models\Webhook;
	5	+use SureCart\Webhooks\WebhooksHistoryService;
	6	+use SureCartCore\Responses\RedirectResponse;
8	7
9	8	/**
10	9	* Handles webhooks
11	10	*/
		@@ -10,83 +9,54 @@
10	9	* Handles webhooks
11	10	*/
12	11	class WebhookController {
13	12	/**
14		- * Create new webhook for this site.
	13	+ * Map object names to their models.
15	14	*
16		- * @param \SureCartCore\Requests\RequestInterface $request Request.
17		- * @return ResponseInterface
	15	+ * @var array
18	16	*/
19		- public function create( $request ) {
20		- // We'll create a webhook for this site register the webhooks.
21		- $registered = RegisteredWebhook::create();
	17	+ protected $models = [
	18	+ 'charge' => \SureCart\Models\Charge::class,
	19	+ 'coupon' => \SureCart\Models\Coupon::class,
	20	+ 'customer' => \SureCart\Models\Customer::class,
	21	+ 'purchase' => \SureCart\Models\Purchase::class,
	22	+ 'price' => \SureCart\Models\Price::class,
	23	+ 'product' => \SureCart\Models\Product::class,
	24	+ 'period' => \SureCart\Models\Period::class,
	25	+ 'order' => \SureCart\Models\Order::class,
	26	+ 'refund' => \SureCart\Models\Refund::class,
	27	+ 'subscription' => \SureCart\Models\Subscription::class,
	28	+ 'invoice' => \SureCart\Models\Invoice::class,
	29	+ ];
22	30
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	31	/**
43		- * Update the webhook.
	32	+ * Remove the webhook.
44	33	*
45	34	* @param \SureCartCore\Requests\RequestInterface $request Request.
46		- * @return ResponseInterface
	35	+ * @return function
47	36	*/
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() ) );
	37	+ public function remove( $request ) {
	38	+ $deleted = Webhook::delete( $request->query( 'id' ) );
	39	+ if ( is_wp_error( $deleted ) ) {
	40	+ wp_die( $deleted->get_error_message() );
53	41	}
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' ) ) );
	42	+ return ( new RedirectResponse( $request ) )->back();
64	43	}
65	44
66	45	/**
67		- * This deletes and recreates the webhook
68		- * in case the signing secret is invalid for some reason.
	46	+ * Remove the webhook.
69	47	*
70	48	* @param \SureCartCore\Requests\RequestInterface $request Request.
71		- * @return ResponseInterface
	49	+ * @return function
72	50	*/
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 );
	51	+ public function ignore( $request ) {
	52	+ $service = new WebHooksHistoryService();
	53	+ $service->deletePreviousWebhook();
	54	+ return ( new RedirectResponse( $request ) )->back();
82	55	}
83	56
84	57	/**
85		- * Recieve webhook.
86		- *
87		- * @param \SureCartCore\Requests\RequestInterface $request Request.
88		- * @return ResponseInterface
	58	+ * Recieve webhook
89	59	*/
90	60	public function receive( $request ) {
91	61	// get json if sent.
92	62	if ( 'application/json' === $request->getHeaderLine( 'Content-Type' ) ) {
		@@ -94,25 +64,13 @@
94	64	} else {
95	65	$body = $request->getParsedBody();
96	66	}
97	67
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 ) ) {
	68	+ // the model does not exist.
	69	+ if ( empty( $this->models[ $body['data']['object']['object'] ] ) ) {
112	70	return \SureCart::json(
113	71	[
114		- 'status' => 'already_handled',
	72	+ 'event_triggered' => 'none',
115	73	]
116	74	)
117	75	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
118	76	->withStatus( 200 );
		@@ -117,46 +75,13 @@
117	75	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
118	76	->withStatus( 200 );
119	77	}
120	78
121		- // create incoming webhook.
122		- $incoming = IncomingWebhook::create(
123		- [
124		- 'webhook_id' => $body['id'],
125		- 'data' => $body,
126		- 'source' => 'surecart',
127		- ]
128		- );
	79	+ // perform the action.
	80	+ $action = $this->doAction( $body );
129	81
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	82	// handle the response.
158		- return $this->handleResponse( $incoming->id, $incoming->toArray() );
	83	+ return $this->handleResponse( $action );
159	84	}
160	85
161	86	/**
162	87	* Handle the response back to the webhook.
		@@ -163,9 +88,9 @@
163	88	*
164	89	* @param array|\WP_Error $data Data.
165	90	* @return function
166	91	*/
167		- public function handleResponse( $id, $data ) {
	92	+ public function handleResponse( $data ) {
168	93	// handle the response.
169	94	if ( is_wp_error( $data ) ) {
170	95	return \SureCart::json( [ $data->get_error_code() => $data->get_error_message() ] )
171	96	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
		@@ -179,9 +104,8 @@
179	104	}
180	105
181	106	return \SureCart::json(
182	107	[
183		- 'process_id' => $id,
184	108	'event_triggered' => $data['event'] ?? 'none',
185	109	'data' => $data,
186	110	]
187	111	)
		@@ -186,6 +110,68 @@
186	110	]
187	111	)
188	112	->withHeader( 'X-SURECART-WP-PLUGIN-VERSION', \SureCart::plugin()->version() )
189	113	->withStatus( 200 );
	114	+ }
	115	+
	116	+ /**
	117	+ * Perform the action.
	118	+ *
	119	+ * @param object $request Request.
	120	+ *
	121	+ * @return array|\WP_Error
	122	+ */
	123	+ public function doAction( $request ) {
	124	+ if ( empty( $request['type'] ) ) {
	125	+ return new \WP_Error( 'missing_type', 'Missing type.' );
	126	+ }
	127	+ if ( empty( $request['data'] ) ) {
	128	+ return new \WP_Error( 'missing_data', 'Missing data.' );
	129	+ }
	130	+
	131	+ // create the event name.
	132	+ $event = $this->createEventName( $request['type'] );
	133	+ $id = $this->getObjectId( $request['data'] );
	134	+ $model = new $this->models[ $request['data']['object']['object'] ]( $request['data']['object'] );
	135	+
	136	+ // broadcast the webhook.
	137	+ do_action( $event, $model, $request );
	138	+
	139	+ // return data.
	140	+ return [
	141	+ 'event' => $event,
	142	+ 'id' => $id,
	143	+ 'request' => $request,
	144	+ ];
	145	+ }
	146	+
	147	+ /**
	148	+ * Replace our dot notation webhook with underscore.
	149	+ *
	150	+ * @param string $type The event type.
	151	+ * @return string
	152	+ */
	153	+ public function createEventName( $type = '' ) {
	154	+ $type = str_replace( '.', '_', $type );
	155	+ return "surecart/$type";
	156	+ }
	157	+
	158	+ /**
	159	+ * Get the first object property in data.
	160	+ *
	161	+ * @param object $data Request data.
	162	+ * @return string
	163	+ */
	164	+ public function getObjectId( $data ) {
	165	+ return $data->object->id ?? '';
	166	+ }
	167	+
	168	+ /**
	169	+ * Find the object name.
	170	+ *
	171	+ * @param object|array $data Request data.
	172	+ * @return string
	173	+ */
	174	+ public function getObjectName( $data ) {
	175	+ return array_key_first( (array) $data );
190	176	}
191	177	}