custom/plugins/SwagAmazonPay/src/DataAbstractionLayer/Entity/SignUpToken/SignUpTokenService.php line 29

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * (c) shopware AG <info@shopware.com>
  4.  * For the full copyright and license information, please view the LICENSE
  5.  * file that was distributed with this source code.
  6.  */
  8. namespace Swag\AmazonPay\DataAbstractionLayer\Entity\SignUpToken;
  10. use Shopware\Core\Defaults;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  15. use Shopware\Core\Framework\Uuid\Uuid;
  17. class SignUpTokenService implements SignUpTokenServiceInterface
  18. {
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     private $signUpTokenRepository;
  24.     public function __construct(EntityRepositoryInterface $signUpTokenRepository)
  25.     {
  26.         $this->signUpTokenRepository = $signUpTokenRepository;
  27.     }
  29.     public function create(Context $context): string
  30.     {
  31.         $id = Uuid::randomHex();
  32.         $this->signUpTokenRepository->create([
  33.             [
  34.                 'id' => $id,
  35.             ],
  36.         ], $context);
  38.         return $id;
  39.     }
  41.     public function validate(string $id, Context $context): bool
  42.     {
  43.         if (!Uuid::isValid($id)) {
  44.             return false;
  45.         }
  47.         $criteria = new Criteria([$id]);
  48.         $criteria->setLimit(1);
  50.         $tokenValid = $this->signUpTokenRepository->searchIds($criteria, $context)->getTotal() === 1;
  51.         if (!$tokenValid) {
  52.             return false;
  53.         }
  55.         $this->signUpTokenRepository->delete([
  56.             [
  57.                 'id' => $id,
  58.             ],
  59.         ], $context);
  61.         return true;
  62.     }
  64.     public function cleanup(Context $context): void
  65.     {
  66.         $lastWeek = new \DateTime('now -7 days');
  67.         $lastWeek = $lastWeek->setTimezone(new \DateTimeZone('UTC'));
  69.         $criteria = new Criteria();
  70.         $criteria->setLimit(500);
  71.         $criteria->addFilter(
  72.             new RangeFilter(
  73.                 'createdAt',
  74.                 [
  75.                     RangeFilter::LTE => $lastWeek->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  76.                 ]
  77.             )
  78.         );
  80.         $ids = $this->signUpTokenRepository->searchIds($criteria, $context)->getIds();
  82.         $deleteData = [];
  83.         foreach ($ids as $id) {
  84.             $deleteData[] = [
  85.                 'id' => $id,
  86.             ];
  87.         }
  89.         if ($deleteData === []) {
  90.             return;
  91.         }
  93.         $this->signUpTokenRepository->delete($deleteData, $context);
  94.     }
  95. }