src/Controller/InternalApiController.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Service\Gauge\GaugeControlManager;
  6. use App\Service\Output\DailyStatusManager;
  7. use App\Service\RemoteImport\RemoteImportLogManager;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\Routing\Annotation\Route;
  15. class InternalApiController extends AbstractController
  16. {
  17. private GaugeControlManager $gaugeControlManager;
  18. private ParameterBagInterface $appParams;
  19. private DailyStatusManager $dailyStatusManager;
  20. private RemoteImportLogManager $remoteImportLogManager;
  22. public function __construct(
  23. ParameterBagInterface $appParams,
  24. GaugeControlManager $gaugeControlManager,
  25. DailyStatusManager $dailyStatusManager,
  26. RemoteImportLogManager $remoteImportLogManager
  27. )
  28. {
  29. $this->gaugeControlManager = $gaugeControlManager;
  30. $this->appParams = $appParams;
  31. $this->dailyStatusManager = $dailyStatusManager;
  32. $this->remoteImportLogManager = $remoteImportLogManager;
  33. }
  35. /**
  36. * @Route("/api-internal/remote-data-control", name="gauge_remote_data_control", methods={"POST"})
  37. *
  38. * @param Request $request
  39. * @return JsonResponse
  40. */
  41. public function limitControl(Request $request): JsonResponse
  42. {
  43. if (!$this->isAuthenticated($request)) {
  44. return new JsonResponse(['message' => 'UNAUTHORIZED'], Response::HTTP_UNAUTHORIZED);
  45. }
  47. try {
  48. $requestContent = $request->getContent();
  49. $data = json_decode($requestContent, true);
  51. if (!is_array($data) || !is_array($data['ids']) || !isset($data['dtFrom'])) {
  52. return new JsonResponse(['message' => 'wrong data'], Response::HTTP_BAD_REQUEST);
  53. }
  55. $controlFrom = new \DateTime($data['dtFrom']);
  57. $this->gaugeControlManager->createTasks($data['ids'], $controlFrom);
  59. return new JsonResponse(['message' => 'data accepted!'], Response::HTTP_ACCEPTED);
  60. } catch (\Exception $exception) {
  61. return new JsonResponse([
  62. 'status' => 'error',
  63. 'message' => $exception->getMessage()
  64. ], Response::HTTP_BAD_REQUEST);
  65. }
  67. return new JsonResponse(['message' => 'OK'], Response::HTTP_ACCEPTED);
  68. }
  70. /**
  71. * @Route("/api-internal/remote-dataset-update", name="gauge_remote_dataset_update", methods={"POST"})
  72. *
  73. * @param Request $request
  74. * @return JsonResponse
  75. */
  76. public function remoteDatasetUpdate(Request $request): JsonResponse
  77. {
  78. if (!$this->isAuthenticated($request)) {
  79. return new JsonResponse(['message' => 'UNAUTHORIZED'], Response::HTTP_UNAUTHORIZED);
  80. }
  82. try {
  83. $requestContent = $request->getContent();
  84. $data = json_decode($requestContent, true);
  86. if (!is_array($data) || !is_array($data['ids']) || !isset($data['dtFrom'])) {
  87. return new JsonResponse(['message' => 'wrong data'], Response::HTTP_BAD_REQUEST);
  88. }
  90. $controlFrom = new \DateTime($data['dtFrom']);
  92. $this->dailyStatusManager->createRemoteDatasetTasks($data['ids'], $controlFrom);
  94. return new JsonResponse(['message' => 'data accepted!'], Response::HTTP_ACCEPTED);
  95. } catch (\Exception $exception) {
  96. return new JsonResponse([
  97. 'status' => 'error',
  98. 'message' => $exception->getMessage()
  99. ], Response::HTTP_BAD_REQUEST);
  100. }
  102. return new JsonResponse(['message' => 'OK'], Response::HTTP_ACCEPTED);
  103. }
  105. /**
  106. * Receive and log import results from the data aggregator.
  107. *
  108. * @Route("/api-internal/remote-import-result", name="remote_import_result", methods={"POST"})
  109. */
  110. public function remoteImportResult(Request $request): JsonResponse
  111. {
  112. if (!$this->isAuthenticated($request)) {
  113. return new JsonResponse(['message' => 'UNAUTHORIZED'], Response::HTTP_UNAUTHORIZED);
  114. }
  116. try {
  117. $data = json_decode($request->getContent(), true);
  119. if (!is_array($data)) {
  120. return new JsonResponse(['message' => 'Invalid JSON'], Response::HTTP_BAD_REQUEST);
  121. }
  123. if (!isset($data['gauge_id'], $data['imported'], $data['skipped'])) {
  124. return new JsonResponse(['message' => 'Missing required fields: gauge_id, imported, skipped'], Response::HTTP_BAD_REQUEST);
  125. }
  127. $userId = isset($data['user_id']) ? (int) $data['user_id'] : null;
  128. $this->remoteImportLogManager->logResult($data, $userId);
  130. return new JsonResponse(['message' => 'result logged'], Response::HTTP_ACCEPTED);
  131. } catch (\InvalidArgumentException $e) {
  132. return new JsonResponse([
  133. 'status' => 'error',
  134. 'message' => $e->getMessage()
  135. ], Response::HTTP_BAD_REQUEST);
  136. } catch (\Exception $e) {
  137. return new JsonResponse([
  138. 'status' => 'error',
  139. 'message' => 'Internal error: ' . $e->getMessage()
  140. ], Response::HTTP_INTERNAL_SERVER_ERROR);
  141. }
  142. }
  144. /**
  145. * @param Request $request
  146. * @return bool
  147. */
  148. private function isAuthenticated(Request $request):bool
  149. {
  150. $token = $request->headers->get('api-key');
  151. return $token === sha1($this->appParams->get('internal.token.salt') . date('Ymd'));
  152. }
  153. }