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

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\Routing\Annotation\RouteScope;
  7. use Shopware\Core\Framework\Routing\Annotation\Since;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\HttpFoundation\Request;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\Routing\Annotation\Route;
  13. /**
  14.  * @RouteScope(scopes={"api"})
  15.  */
  16. class IncrementApiController
  17. {
  18.     private IncrementGatewayRegistry $gatewayRegistry;
  20.     public function __construct(IncrementGatewayRegistry $gatewayRegistry)
  21.     {
  22.         $this->gatewayRegistry = $gatewayRegistry;
  23.     }
  25.     /**
  26.      * @Since("6.4.6.0")
  27.      * @Route("/api/_action/increment/{pool}", name="api.increment.increment", methods={"POST"})
  28.      */
  29.     public function increment(Request $request, string $pool): Response
  30.     {
  31.         $key = $request->request->get('key');
  33.         if (!$key || !\is_string($key)) {
  34.             throw new \InvalidArgumentException('Increment key must be null or a string');
  35.         }
  37.         $cluster = $this->getCluster($request);
  39.         $poolGateway = $this->gatewayRegistry->get($pool);
  41.         $poolGateway->increment($cluster, $key);
  43.         return new JsonResponse(['success' => true]);
  44.     }
  46.     /**
  47.      * @Since("6.4.6.0")
  48.      * @Route("/api/_action/decrement/{pool}", name="api.increment.decrement", methods={"POST"})
  49.      */
  50.     public function decrement(Request $request, string $pool): Response
  51.     {
  52.         $key = $request->request->get('key');
  54.         if (!$key || !\is_string($key)) {
  55.             throw new \InvalidArgumentException('Increment key must be null or a string');
  56.         }
  58.         $cluster = $this->getCluster($request);
  60.         $poolGateway = $this->gatewayRegistry->get($pool);
  62.         $poolGateway->decrement(
  63.             $cluster,
  64.             $key
  65.         );
  67.         return new JsonResponse(['success' => true]);
  68.     }
  70.     /**
  71.      * @Since("6.4.6.0")
  72.      * @Route("/api/_action/increment/{pool}", name="api.increment.list", methods={"GET"})
  73.      */
  74.     public function getIncrement(string $pool, Request $request): Response
  75.     {
  76.         $cluster = $this->getCluster($request);
  78.         $poolGateway = $this->gatewayRegistry->get($pool);
  80.         $limit = $request->query->getInt('limit', 5);
  81.         $offset = $request->query->getInt('offset', 0);
  83.         $result = $poolGateway->list($cluster, $limit, $offset);
  85.         return new JsonResponse($result);
  86.     }
  88.     /**
  89.      * @Since("6.4.6.0")
  90.      * @Route("/api/_action/reset-increment/{pool}", name="api.increment.reset", methods={"POST"})
  91.      */
  92.     public function reset(string $pool, Request $request): Response
  93.     {
  94.         $cluster = $this->getCluster($request);
  95.         $poolGateway = $this->gatewayRegistry->get($pool);
  97.         $key = $request->request->get('key');
  99.         if ($key !== null && !\is_string($key)) {
  100.             throw new \InvalidArgumentException('Increment key must be null or a string');
  101.         }
  103.         $poolGateway->reset($cluster, $key);
  105.         return new JsonResponse(['success' => true]);
  106.     }
  108.     private function getCluster(Request $request): string
  109.     {
  110.         $cluster = $request->get('cluster');
  112.         if ($cluster && \is_string($cluster)) {
  113.             return $cluster;
  114.         }
  116.         throw new \InvalidArgumentException('Argument cluster is missing or invalid');
  117.     }
  118. }