refs #1151. Integracion ogRepository

migrations/Version20241108062659.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241108062659 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE image ADD image_fullsum VARCHAR(255) DEFAULT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE image DROP image_fullsum');
+    }
+}

migrations/Version20241111101047.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241111101047 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE image ADD status VARCHAR(255) NOT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE image DROP status');
+    }
+}

migrations/Version20241113084353.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241113084353 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE network_settings ADD og_log VARCHAR(255) DEFAULT NULL, ADD og_share VARCHAR(255) DEFAULT NULL');
+        $this->addSql('ALTER TABLE trace ADD input VARCHAR(255) DEFAULT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE network_settings DROP og_log, DROP og_share');
+        $this->addSql('ALTER TABLE trace DROP input');
+    }
+}

migrations/Version20241114081247.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241114081247 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE trace CHANGE input input JSON DEFAULT NULL COMMENT \'(DC2Type:json)\'');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE trace CHANGE input input VARCHAR(255) DEFAULT NULL');
+    }
+}

migrations/Version20241115074840.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241115074840 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE UNIQUE INDEX UNIQ_IDENTIFIER_NAME ON image (name)');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('DROP INDEX UNIQ_IDENTIFIER_NAME ON image');
+    }
+}

src/Controller/OgRepository/AbstractOgRepositoryController.php

@@ -1,8 +1,58 @@
 <?php
 
+declare(strict_types=1);
+
 namespace App\Controller\OgRepository;
 
-class AbstractOgRepositoryController
-{
+use App\Service\Trace\CreateService;
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Attribute\AsController;
+use Symfony\Component\HttpKernel\Exception\HttpException;
+use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
 
-}
+#[AsController]
+abstract class AbstractOgRepositoryController extends AbstractController
+{
+    public function __construct(
+        protected readonly  EntityManagerInterface   $entityManager,
+        protected readonly  HttpClientInterface      $httpClient,
+        protected readonly  CreateService            $createService,
+    )
+    {
+    }
+
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function createRequest (string $method, string $url, array $params = []): JsonResponse|array
+    {
+        $params = array_merge($params, [
+            'headers' => [
+                'accept' => 'application/json',
+                'Content-Type' => 'application/json'
+            ],
+        ]);
+
+        try {
+            $response = $this->httpClient->request($method, $url, $params);
+
+            return json_decode($response->getContent(), true);
+        } catch (ClientExceptionInterface | ServerExceptionInterface $e) {
+            $response = $e->getResponse();
+            $content = json_decode($response->getContent(false), true);
+            throw new HttpException($response->getStatusCode(), $content['error'] ?? 'An error occurred');
+        } catch (TransportExceptionInterface $e) {
+            throw new HttpException(Response::HTTP_INTERNAL_SERVER_ERROR, $e->getMessage());
+        }
+    }
+}

src/Controller/OgRepository/GetCollectionAction.php

@@ -1,10 +1,8 @@
 <?php
 
-namespace App\Controller\OgRepository\Image;
+namespace App\Controller\OgRepository;
 
-use App\Controller\OgBoot\AbstractOgBootController;
-use App\Controller\OgRepository\AbstractOgRepositoryController;
-use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use App\Entity\ImageRepository;
 use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\HttpKernel\Attribute\AsController;
@@ -23,20 +21,10 @@ class GetCollectionAction extends AbstractOgRepositoryController
      * @throws RedirectionExceptionInterface
      * @throws ClientExceptionInterface
      */
-    public function __invoke(HttpClientInterface $httpClient): JsonResponse
+    public function __invoke(ImageRepository $data, HttpClientInterface $httpClient): JsonResponse
     {
-        try {
-            $response = $httpClient->request('GET', $this->ogRepositoryApiUrl.'/ogrepository/v1/images', [
-                'headers' => [
-                    'accept' => 'application/json',
-                ],
-            ]);
-        } catch (TransportExceptionInterface $e) {
-            return new JsonResponse( data: 'An error occurred', status: Response::HTTP_INTERNAL_SERVER_ERROR);
-        }
+        $content = $this->createRequest($httpClient, 'GET', 'http://'.$data->getIp(). '/ogrepository/v1/images');
 
-        $data = json_decode($response->getContent(), true);
-
-        return new JsonResponse( data: $data, status: Response::HTTP_OK);
+        return new JsonResponse( data: $content, status: Response::HTTP_OK);
     }
 }

src/Controller/OgRepository/Image/CreateAuxFilesAction.php

@@ -2,7 +2,57 @@
 
 namespace App\Controller\OgRepository\Image;
 
-class CreateAuxFilesAction
-{
+use App\Controller\OgRepository\AbstractOgRepositoryController;
+use App\Entity\Command;
+use App\Entity\Image;
+use App\Model\ImageStatus;
+use App\Model\TraceStatus;
+use Doctrine\ORM\EntityManagerInterface;
+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;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
 
+#[AsController]
+class CreateAuxFilesAction extends AbstractOgRepositoryController
+{
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function __invoke(Image $data): JsonResponse
+    {
+        if (!$data->getName()) {
+            throw new ValidatorException('Name is required');
+        }
+
+        $params = [
+            'json' => [
+                'image' => $data->getName().'.img'
+            ]
+        ];
+
+        $content = $this->createRequest('POST', 'http://'.$data->getRepository()->getIp().':8006/ogrepository/v1/images/torrentsum', $params);
+        $command = $this->entityManager->getRepository(Command::class)->findOneBy(['name' => 'Crear Imagen']);
+
+        $inputData = [
+            'imageName' => $data->getName(),
+            'imageUuid' => $data->getUuid(),
+        ];
+
+        $this->createService->__invoke($data->getClient(), $command, TraceStatus::IN_PROGRESS, $content['job_id'], $inputData);
+
+        $data->setStatus(ImageStatus::IN_PROGRESS);
+        $this->entityManager->persist($data);
+        $this->entityManager->flush();
+
+        return new JsonResponse(data: $content, status: Response::HTTP_OK);
+    }
 }

src/Controller/OgRepository/Image/DeletePermanentAction.php

@@ -2,7 +2,38 @@
 
 namespace App\Controller\OgRepository\Image;
 
-class DeletePermanentAction
-{
+use App\Controller\OgRepository\AbstractOgRepositoryController;
+use App\Entity\Image;
+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;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
 
+#[AsController]
+class DeletePermanentAction extends AbstractOgRepositoryController
+{
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function __invoke(Image $data, HttpClientInterface $httpClient): JsonResponse
+    {
+        if (!$data->getImageFullsum()) {
+            throw new ValidatorException('Fullsum is required');
+        }
+
+        $content = $this->createRequest($httpClient, 'DELETE', 'http://'.$data->getRepository()->getIp().'/ogrepository/v1/images/'.$data->getImageFullsum().'?method=trash');
+
+        $this->entityManager->remove($data);
+        $this->entityManager->flush();
+
+        return new JsonResponse(data: $content, status: Response::HTTP_OK);
+    }
 }

src/Controller/OgRepository/Image/DeleteTrashAction.php

@@ -4,6 +4,7 @@ namespace App\Controller\OgRepository\Image;
 
 use App\Controller\OgRepository\AbstractOgRepositoryController;
 use App\Entity\Image;
+use App\Model\ImageStatus;
 use Symfony\Component\HttpFoundation\JsonResponse;
 use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\HttpKernel\Attribute\AsController;
@@ -15,7 +16,7 @@ use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
 use Symfony\Contracts\HttpClient\HttpClientInterface;
 
 #[AsController]
-class DeleteAction extends AbstractOgRepositoryController
+class DeleteTrashAction extends AbstractOgRepositoryController
 {
     /**
      * @throws TransportExceptionInterface
@@ -31,7 +32,8 @@ class DeleteAction extends AbstractOgRepositoryController
 
         $content = $this->createRequest($httpClient, 'DELETE', 'http://'.$data->getRepository()->getIp().'/ogrepository/v1/images/'.$data->getImageFullsum().'?method=trash');
 
-        $this->entityManager->remove($data);
+        $data->setStatus(ImageStatus::TRASH);
+        $this->entityManager->persist($data);
         $this->entityManager->flush();
 
         return new JsonResponse(data: $content, status: Response::HTTP_OK);

src/Controller/OgRepository/Image/DeployImageAction.php

@@ -8,6 +8,7 @@ use App\Entity\Command;
 use App\Entity\Image;
 use App\Model\TraceStatus;
 use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\HttpKernel\Attribute\AsController;
 use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
 use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
@@ -16,7 +17,7 @@ use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
 use Symfony\Contracts\HttpClient\HttpClientInterface;
 
 #[AsController]
-class DeployImage extends AbstractOgRepositoryController
+class DeployImageAction extends AbstractOgRepositoryController
 {
     /**
      * @throws TransportExceptionInterface

src/Controller/OgRepository/Image/GetAction.php

@@ -2,7 +2,35 @@
 
 namespace App\Controller\OgRepository\Image;
 
-class GetAction
-{
+use App\Controller\OgRepository\AbstractOgRepositoryController;
+use App\Entity\Image;
+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;
+use Symfony\Contracts\HttpClient\HttpClientInterface;
 
+#[AsController]
+class GetAction extends AbstractOgRepositoryController
+{
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function __invoke(Image $data): JsonResponse
+    {
+        if (!$data->getImageFullsum()) {
+            throw new ValidatorException('Fullsum is required');
+        }
+
+        $content = $this->createRequest('GET', 'http://'.$data->getRepository()->getIp().':8006/ogrepository/v1/images/'.$data->getImageFullsum());
+
+        return new JsonResponse(data: $content, status: Response::HTTP_OK);
+    }
 }

src/Controller/OgRepository/StatusAction.php

@@ -23,18 +23,8 @@ class StatusAction extends AbstractOgRepositoryController
      */
     public function __invoke(ImageRepository $data, HttpClientInterface $httpClient): JsonResponse
     {
-        try {
-            $response = $httpClient->request('GET', $data->getIp().'/ogrepository/v1/status', [
-                'headers' => [
-                    'accept' => 'application/json',
-                ],
-            ]);
-        } catch (TransportExceptionInterface $e) {
-            return new JsonResponse( data: 'An error occurred', status: Response::HTTP_INTERNAL_SERVER_ERROR);
-        }
+        $content = $this->createRequest('GET', 'http://'.$data->getIp(). ':8006/ogrepository/v1/status');
 
-        $data = json_decode($response->getContent(), true);
-
-        return new JsonResponse( data: $data, status: Response::HTTP_OK);
+        return new JsonResponse( data: $content, status: Response::HTTP_OK);
     }
 }

src/Controller/OgRepository/SyncAction.php

@@ -1,17 +1,13 @@
 <?php
 
-namespace App\Controller\OgRepository\Image;
+namespace App\Controller\OgRepository;
 
-use App\Controller\OgBoot\AbstractOgBootController;
-use App\Controller\OgRepository\AbstractOgRepositoryController;
 use App\Entity\Image;
-use App\Entity\OgLive;
-use App\Model\OgLiveStatus;
+use App\Entity\ImageRepository;
 use Doctrine\ORM\EntityManagerInterface;
 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;
@@ -27,9 +23,9 @@ class SyncAction extends AbstractOgRepositoryController
      * @throws RedirectionExceptionInterface
      * @throws ClientExceptionInterface
      */
-    public function __invoke(HttpClientInterface $httpClient, EntityManagerInterface $entityManager): JsonResponse
+    public function __invoke(ImageRepository $data, HttpClientInterface $httpClient, EntityManagerInterface $entityManager): JsonResponse
     {
-        $content = $this->createRequest($httpClient, 'GET', $this->ogRepositoryApiUrl . '/ogrepository/v1/images');
+        $content = $this->createRequest($httpClient, 'GET', 'http://'.$data->getIp(). '/ogrepository/v1/images');
 
         if (!isset($content['output']['REPOSITORY']['images'])) {
             return new JsonResponse(data: 'No images found', status: Response::HTTP_NOT_FOUND);

src/Controller/OgRepository/Webhook/ResponseController.php

@@ -2,7 +2,58 @@
 
 namespace App\Controller\OgRepository\Webhook;
 
-class ResponseController
-{
+use App\Entity\Image;
+use App\Entity\Trace;
+use App\Model\ImageStatus;
+use App\Model\TraceStatus;
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Attribute\AsController;
+use Symfony\Component\Routing\Annotation\Route;
 
+#[AsController]
+class ResponseController extends AbstractController
+{
+    public function __construct(
+        protected readonly EntityManagerInterface $entityManager
+    )
+    {
+    }
+
+    #[Route('/og-repository/webhook', name: 'og_repository_webhook', methods: ['POST'])]
+    public function repositoryWebhook(Request $request): JsonResponse
+    {
+        $data = json_decode($request->getContent(), true);
+
+        $trace = $this->entityManager->getRepository(Trace::class)->findOneBy(['jobId' => $data['job_id']]);
+        $imageUuid = $trace->getInput()['imageUuid'];
+
+        $image = $this->entityManager->getRepository(Image::class)->findOneBy(['uuid' => $imageUuid]);
+
+        if ($image === null) {
+            $trace->setStatus(TraceStatus::FAILED);
+            $trace->setFinishedAt(new \DateTime());
+            $trace->setOutput('Image not found');
+            $this->entityManager->persist($trace);
+            $this->entityManager->flush();
+
+            return new JsonResponse(['message' => 'Image not found'], Response::HTTP_NOT_FOUND);
+        }
+
+        $image->setImageFullsum($data['image_id']);
+        $image->setStatus(ImageStatus::SUCCESS);
+        $this->entityManager->persist($image);
+
+        $trace->setStatus(TraceStatus::SUCCESS);
+        $trace->setFinishedAt(new \DateTime());
+
+        $this->entityManager->persist($trace);
+        $this->entityManager->flush();
+
+        return new JsonResponse($data, Response::HTTP_OK);
+
+    }
 }

src/Service/OgRepository/StatusService.php

@@ -2,7 +2,45 @@
 
 namespace App\Service\OgRepository;
 
+use Symfony\Component\HttpClient\HttpClient;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
+use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
+
 class StatusService
 {
+    public function __construct(
+    )
+    {
+    }
 
+    /**
+     * @throws TransportExceptionInterface
+     * @throws ServerExceptionInterface
+     * @throws RedirectionExceptionInterface
+     * @throws ClientExceptionInterface
+     */
+    public function __invoke()
+    {
+
+        $httpClient = HttpClient::create([
+            'verify_peer' => false,
+            'verify_host' => false,
+        ]);
+
+        try {
+            $response = $httpClient->request('GET', ''.'/ogrepository/v1/status', [
+                'headers' => [
+                    'accept' => 'application/json',
+                ],
+            ]);
+        } catch (TransportExceptionInterface $e) {
+            return new JsonResponse( data: 'An error occurred', status: Response::HTTP_INTERNAL_SERVER_ERROR);
+        }
+
+        return json_decode($response->getContent(), true);
+    }
 }