diff --git a/src/Controller/DeployImageAction.php b/src/Controller/DeployImageAction.php index d414880..a48beec 100644 --- a/src/Controller/DeployImageAction.php +++ b/src/Controller/DeployImageAction.php @@ -106,6 +106,13 @@ class DeployImageAction extends AbstractController 'numPartition' => (string) $input->partitionNumber, ]; + try { + $this->deployImageOgRepositoryAction->__invoke($input, $image, $client->getEntity(), $this->httpClient); + } catch (\Exception $e) { + //return new JsonResponse(data: ['error' => $e->getMessage()], status: Response::HTTP_INTERNAL_SERVER_ERROR); + continue; + } + $agentJobId = $this->deployImageOgAgentAction->__invoke($image, $input, $client->getEntity(), DeployMethodTypes::TORRENT); $this->createService->__invoke($client->getEntity(), CommandTypes::DEPLOY_IMAGE, TraceStatus::IN_PROGRESS, $agentJobId, $inputData); } diff --git a/src/Controller/OgAgent/Webhook/ClientsController.php b/src/Controller/OgAgent/Webhook/ClientsController.php index e628f7a..3a779b4 100644 --- a/src/Controller/OgAgent/Webhook/ClientsController.php +++ b/src/Controller/OgAgent/Webhook/ClientsController.php @@ -53,7 +53,7 @@ class ClientsController extends AbstractController public function index(Request $request): JsonResponse { $data = $request->toArray(); - $requiredFields = ['res', 'der', 'job_id']; + $requiredFields = ['nfn', 'res', 'der', 'job_id']; foreach ($requiredFields as $field) { if (!isset($data[$field])) {