From ab1e0e76770cd0a20a5cdca8ab7c7604f520ccba Mon Sep 17 00:00:00 2001 From: backdev-1 Date: Thu, 11 Jun 2026 13:14:24 +0700 Subject: [PATCH] Add monitoring with another system --- .../nocopy/controller/HealtCheckController.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/src/main/java/ru/soune/nocopy/controller/HealtCheckController.java b/src/main/java/ru/soune/nocopy/controller/HealtCheckController.java index 706774c..b73f375 100644 --- a/src/main/java/ru/soune/nocopy/controller/HealtCheckController.java +++ b/src/main/java/ru/soune/nocopy/controller/HealtCheckController.java @@ -8,6 +8,7 @@ import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.kafka.core.KafkaTemplate; import org.springframework.web.bind.annotation.*; +import org.springframework.web.servlet.function.EntityResponse; import ru.soune.nocopy.dto.monitoring.MonitoringDTO; import ru.soune.nocopy.entity.monitoring.FileMonitoringEntity; import ru.soune.nocopy.repository.FileMonitoringRepository; @@ -73,4 +74,20 @@ public class HealtCheckController { this.buildTimeBack = buildTimeBack; } } + + @PostMapping("/test/monitoring/{fileId}") + public ResponseEntity startMonitoringKafka(@PathVariable String fileId) throws JsonProcessingException { + MonitoringDTO monitoringYandexDTO = MonitoringDTO.builder().baseUrl(baseUrl). + fileId(fileId) + .engine("yandex_reverse_image") + .searchType("visual_matches") + .build(); + + kafkaTemplate.send("monitoring-commands", objectMapper.writeValueAsString(monitoringYandexDTO)); + + + return ResponseEntity + .ok() + .body("OK"); + } }