ivan-igorevich/dc-observatio
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

-sonar

Browse Source
This commit is contained in:
emelianov
2026-05-27 17:55:03 +03:00
parent 7dc786362c
commit 6e62a0bd19
3 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/pcp-ui-service/src/main/kotlin/space/nstart/pcp/slots_service/service/TleMonitoringService.kt
+11 -5
View File
@@ -16,17 +16,18 @@ class TleMonitoringService(webClientBuilderProvider: ObjectProvider<WebClient.Bu
private val webClientBuilder: WebClient.Builder = webClientBuilderProvider.ifAvailable ?: WebClient.builder()
private val logger = LoggerFactory.getLogger(this::class.java)
@Value("\${settings.tle-monitoring-service:tle-monitoring-service}")
@Value("\${settings.tle-monitoring-service:http://tle-monitoring-service:8080}")
private val tleMonitoringUrl: String = ""
fun allTles(): List<TLEExtensionDTO> {
logger.info("TLE monitoring client all TLE request started")
val baseUrl = tleMonitoringUrl.trimEnd('/')
logger.info("TLE monitoring client all TLE request started: baseUrl={}", baseUrl)
return runCatching {
var records = emptyList<TLEExtensionDTO>()
val durationMs = measureTimeMillis {
records = webClientBuilder.build()
.get()
.uri("$tleMonitoringUrl/v1/api/tle")
.uri("$baseUrl/v1/api/tle")
.retrieve()
.onStatus({ status -> status.isError }, ::mapError)
.bodyToFlux(TLEExtensionDTO::class.java)
@@ -47,13 +48,18 @@ class TleMonitoringService(webClientBuilderProvider: ObjectProvider<WebClient.Bu
}
fun satelliteTles(satelliteId: Long): List<TLEExtensionDTO> {
logger.info("TLE monitoring client satellite TLE request started: satelliteId={}", satelliteId)
val baseUrl = tleMonitoringUrl.trimEnd('/')
logger.info(
"TLE monitoring client satellite TLE request started: satelliteId={}, baseUrl={}",
satelliteId,
baseUrl
)
return runCatching {
var records = emptyList<TLEExtensionDTO>()
val durationMs = measureTimeMillis {
records = webClientBuilder.build()
.get()
.uri("$tleMonitoringUrl/v1/api/tle/satellite/$satelliteId")
.uri("$baseUrl/v1/api/tle/satellite/$satelliteId")
.retrieve()
.onStatus({ status -> status.isError }, ::mapError)
.bodyToFlux(TLEExtensionDTO::class.java)