custom/plugins/SendcloudShipping/src/Controller/API/Frontend/AsyncProcessController.php line 49

Open in your IDE?
  1. <?php
  4. namespace Sendcloud\Shipping\Controller\API\Frontend;
  6. use Sendcloud\Shipping\Core\Infrastructure\Interfaces\Exposed\Runnable;
  7. use Sendcloud\Shipping\Core\Infrastructure\Logger\Logger;
  8. use Sendcloud\Shipping\Entity\Process\ProcessEntityRepository;
  9. use Sendcloud\Shipping\Service\Utility\Initializer;
  10. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\Routing\Annotation\Route;
  15. /**
  16.  * Class AsyncProcessController
  17.  *
  18.  * @package Sendcloud\Shipping\Controller\API\Frontend
  19.  */
  20. class AsyncProcessController extends AbstractController
  21. {
  22.     /**
  23.      * @var ProcessEntityRepository
  24.      */
  25.     private $processRepository;
  27.     /**
  28.      * AsyncProcessController constructor.
  29.      *
  30.      * @param Initializer $initializer
  31.      * @param ProcessEntityRepository $processRepository
  32.      */
  33.     public function __construct(Initializer $initializer, ProcessEntityRepository $processRepository)
  34.     {
  35.         $initializer->registerServices();
  36.         $this->processRepository = $processRepository;
  37.     }
  39.     /**
  40.      * Async process starter endpoint
  41.      *
  42.      * @RouteScope(scopes={"api"})
  43.      * @Route(path="/api/v{version}/sendcloud/async/{guid}", name="api.sendcloud.async", defaults={"auth_required"=false}, methods={"GET", "POST"})
  44.      * @Route(path="/api/sendcloud/async/{guid}", name="api.sendcloud.async.new", defaults={"auth_required"=false}, methods={"GET", "POST"})
  45.      * @param string $guid
  46.      *
  47.      * @return JsonResponse
  48.      */
  49.     public function run(string $guid): JsonResponse
  50.     {
  51.         try {
  52.             $processEntity = $this->processRepository->getProcessByGuid($guid);
  53.             if ($processEntity) {
  54.                 /** @var Runnable $runner */
  55.                 $runner =unserialize($processEntity->get('runner'));
  56.                 $runner->run();
  57.             }
  59.             $this->processRepository->deleteByGuid($guid);
  60.         } catch (\Exception $exception) {
  61.             Logger::logError("Ann error occurred when accessing process table: {$exception->getMessage()}");
  62.         }
  64.         return new JsonResponse(['success' => true]);
  65.     }
  66. }