src/YEDIBundle/Controller/Admin/APIController.php line 47

Open in your IDE?
  1. <?php declare(strict_types = 1);
  3. namespace App\YEDIBundle\Controller\Admin;
  5. use App\YEDIBundle\Controller\Rest\AbstractRestController;
  6. use Pimcore\Bundle\AdminBundle\Security\User\TokenStorageUserResolver;
  7. use Pimcore\Controller\Controller;
  8. use Pimcore\Http\Exception\ResponseException;
  9. use Pimcore\Kernel;
  10. use Pimcore\Model\AbstractModel;
  11. use Pimcore\Model\DataObject\Concrete;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpFoundation\RequestStack;
  15. use Symfony\Component\Routing\Annotation\Route;
  16. use App\YEDIBundle\Services\API\ActionService;
  17. use App\YEDIBundle\Services\FormatterService;
  18. use App\YEDIBundle\Services\ResponseService;
  19. use App\YEDIBundle\YEDIBundle;
  20. use Pimcore\Version;
  22. class APIController extends AbstractRestController
  23. {
  24.     private ActionService $actionService;
  25.     private FormatterService $formatterService;
  27.     /**
  28.      * @param ActionService $actionService
  29.      * @param FormatterService $formatterService
  30.      * @param TokenStorageUserResolver $resolver
  31.      */
  32.     public function __construct(ActionService $actionService, FormatterService $formatterService, RequestStack $requestStack)
  33.     {
  34.         $this->actionService = $actionService;
  35.         $this->formatterService = $formatterService;
  37.         parent::__construct($requestStack);
  38.     }
  40.     /**
  41.      * @Route("webservice/yedi/data-object")
  42.      *
  43.      * @param Request $request
  44.      * @return JsonResponse
  45.      * @throws ResponseException
  46.      */
  47.     public function dataObjectAction(Request $request)
  48.     {
  49.         $this->checkPermission('objects');
  51.         return $this->entityAction($request, ActionService::DATA_OBJECT_ACTION);
  52.     }
  54.     /**
  55.      * @Route("/webservice/yedi/asset")
  56.      *
  57.      * @param Request $request
  58.      * @return JsonResponse
  59.      * @throws ResponseException
  60.      */
  61.     public function assetAction( Request $request)
  62.     {
  63.         $this->checkPermission('assets');
  65.         return $this->entityAction($request, ActionService::ASSET_ACTION);
  66.     }
  69.     /**
  70.      * @param Request $request
  71.      * @param string $actionType
  72.      * @return JsonResponse
  73.      * @throws ResponseException
  74.      */
  75.     private function entityAction(Request $request, string $actionType)
  76.     {
  77.         $content = json_decode($request->getContent(), true);
  79.         $body = $content['body'];
  80.         $detailed = $content['detailed'] ?? false;
  82.         if($body === null){
  83.             throw new ResponseException($this->container->get(ResponseService::class)->createErrorResponse(
  84.                 'Missing body parameter.', 422
  85.             ));
  86.         } else if (count(array_filter(array_keys($body), 'is_string')) > 0) {
  87.             throw new ResponseException($this->container->get(ResponseService::class)->createErrorResponse(
  88.                 'Provide an array of entities.', 422
  89.             ));
  90.         }
  92.         try {
  93.             $response = $this->actionService->process($body, $actionType);
  94.         } catch (\Throwable $e) {
  95.             return new JsonResponse([
  96.                 'data' => 'Action could not be processed correctly.',
  97.                 'errors' => [
  98.                     [
  99.                         'message' => $e->getMessage(),
  100.                         'stack' => $e->getTraceAsString()
  101.                     ],
  102.                 ]
  103.             ]);
  104.         }
  106.         return new JsonResponse($this->formatResponse($response, $detailed));
  108.     }
  110.     /**
  111.      * @Route("/webservice/yedi/version")
  112.      *
  113.      * @param Kernel $kernel
  114.      * @return JsonResponse
  115.      */
  116.     public function versionAction(Kernel $kernel)
  117.     {
  118.         $this->checkPermission('objects');
  120.         /** @var YEDIBundle $bundle */
  121.         $bundle = $kernel->getBundle('YEDIBundle');
  123.         $yediBundle = [
  124.             'version' => $bundle->getVersion()
  125.         ];
  127.         $pimcore = [
  128.             'version' => Version::getVersion(),
  129.             'revision' => Version::getRevision(),
  130.             'constants' => array_filter((array)get_defined_constants(), function($key) {
  131.                 return strpos($key, 'PIMCORE_') === 0;
  132.             }, ARRAY_FILTER_USE_KEY),
  133.         ];
  136.         return new JsonResponse([
  137.             'success' => true,
  138.             'yediBundle' => $yediBundle,
  139.             'pimcore' => $pimcore
  140.         ]);
  141.     }
  143.     /**
  144.      * @param array $response
  145.      * @param bool $detailed
  146.      * @return array
  147.      */
  148.     private function formatResponse(array $response, bool $detailed = false): array
  149.     {
  150.         ['data' => $data, 'errors' => $errors] = $response;
  152.         foreach ($data as &$queryResults) {
  153.             /** @var Concrete $result */
  154.             foreach ($queryResults as &$result) {
  155.                 if ($detailed && $result instanceof AbstractModel) {
  156.                     $result = $this->formatterService->format($result, true);
  157.                 } else {
  158.                     $result = $result->getId();
  159.                 }
  160.             }
  161.         }
  163.         return ['data' => $data, 'errors' => $errors];
  164.     }
  165. }