Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory :  /home/corals/syn.corals.io/Corals/modules/Utility/Models/Webhook/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

<?php

namespace Corals\Modules\Utility\Models\Webhook;

use Corals\Foundation\Models\BaseModel;
use Corals\Foundation\Traits\ModelPropertiesTrait;
use Corals\Foundation\Transformers\PresentableTrait;
use Corals\Modules\Utility\Facades\Webhook\Webhooks;
use Exception;
use Spatie\Activitylog\Traits\LogsActivity;

class Webhook extends BaseModel
{
    use PresentableTrait, LogsActivity, ModelPropertiesTrait;

    protected $casts = [
        'payload' => 'json',
        'exception' => 'json',
        'properties' => 'json',
    ];

    /**
     *  Model configuration.
     * @var string
     */
    public $config = 'utility.models.webhook';

    protected static $logAttributes = [
        'event_name',
        'payload',
        'exception',
        'status',
        'properties',
    ];

    protected $guarded = ['id'];

    protected $table = 'utility_webhooks';


    /**
     * @throws Exception
     */
    public function process()
    {
        $this->clearException();

        if (empty($this->event_name)) {
            throw new \Exception(trans("Utility::exceptions.webhook.empty_event_name", ['id' => $this->id]));
        }

        $jobClass = $this->determineJobClass($this->event_name);

        if ($jobClass) {
            dispatch(new $jobClass($this));
        } else {
            throw new \Exception(trans("Utility::exceptions.webhook.event_name_not_registered", ['name' => $this->event_name, 'id' => $this->id]));
        }
    }

    /**
     * @param Exception $exception
     * @return $this
     */
    public function saveException(Exception $exception)
    {
        $this->exception = [
            'message' => $exception->getMessage(),
        ];

        $this->status = 'failed';

        $this->save();

        return $this;
    }

    protected function determineJobClass(string $eventName)
    {
        return Webhooks::getEventJob($eventName);
    }

    protected function clearException()
    {
        $this->exception = null;

        $this->save();

        return $this;
    }

    public function markAs($status)
    {
        $this->fill(['status' => $status])->save();
    }
}