pcvolkmer/onco-analytics-monitor
1
0
Fork 0
mirror of https://github.com/pcvolkmer/onco-analytics-monitor.git synced 2025-04-19 11:06:52 +00:00
Code Issues Activity

refactor: rename to FhirObdsTopicMonitor and related parts

Browse Source
This commit is contained in:
Paul-Christian Volkmer 2024-08-06 09:10:31 +02:00
parent c24587a5bd
commit 3dc5d79808
4 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/OncoAnalyticsMonitorApplication.kt
View File

@ -23,7 +23,7 @@ class OncoAnalyticsMonitorApplication {
}
@Bean
fun obdsFhirConditionRepository(): ConditionInMemoryRepository {
fun fhirObdsConditionRepository(): ConditionInMemoryRepository {
return ConditionInMemoryRepository()
}

6
src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/ObdsFhirTopicMonitor.kt → src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/topiclisteners/FhirObdsTopicMonitor.kt
View File

@ -15,8 +15,8 @@ import org.springframework.messaging.handler.annotation.Payload
import org.springframework.stereotype.Component
@Component
class ObdsFhirTopicMonitor(
@Qualifier("obdsFhirConditionRepository")
class FhirObdsTopicMonitor(
@Qualifier("fhirObdsConditionRepository")
private val conditionRepository: ConditionInMemoryRepository,
statisticsEventProducer: StatisticsSink,
) : TopicMonitor(statisticsEventProducer) {
@ -45,7 +45,7 @@ class ObdsFhirTopicMonitor(
)
if (updated) {
sendUpdatedStatistics(fetchStatistics("obdsfhir", conditionRepository))
sendUpdatedStatistics(fetchStatistics("fhirobds", conditionRepository))
}
}
} catch (e: Exception) {

8
src/main/kotlin/dev/pcvolkmer/oncoanalytics/monitor/web/StatisticsController.kt
View File

@ -13,8 +13,8 @@ import org.springframework.web.bind.annotation.RestController
class StatisticsController(
@Qualifier("obdsXmlConditionRepository")
private val obdsXmlConditionRepository: ConditionInMemoryRepository,
@Qualifier("obdsFhirConditionRepository")
private val obdsFhirConditionRepository: ConditionInMemoryRepository,
@Qualifier("fhirObdsConditionRepository")
private val fhirObdsConditionRepository: ConditionInMemoryRepository,
@Qualifier("fhirPseudonymizedConditionRepository")
private val fhirPseudonymizedConditionRepository: ConditionInMemoryRepository,
) {
@ -24,9 +24,9 @@ class StatisticsController(
return fetchStatistics("obdsxml", obdsXmlConditionRepository)
}
@GetMapping(path = ["obdsfhir"])
@GetMapping(path = ["fhirobds"])
fun obdsfhirStatistics(): Statistics {
return fetchStatistics("obdfhir", obdsFhirConditionRepository)
return fetchStatistics("fhirobds", fhirObdsConditionRepository)
}
@GetMapping(path = ["fhirpseudonymized"])

8
src/main/resources/templates/index.html
View File

@ -44,7 +44,7 @@
<img class="logo" th:src="@{/images/topic.png}" alt="topic"/>
<div class="description">Kafka Topic<br/>oBDS FHIR</div>
<div class="statistics">
<table id="obdsfhir"></table>
<table id="fhirobds"></table>
</div>
</div>
</div><div class="step">
@ -78,7 +78,7 @@
}
fetch('/statistics/obdsxml').then(res => res.json()).then(data => updateData(data, 'obdsxml'));
fetch('/statistics/obdsfhir').then(res => res.json()).then(data => updateData(data, 'obdsfhir'));
fetch('/statistics/fhirobds').then(res => res.json()).then(data => updateData(data, 'fhirobds'));
fetch('/statistics/fhirpseudonymized').then(res => res.json()).then(data => updateData(data, 'fhirpseudonymized'));
window.addEventListener('load', () => {
@ -88,8 +88,8 @@
updateData(JSON.parse(event.data), 'obdsxml')
});
evtSource.addEventListener('obdsfhir', (event) => {
updateData(JSON.parse(event.data), 'obdsfhir')
evtSource.addEventListener('fhirobds', (event) => {
updateData(JSON.parse(event.data), 'fhirobds')
});
evtSource.addEventListener('fhirpseudonymized', (event) => {