diff --git a/app/Observers/ProductObserver.php b/app/Observers/ProductObserver.php index cf759b798151..fbd85c18d49f 100644 --- a/app/Observers/ProductObserver.php +++ b/app/Observers/ProductObserver.php @@ -11,7 +11,9 @@ namespace App\Observers; +use App\Jobs\Util\WebhookHandler; use App\Models\Product; +use App\Models\Webhook; class ProductObserver { @@ -24,8 +26,8 @@ class ProductObserver public function created(Product $product) { $subscriptions = Webhook::where('company_id', $product->company->id) - ->where('event_id', Webhook::EVENT_CREATE_PRODUCT) - ->exists(); + ->where('event_id', Webhook::EVENT_CREATE_PRODUCT) + ->exists(); if ($subscriptions) { WebhookHandler::dispatch(Webhook::EVENT_CREATE_PRODUCT, $product, $product->company)->delay(now()->addSeconds(2)); @@ -41,8 +43,8 @@ class ProductObserver public function updated(Product $product) { $subscriptions = Webhook::where('company_id', $product->company->id) - ->where('event_id', Webhook::EVENT_UPDATE_PRODUCT) - ->exists(); + ->where('event_id', Webhook::EVENT_UPDATE_PRODUCT) + ->exists(); if ($subscriptions) { WebhookHandler::dispatch(Webhook::EVENT_UPDATE_PRODUCT, $product, $product->company)->delay(now()->addSeconds(2)); @@ -58,8 +60,8 @@ class ProductObserver public function deleted(Product $product) { $subscriptions = Webhook::where('company_id', $product->company->id) - ->where('event_id', Webhook::EVENT_DELETE_PRODUCT) - ->exists(); + ->where('event_id', Webhook::EVENT_DELETE_PRODUCT) + ->exists(); if ($subscriptions) { WebhookHandler::dispatch(Webhook::EVENT_DELETE_PRODUCT, $product, $product->company)->delay(now()->addSeconds(2));