29 lines
1.6 KiB
PHP
29 lines
1.6 KiB
PHP
<?php
|
|
|
|
namespace Modules\Api\Services;
|
|
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Support\Str;
|
|
use Modules\Api\Models\Webhook;
|
|
use Modules\Api\Models\WebhookDelivery;
|
|
|
|
final class WebhookDispatcher
|
|
{
|
|
public function dispatch(string $event, array $payload, ?int $siteId = null): void
|
|
{
|
|
Webhook::where('is_active', true)->get()->filter(fn (Webhook $h) => ($h->site_id === null || $h->site_id === $siteId) && $h->subscribesTo($event))->each(function (Webhook $h) use ($event, $payload): void {
|
|
$uuid = (string) Str::uuid();
|
|
$json = json_encode($payload, JSON_UNESCAPED_SLASHES) ?: '{}';
|
|
$delivery = WebhookDelivery::create(['webhook_id' => $h->id, 'uuid' => $uuid, 'event' => $event, 'payload' => $payload, 'attempts' => 1]);
|
|
try {
|
|
$res = Http::timeout((int) config('api.webhook_timeout', 10))->withHeaders(['X-CMS-Event' => $event, 'X-CMS-Delivery' => $uuid, 'X-CMS-Signature' => 'sha256='.hash_hmac('sha256', $json, $h->getRawOriginal('secret'))])->withBody($json, 'application/json')->post($h->url);
|
|
$delivery->update(['response_status' => $res->status(), 'response_body' => Str::limit($res->body(), 10000), 'delivered_at' => $res->successful() ? now() : null, 'failed_at' => $res->successful() ? null : now()]);
|
|
$h->update(['last_triggered_at' => now(), 'failure_count' => $res->successful() ? 0 : $h->failure_count + 1]);
|
|
} catch (\Throwable $e) {
|
|
$delivery->update(['response_body' => $e->getMessage(), 'failed_at' => now()]);
|
|
$h->increment('failure_count');
|
|
}
|
|
});
|
|
}
|
|
}
|