mirror of
https://github.com/snipe/snipe-it.git
synced 2024-11-16 02:24:09 -08:00
8adfa8dd83
Signed-off-by: snipe <snipe@snipe.net>
265 lines
8.6 KiB
PHP
265 lines
8.6 KiB
PHP
<?php
|
|
|
|
namespace App\Listeners;
|
|
|
|
use App\Events\CheckoutableCheckedOut;
|
|
use App\Models\Accessory;
|
|
use App\Models\Asset;
|
|
use App\Models\CheckoutAcceptance;
|
|
use App\Models\Component;
|
|
use App\Models\Consumable;
|
|
use App\Models\LicenseSeat;
|
|
use App\Models\Recipients\AdminRecipient;
|
|
use App\Models\Setting;
|
|
use App\Notifications\CheckinAccessoryNotification;
|
|
use App\Notifications\CheckinAssetNotification;
|
|
use App\Notifications\CheckinLicenseSeatNotification;
|
|
use App\Notifications\CheckoutAccessoryNotification;
|
|
use App\Notifications\CheckoutAssetNotification;
|
|
use App\Notifications\CheckoutConsumableNotification;
|
|
use App\Notifications\CheckoutLicenseSeatNotification;
|
|
use GuzzleHttp\Exception\ClientException;
|
|
use Illuminate\Support\Facades\Notification;
|
|
use Exception;
|
|
use Log;
|
|
|
|
class CheckoutableListener
|
|
{
|
|
private array $skipNotificationsFor = [
|
|
Component::class,
|
|
];
|
|
|
|
/**
|
|
* Notify the user and post to webhook about the checked out checkoutable
|
|
* and add a record to the checkout_requests table.
|
|
*/
|
|
public function onCheckedOut($event)
|
|
{
|
|
if ($this->shouldNotSendAnyNotifications($event->checkoutable)){
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* Make a checkout acceptance and attach it in the notification
|
|
*/
|
|
$acceptance = $this->getCheckoutAcceptance($event);
|
|
|
|
try {
|
|
if (! $event->checkedOutTo->locale) {
|
|
Notification::locale(Setting::getSettings()->locale)->send(
|
|
$this->getNotifiables($event),
|
|
$this->getCheckoutNotification($event, $acceptance)
|
|
);
|
|
} else {
|
|
Notification::send(
|
|
$this->getNotifiables($event),
|
|
$this->getCheckoutNotification($event, $acceptance)
|
|
);
|
|
}
|
|
|
|
if ($this->shouldSendWebhookNotification()) {
|
|
|
|
//slack doesn't include the url in its messaging format so this is needed to hit the endpoint
|
|
|
|
if(Setting::getSettings()->webhook_selected =='slack' || Setting::getSettings()->webhook_selected =='general') {
|
|
|
|
|
|
Notification::route('slack', Setting::getSettings()->webhook_endpoint)
|
|
->notify($this->getCheckoutNotification($event));
|
|
}
|
|
}
|
|
} catch (ClientException $e) {
|
|
Log::warning("Exception caught during checkout notification: " . $e->getMessage());
|
|
} catch (Exception $e) {
|
|
Log::warning("Exception caught during checkout notification: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Notify the user and post to webhook about the checked in checkoutable
|
|
*/
|
|
public function onCheckedIn($event)
|
|
{
|
|
\Log::debug('onCheckedIn in the Checkoutable listener fired');
|
|
|
|
if ($this->shouldNotSendAnyNotifications($event->checkoutable)) {
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* Send the appropriate notification
|
|
*/
|
|
if ($event->checkedOutTo && $event->checkoutable){
|
|
$acceptances = CheckoutAcceptance::where('checkoutable_id', $event->checkoutable->id)
|
|
->where('assigned_to_id', $event->checkedOutTo->id)
|
|
->get();
|
|
|
|
foreach($acceptances as $acceptance){
|
|
if($acceptance->isPending()){
|
|
$acceptance->delete();
|
|
}
|
|
}
|
|
}
|
|
|
|
try {
|
|
// Use default locale
|
|
if (! $event->checkedOutTo->locale) {
|
|
Notification::locale(Setting::getSettings()->locale)->send(
|
|
$this->getNotifiables($event),
|
|
$this->getCheckinNotification($event)
|
|
);
|
|
} else {
|
|
Notification::send(
|
|
$this->getNotifiables($event),
|
|
$this->getCheckinNotification($event)
|
|
);
|
|
}
|
|
//slack doesn't include the url in its messaging format so this is needed to hit the endpoint
|
|
if(Setting::getSettings()->webhook_selected =='slack' || Setting::getSettings()->webhook_selected =='general') {
|
|
|
|
if ($this->shouldSendWebhookNotification()) {
|
|
Notification::route('slack', Setting::getSettings()->webhook_endpoint)
|
|
->notify($this->getCheckinNotification($event));
|
|
}
|
|
}
|
|
|
|
} catch (ClientException $e) {
|
|
Log::warning("Exception caught during checkout notification: " . $e->getMessage());
|
|
} catch (Exception $e) {
|
|
Log::warning("Exception caught during checkin notification: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Generates a checkout acceptance
|
|
* @param Event $event
|
|
* @return mixed
|
|
*/
|
|
private function getCheckoutAcceptance($event)
|
|
{
|
|
if (! $event->checkoutable->requireAcceptance()) {
|
|
return null;
|
|
}
|
|
|
|
$acceptance = new CheckoutAcceptance;
|
|
$acceptance->checkoutable()->associate($event->checkoutable);
|
|
$acceptance->assignedTo()->associate($event->checkedOutTo);
|
|
$acceptance->save();
|
|
|
|
return $acceptance;
|
|
}
|
|
|
|
/**
|
|
* Gets the entities to be notified of the passed event
|
|
*
|
|
* @param Event $event
|
|
* @return Collection
|
|
*/
|
|
private function getNotifiables($event)
|
|
{
|
|
$notifiables = collect();
|
|
|
|
/**
|
|
* Notify who checked out the item as long as the model can route notifications
|
|
*/
|
|
if (method_exists($event->checkedOutTo, 'routeNotificationFor')) {
|
|
$notifiables->push($event->checkedOutTo);
|
|
}
|
|
|
|
/**
|
|
* Notify Admin users if the settings is activated
|
|
*/
|
|
if ((Setting::getSettings()) && (Setting::getSettings()->admin_cc_email != '')) {
|
|
$notifiables->push(new AdminRecipient());
|
|
}
|
|
|
|
return $notifiables;
|
|
}
|
|
|
|
/**
|
|
* Get the appropriate notification for the event
|
|
*
|
|
* @param CheckoutableCheckedIn $event
|
|
* @return Notification
|
|
*/
|
|
private function getCheckinNotification($event)
|
|
{
|
|
|
|
$notificationClass = null;
|
|
|
|
switch (get_class($event->checkoutable)) {
|
|
case Accessory::class:
|
|
$notificationClass = CheckinAccessoryNotification::class;
|
|
break;
|
|
case Asset::class:
|
|
$notificationClass = CheckinAssetNotification::class;
|
|
break;
|
|
case LicenseSeat::class:
|
|
$notificationClass = CheckinLicenseSeatNotification::class;
|
|
break;
|
|
}
|
|
|
|
\Log::debug('Notification class: '.$notificationClass);
|
|
|
|
return new $notificationClass($event->checkoutable, $event->checkedOutTo, $event->checkedInBy, $event->note);
|
|
}
|
|
|
|
/**
|
|
* Get the appropriate notification for the event
|
|
*
|
|
* @param CheckoutableCheckedOut $event
|
|
* @param CheckoutAcceptance|null $acceptance
|
|
* @return Notification
|
|
*/
|
|
private function getCheckoutNotification($event, $acceptance = null)
|
|
{
|
|
$notificationClass = null;
|
|
|
|
switch (get_class($event->checkoutable)) {
|
|
case Accessory::class:
|
|
$notificationClass = CheckoutAccessoryNotification::class;
|
|
break;
|
|
case Asset::class:
|
|
$notificationClass = CheckoutAssetNotification::class;
|
|
break;
|
|
case Consumable::class:
|
|
$notificationClass = CheckoutConsumableNotification::class;
|
|
break;
|
|
case LicenseSeat::class:
|
|
$notificationClass = CheckoutLicenseSeatNotification::class;
|
|
break;
|
|
}
|
|
|
|
|
|
return new $notificationClass($event->checkoutable, $event->checkedOutTo, $event->checkedOutBy, $acceptance, $event->note);
|
|
}
|
|
|
|
/**
|
|
* Register the listeners for the subscriber.
|
|
*
|
|
* @param Illuminate\Events\Dispatcher $events
|
|
*/
|
|
public function subscribe($events)
|
|
{
|
|
$events->listen(
|
|
\App\Events\CheckoutableCheckedIn::class,
|
|
'App\Listeners\CheckoutableListener@onCheckedIn'
|
|
);
|
|
|
|
$events->listen(
|
|
\App\Events\CheckoutableCheckedOut::class,
|
|
'App\Listeners\CheckoutableListener@onCheckedOut'
|
|
);
|
|
}
|
|
|
|
private function shouldNotSendAnyNotifications($checkoutable): bool
|
|
{
|
|
return in_array(get_class($checkoutable), $this->skipNotificationsFor);
|
|
}
|
|
|
|
private function shouldSendWebhookNotification(): bool
|
|
{
|
|
return Setting::getSettings() && Setting::getSettings()->webhook_endpoint;
|
|
}
|
|
}
|