← All changes | addons/automator/includes/actions/webhook-actions.php +128 -128 8.7.9 → 8.8.2 View file →

		@@ -1,128 +1,128 @@
1		-<?php
2		-/**
3		- * Webhook Actions
4		- *
5		- * @package WPbot_Automator
6		- */
7		-
8		-namespace WPbot_Automator\Actions;
9		-
10		-if ( ! defined( 'ABSPATH' ) ) {
11		- exit;
12		-}
13		-
14		-/**
15		- * Class Webhook_Actions
16		- */
17		-class Webhook_Actions extends Action {
18		-
19		- /**
20		- * Constructor
21		- */
22		- public function __construct() {
23		- $this->id = 'webhook';
24		- $this->group = __( 'Webhook', 'wpbot-automator' );
25		- }
26		-
27		- /**
28		- * Execute the action
29		- */
30		- public function execute( $action_data, $trigger_data ) {
31		- $action_id = isset( $action_data['actionId'] ) ? $action_data['actionId'] : '';
32		-
33		- if ( empty( $action_id ) ) {
34		- return false;
35		- }
36		-
37		- switch ( $action_id ) {
38		- case 'outgoing_webhook':
39		- return $this->outgoing_webhook( $action_data, $trigger_data );
40		- default:
41		- return false;
42		- }
43		- }
44		-
45		- /**
46		- * Send outgoing webhook
47		- */
48		- private function outgoing_webhook( $config, $trigger_data ) {
49		- $config_values = isset( $config['config'] ) ? $config['config'] : array();
50		-
51		- $url = isset( $config_values['url'] ) ? $this->parse_tokens( $config_values['url'], $trigger_data ) : '';
52		- $method = isset( $config_values['method'] ) ? $config_values['method'] : 'POST';
53		- $body = isset( $config_values['body'] ) ? $this->parse_tokens( $config_values['body'], $trigger_data ) : '';
54		-
55		- if ( empty( $url ) ) {
56		- return array(
57		- 'success' => false,
58		- 'message' => 'Request URL is required.',
59		- );
60		- }
61		-
62		- // Prepare headers
63		- $headers = array();
64		- if ( ! empty( $config_values['headers'] ) ) {
65		- $headers_data = $config_values['headers'];
66		- if ( is_string( $headers_data ) ) {
67		- $headers_data = json_decode( $headers_data, true );
68		- }
69		- if ( is_array( $headers_data ) ) {
70		- foreach ( $headers_data as $pair ) {
71		- if ( ! empty( $pair['key'] ) ) {
72		- $headers[ $pair['key'] ] = $this->parse_tokens( $pair['value'], $trigger_data );
73		- }
74		- }
75		- }
76		- }
77		-
78		- // Set default Content-Type if not provided and body is present
79		- if ( ! isset( $headers['Content-Type'] ) && ! empty( $body ) ) {
80		- $headers['Content-Type'] = 'application/json';
81		- }
82		-
83		- // Prepare Query Params
84		- if ( ! empty( $config_values['params'] ) ) {
85		- $params_data = $config_values['params'];
86		- if ( is_string( $params_data ) ) {
87		- $params_data = json_decode( $params_data, true );
88		- }
89		- if ( is_array( $params_data ) ) {
90		- $query_args = array();
91		- foreach ( $params_data as $pair ) {
92		- if ( ! empty( $pair['key'] ) ) {
93		- $query_args[ $pair['key'] ] = $this->parse_tokens( $pair['value'], $trigger_data );
94		- }
95		- }
96		- if ( ! empty( $query_args ) ) {
97		- $url = add_query_arg( $query_args, $url );
98		- }
99		- }
100		- }
101		-
102		- $args = array(
103		- 'method' => $method,
104		- 'headers' => $headers,
105		- 'body' => $body,
106		- 'timeout' => 30,
107		- );
108		-
109		- $response = wp_remote_request( $url, $args );
110		-
111		- if ( is_wp_error( $response ) ) {
112		- return array(
113		- 'success' => false,
114		- 'message' => $response->get_error_message(),
115		- );
116		- }
117		-
118		- $response_code = wp_remote_retrieve_response_code( $response );
119		- $response_body = wp_remote_retrieve_body( $response );
120		-
121		- return array(
122		- 'success' => $response_code >= 200 && $response_code < 300,
123		- 'code' => $response_code,
124		- 'body' => $response_body,
125		- 'message' => sprintf( 'Response Code: %d', $response_code ),
126		- );
127		- }
128		-}
	1	+<?php
	2	+/**
	3	+ * Webhook Actions
	4	+ *
	5	+ * @package WPbot_Automator
	6	+ */
	7	+
	8	+namespace WPbot_Automator\Actions;
	9	+
	10	+if ( ! defined( 'ABSPATH' ) ) {
	11	+ exit;
	12	+}
	13	+
	14	+/**
	15	+ * Class Webhook_Actions
	16	+ */
	17	+class Webhook_Actions extends Action {
	18	+
	19	+ /**
	20	+ * Constructor
	21	+ */
	22	+ public function __construct() {
	23	+ $this->id = 'webhook';
	24	+ $this->group = __( 'Webhook', 'wpbot-automator' );
	25	+ }
	26	+
	27	+ /**
	28	+ * Execute the action
	29	+ */
	30	+ public function execute( $action_data, $trigger_data ) {
	31	+ $action_id = isset( $action_data['actionId'] ) ? $action_data['actionId'] : '';
	32	+
	33	+ if ( empty( $action_id ) ) {
	34	+ return false;
	35	+ }
	36	+
	37	+ switch ( $action_id ) {
	38	+ case 'outgoing_webhook':
	39	+ return $this->outgoing_webhook( $action_data, $trigger_data );
	40	+ default:
	41	+ return false;
	42	+ }
	43	+ }
	44	+
	45	+ /**
	46	+ * Send outgoing webhook
	47	+ */
	48	+ private function outgoing_webhook( $config, $trigger_data ) {
	49	+ $config_values = isset( $config['config'] ) ? $config['config'] : array();
	50	+
	51	+ $url = isset( $config_values['url'] ) ? $this->parse_tokens( $config_values['url'], $trigger_data ) : '';
	52	+ $method = isset( $config_values['method'] ) ? $config_values['method'] : 'POST';
	53	+ $body = isset( $config_values['body'] ) ? $this->parse_tokens( $config_values['body'], $trigger_data ) : '';
	54	+
	55	+ if ( empty( $url ) ) {
	56	+ return array(
	57	+ 'success' => false,
	58	+ 'message' => 'Request URL is required.',
	59	+ );
	60	+ }
	61	+
	62	+ // Prepare headers
	63	+ $headers = array();
	64	+ if ( ! empty( $config_values['headers'] ) ) {
	65	+ $headers_data = $config_values['headers'];
	66	+ if ( is_string( $headers_data ) ) {
	67	+ $headers_data = json_decode( $headers_data, true );
	68	+ }
	69	+ if ( is_array( $headers_data ) ) {
	70	+ foreach ( $headers_data as $pair ) {
	71	+ if ( ! empty( $pair['key'] ) ) {
	72	+ $headers[ $pair['key'] ] = $this->parse_tokens( $pair['value'], $trigger_data );
	73	+ }
	74	+ }
	75	+ }
	76	+ }
	77	+
	78	+ // Set default Content-Type if not provided and body is present
	79	+ if ( ! isset( $headers['Content-Type'] ) && ! empty( $body ) ) {
	80	+ $headers['Content-Type'] = 'application/json';
	81	+ }
	82	+
	83	+ // Prepare Query Params
	84	+ if ( ! empty( $config_values['params'] ) ) {
	85	+ $params_data = $config_values['params'];
	86	+ if ( is_string( $params_data ) ) {
	87	+ $params_data = json_decode( $params_data, true );
	88	+ }
	89	+ if ( is_array( $params_data ) ) {
	90	+ $query_args = array();
	91	+ foreach ( $params_data as $pair ) {
	92	+ if ( ! empty( $pair['key'] ) ) {
	93	+ $query_args[ $pair['key'] ] = $this->parse_tokens( $pair['value'], $trigger_data );
	94	+ }
	95	+ }
	96	+ if ( ! empty( $query_args ) ) {
	97	+ $url = add_query_arg( $query_args, $url );
	98	+ }
	99	+ }
	100	+ }
	101	+
	102	+ $args = array(
	103	+ 'method' => $method,
	104	+ 'headers' => $headers,
	105	+ 'body' => $body,
	106	+ 'timeout' => 30,
	107	+ );
	108	+
	109	+ $response = wp_remote_request( $url, $args );
	110	+
	111	+ if ( is_wp_error( $response ) ) {
	112	+ return array(
	113	+ 'success' => false,
	114	+ 'message' => $response->get_error_message(),
	115	+ );
	116	+ }
	117	+
	118	+ $response_code = wp_remote_retrieve_response_code( $response );
	119	+ $response_body = wp_remote_retrieve_body( $response );
	120	+
	121	+ return array(
	122	+ 'success' => $response_code >= 200 && $response_code < 300,
	123	+ 'code' => $response_code,
	124	+ 'body' => $response_body,
	125	+ 'message' => sprintf( 'Response Code: %d', $response_code ),
	126	+ );
	127	+ }
	128	+}