101 lines
3.1 KiB
PHP
101 lines
3.1 KiB
PHP
<?php
|
|
|
|
require_once __DIR__.'/../init.php';
|
|
|
|
cli_set_process_title('Webhooks V1 Worker');
|
|
|
|
echo APP_NAME.' webhooks worker v1 has started';
|
|
|
|
use Database\Database;
|
|
use Database\Validator\Authorization;
|
|
|
|
class WebhooksV1
|
|
{
|
|
public $args = [];
|
|
|
|
public function setUp()
|
|
{
|
|
}
|
|
|
|
public function perform()
|
|
{
|
|
global $consoleDB, $version;
|
|
|
|
$errors = [];
|
|
|
|
// Event
|
|
$projectId = $this->args['projectId'];
|
|
$event = $this->args['event'];
|
|
$payload = json_encode($this->args['payload']);
|
|
|
|
// Webhook
|
|
|
|
Authorization::disable();
|
|
|
|
$project = $consoleDB->getDocument($projectId);
|
|
|
|
Authorization::enable();
|
|
|
|
if (is_null($project->getId()) || Database::SYSTEM_COLLECTION_PROJECTS !== $project->getCollection()) {
|
|
throw new Exception('Project Not Found');
|
|
}
|
|
|
|
foreach ($project->getAttribute('webhooks', []) as $webhook) {
|
|
if (!(isset($webhook['events']) && is_array($webhook['events']) && in_array($event, $webhook['events']))) {
|
|
continue;
|
|
}
|
|
|
|
$name = (isset($webhook['name'])) ? $webhook['name'] : '';
|
|
$signature = (isset($webhook['signature'])) ? $webhook['signature'] : 'not-yet-implemented';
|
|
$url = (isset($webhook['url'])) ? $webhook['url'] : '';
|
|
$security = (isset($webhook['security'])) ? (bool) $webhook['security'] : true;
|
|
$httpUser = (isset($webhook['httpUser'])) ? $webhook['httpUser'] : null;
|
|
$httpPass = (isset($webhook['httpPass'])) ? $webhook['httpPass'] : null;
|
|
|
|
$ch = curl_init($url);
|
|
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
|
|
curl_setopt($ch, CURLOPT_HEADER, 0);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
curl_setopt($ch, CURLOPT_USERAGENT, sprintf(APP_USERAGENT, $version));
|
|
curl_setopt(
|
|
$ch,
|
|
CURLOPT_HTTPHEADER,
|
|
[
|
|
'Content-Type: application/json',
|
|
'Content-Length: '.strlen($payload),
|
|
'X-'.APP_NAME.'-Webhook-Event: '.$event,
|
|
'X-'.APP_NAME.'-Webhook-Name: '.$name,
|
|
'X-'.APP_NAME.'-Webhook-Signature: '.$signature,
|
|
]
|
|
);
|
|
|
|
if (!$security) {
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
|
}
|
|
|
|
if (!empty($httpUser) && !empty($httpPass)) {
|
|
curl_setopt($ch, CURLOPT_USERPWD, "$httpUser:$httpPass");
|
|
curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
|
|
}
|
|
|
|
if (false === curl_exec($ch)) {
|
|
$errors[] = curl_error($ch).' in event '.$event.' for webhook '.$name;
|
|
}
|
|
|
|
curl_close($ch);
|
|
}
|
|
|
|
if (!empty($errors)) {
|
|
throw new Exception(implode(" / \n\n", $errors));
|
|
}
|
|
}
|
|
|
|
public function tearDown()
|
|
{
|
|
// ... Remove environment for this job
|
|
}
|
|
}
|