vendor/shopware/administration/Notification/NotificationService.php line 60

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Administration\Notification;
  5. use Shopware\Core\Defaults;
  6. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  7. use Shopware\Core\Framework\Api\Context\Exception\InvalidContextSourceException;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  14. use Shopware\Core\Framework\Log\Package;
  16. /**
  17.  * @internal
  18.  */
  19. #[Package('administration')]
  20. class NotificationService
  21. {
  22.     private EntityRepositoryInterface $notificationRepository;
  24.     public function __construct(EntityRepositoryInterface $notificationRepository)
  25.     {
  26.         $this->notificationRepository = $notificationRepository;
  27.     }
  29.     public function createNotification(array $data, Context $context): void
  30.     {
  31.         $context->scope(Context::SYSTEM_SCOPE, function (Context $context) use ($data): void {
  32.             $this->notificationRepository->create([$data], $context);
  33.         });
  34.     }
  36.     public function getNotifications(Context $context, int $limit, ?string $latestTimestamp): array
  37.     {
  38.         $source = $context->getSource();
  39.         if (!$source instanceof AdminApiSource) {
  40.             throw new InvalidContextSourceException(AdminApiSource::class, \get_class($context->getSource()));
  41.         }
  43.         $criteria = new Criteria();
  44.         $isAdmin = $source->isAdmin();
  45.         if (!$isAdmin) {
  46.             $criteria->addFilter(new EqualsFilter('adminOnly', false));
  47.         }
  49.         if ($latestTimestamp) {
  50.             $criteria->addFilter(new RangeFilter('createdAt', [
  51.                 RangeFilter::GT => $latestTimestamp,
  52.             ]));
  53.         }
  55.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::ASCENDING));
  56.         $criteria->setLimit($limit);
  58.         $notifications = $context->scope(Context::SYSTEM_SCOPE, function (Context $context) use ($criteria) {
  59.             /** @var NotificationCollection $notifications */
  60.             $notifications = $this->notificationRepository->search($criteria, $context)->getEntities();
  62.             return $notifications;
  63.         });
  65.         if ($notifications->count() === 0) {
  66.             return [
  67.                 'notifications' => new NotificationCollection(),
  68.                 'timestamp' => null,
  69.             ];
  70.         }
  72.         /** @var NotificationEntity $notification */
  73.         $notification = $notifications->last();
  75.         /** @var \DateTimeInterface $latestTimestamp */
  76.         $latestTimestamp = $notification->getCreatedAt();
  77.         $latestTimestamp = $latestTimestamp->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  79.         if ($isAdmin) {
  80.             return [
  81.                 'notifications' => $notifications,
  82.                 'timestamp' => $latestTimestamp,
  83.             ];
  84.         }
  86.         $notifications = $this->formatNotifications($notifications, $source);
  88.         return [
  89.             'notifications' => $notifications,
  90.             'timestamp' => $latestTimestamp,
  91.         ];
  92.     }
  94.     private function formatNotifications(NotificationCollection $notifications, AdminApiSource $source): NotificationCollection
  95.     {
  96.         $responseNotifications = new NotificationCollection();
  98.         /** @var NotificationEntity $notification */
  99.         foreach ($notifications as $notification) {
  100.             if ($this->isAllow($notification->getRequiredPrivileges(), $source)) {
  101.                 $responseNotifications->add($notification);
  102.             }
  103.         }
  105.         return $responseNotifications;
  106.     }
  108.     private function isAllow(array $privileges, AdminApiSource $source): bool
  109.     {
  110.         foreach ($privileges as $privilege) {
  111.             if (!$source->isAllowed($privilege)) {
  112.                 return false;
  113.             }
  114.         }
  116.         return true;
  117.     }
  118. }