59 lines
1.2 KiB
PHP
59 lines
1.2 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Core PHP Framework
|
||
|
|
*
|
||
|
|
* Licensed under the European Union Public Licence (EUPL) v1.2.
|
||
|
|
* See LICENSE file for details.
|
||
|
|
*/
|
||
|
|
|
||
|
|
declare(strict_types=1);
|
||
|
|
|
||
|
|
namespace Core\Webhook;
|
||
|
|
|
||
|
|
use Illuminate\Database\Eloquent\Builder;
|
||
|
|
use Illuminate\Database\Eloquent\Concerns\HasUlids;
|
||
|
|
use Illuminate\Database\Eloquent\Model;
|
||
|
|
|
||
|
|
class WebhookCall extends Model
|
||
|
|
{
|
||
|
|
use HasUlids;
|
||
|
|
|
||
|
|
public $timestamps = false;
|
||
|
|
|
||
|
|
protected $fillable = [
|
||
|
|
'source',
|
||
|
|
'event_type',
|
||
|
|
'headers',
|
||
|
|
'payload',
|
||
|
|
'signature_valid',
|
||
|
|
'processed_at',
|
||
|
|
];
|
||
|
|
|
||
|
|
protected function casts(): array
|
||
|
|
{
|
||
|
|
return [
|
||
|
|
'headers' => 'array',
|
||
|
|
'payload' => 'array',
|
||
|
|
'signature_valid' => 'boolean',
|
||
|
|
'processed_at' => 'datetime',
|
||
|
|
'created_at' => 'datetime',
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
public function scopeUnprocessed(Builder $query): Builder
|
||
|
|
{
|
||
|
|
return $query->whereNull('processed_at');
|
||
|
|
}
|
||
|
|
|
||
|
|
public function scopeForSource(Builder $query, string $source): Builder
|
||
|
|
{
|
||
|
|
return $query->where('source', $source);
|
||
|
|
}
|
||
|
|
|
||
|
|
public function markProcessed(): void
|
||
|
|
{
|
||
|
|
$this->update(['processed_at' => now()]);
|
||
|
|
}
|
||
|
|
}
|