vendor/shopware/core/Framework/Increment/Controller/IncrementApiController.php line 79

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Increment\Controller;
  5. use Shopware\Core\Framework\Increment\IncrementGatewayRegistry;
  6. use Shopware\Core\Framework\Log\Package;
  7. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  8. use Shopware\Core\Framework\Routing\Annotation\Since;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\Routing\Annotation\Route;
  14. /**
  15.  * @Route(defaults={"_routeScope"={"api"}})
  16.  */
  17. #[Package('system-settings')]
  18. class IncrementApiController
  19. {
  20.     private IncrementGatewayRegistry $gatewayRegistry;
  22.     /**
  23.      * @internal
  24.      */
  25.     public function __construct(IncrementGatewayRegistry $gatewayRegistry)
  26.     {
  27.         $this->gatewayRegistry = $gatewayRegistry;
  28.     }
  30.     /**
  31.      * @Since("6.4.6.0")
  32.      * @Route("/api/_action/increment/{pool}", name="api.increment.increment", methods={"POST"})
  33.      */
  34.     public function increment(Request $request, string $pool): Response
  35.     {
  36.         $key = $request->request->get('key');
  38.         if (!$key || !\is_string($key)) {
  39.             throw new \InvalidArgumentException('Increment key must be null or a string');
  40.         }
  42.         $cluster = $this->getCluster($request);
  44.         $poolGateway = $this->gatewayRegistry->get($pool);
  46.         $poolGateway->increment($cluster, $key);
  48.         return new JsonResponse(['success' => true]);
  49.     }
  51.     /**
  52.      * @Since("6.4.6.0")
  53.      * @Route("/api/_action/decrement/{pool}", name="api.increment.decrement", methods={"POST"})
  54.      */
  55.     public function decrement(Request $request, string $pool): Response
  56.     {
  57.         $key = $request->request->get('key');
  59.         if (!$key || !\is_string($key)) {
  60.             throw new \InvalidArgumentException('Increment key must be null or a string');
  61.         }
  63.         $cluster = $this->getCluster($request);
  65.         $poolGateway = $this->gatewayRegistry->get($pool);
  67.         $poolGateway->decrement(
  68.             $cluster,
  69.             $key
  70.         );
  72.         return new JsonResponse(['success' => true]);
  73.     }
  75.     /**
  76.      * @Since("6.4.6.0")
  77.      * @Route("/api/_action/increment/{pool}", name="api.increment.list", methods={"GET"})
  78.      */
  79.     public function getIncrement(string $pool, Request $request): Response
  80.     {
  81.         $cluster = $this->getCluster($request);
  83.         $poolGateway = $this->gatewayRegistry->get($pool);
  85.         $limit = $request->query->getInt('limit', 5);
  86.         $offset = $request->query->getInt('offset', 0);
  88.         $result = $poolGateway->list($cluster, $limit, $offset);
  90.         return new JsonResponse($result);
  91.     }
  93.     /**
  94.      * @Since("6.4.6.0")
  95.      * @Route("/api/_action/reset-increment/{pool}", name="api.increment.reset", methods={"POST"})
  96.      */
  97.     public function reset(string $pool, Request $request): Response
  98.     {
  99.         $cluster = $this->getCluster($request);
  100.         $poolGateway = $this->gatewayRegistry->get($pool);
  102.         $key = $request->request->get('key');
  104.         if ($key !== null && !\is_string($key)) {
  105.             throw new \InvalidArgumentException('Increment key must be null or a string');
  106.         }
  108.         $poolGateway->reset($cluster, $key);
  110.         return new JsonResponse(['success' => true]);
  111.     }
  113.     private function getCluster(Request $request): string
  114.     {
  115.         $cluster = $request->get('cluster');
  117.         if ($cluster && \is_string($cluster)) {
  118.             return $cluster;
  119.         }
  121.         throw new \InvalidArgumentException('Argument cluster is missing or invalid');
  122.     }
  123. }