enable_rest_api();
$this->enable_wp_cli();
add_action('init', array($this, 'register_webhook_listeners'));
add_action('wp_ajax_wu_send_test_event', array($this, 'send_test_event'));
} // end init;
/**
* Adds the listeners to the webhook callers, extend this by adding actions to wu_register_webhook_listeners
*
* @todo This needs to have a switch, allowing us to turn it on and off.
* @return void.
*/
public function register_webhook_listeners() {
foreach (wu_get_event_types() as $key => $event) {
add_action('wu_event_' . $key, array($this, 'send_webhooks'));
} // end foreach;
} // end register_webhook_listeners;
/**
* Sends all the webhooks that are triggered by a specific event.
*
* @since 2.0.0
*
* @param array $args with events slug and payload.
* @return void
*/
public function send_webhooks($args) {
$webhooks = Webhook::get_all();
foreach ($webhooks as $webhook) {
if ('wu_event_' . $webhook->get_event() === current_filter()) {
$blocking = wu_get_setting('webhook_calls_blocking', false);
$this->send_webhook($webhook, $args, $blocking);
} // end if;
} // end foreach;
} // end send_webhooks;
/**
* Sends a specific webhook.
*
* @since 2.0.0
*
* @param Webhook $webhook The webhook to send.
* @param array $data Key-value array of data to send.
* @param boolean $blocking Decides if we want to wait for a response to keep a log.
* @param boolean $count If we should update the webhook event count.
* @return string|null.
*/
public function send_webhook($webhook, $data, $blocking = true, $count = true) {
if (!$data) {
return;
} // end if;
$request = wp_remote_post($webhook->get_webhook_url(), array(
'method' => 'POST',
'timeout' => 45,
'redirection' => 5,
'headers' => array(
'Content-Type' => 'application/json',
),
'cookies' => array(),
'body' => wp_json_encode($data),
'blocking' => $blocking,
), current_filter(), $webhook);
if (is_wp_error($request)) {
$error_message = $request->get_error_message();
if ($count) {
$this->create_event(
$webhook->get_event(),
$webhook->get_id(),
$webhook->get_webhook_url(),
$data,
$error_message,
true
);
} // end if;
return $error_message;
} // end if;
$response = '';
// if blocking, we have a response
if ($blocking) {
$response = wp_remote_retrieve_body($request);
} // end if;
if ($count) {
$this->create_event(
$webhook->get_event(),
$webhook->get_id(),
$webhook->get_webhook_url(),
$data,
$response
);
$new_count = $webhook->get_event_count() + 1;
$webhook->set_event_count($new_count);
$webhook->save();
} // end if;
return $response;
} // end send_webhook;
/**
* Send a test event of the webhook
*
* @return void
*/
public function send_test_event() {
if (!current_user_can('manage_network')) {
wp_send_json(array(
'response' => __('You do not have enough permissions to send a test event.', 'wp-ultimo'),
'webhooks' => Webhook::get_items_as_array(),
));
} // end if;
$event = wu_get_event_type($_POST['webhook_event']);
$webhook_data = array(
'webhook_url' => $_POST['webhook_url'],
'event' => $_POST['webhook_event'],
'active' => true,
);
$webhook = new Webhook($webhook_data);
$response = $this->send_webhook($webhook, wu_maybe_lazy_load_payload($event['payload']), true, false);
wp_send_json(array(
'response' => htmlentities2($response),
'id' => wu_request('webhook_id')
));
} // end send_test_event;
/**
* Reads the log file and displays the content.
*
* @return void.
*/
public function serve_logs() {
echo '
';
if (!current_user_can('manage_network')) {
echo __('You do not have enough permissions to read the logs of this webhook.', 'wp-ultimo');
exit;
} // end if;
$id = absint($_REQUEST['id']);
$logs = array_map(function($line): string {
$line = str_replace(' - ', ' - ', $line);
$matches = array();
$line = str_replace('\'', '\\\'', $line);
$line = preg_replace('~(\{(?:[^{}]|(?R))*\})~', '', $line);
return '' . $line . '
';
}, Logger::read_lines("webhook-$id", 5));
echo implode('', $logs);
exit;
} // end serve_logs;
/**
* Log a webhook sent for later reference.
*
* @since 2.0.0
*
* @param string $event_name The name of the event.
* @param int $id The id of the webhook sent.
* @param string $url The URL called by the webhook.
* @param array $data The array with data to be sent.
* @param string $response The response got on webhook call.
* @param bool $is_error If the response is a WP_Error message.
* @return void
*/
protected function create_event($event_name, $id, $url, $data, $response, $is_error = false) {
$message = sprintf('Sent a %s event to the URL %s with data: %s ', $event_name, $url, json_encode($data));
if (!$is_error) {
$message .= empty($response) ? sprintf('Got response: %s', $response) : 'To debug the remote server response, turn the "Wait for Response" option on the WP Ultimo Settings > API & Webhooks Tab';
} else {
$message .= sprintf('Got error: %s', $response);
} // end if;
$event_data = array(
'object_id' => $id,
'object_type' => $this->slug,
'slug' => $event_name,
'payload' => array(
'message' => $message,
),
);
wu_create_event($event_data);
} // end create_event;
} // end class Webhook_Manager;