ogRepo new endpoints. Export/Import image

config/api_platform/ImageRepository.yaml

@@ -55,6 +55,24 @@ resources:
                 uriTemplate: /image-repositories/server/{uuid}/status
                 controller: App\Controller\OgRepository\StatusAction
 
+            export_image_ogrepository:
+                shortName: OgRepository Server
+                description: Export Image in OgRepository
+                class: ApiPlatform\Metadata\Post
+                method: POST
+                input:  App\Dto\Input\ExportImportImageRepositoryInput
+                uriTemplate: /image-repositories/{uuid}/export-image
+                controller: App\Controller\OgRepository\Image\ExportAction
+
+            import_image_ogrepository:
+                shortName: OgRepository Server
+                description: Export Image in OgRepository
+                class: ApiPlatform\Metadata\Post
+                method: POST
+                input: App\Dto\Input\ExportImportImageRepositoryInput
+                uriTemplate: /image-repositories/{uuid}/import-image
+                controller: App\Controller\OgRepository\Image\ImportAction
+
 properties:
     App\Entity\ImageRepository:
         id:

src/Controller/OgRepository/Image/ExportAction.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace App\Controller\OgRepository\Image;
+
+use App\Controller\OgRepository\AbstractOgRepositoryController;
+use App\Dto\Input\ExportImportImageRepositoryInput;
+use App\Entity\Image;
+use App\Entity\ImageRepository;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Attribute\AsController;
+use Symfony\Component\Validator\Exception\ValidatorException;
+use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
+
+#[AsController]
+class ExportAction extends AbstractOgRepositoryController
+{
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function __invoke(ExportImportImageRepositoryInput $input, ImageRepository $repository): JsonResponse
+    {
+        $images = $input->images;
+
+        foreach ($images as $imageEntity) {
+            /** @var Image $image */
+            $image = $imageEntity->getEntity();
+
+            if (!$image->getImageFullsum()) {
+                throw new ValidatorException('Fullsum is required');
+            }
+
+            $params = [
+                'json' => [
+                    'ID_img' => $image->getImageFullsum(),
+                    'repo_ip' => $repository->getIp(),
+                    'user' => 'opengnsys',
+                ]
+            ];
+
+            $content = $this->createRequest('PUT', 'http://'.$image->getRepository()->getIp().':8006/ogrepository/v1/repo/images', $params);
+
+            $image->setRepository($repository);
+            $this->entityManager->persist($image);
+            $this->entityManager->flush();
+        }
+
+        return new JsonResponse(data: [], status: Response::HTTP_OK);
+    }
+}

src/Controller/OgRepository/Image/ImportAction.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace App\Controller\OgRepository\Image;
+
+use App\Controller\OgRepository\AbstractOgRepositoryController;
+use App\Dto\Input\ExportImportImageRepositoryInput;
+use App\Entity\Image;
+use App\Entity\ImageRepository;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Attribute\AsController;
+use Symfony\Component\Validator\Exception\ValidatorException;
+use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
+
+#[AsController]
+class ImportAction extends AbstractOgRepositoryController
+{
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function __invoke(ExportImportImageRepositoryInput $input, ImageRepository $repository): JsonResponse
+    {
+        $images = $input->images;
+
+        foreach ($images as $imageEntity) {
+            /** @var Image $image */
+            $image = $imageEntity->getEntity();
+
+            if (!$image->getImageFullsum()) {
+                throw new ValidatorException('Fullsum is required');
+            }
+
+            $params = [
+                'json' => [
+                    'image' => $image->getName(),
+                    'repo_ip' => $repository->getIp(),
+                    'user' => 'opengnsys',
+                ]
+            ];
+
+            $content = $this->createRequest('POST', 'http://'.$image->getRepository()->getIp().':8006/ogrepository/v1/repo/images', $params);
+
+            $image->setRepository($repository);
+            $this->entityManager->persist($image);
+            $this->entityManager->flush();
+        }
+
+        return new JsonResponse(data: [], status: Response::HTTP_OK);
+    }
+}

src/Dto/Input/ExportImportImageRepositoryInput.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Dto\Input;
+
+use App\Dto\Output\ImageOutput;
+use App\Dto\Output\ImageRepositoryOutput;
+use Symfony\Component\Serializer\Annotation\Groups;
+use Symfony\Component\Validator\Constraints as Assert;
+
+class ExportImportImageRepositoryInput
+{
+    /**
+     * @var ImageOutput[]
+     */
+    #[Assert\NotNull]
+    #[Groups(['repository:write'])]
+    public array $images = [];
+}