114 lines
3.5 KiB
PHP
114 lines
3.5 KiB
PHP
<?php
|
|
|
|
use Utopia\App;
|
|
use Utopia\CLI\Console;
|
|
use Utopia\Config\Config;
|
|
use Appwrite\Database\Database;
|
|
use Appwrite\Database\Adapter\MySQL as MySQLAdapter;
|
|
use Appwrite\Database\Adapter\Redis as RedisAdapter;
|
|
use Appwrite\Database\Validator\Authorization;
|
|
|
|
require_once __DIR__.'/../init.php';
|
|
|
|
\cli_set_process_title('Webhooks V1 Worker');
|
|
|
|
Console::success(APP_NAME.' webhooks worker v1 has started');
|
|
|
|
class WebhooksV1
|
|
{
|
|
public $args = [];
|
|
|
|
public function setUp(): void
|
|
{
|
|
}
|
|
|
|
public function perform()
|
|
{
|
|
global $register;
|
|
|
|
$consoleDB = new Database();
|
|
$consoleDB->setAdapter(new RedisAdapter(new MySQLAdapter($register), $register));
|
|
$consoleDB->setNamespace('app_console'); // Main DB
|
|
$consoleDB->setMocks(Config::getParam('collections', []));
|
|
|
|
$errors = [];
|
|
|
|
// Event
|
|
$projectId = $this->args['projectId'];
|
|
$event = $this->args['event'];
|
|
$payload = \json_encode($this->args['payload']);
|
|
|
|
// Webhook
|
|
|
|
Authorization::disable();
|
|
|
|
$project = $consoleDB->getDocument($projectId);
|
|
|
|
Authorization::reset();
|
|
|
|
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 = $webhook['name'] ?? '';
|
|
$signature = $webhook['signature'] ?? 'not-yet-implemented';
|
|
$url = $webhook['url'] ?? '';
|
|
$security = (bool) $webhook['security'] ?? true;
|
|
$httpUser = $webhook['httpUser'] ?? null;
|
|
$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,
|
|
App::getEnv('_APP_VERSION', 'UNKNOWN'),
|
|
App::getEnv('_APP_SYSTEM_SECURITY_EMAIL_ADDRESS', APP_EMAIL_SECURITY)
|
|
));
|
|
\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(): void
|
|
{
|
|
// ... Remove environment for this job
|
|
}
|
|
}
|