diff --git a/app/Handlers/Events/WebhookEventHandler.php b/app/Handlers/Events/WebhookEventHandler.php index 3d0f12a2e3..3599e692e5 100644 --- a/app/Handlers/Events/WebhookEventHandler.php +++ b/app/Handlers/Events/WebhookEventHandler.php @@ -26,6 +26,7 @@ namespace FireflyIII\Handlers\Events; use FireflyIII\Jobs\SendWebhookMessage; use FireflyIII\Models\WebhookMessage; +use Illuminate\Support\Facades\Log; /** * Class WebhookEventHandler @@ -37,7 +38,12 @@ class WebhookEventHandler */ public function sendWebhookMessages(): void { - app('log')->debug(sprintf('Now in %s', __METHOD__)); + Log::debug(sprintf('Now in %s', __METHOD__)); + if(false === config('firefly.feature_flags.webhooks') || false === config('firefly.allow_webhooks')) { + Log::info('Webhook event handler is disabled, do not run sendWebhookMessages().'); + return; + } + // kick off the job! $messages = WebhookMessage::where('webhook_messages.sent', false) ->get(['webhook_messages.*']) @@ -45,14 +51,14 @@ class WebhookEventHandler static fn (WebhookMessage $message) => $message->webhookAttempts()->count() <= 2 )->splice(0, 5) ; - app('log')->debug(sprintf('Found %d webhook message(s) ready to be send.', $messages->count())); + Log::debug(sprintf('Found %d webhook message(s) ready to be send.', $messages->count())); foreach ($messages as $message) { if (false === $message->sent) { - app('log')->debug(sprintf('Send message #%d', $message->id)); + Log::debug(sprintf('Send message #%d', $message->id)); SendWebhookMessage::dispatch($message)->afterResponse(); } if (false !== $message->sent) { - app('log')->debug(sprintf('Skip message #%d', $message->id)); + Log::debug(sprintf('Skip message #%d', $message->id)); } } }