vendor/shopware/core/Framework/Api/Controller/SyncController.php line 82

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\Api\Controller;
  5. use Doctrine\DBAL\ConnectionException;
  6. use Shopware\Core\Framework\Api\Exception\InvalidSyncOperationException;
  7. use Shopware\Core\Framework\Api\Sync\SyncBehavior;
  8. use Shopware\Core\Framework\Api\Sync\SyncOperation;
  9. use Shopware\Core\Framework\Api\Sync\SyncResult;
  10. use Shopware\Core\Framework\Api\Sync\SyncServiceInterface;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\Feature;
  13. use Shopware\Core\Framework\Log\Package;
  14. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  15. use Shopware\Core\Framework\Routing\Annotation\Since;
  16. use Shopware\Core\PlatformRequest;
  17. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  18. use Symfony\Component\HttpFoundation\JsonResponse;
  19. use Symfony\Component\HttpFoundation\Request;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\Routing\Annotation\Route;
  22. use Symfony\Component\Serializer\Serializer;
  24. /**
  25.  * @Route(defaults={"_routeScope"={"api"}})
  26.  */
  27. #[Package('core')]
  28. class SyncController extends AbstractController
  29. {
  30.     public const ACTION_UPSERT = 'upsert';
  31.     public const ACTION_DELETE = 'delete';
  33.     private Serializer $serializer;
  35.     private SyncServiceInterface $syncService;
  37.     /**
  38.      * @internal
  39.      */
  40.     public function __construct(SyncServiceInterface $syncService, Serializer $serializer)
  41.     {
  42.         $this->serializer = $serializer;
  43.         $this->syncService = $syncService;
  44.     }
  46.     /**
  47.      * @Since("6.0.0.0")
  48.      * @Route("/api/_action/sync", name="api.action.sync", methods={"POST"})
  49.      *
  50.      * @throws ConnectionException
  51.      * @throws InvalidSyncOperationException
  52.      */
  53.     public function sync(Request $request, Context $context): JsonResponse
  54.     {
  55.         $indexingSkips = array_filter(explode(',', $request->headers->get(PlatformRequest::HEADER_INDEXING_SKIP, '')));
  57.         if (Feature::isActive('FEATURE_NEXT_15815')) {
  58.             $behavior = new SyncBehavior(
  59.                 $request->headers->get(PlatformRequest::HEADER_INDEXING_BEHAVIOR),
  60.                 $indexingSkips
  61.             );
  62.         } else {
  63.             $behavior = new SyncBehavior(
  64.                 filter_var($request->headers->get(PlatformRequest::HEADER_FAIL_ON_ERROR, 'true'), \FILTER_VALIDATE_BOOLEAN),
  65.                 filter_var($request->headers->get(PlatformRequest::HEADER_SINGLE_OPERATION, 'false'), \FILTER_VALIDATE_BOOLEAN),
  66.                 $request->headers->get(PlatformRequest::HEADER_INDEXING_BEHAVIOR, null),
  67.                 $indexingSkips
  68.             );
  69.         }
  71.         $payload = $this->serializer->decode($request->getContent(), 'json');
  73.         $operations = [];
  74.         foreach ($payload as $key => $operation) {
  75.             if (isset($operation['key'])) {
  76.                 $key = $operation['key'];
  77.             }
  78.             $operations[] = new SyncOperation((string) $key, $operation['entity'], $operation['action'], $operation['payload']);
  79.         }
  81.         $result = $context->scope(Context::CRUD_API_SCOPE, function (Context $context) use ($operations, $behavior): SyncResult {
  82.             return $this->syncService->sync($operations, $context, $behavior);
  83.         });
  85.         if (Feature::isActive('FEATURE_NEXT_15815')) {
  86.             return $this->createResponse($result, Response::HTTP_OK);
  87.         }
  89.         if ($behavior->failOnError() && !$result->isSuccess()) {
  90.             return $this->createResponse($result, Response::HTTP_BAD_REQUEST);
  91.         }
  93.         return $this->createResponse($result, Response::HTTP_OK);
  94.     }
  96.     private function createResponse(SyncResult $result, int $statusCode = 200): JsonResponse
  97.     {
  98.         $response = new JsonResponse(null, $statusCode);
  99.         $response->setEncodingOptions(JsonResponse::DEFAULT_ENCODING_OPTIONS | \JSON_INVALID_UTF8_SUBSTITUTE);
  100.         $response->setData($result);
  102.         return $response;
  103.     }
  104. }