src/Administration/Notification/NotificationService.php line 55

  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\EntityRepository;
  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.     public function __construct(private readonly EntityRepository $notificationRepository)
  23.     {
  24.     }
  26.     public function createNotification(array $data, Context $context): void
  27.     {
  28.         $context->scope(Context::SYSTEM_SCOPE, function (Context $context) use ($data): void {
  29.             $this->notificationRepository->create([$data], $context);
  30.         });
  31.     }
  33.     public function getNotifications(Context $context, int $limit, ?string $latestTimestamp): array
  34.     {
  35.         $source = $context->getSource();
  36.         if (!$source instanceof AdminApiSource) {
  37.             throw new InvalidContextSourceException(AdminApiSource::class, $context->getSource()::class);
  38.         }
  40.         $criteria = new Criteria();
  41.         $isAdmin = $source->isAdmin();
  42.         if (!$isAdmin) {
  43.             $criteria->addFilter(new EqualsFilter('adminOnly', false));
  44.         }
  46.         if ($latestTimestamp) {
  47.             $criteria->addFilter(new RangeFilter('createdAt', [
  48.                 RangeFilter::GT => $latestTimestamp,
  49.             ]));
  50.         }
  52.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::ASCENDING));
  53.         $criteria->setLimit($limit);
  55.         $notifications = $context->scope(Context::SYSTEM_SCOPE, function (Context $context) use ($criteria) {
  56.             /** @var NotificationCollection $notifications */
  57.             $notifications = $this->notificationRepository->search($criteria, $context)->getEntities();
  59.             return $notifications;
  60.         });
  62.         if ($notifications->count() === 0) {
  63.             return [
  64.                 'notifications' => new NotificationCollection(),
  65.                 'timestamp' => null,
  66.             ];
  67.         }
  69.         /** @var NotificationEntity $notification */
  70.         $notification = $notifications->last();
  72.         /** @var \DateTimeInterface $latestTimestamp */
  73.         $latestTimestamp = $notification->getCreatedAt();
  74.         $latestTimestamp = $latestTimestamp->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  76.         if ($isAdmin) {
  77.             return [
  78.                 'notifications' => $notifications,
  79.                 'timestamp' => $latestTimestamp,
  80.             ];
  81.         }
  83.         $notifications = $this->formatNotifications($notifications, $source);
  85.         return [
  86.             'notifications' => $notifications,
  87.             'timestamp' => $latestTimestamp,
  88.         ];
  89.     }
  91.     private function formatNotifications(NotificationCollection $notifications, AdminApiSource $source): NotificationCollection
  92.     {
  93.         $responseNotifications = new NotificationCollection();
  95.         /** @var NotificationEntity $notification */
  96.         foreach ($notifications as $notification) {
  97.             if ($this->isAllow($notification->getRequiredPrivileges(), $source)) {
  98.                 $responseNotifications->add($notification);
  99.             }
  100.         }
  102.         return $responseNotifications;
  103.     }
  105.     private function isAllow(array $privileges, AdminApiSource $source): bool
  106.     {
  107.         foreach ($privileges as $privilege) {
  108.             if (!$source->isAllowed($privilege)) {
  109.                 return false;
  110.             }
  111.         }
  113.         return true;
  114.     }
  115. }