diff --git a/src/Controller/OgRepository/Image/ImportAction.php b/src/Controller/OgRepository/Image/ImportAction.php index 79ea5ad..cb28a67 100644 --- a/src/Controller/OgRepository/Image/ImportAction.php +++ b/src/Controller/OgRepository/Image/ImportAction.php @@ -50,14 +50,22 @@ class ImportAction extends AbstractOgRepositoryController throw new ValidatorException('This image already exists in this repository'); } + $imageImageRepositoryEntity = new ImageImageRepository(); + $imageImageRepositoryEntity->setStatus(ImageStatus::AUX_FILES_PENDING); + $imageImageRepositoryEntity->setImage($imageEntity); + $imageImageRepositoryEntity->setRepository($repository); + + $this->entityManager->persist($imageImageRepositoryEntity); + $this->entityManager->flush(); + + $this->logger->info('Creating aux files', ['image' => $image]); + $params = [ 'json' => [ 'image' => $image.'.img' ] ]; - $this->logger->info('Creating aux files', ['image' => $image]); - $content = $this->createRequest('POST', 'http://'.$repository->getIp().':8006/ogrepository/v1/images/torrentsum', $params); if (isset($content['error']) && $content['code'] === Response::HTTP_INTERNAL_SERVER_ERROR ) { @@ -71,14 +79,6 @@ class ImportAction extends AbstractOgRepositoryController $this->createService->__invoke(null, CommandTypes::CREATE_IMAGE_AUX_FILE, TraceStatus::IN_PROGRESS, $content['job_id'], $inputData); - $imageImageRepositoryEntity = new ImageImageRepository(); - $imageImageRepositoryEntity->setStatus(ImageStatus::AUX_FILES_PENDING); - $imageImageRepositoryEntity->setImage($imageEntity); - $imageImageRepositoryEntity->setRepository($repository); - - $this->entityManager->persist($imageImageRepositoryEntity); - $this->entityManager->flush(); - return new JsonResponse(data: [], status: Response::HTTP_OK); } } \ No newline at end of file