PHP code example of belisoful / prado-webhooks

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

belisoful / prado-webhooks example snippets

public function init($config)
{
	parent::init($config);
	$this->getApplication()->onInitComplete[] = function () {
		// Null on any request another service is handling, which is most of them.
		$service = TWebhookService::getInstance();
		if ($service === null) {
			return;
		}
		$service->onWebhook[] = [$this, 'anyWebhook'];   // every endpoint's accepted deliveries
		$service->onRefused[] = [$this, 'countRefusal']; // and the ones an endpoint turned away
		if (($github = $service->getEndpoint('github')) !== null) {
			$github->onWebhook[] = [$this, 'github'];
		}
	};
}

public function github(TWebhookEndpoint $sender, TWebhookEventParameter $param): void
{
	if ($param->getEvent() !== 'push') {
		return;
	}
	$this->queueDeploy($param['repository']['full_name'], $param['after']);
	$param->setStatusCode(202);
}

$webhooks = $this->getApplication()->getModule('belisoful/prado-webhooks');

$deliveries = $webhooks->send([
	['url' => $row['url'], 'secret' => $row['secret'], 'events' => ['invoice.paid']],
	'https://example.com/hooks/prado',
], ['invoice' => $invoice->toArray()], 'invoice.paid');

foreach ($deliveries as $delivery) {
	if (!$delivery->getSuccessful()) {
		$this->reschedule($delivery->getTarget()->getData(), $delivery->getStatusText());
	}
}

$webhooks->queue($subscriberRows, ['invoice' => $invoice->toArray()], 'invoice.paid');

// the secret goes into the queue table with the delivery
$webhooks->queue([['url' => $row['url'], 'secret' => $row['secret']]], $payload, 'invoice.paid');

// or queue a reference, and put the target back on the way out
$webhooks->queue([['url' => $row['url'], 'data' => $row['id']]], $payload, 'invoice.paid');

$webhooks->onDequeue[] = function ($sender, TWebhookQueueItem $item) {
	$target = TWebhookTarget::ensure($item->getTargetSpec());
	$target->setSignature($this->signerFor($item->getTargetSpec()['data']));
	$item->setTarget($target);
};