src/Core/Framework/Api/Controller/SyncController.php line 40

  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\Log\Package;
  13. use Shopware\Core\PlatformRequest;
  14. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  15. use Symfony\Component\HttpFoundation\JsonResponse;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\Response;
  18. use Symfony\Component\Routing\Annotation\Route;
  19. use Symfony\Component\Serializer\Encoder\DecoderInterface;
  21. #[Route(defaults: ['_routeScope' => ['api']])]
  22. #[Package('core')]
  23. class SyncController extends AbstractController
  24. {
  25.     final public const ACTION_UPSERT = 'upsert';
  26.     final public const ACTION_DELETE = 'delete';
  28.     /**
  29.      * @internal
  30.      */
  31.     public function __construct(private readonly SyncServiceInterface $syncService, private readonly DecoderInterface $serializer)
  32.     {
  33.     }
  35.     /**
  36.      * @throws ConnectionException
  37.      * @throws InvalidSyncOperationException
  38.      */
  39.     #[Route(path: '/api/_action/sync', name: 'api.action.sync', methods: ['POST'])]
  40.     public function sync(Request $request, Context $context): JsonResponse
  41.     {
  42.         $indexingSkips = array_filter(explode(',', (string) $request->headers->get(PlatformRequest::HEADER_INDEXING_SKIP, '')));
  44.         $behavior = new SyncBehavior(
  45.             $request->headers->get(PlatformRequest::HEADER_INDEXING_BEHAVIOR),
  46.             $indexingSkips
  47.         );
  49.         $payload = $this->serializer->decode($request->getContent(), 'json');
  51.         $operations = [];
  52.         foreach ($payload as $key => $operation) {
  53.             if (isset($operation['key'])) {
  54.                 $key = $operation['key'];
  55.             }
  56.             $operations[] = new SyncOperation((string) $key, $operation['entity'], $operation['action'], $operation['payload']);
  57.         }
  59.         $result = $context->scope(Context::CRUD_API_SCOPE, fn (Context $context): SyncResult => $this->syncService->sync($operations, $context, $behavior));
  61.         return $this->createResponse($result, Response::HTTP_OK);
  62.     }
  64.     private function createResponse(SyncResult $result, int $statusCode = 200): JsonResponse
  65.     {
  66.         $response = new JsonResponse(null, $statusCode);
  67.         $response->setEncodingOptions(JsonResponse::DEFAULT_ENCODING_OPTIONS | \JSON_INVALID_UTF8_SUBSTITUTE);
  68.         $response->setData($result);
  70.         return $response;
  71.     }
  72. }