Added spring doc webflux support and kotlin coroutines

.drone.yml

@@ -30,7 +30,6 @@ volumes:
 trigger:
   event:
     include:
-      - push
       - pull_request
       - custom
 
@@ -51,7 +50,7 @@ steps:
     image: alpine/git
     environment:
       SSH_KEY:
-        from_secret: ssh_key
+        from_secret: private_ssh_key
     commands:
       - mkdir $HOME/.ssh
       - echo "$SSH_KEY" > $HOME/.ssh/id_ed25519
@@ -69,7 +68,7 @@ steps:
       PASSWORD:
         from_secret: docker_password
       SSH_KEY:
-        from_secret: ssh_key
+        from_secret: private_ssh_key
     volumes:
       - name: cache
         path: /home/gradle/.gradle
@@ -88,10 +87,81 @@ volumes:
       path: /var/lib/drone/cache/.gradle
 
 trigger:
-  branches:
-    - main
   event:
     include:
-      - push
-      - custom
+      - tag
 
+---
+kind: pipeline
+name: deploy image
+type: docker
+
+platform:
+  os: linux
+  arch: arm64
+
+clone:
+  disable: true
+
+steps:
+  - name: clone
+    image: alpine/git
+    environment:
+      SSH_KEY:
+        from_secret: private_ssh_key
+    commands:
+      - mkdir $HOME/.ssh
+      - echo "$SSH_KEY" > $HOME/.ssh/id_ed25519
+      - chmod 600 $HOME/.ssh/id_ed25519
+      - touch $HOME/.ssh/known_hosts
+      - chmod 600 $HOME/.ssh/known_hosts
+      - ssh-keyscan -H git.2martens.de > $HOME/.ssh/known_hosts 2>/dev/null
+      - git clone ssh://giteajim@git.2martens.de:22/2martens/cloud-configuration.git .
+      - git checkout main
+  - name: modify deployed image
+    image: alpine
+    commands:
+      - sed -i -r "s/(wahlrecht_image_version:).*/\1\ ${DRONE_SEMVER}/" ansible/inventories/host_vars/api-server/public.yaml
+  - name: save modified variable file
+    image: alpine/git
+    environment:
+      SSH_KEY:
+        from_secret: private_ssh_key
+    commands:
+      - mkdir $HOME/.ssh
+      - echo "$SSH_KEY" > $HOME/.ssh/id_ed25519
+      - chmod 600 $HOME/.ssh/id_ed25519
+      - touch $HOME/.ssh/known_hosts
+      - chmod 600 $HOME/.ssh/known_hosts
+      - ssh-keyscan -H git.2martens.de > $HOME/.ssh/known_hosts 2>/dev/null
+      - git add ansible/inventories/host_vars/api-server/public.yaml
+      - git diff-index --quiet HEAD || git commit -m "[Drone] Changed wahlrecht_image_version to ${DRONE_SEMVER}"
+      - git push origin main
+  - name: deploy image
+    image: plugins/ansible:latest
+    volumes:
+      - name: cache
+        path: /root/.ansible
+    settings:
+      playbook: ansible/deploy_spring.yaml
+      inventory: ansible/inventories/production
+      galaxy: ansible/requirements.yaml
+      galaxy_force: false
+      private_key:
+        from_secret: private_ssh_key
+      vault_password:
+        from_secret: vault_password
+
+volumes:
+  - name: cache
+    host:
+      path: /var/lib/drone/cache/.ansible
+
+trigger:
+#  target:
+#    - production
+  event:
+    include:
+      - promote
+      - rollback
+      - custom

buildSrc/src/main/kotlin/twomartens.kotlin.gradle.kts

@@ -8,6 +8,9 @@ val libs = the<LibrariesForLibs>()
 
 dependencies {
     implementation(libs.kotlin.logging)
+    implementation(libs.kotlin.reactor)
+    implementation(libs.kotlin.coroutines)
+    implementation(libs.kotlin.coroutines.reactor)
     implementation(kotlin("reflect"))
 }
 

buildSrc/src/main/kotlin/twomartens.spring-boot-cloud.gradle.kts

@@ -9,7 +9,6 @@ val libs = the<LibrariesForLibs>()
 dependencies {
     implementation(platform(libs.spring.cloud))
     implementation(libs.bundles.spring.boot.server)
-    implementation(libs.spring.openapi)
 
     implementation(libs.httpclient)
     implementation(libs.prometheus)

buildSrc/src/main/kotlin/twomartens.spring-boot.gradle.kts

@@ -62,7 +62,7 @@ tasks.named("buildAll") {
 
 val formatter: DateTimeFormatter = ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSSZ")
 
-tasks.bootJar {
+tasks.jar {
     manifest {
         attributes["Implementation-Title"] = rootProject.name
         attributes["Implementation-Version"] = archiveVersion.get()

gradle/libs.versions.toml

@@ -1,6 +1,7 @@
 [versions]
 spring-boot = "3.1.2"
 spring-doc = "2.1.0"
+spring-doc-webflux = "1.7.0"
 spring-cloud = "2022.0.4"
 spring-grpc = "2.14.0.RELEASE"
 grpc = "1.57.0"
@@ -17,6 +18,8 @@ keycloak = "22.0.1"
 kotlin-logging = "3.0.5"
 kotlin-reflect = "1.9.0"
 kotlin-lombok = "1.9.0"
+kotlin-reactor = "1.2.2"
+kotlin-coroutines = "1.7.3"
 plugin-nebula-release = "17.2.2"
 plugin-lombok = "8.0.1"
 plugin-gradle-versions = "0.46.0"
@@ -31,20 +34,24 @@ spring-boot-web = { module = "org.springframework.boot:spring-boot-starter-web"
 spring-boot-log4j = { module = "org.springframework.boot:spring-boot-starter-log4j2" }
 spring-boot-thymeleaf = { module = "org.springframework.boot:spring-boot-starter-thymeleaf" }
 spring-boot-mongo = { module = "org.springframework.boot:spring-boot-starter-data-mongodb" }
+spring-boot-mongo-reactive = { module = "org.springframework.boot:spring-boot-starter-data-mongodb-reactive" }
 spring-boot-validation = { module = "org.springframework.boot:spring-boot-starter-validation" }
 spring-boot-test = { module = "org.springframework.boot:spring-boot-starter-test" }
 spring-boot-security = { module = "org.springframework.boot:spring-boot-starter-security" }
 spring-boot-oauth2-resource-server = { module = "org.springframework.boot:spring-boot-starter-oauth2-resource-server" }
+spring-boot-webflux = { module = "org.springframework.boot:spring-boot-starter-webflux" }
 spring-boot-config = { module = "org.springframework.boot:spring-boot-configuration-processor", version.ref = "spring-boot" }
 spring-cloud = { module = "org.springframework.cloud:spring-cloud-dependencies", version.ref = "spring-cloud" }
 spring-cloud-starter = { module = "org.springframework.cloud:spring-cloud-starter" }
+spring-cloud-starter-bus-kafka = { module = "org.springframework.cloud:spring-cloud-starter-bus-kafka" }
 spring-cloud-starter-config = { module = "org.springframework.cloud:spring-cloud-starter-config" }
 spring-cloud-config-server = { module = "org.springframework.cloud:spring-cloud-config-server" }
 spring-boot-starter = { module = "org.springframework.boot:spring-boot-starter" }
 spring-grpc = { module = "net.devh:grpc-spring-boot-starter", version.ref = "spring-grpc" }
 spring-ui = { module = "org.springdoc:springdoc-openapi-starter-webmvc-ui", version.ref = "spring-doc" }
-spring-sec = { module = "org.springdoc:springdoc-openapi-starter-common", version.ref = "spring-doc" }
-spring-openapi = { module = "org.springdoc:springdoc-openapi-starter-webmvc-api", version.ref = "spring-doc" }
+spring-openapi-starter = { module = "org.springdoc:springdoc-openapi-starter-common", version.ref = "spring-doc" }
+spring-openapi-webmvc = { module = "org.springdoc:springdoc-openapi-starter-webmvc-api", version.ref = "spring-doc" }
+spring-openapi-webflux = { module = "org.springdoc:springdoc-openapi-webflux-ui", version.ref = "spring-doc-webflux" }
 keycloak-core = { module = "org.keycloak:keycloak-core", version.ref = "keycloak" }
 keycloak-policy-enforcer = { module = "org.keycloak:keycloak-policy-enforcer", version.ref = "keycloak" }
 grpc-api = { module = "io.grpc:grpc-api", version.ref = "grpc" }
@@ -77,6 +84,9 @@ mockito-inline = "org.mockito:mockito-inline:5.2.0"
 mockito-junit = { module = "org.mockito:mockito-junit-jupiter", version.ref = "mockito" }
 kotlin-logging = { module = "io.github.microutils:kotlin-logging-jvm", version.ref = "kotlin-logging" }
 kotlin-reflect = { module = "org.jetbrains.kotlin:kotlin-reflect", version.ref = "kotlin-reflect" }
+kotlin-reactor = { module = "io.projectreactor.kotlin:reactor-kotlin-extensions", version.ref = "kotlin-reactor" }
+kotlin-coroutines = { module = "org.jetbrains.kotlinx:kotlin-coroutines-core", version.ref = "kotlin-coroutines" }
+kotlin-coroutines-reactor = { module = "org.jetbrains.kotlinx:kotlin-coroutines-reactor", version.ref = "kotlin-coroutines" }
 plugin-nebula-release = { module = "com.netflix.nebula:nebula-release-plugin", version.ref = "plugin-nebula-release" }
 plugin-springboot = { module = "org.springframework.boot:spring-boot-gradle-plugin", version.ref = "spring-boot" }
 plugin-lombok = { module = "io.freefair.gradle:lombok-plugin", version.ref = "plugin-lombok" }
@@ -111,12 +121,14 @@ spring-boot = [
 spring-boot-server = [
     "spring-boot-actuator",
     "spring-boot-log4j",
-    "spring-boot-mongo",
+    "spring-boot-mongo-reactive",
     "spring-boot-thymeleaf",
     "spring-boot-validation",
     "spring-boot-web",
+    "spring-boot-webflux",
     "spring-cloud-starter",
-    "spring-sec",
+    "spring-openapi-starter",
+    "spring-openapi-webflux",
     "spring-ui",
 ]
 spring-boot-security = [

http-requests/calculate-result.http

@@ -1,4 +1,4 @@
-POST http://localhost:12000/wahlrecht/v1/calculate
+POST {{backend}}/wahlrecht/v1/calculate
 Content-Type: application/json
 
 {

http-requests/get-elections.http

@@ -0,0 +1,2 @@
+GET {{backend}}/wahlrecht/v1/elections
+Content-Type: application/json

http-requests/http-client.env.json

@@ -0,0 +1,8 @@
+{
+  "dev": {
+    "backend": "http://localhost:12000"
+  },
+  "prod" : {
+    "backend": "https://api.2martens.de"
+  }
+}

module-deploy/deploy.gradle.kts

@@ -31,10 +31,8 @@ jib {
         }
     }
     container {
-        extraClasspath = listOf("/configmap")
         mainClass = "de.twomartens.wahlrecht.MainApplicationKt"
         jvmFlags = listOf("-XX:+UseContainerSupport",
-                "-XX:MaxRAMPercentage=75.0",
-                "-Dlog4j.configurationFile=/configmap/log4j2.xml")
+                "-XX:MaxRAMPercentage=75.0")
     }
 }

module-deploy/k8s/prod/application-prod.yaml

@@ -1,2 +0,0 @@
-server:
-  port: 12000

module-server/server.gradle.kts

@@ -10,4 +10,5 @@ dependencies {
     annotationProcessor(libs.mapstruct.processor)
     kapt(libs.mapstruct.processor)
     implementation(libs.spring.cloud.starter.config)
+    implementation(libs.spring.cloud.starter.bus.kafka)
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/MainApplication.kt

@@ -3,11 +3,13 @@ package de.twomartens.wahlrecht
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication
 import org.springframework.data.mongodb.config.EnableMongoAuditing
+import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories
 import org.springframework.scheduling.annotation.EnableScheduling
 
 @EnableMongoAuditing
 @EnableScheduling
 @SpringBootApplication
+@EnableReactiveMongoRepositories
 open class MainApplication
 
 fun main(args: Array<String>) {

module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/OpenApiConfiguration.kt

@@ -6,6 +6,7 @@ import io.swagger.v3.oas.annotations.security.OAuthFlows
 import io.swagger.v3.oas.annotations.security.SecurityScheme
 import io.swagger.v3.oas.models.OpenAPI
 import io.swagger.v3.oas.models.info.Info
+import io.swagger.v3.oas.models.servers.Server
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
@@ -35,5 +36,7 @@ open class OpenApiConfiguration {
                     .version(apiVersion)
                     .description(apiDescription)
             )
+            .addServersItem(Server().url("http://localhost:12000"))
+            .addServersItem(Server().url("https://api.2martens.de"))
     }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/WebConfiguration.kt

@@ -16,10 +16,13 @@ open class WebConfiguration(private val headerInterceptorRest: HeaderInterceptor
     override fun addCorsMappings(registry: CorsRegistry) {
         val registration = registry.addMapping("/**")
         registration.allowedMethods(
-            HttpMethod.GET.name(), HttpMethod.POST.name(),
-            HttpMethod.PUT.name(), HttpMethod.OPTIONS.name()
+                HttpMethod.GET.name(), HttpMethod.POST.name(),
+                HttpMethod.PUT.name(), HttpMethod.HEAD.name()
         )
         registration.allowCredentials(true)
-        registration.allowedOrigins("http://localhost:4200")
+        registration.allowedOrigins(
+                "http://localhost:4200",
+                "https://wahlrecht.2martens.de"
+        )
     }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/controller/VersionHtmlController.kt

@@ -32,14 +32,16 @@ class VersionHtmlController {
     }
 
     private fun getTitle(): String {
-        val title = VersionHtmlController::class.java.getPackage().implementationTitle
+        val title = VersionHtmlController::class.java.`package`.implementationTitle
+                ?: return "application"
         return title.ifBlank {
             "application"
         }
     }
 
     private fun getVersion(): String {
-        val version = VersionHtmlController::class.java.getPackage().implementationVersion
+        val version = VersionHtmlController::class.java.`package`.implementationVersion
+                ?: return "DEVELOPER"
         return version.ifBlank {
             "DEVELOPER"
         }

module-server/src/main/kotlin/de/twomartens/wahlrecht/controller/v1/CalculationController.kt

@@ -18,6 +18,7 @@ import org.springframework.web.bind.annotation.PostMapping
 import org.springframework.web.bind.annotation.RequestBody
 import org.springframework.web.bind.annotation.RequestMapping
 import org.springframework.web.bind.annotation.RestController
+import reactor.core.publisher.Mono
 
 @RestController
 @RequestMapping(value = ["/wahlrecht/v1"])
@@ -47,12 +48,12 @@ class CalculationController(private val service: CalculationService) {
     @SecurityRequirement(name = "oauth2")
     fun calculateResult(
         @RequestBody electionResult: ElectionResult
-    ): ResponseEntity<ElectedCandidates> {
+    ): ResponseEntity<Mono<ElectedCandidates>> {
         val result = electedCandidatesMapper.mapToExternal(
             service.determineElectedCandidates(electionResultMapper.mapToInternal(electionResult))
         )
         return ResponseEntity.ok()
             .contentType(MediaType.APPLICATION_JSON)
-            .body(result)
+            .body(Mono.just(result))
     }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/controller/v1/ElectionController.kt

@@ -12,80 +12,97 @@ import io.swagger.v3.oas.annotations.responses.ApiResponse
 import io.swagger.v3.oas.annotations.security.SecurityRequirement
 import io.swagger.v3.oas.annotations.tags.Tag
 import org.mapstruct.factory.Mappers
-import org.springframework.http.HttpStatus
 import org.springframework.http.MediaType
 import org.springframework.http.ResponseEntity
 import org.springframework.web.bind.annotation.*
+import org.springframework.web.util.UriComponentsBuilder
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuples
 
 @RestController
 @RequestMapping(value = ["/wahlrecht/v1"])
 @Tag(name = "Elections", description = "all requests relating to elections")
 class ElectionController(private val service: ElectionService) {
-    private val mapper = Mappers.getMapper(ElectionMapper::class.java)
+  private val mapper = Mappers.getMapper(ElectionMapper::class.java)
 
-    @SecurityRequirement(name = "oauth2")
-    @SecurityRequirement(name = "bearerAuth")
-    @GetMapping(value = ["/elections"], produces = [MediaType.APPLICATION_JSON_VALUE])
-    @Operation(
-        summary = "Returns all stored elections",
-        responses = [ApiResponse(
-            responseCode = "200",
-            description = "Returns all stored elections",
-            content = [Content(
-                mediaType = "application/json",
-                array = ArraySchema(
-                    schema = Schema(
-                        implementation = Election::class
-                    )
-                )
-            )]
-        )]
-    )
-    fun getElections(): ResponseEntity<Collection<Election>> {
-            val elections = service.elections.asSequence()
-                .map { mapper.mapToExternal(it.value) }
-                .toList()
-            return ResponseEntity.ok()
-                .contentType(MediaType.APPLICATION_JSON)
-                .body(elections)
+  @SecurityRequirement(name = "oauth2")
+  @SecurityRequirement(name = "bearerAuth")
+  @GetMapping(value = ["/elections"])
+  @Operation(
+      summary = "Returns all stored elections",
+      responses = [ApiResponse(
+          responseCode = "200",
+          description = "Returns all stored elections",
+          content = [Content(
+              mediaType = "application/json",
+              array = ArraySchema(
+                  schema = Schema(
+                      implementation = Election::class
+                  )
+              )
+          )]
+      )]
+  )
+  fun getElections(): Flux<Election> {
+    val elections = service.getElections()
+        .map {
+          mapper.mapToExternal(it)
         }
+    return elections
+  }
 
-    @Operation(
-        summary = "Returns election matching provided name",
-        responses = [ApiResponse(
-            responseCode = "200",
-            description = "Returns matching election",
-            content = [Content(mediaType = "application/json", schema = Schema(implementation = Election::class))]
-        )]
-    )
-    @GetMapping(value = ["/elections/by-name/{electionName}"], produces = [MediaType.APPLICATION_JSON_VALUE])
-    @SecurityRequirement(name = "bearerAuth")
-    @SecurityRequirement(name = "oauth2")
-    fun getElectionByName(
-        @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String?
-    ): ResponseEntity<Election> {
-        val election = mapper.mapToExternal(service.elections[electionName]!!)
-        return ResponseEntity.ok()
-            .contentType(MediaType.APPLICATION_JSON)
-            .body(election)
-    }
+  @Operation(
+      summary = "Returns election matching provided name",
+      responses = [ApiResponse(
+          responseCode = "200",
+          description = "Returns matching election",
+          content = [Content(mediaType = "application/json", schema = Schema(implementation = Election::class))]
+      )]
+  )
+  @GetMapping(value = ["/elections/{electionName}"], produces = [MediaType.APPLICATION_JSON_VALUE])
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun getElectionByName(
+      @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String
+  ): ResponseEntity<Mono<Election>> {
+    val election = service.findElectionByName(electionName)
+        .map { mapper.mapToExternal(it) }
+    return ResponseEntity.ok()
+        .contentType(MediaType.APPLICATION_JSON)
+        .body(election)
+  }
 
-    @Operation(
-        summary = "Stores a new election",
-        responses = [ApiResponse(
-            responseCode = "201",
-            description = "Election was created"
-        ), ApiResponse(responseCode = "200", description = "Election was modified"), ApiResponse(
-            responseCode = "401",
-            description = "Unauthorized",
-            content = [Content(mediaType = "plain/text")]
-        )]
-    )
-    @PutMapping("/election")
-    @SecurityRequirement(name = "bearerAuth")
-    @SecurityRequirement(name = "oauth2")
-    fun putElection(@RequestBody election: Election?): ResponseEntity<*> {
-        val createdNew = service.storeElection(mapper.mapToDB(election!!))
-        return if (createdNew) ResponseEntity<Any>(HttpStatus.CREATED) else ResponseEntity<Any>(HttpStatus.OK)
-    }
+  @Operation(
+      summary = "Stores a new election",
+      responses = [ApiResponse(
+          responseCode = "201",
+          description = "Election was created"
+      ), ApiResponse(responseCode = "200", description = "Election was modified"), ApiResponse(
+          responseCode = "401",
+          description = "Unauthorized",
+          content = [Content(mediaType = "plain/text")]
+      )]
+  )
+  @PutMapping("/election")
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun putElection(@RequestBody election: Election, uriComponentsBuilder: UriComponentsBuilder): Mono<ResponseEntity<Election>> {
+    return service.storeElection(mapper.mapToDB(election))
+        .map { tuple ->
+          Tuples.of(tuple.t1, mapper.mapToExternal(tuple.t2))
+        }
+        .map { tuple ->
+          if (tuple.t1) {
+            ResponseEntity.created(uriComponentsBuilder.path("/elections/{electionName}")
+                .buildAndExpand(tuple.t2.name).toUri())
+                .contentType(MediaType.APPLICATION_JSON)
+                .body(tuple.t2)
+          } else {
+            ResponseEntity.ok()
+                .contentType(MediaType.APPLICATION_JSON)
+                .body(tuple.t2)
+          }
+        }
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/controller/v1/ElectionResultController.kt

@@ -14,10 +14,12 @@ import io.swagger.v3.oas.annotations.tags.Tag
 import lombok.RequiredArgsConstructor
 import lombok.extern.slf4j.Slf4j
 import org.mapstruct.factory.Mappers
-import org.springframework.http.HttpStatus
 import org.springframework.http.MediaType
 import org.springframework.http.ResponseEntity
 import org.springframework.web.bind.annotation.*
+import org.springframework.web.util.UriComponentsBuilder
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuples
 
 @Slf4j
 @RestController
@@ -25,51 +27,72 @@ import org.springframework.web.bind.annotation.*
 @RequestMapping(value = ["/wahlrecht/v1"])
 @Tag(name = "ElectionResults", description = "all requests relating to election results")
 class ElectionResultController(private val service: ElectionResultService) {
-    private val mapper = Mappers.getMapper(ElectionResultMapper::class.java)
+  private val mapper = Mappers.getMapper(ElectionResultMapper::class.java)
 
-    @Operation(
-        summary = "Returns election result for given election name",
-        responses = [ApiResponse(
-            responseCode = "200",
-            description = "Returns stored election result for given election name",
-            content = [Content(mediaType = "application/json", schema = Schema(implementation = ElectionResult::class))]
-        ), ApiResponse(
-            responseCode = "404",
-            description = "No election result found",
-            content = [Content(mediaType = "application/json", schema = Schema(implementation = ErrorMessage::class))]
-        )]
-    )
-    @GetMapping(
-        value = ["/electionResult/by-election-name/{electionName}"],
-        produces = [MediaType.APPLICATION_JSON_VALUE]
-    )
-    @SecurityRequirement(name = "bearerAuth")
-    @SecurityRequirement(name = "oauth2")
-    fun getElectionByName(
-        @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String
-    ): ResponseEntity<ElectionResult> {
-        val result = mapper.mapToExternal(service.getElectionResult(electionName))
-        return ResponseEntity.ok()
-            .contentType(MediaType.APPLICATION_JSON)
-            .body(result)
-    }
+  @Operation(
+      summary = "Returns election result for given election name",
+      responses = [ApiResponse(
+          responseCode = "200",
+          description = "Returns stored election result for given election name",
+          content = [Content(mediaType = "application/json", schema = Schema(implementation = ElectionResult::class))]
+      ), ApiResponse(
+          responseCode = "404",
+          description = "No election result found",
+          content = [Content(mediaType = "application/json", schema = Schema(implementation = ErrorMessage::class))]
+      )]
+  )
+  @GetMapping(
+      value = ["/electionResult/{electionName}"],
+      produces = [MediaType.APPLICATION_JSON_VALUE]
+  )
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun getElectionByName(
+      @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String
+  ): Mono<ResponseEntity<ElectionResult>> {
+    return service.getElectionResult(electionName)
+        .map {
+          mapper.mapToExternal(it)
+        }
+        .map {
+          ResponseEntity.ok()
+              .contentType(MediaType.APPLICATION_JSON)
+              .body(it)
+        }
+  }
 
-    @Operation(
-        summary = "Stores a new election",
-        responses = [ApiResponse(
-            responseCode = "201",
-            description = "Election was created"
-        ), ApiResponse(responseCode = "200", description = "Election was modified"), ApiResponse(
-            responseCode = "401",
-            description = "Unauthorized",
-            content = [Content(mediaType = "plain/text")]
-        )]
-    )
-    @PutMapping("/electionResult")
-    @SecurityRequirement(name = "bearerAuth")
-    @SecurityRequirement(name = "oauth2")
-    fun putElection(@RequestBody electionResult: ElectionResult?): ResponseEntity<*> {
-        val createdNew = service.storeResult(mapper.mapToDB(electionResult!!))
-        return if (createdNew) ResponseEntity<Any>(HttpStatus.CREATED) else ResponseEntity<Any>(HttpStatus.OK)
-    }
+  @Operation(
+      summary = "Stores a new election",
+      responses = [ApiResponse(
+          responseCode = "201",
+          description = "Election was created"
+      ), ApiResponse(responseCode = "200", description = "Election was modified"), ApiResponse(
+          responseCode = "401",
+          description = "Unauthorized",
+          content = [Content(mediaType = "plain/text")]
+      )]
+  )
+  @PutMapping("/electionResult")
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun putElection(@RequestBody electionResult: ElectionResult,
+                  uriComponentsBuilder: UriComponentsBuilder): Mono<ResponseEntity<ElectionResult>> {
+    val storedElection = service.storeResult(mapper.mapToDB(electionResult))
+    return storedElection
+        .map { tuple ->
+          Tuples.of(tuple.t1, mapper.mapToExternal(tuple.t2))
+        }
+        .map { tuple ->
+          if (tuple.t1) {
+            ResponseEntity.created(uriComponentsBuilder.path("/electionResult/{electionName}")
+                .buildAndExpand(tuple.t2.electionName).toUri())
+                .contentType(MediaType.APPLICATION_JSON)
+                .body(tuple.t2)
+          } else {
+            ResponseEntity.ok()
+                .contentType(MediaType.APPLICATION_JSON)
+                .body(tuple.t2)
+          }
+        }
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/controller/v1/HealthCheckController.kt

@@ -1,5 +1,6 @@
 package de.twomartens.wahlrecht.controller.v1
 
+import de.twomartens.wahlrecht.property.ServiceProperties
 import io.swagger.v3.oas.annotations.Hidden
 import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.RequestMapping
@@ -7,11 +8,12 @@ import org.springframework.web.bind.annotation.RestController
 
 @RestController
 @RequestMapping(value = ["/wahlrecht/v1"])
-class HealthCheckController {
+class HealthCheckController(private val properties: ServiceProperties) {
+
 
     @Hidden
     @GetMapping("/healthCheck")
     fun healthCheck(message: String): String {
-        return message
+        return properties.greeting.format(message)
     }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/controller/v1/PartyController.kt

@@ -13,65 +13,115 @@ import io.swagger.v3.oas.annotations.responses.ApiResponse
 import io.swagger.v3.oas.annotations.security.SecurityRequirement
 import io.swagger.v3.oas.annotations.tags.Tag
 import org.mapstruct.factory.Mappers
-import org.springframework.http.HttpStatus
 import org.springframework.http.MediaType
 import org.springframework.http.ResponseEntity
+import org.springframework.http.ResponseEntity.created
+import org.springframework.http.ResponseEntity.ok
 import org.springframework.stereotype.Controller
 import org.springframework.web.bind.annotation.*
+import org.springframework.web.util.UriComponentsBuilder
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuples
 
 @Controller
 @RequestMapping(value = ["/wahlrecht/v1"])
 @Tag(name = "Parties", description = "all requests relating to parties")
 class PartyController(private val service: PartyService) {
-    private val mapper = Mappers.getMapper(PartyInElectionMapper::class.java)
-    @Operation(
-        summary = "Returns all stored parties for given election name",
-        responses = [ApiResponse(
-            responseCode = "200",
-            description = "Returns all stored parties",
-            content = [Content(
-                mediaType = "application/json",
-                array = ArraySchema(schema = Schema(implementation = PartyInElection::class))
-            )]
-        ), ApiResponse(
-            responseCode = "404",
-            description = "No parties found",
-            content = [Content(mediaType = "application/json", schema = Schema(implementation = ErrorMessage::class))]
-        )]
-    )
-    @GetMapping(value = ["/parties/by-election-name/{electionName}"], produces = [MediaType.APPLICATION_JSON_VALUE])
-    @SecurityRequirement(name = "bearerAuth")
-    @SecurityRequirement(name = "oauth2")
-    fun getPartiesByElectionName(
-        @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String
-    ): ResponseEntity<Collection<PartyInElection>> {
-        val parties = service.getPartiesByElectionName(electionName).stream()
-            .map { election: de.twomartens.wahlrecht.model.db.PartyInElection? ->
-                mapper.mapToExternal(
-                    election!!
-                )
-            }
-            .toList()
-        return ResponseEntity.ok()
-            .contentType(MediaType.APPLICATION_JSON)
-            .body(parties)
-    }
+  private val mapper = Mappers.getMapper(PartyInElectionMapper::class.java)
 
-    @Operation(
-        summary = "Stores a new party in an election",
-        responses = [ApiResponse(
-            responseCode = "201",
-            description = "Party was created"
-        ), ApiResponse(responseCode = "200", description = "Party was modified"), ApiResponse(
-            responseCode = "401",
-            description = "Unauthorized"
-        )]
-    )
-    @PutMapping("/party")
-    @SecurityRequirement(name = "bearerAuth")
-    @SecurityRequirement(name = "oauth2")
-    fun putParty(@RequestBody party: PartyInElection?): ResponseEntity<*> {
-        val createdNew = service.storeParty(mapper.mapToDB(party!!))
-        return if (createdNew) ResponseEntity<Any>(HttpStatus.CREATED) else ResponseEntity<Any>(HttpStatus.OK)
-    }
+  @Operation(
+      summary = "Returns all stored parties for given election name",
+      responses = [ApiResponse(
+          responseCode = "200",
+          description = "Returns all stored parties",
+          content = [Content(
+              mediaType = "application/json",
+              array = ArraySchema(schema = Schema(implementation = PartyInElection::class))
+          )]
+      ), ApiResponse(
+          responseCode = "404",
+          description = "No parties found",
+          content = [Content(mediaType = "application/json", schema = Schema(implementation = ErrorMessage::class))]
+      )]
+  )
+  @GetMapping(value = ["/parties/by-election-name/{electionName}"], produces = [MediaType.APPLICATION_JSON_VALUE])
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun getPartiesByElectionName(
+      @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String
+  ): ResponseEntity<Flux<PartyInElection>> {
+    val parties = service.getPartiesByElectionName(electionName)
+        .map { election: de.twomartens.wahlrecht.model.db.PartyInElection ->
+          mapper.mapToExternal(election)
+        }
+    return ok()
+        .contentType(MediaType.APPLICATION_JSON)
+        .body(parties)
+  }
+
+  @Operation(
+      summary = "Returns party stored for given election name and abbreviation",
+      responses = [ApiResponse(
+          responseCode = "200",
+          description = "Returns stored party",
+          content = [Content(
+              mediaType = "application/json",
+              schema = Schema(implementation = PartyInElection::class)
+          )]
+      ), ApiResponse(
+          responseCode = "404",
+          description = "No party found",
+          content = [Content(mediaType = "application/json", schema = Schema(implementation = ErrorMessage::class))]
+      )]
+  )
+  @GetMapping(value = ["/parties/{electionName}/{abbreviation}"], produces = [MediaType.APPLICATION_JSON_VALUE])
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun getPartyByElectionNameAndAbbreviation(
+      @PathVariable @Parameter(description = "the election name", example = "Bezirkswahl 2019") electionName: String,
+      @PathVariable @Parameter(description = "the party abbreviation", example = "SPD") abbreviation: String
+  ): ResponseEntity<Mono<PartyInElection>> {
+    val party = service.getPartyByElectionNameAndAbbreviation(electionName, abbreviation)
+        .map { stored: de.twomartens.wahlrecht.model.db.PartyInElection ->
+          mapper.mapToExternal(stored)
+        }
+    return ok()
+        .contentType(MediaType.APPLICATION_JSON)
+        .body(party)
+  }
+
+  @Operation(
+      summary = "Stores a new party in an election",
+      responses = [ApiResponse(
+          responseCode = "201",
+          description = "Party was created"
+      ), ApiResponse(responseCode = "200", description = "Party was modified"), ApiResponse(
+          responseCode = "401",
+          description = "Unauthorized"
+      )]
+  )
+  @PutMapping("/party")
+  @SecurityRequirement(name = "bearerAuth")
+  @SecurityRequirement(name = "oauth2")
+  fun putParty(@RequestBody party: PartyInElection,
+               uriComponentsBuilder: UriComponentsBuilder): Mono<ResponseEntity<PartyInElection>> {
+    val storedParty = service.storeParty(mapper.mapToDB(party))
+    return storedParty
+        .map { tuple ->
+          Tuples.of(tuple.t1, mapper.mapToExternal(tuple.t2))
+        }
+        .map { tuple ->
+          if (tuple.t1) {
+            created(uriComponentsBuilder.path("/parties/{electionName}/{abbreviation}")
+                .buildAndExpand(tuple.t2.electionName, tuple.t2.abbreviation).toUri())
+                .contentType(MediaType.APPLICATION_JSON)
+                .body(tuple.t2)
+          } else {
+            ok()
+                .contentType(MediaType.APPLICATION_JSON)
+                .body(tuple.t2)
+          }
+        }
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/model/db/Nomination.kt

@@ -7,27 +7,30 @@ import org.springframework.data.annotation.Id
 import org.springframework.data.annotation.LastModifiedDate
 import org.springframework.data.mongodb.core.index.CompoundIndex
 import org.springframework.data.mongodb.core.mapping.Document
+import org.springframework.data.mongodb.core.mapping.DocumentReference
 import java.time.Instant
 
 @Document
 @EqualsAndHashCode
 @CompoundIndex(def = "{'name': 1, 'partyAbbreviation': 1, 'electionName': 1}")
 class Nomination {
-    @EqualsAndHashCode.Exclude
-    @Id
-    var id: ObjectId? = null
+  @EqualsAndHashCode.Exclude
+  @Id
+  var id: ObjectId? = null
 
-    @EqualsAndHashCode.Exclude
-    @CreatedDate
-    var created: Instant? = null
+  @EqualsAndHashCode.Exclude
+  @CreatedDate
+  var created: Instant? = null
 
-    @EqualsAndHashCode.Exclude
-    @LastModifiedDate
-    var lastModified: Instant? = null
+  @EqualsAndHashCode.Exclude
+  @LastModifiedDate
+  var lastModified: Instant? = null
 
-    var name: String = ""
-    var partyAbbreviation: String = ""
-    var electionName: String = ""
-    var candidates: Collection<Candidate> = emptyList()
-    var supportVotesOnNomination = false
+  var name: String = ""
+  var partyAbbreviation: String = ""
+  var electionName: String = ""
+
+  @DocumentReference
+  var candidates: Collection<Candidate> = emptyList()
+  var supportVotesOnNomination = false
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/monitoring/actuator/RestHealthIndicator.kt

@@ -1,6 +1,7 @@
 package de.twomartens.wahlrecht.monitoring.actuator
 
 import de.twomartens.wahlrecht.interceptor.HeaderInterceptorRest
+import de.twomartens.wahlrecht.property.ServiceProperties
 import org.springframework.boot.actuate.health.Health
 import org.springframework.boot.actuate.health.HealthIndicator
 import org.springframework.boot.actuate.health.Status
@@ -28,8 +29,10 @@ import java.time.Clock
  */
 @Component
 class RestHealthIndicator(
-    clock: Clock, interceptor: HeaderInterceptorRest,
-    serverProperties: ServerProperties, private val restTemplateRestHealthIndicator: RestTemplate
+        clock: Clock, interceptor: HeaderInterceptorRest,
+        serverProperties: ServerProperties,
+        private val restTemplateRestHealthIndicator: RestTemplate,
+        private val serviceProperties: ServiceProperties
 ) : AbstractHealthIndicator(clock, Preparable { interceptor.markAsHealthCheck() }), HealthIndicator {
     private val randomizer = SecureRandom()
     private val urlPrefix: String = (HTTP_PREFIX + HOST + HOST_PORT_SEPARATOR
@@ -43,10 +46,10 @@ class RestHealthIndicator(
         val random = randomizer.nextInt(100000, 999999).toString()
         val url = "$urlPrefix{random}"
         val response = restTemplateRestHealthIndicator.getForEntity(url, String::class.java, random)
-        val status = if (response.body == random) Status.UP else Status.DOWN
+        val status = if (response.body == serviceProperties.greeting.format(random)) Status.UP else Status.DOWN
         return Health.status(status)
-            .withDetail(DETAIL_ENDPOINT_KEY, url)
-            .build()
+                .withDetail(DETAIL_ENDPOINT_KEY, url)
+                .build()
     }
 
     companion object {

module-server/src/main/kotlin/de/twomartens/wahlrecht/property/ServiceProperties.kt

@@ -2,11 +2,13 @@ package de.twomartens.wahlrecht.property
 
 import io.swagger.v3.oas.annotations.media.Schema
 import org.springframework.boot.context.properties.ConfigurationProperties
-import org.springframework.boot.context.properties.bind.ConstructorBinding
 import org.springframework.cloud.context.config.annotation.RefreshScope
 import java.time.ZoneId
 
 @RefreshScope
 @ConfigurationProperties(prefix = "de.twomartens.wahlrecht")
 @Schema(description = "Properties, to configure this Application")
-data class ServiceProperties @ConstructorBinding constructor(val defaultTimeZone: ZoneId, val greeting: String)
+class ServiceProperties {
+    lateinit var defaultTimeZone: ZoneId
+    lateinit var greeting: String
+}

module-server/src/main/kotlin/de/twomartens/wahlrecht/repository/CandidateRepository.kt

@@ -1,6 +1,31 @@
 package de.twomartens.wahlrecht.repository
 
 import de.twomartens.wahlrecht.model.db.Candidate
-import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
 
-interface CandidateRepository : MongoRepository<Candidate, String>
+interface CandidateRepository : ReactiveMongoRepository<Candidate, String> {
+  fun findByName(name: String): Mono<Candidate>
+
+  fun findAndModify(new: Candidate): Mono<Candidate> {
+    val existing = findByName(new.name)
+    return existing.hasElement().flatMap { hasElement ->
+      if (hasElement) {
+        existing.flatMap { old ->
+          old.profession = new.profession
+          save(old)
+        }
+      } else {
+        save(new)
+      }
+    }
+  }
+
+  fun findAllAndModify(new: Collection<Candidate>): Flux<Candidate> {
+    val existing = new.map {
+      findAndModify(it)
+    }
+    return Flux.merge(existing)
+  }
+}

module-server/src/main/kotlin/de/twomartens/wahlrecht/repository/ConstituencyRepository.kt

@@ -1,6 +1,27 @@
 package de.twomartens.wahlrecht.repository
 
 import de.twomartens.wahlrecht.model.db.Constituency
-import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository
+import reactor.core.publisher.Mono
 
-interface ConstituencyRepository : MongoRepository<Constituency, String>
+interface ConstituencyRepository : ReactiveMongoRepository<Constituency, String> {
+  fun findByElectionNameAndNumber(electionName: String, number: Int): Mono<Constituency>
+
+  fun findAndModify(new: Constituency): Mono<Constituency> {
+    val existing = findByElectionNameAndNumber(
+        new.electionName,
+        new.number)
+
+    return existing.hasElement().flatMap { hasElement ->
+      if (hasElement) {
+        existing.flatMap { old ->
+          old.name = new.name
+          old.numberOfSeats = new.numberOfSeats
+          save(old)
+        }
+      } else {
+        save(new)
+      }
+    }
+  }
+}

module-server/src/main/kotlin/de/twomartens/wahlrecht/repository/ElectionRepository.kt

@@ -1,6 +1,27 @@
 package de.twomartens.wahlrecht.repository
 
 import de.twomartens.wahlrecht.model.db.Election
-import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuple2
 
-interface ElectionRepository : MongoRepository<Election, String>
+interface ElectionRepository : ReactiveMongoRepository<Election, String> {
+  fun findByName(name: String): Mono<Election>
+
+  fun findAndModify(new: Election): Mono<Tuple2<Boolean, Election>> {
+    val electionName = new.name
+    val existing = findByName(electionName)
+    return existing.hasElement().flatMap { hasElement ->
+      if (hasElement) {
+        existing.flatMap { old ->
+          old.constituencies = new.constituencies
+          old.totalNumberOfSeats = new.totalNumberOfSeats
+          old.votingThreshold = new.votingThreshold
+          Mono.just(false).zipWith(save(old))
+        }
+      } else {
+        Mono.just(true).zipWith(save(new))
+      }
+    }
+  }
+}

module-server/src/main/kotlin/de/twomartens/wahlrecht/repository/ElectionResultRepository.kt

@@ -1,6 +1,25 @@
 package de.twomartens.wahlrecht.repository
 
 import de.twomartens.wahlrecht.model.db.ElectionResult
-import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuple2
 
-interface ElectionResultRepository : MongoRepository<ElectionResult, String>
+interface ElectionResultRepository : ReactiveMongoRepository<ElectionResult, String> {
+  fun findByElectionName(electionName: String): Mono<ElectionResult>
+
+  fun findAndModify(new: ElectionResult): Mono<Tuple2<Boolean, ElectionResult>> {
+    val existing = findByElectionName(new.electionName)
+    return existing.hasElement().flatMap { hasElement ->
+      if (hasElement) {
+        existing.flatMap { old ->
+          old.overallResults = new.overallResults
+          old.constituencyResults = new.constituencyResults
+          Mono.just(false).zipWith(save(old))
+        }
+      } else {
+        Mono.just(true).zipWith(save(new))
+      }
+    }
+  }
+}

module-server/src/main/kotlin/de/twomartens/wahlrecht/repository/NominationRepository.kt

@@ -1,6 +1,31 @@
 package de.twomartens.wahlrecht.repository
 
 import de.twomartens.wahlrecht.model.db.Nomination
-import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository
+import reactor.core.publisher.Mono
+import reactor.core.scheduler.Schedulers
 
-interface NominationRepository : MongoRepository<Nomination, String>
+interface NominationRepository : ReactiveMongoRepository<Nomination, String> {
+  fun findByElectionNameAndPartyAbbreviationAndName(electionName: String,
+                                                             abbreviation: String,
+                                                             name: String): Mono<Nomination>
+
+  fun findAndModify(new: Nomination): Mono<Nomination> {
+    val existing = findByElectionNameAndPartyAbbreviationAndName(
+        new.electionName,
+        new.partyAbbreviation,
+        new.name
+    )
+    return existing.hasElement().flatMap { hasElement ->
+      if (hasElement) {
+        existing.publishOn(Schedulers.boundedElastic()).publishOn(Schedulers.boundedElastic()).flatMap { old ->
+          old.supportVotesOnNomination = new.supportVotesOnNomination
+          old.candidates = new.candidates
+          save(old)
+        }
+      } else {
+        save(new)
+      }
+    }
+  }
+}

module-server/src/main/kotlin/de/twomartens/wahlrecht/repository/PartyRepository.kt

@@ -1,8 +1,30 @@
 package de.twomartens.wahlrecht.repository
 
 import de.twomartens.wahlrecht.model.db.PartyInElection
-import org.springframework.data.mongodb.repository.MongoRepository
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuple2
 
-interface PartyRepository : MongoRepository<PartyInElection, String> {
-    fun findByElectionName(name: String): Collection<PartyInElection>
+interface PartyRepository : ReactiveMongoRepository<PartyInElection, String> {
+
+  fun findByElectionName(name: String): Flux<PartyInElection>
+
+  fun findByElectionNameAndAbbreviation(electionName: String, abbreviation: String): Mono<PartyInElection>
+
+  fun findAndModify(party: PartyInElection): Mono<Tuple2<Boolean, PartyInElection>> {
+    val existing = findByElectionNameAndAbbreviation(party.electionName, party.abbreviation)
+    return existing.hasElement().flatMap { hasElement ->
+      if (hasElement) {
+        existing.flatMap { old ->
+          old.name = party.name
+          old.overallNomination = party.overallNomination
+          old.constituencyNominations = party.constituencyNominations
+          Mono.just(false).zipWith(save(old))
+        }
+      } else {
+        Mono.just(true).zipWith(save(party))
+      }
+    }
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/CalculationService.kt

@@ -17,9 +17,9 @@ class CalculationService(
         log.info("Calculate election result for election {}", electionResult.electionName)
         val stopWatch = StopWatch()
         stopWatch.start("determineElectedCandidates")
-        val election = electionService.getElectionInternal(electionResult.electionName)
+        val election = electionService.getElectionInternal(electionResult.electionName).block()
         val seatResult = calculateOverallSeatDistribution(
-            election,
+            election!!,
             electionResult.overallResults
         )
         val constituencyResults: MutableMap<Int, ElectedResult> = HashMap()
@@ -192,8 +192,8 @@ class CalculationService(
             .toMap()
             .toMutableMap()
         val nominationId = votingResult.nominationId
-        val nomination = nominationService.getNominationInternal(nominationId)
-        if (nomination.supportsVotesOnNomination()) {
+        val nomination = nominationService.getNominationInternal(nominationId).block()
+        if (nomination!!.supportsVotesOnNomination()) {
             val seatsByNomination = calculateSeatsByNominationOrder(votingResult, numberOfSeats)
             seatsByVoteOrder = numberOfSeats - seatsByNomination
             val candidates = nomination.getCandidates()

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/CandidateService.kt

@@ -3,33 +3,17 @@ package de.twomartens.wahlrecht.service
 import de.twomartens.wahlrecht.model.db.Candidate
 import de.twomartens.wahlrecht.repository.CandidateRepository
 import org.springframework.stereotype.Service
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
 
 @Service
 class CandidateService(private val repository: CandidateRepository) {
-    private val candidates: MutableMap<String, Candidate> by lazy {
-        fetchCandidates()
-    }
 
-    fun storeCandidate(candidate: Candidate): Candidate {
-        var result = candidate
-        val existing = candidates[candidate.name]
-        val needsUpdate = candidate != existing
-        if (!needsUpdate && existing != null) {
-            return existing
-        }
-        if (existing != null) {
-            existing.profession = candidate.profession
-            result = existing
-        }
-        result = repository.save(result)
-        candidates[candidate.name] = candidate
-        return result
-    }
+  fun storeCandidate(candidate: Candidate): Mono<Candidate> {
+    return repository.findAndModify(candidate)
+  }
 
-    private fun fetchCandidates(): MutableMap<String, Candidate> {
-        return repository.findAll().asSequence()
-            .map { Pair(it.name, it) }
-            .toMap()
-            .toMutableMap()
-    }
+  fun storeCandidates(candidates: Collection<Candidate>): Flux<Candidate> {
+    return Flux.merge(candidates.map { storeCandidate(it) })
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/ConstituencyService.kt

@@ -1,40 +1,14 @@
 package de.twomartens.wahlrecht.service
 
 import de.twomartens.wahlrecht.model.db.Constituency
-import de.twomartens.wahlrecht.model.internal.ConstituencyId
 import de.twomartens.wahlrecht.repository.ConstituencyRepository
 import org.springframework.stereotype.Service
+import reactor.core.publisher.Flux
 
 @Service
 class ConstituencyService(private val repository: ConstituencyRepository) {
-    private val constituencies: MutableMap<ConstituencyId, Constituency> by lazy {
-        fetchConstituencies()
-    }
 
-    fun storeConstituency(constituency: Constituency): Constituency {
-        var result = constituency
-        val constituencyId = ConstituencyId(
-            constituency.electionName,
-            constituency.number
-        )
-        val existing = constituencies[constituencyId]
-        if (constituency == existing) {
-            return existing
-        }
-        if (existing != null) {
-            existing.numberOfSeats = constituency.numberOfSeats
-            existing.name = constituency.name
-            result = existing
-        }
-        val stored = repository.save(result)
-        constituencies[constituencyId] = stored
-        return stored
-    }
-
-    private fun fetchConstituencies(): MutableMap<ConstituencyId, Constituency> {
-        return repository.findAll().asSequence()
-            .map { Pair(ConstituencyId(electionName = it.electionName, number = it.number), it) }
-            .toMap()
-            .toMutableMap()
-    }
+  fun storeConstituencies(constituencies: Collection<Constituency>): Flux<Constituency> {
+    return Flux.merge(constituencies.map { repository.findAndModify(it) })
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/ElectionResultService.kt

@@ -5,45 +5,20 @@ import de.twomartens.wahlrecht.repository.ElectionResultRepository
 import org.springframework.http.HttpStatus
 import org.springframework.stereotype.Service
 import org.springframework.web.server.ResponseStatusException
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuple2
 
 @Service
 class ElectionResultService(private val repository: ElectionResultRepository) {
-    private val electionResults: MutableMap<String, ElectionResult> by lazy {
-        fetchResults()
-    }
-    fun getElectionResult(electionName: String): ElectionResult {
-        return electionResults[electionName]
-            ?: throw ResponseStatusException(
-                HttpStatus.NOT_FOUND,
-                "no election result found for $electionName"
-            )
-    }
 
-    fun storeResult(electionResult: ElectionResult): Boolean {
-        var result = electionResult
+  fun getElectionResult(electionName: String): Mono<ElectionResult> {
+    return repository.findByElectionName(electionName)
+        .switchIfEmpty(Mono.error(
+            ResponseStatusException(HttpStatus.NOT_FOUND, "no election result found for $electionName")
+        ))
+  }
 
-        val id = result.electionName
-        val existing = electionResults[id]
-        val needsUpdate = result != existing
-        if (!needsUpdate) {
-            return false
-        }
-        var createdNew = true
-        if (existing != null) {
-            existing.overallResults = result.overallResults
-            existing.constituencyResults = result.constituencyResults
-            result = existing
-            createdNew = false
-        }
-        val stored = repository.save(result)
-        electionResults[id] = stored
-        return createdNew
-    }
-
-    private fun fetchResults(): MutableMap<String, ElectionResult> {
-        return repository.findAll().asSequence()
-            .map { Pair(it.electionName, it) }
-            .toMap()
-            .toMutableMap()
-    }
+  fun storeResult(new: ElectionResult): Mono<Tuple2<Boolean, ElectionResult>> {
+    return repository.findAndModify(new)
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/ElectionService.kt

@@ -1,60 +1,35 @@
 package de.twomartens.wahlrecht.service
 
 import de.twomartens.wahlrecht.mapper.v1.ElectionMapper
-import de.twomartens.wahlrecht.model.db.Constituency
 import de.twomartens.wahlrecht.model.db.Election
 import de.twomartens.wahlrecht.repository.ElectionRepository
 import org.mapstruct.factory.Mappers
 import org.springframework.stereotype.Service
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuple2
 
 @Service
 class ElectionService(
-    private val electionRepository: ElectionRepository,
-    private val constituencyService: ConstituencyService
+    private val electionRepository: ElectionRepository
 ) {
-    private val electionMapper = Mappers.getMapper(ElectionMapper::class.java)
-    private val _elections: MutableMap<String, Election> by lazy {
-        fetchElections()
-    }
+  private val electionMapper = Mappers.getMapper(ElectionMapper::class.java)
 
-    val elections: Map<String, Election> = _elections
+  fun getElections(): Flux<Election> {
+    return electionRepository.findAll()
+  }
 
-    private fun getElection(electionName: String): Election? {
-        return elections[electionName]
-    }
+  fun findElectionByName(electionName: String): Mono<Election> {
+    return electionRepository.findByName(electionName)
+  }
 
-    fun getElectionInternal(electionName: String): de.twomartens.wahlrecht.model.internal.Election {
-        return electionMapper.mapToInternal(getElection(electionName)!!)
+  fun getElectionInternal(electionName: String): Mono<de.twomartens.wahlrecht.model.internal.Election> {
+    return findElectionByName(electionName).map {
+      electionMapper.mapToInternal(it)
     }
+  }
 
-    fun storeElection(election: Election): Boolean {
-        var result = election
-        var createdNew = true
-        val electionName = election.name
-        val existing = elections[electionName]
-        if (election == existing) {
-            return false
-        }
-        val constituencies: MutableCollection<Constituency> = mutableListOf()
-        result.constituencies
-            .forEach { constituencies.add(constituencyService.storeConstituency(it)) }
-        if (existing != null) {
-            existing.day = election.day
-            existing.totalNumberOfSeats = election.totalNumberOfSeats
-            existing.votingThreshold = election.votingThreshold
-            result = existing
-            createdNew = false
-        }
-        result.constituencies = constituencies
-        val stored = electionRepository.save(result)
-        _elections[electionName] = stored
-        return createdNew
-    }
-
-    private fun fetchElections(): MutableMap<String, Election> {
-        return electionRepository.findAll().asSequence()
-            .map { Pair(it.name, it) }
-            .toMap()
-            .toMutableMap()
-    }
+  fun storeElection(new: Election): Mono<Tuple2<Boolean, Election>> {
+    return electionRepository.findAndModify(new)
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/NominationService.kt

@@ -1,69 +1,41 @@
 package de.twomartens.wahlrecht.service
 
 import de.twomartens.wahlrecht.mapper.v1.NominationMapper
-import de.twomartens.wahlrecht.model.db.Candidate
 import de.twomartens.wahlrecht.model.db.Nomination
 import de.twomartens.wahlrecht.model.internal.NominationId
 import de.twomartens.wahlrecht.repository.NominationRepository
 import org.mapstruct.factory.Mappers
 import org.springframework.stereotype.Service
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
 
 @Service
 class NominationService(
-    private val repository: NominationRepository,
-    private val candidateService: CandidateService
+    private val repository: NominationRepository
 ) {
-    private val mapper = Mappers.getMapper(NominationMapper::class.java)
-    private val nominations: MutableMap<NominationId, Nomination> by lazy {
-        fetchNominations()
-    }
+  private val mapper = Mappers.getMapper(NominationMapper::class.java)
 
-    fun getNominationInternal(id: NominationId): de.twomartens.wahlrecht.model.internal.Nomination {
-        return mapper.mapToInternal(getNomination(id)!!)
+  fun getNominationInternal(id: NominationId): Mono<de.twomartens.wahlrecht.model.internal.Nomination> {
+    return getNomination(id).map {
+      mapper.mapToInternal(it)
     }
+  }
 
-    fun storeNomination(nomination: Nomination?): Nomination? {
-        if (nomination == null) return null
-        val nominationId = NominationId(
-            nomination.electionName,
-            nomination.partyAbbreviation,
-            nomination.name
-        )
-        val existing = nominations[nominationId]
-        val needsUpdate = nomination != existing
-        if (!needsUpdate) {
-            return existing
-        }
-        var result: Nomination = nomination
-        val candidates: MutableCollection<Candidate> = ArrayList()
-        result.candidates
-            .forEach { candidates.add(candidateService.storeCandidate(it)) }
-        if (existing != null) {
-            result = existing
-        }
-        result.candidates = candidates
-        result = repository.save(nomination)
-        nominations[nominationId] = result
-        return result
-    }
+  fun storeNomination(new: Nomination?): Mono<Nomination> {
+    if (new == null) return Mono.empty()
 
-    private fun getNomination(id: NominationId): Nomination? {
-        return nominations[id]
-    }
+    return repository.findAndModify(new)
+  }
 
-    private fun fetchNominations(): MutableMap<NominationId, Nomination> {
-        return repository.findAll().asSequence()
-            .map {
-                Pair(
-                    NominationId(
-                        electionName = it.electionName,
-                        partyAbbreviation = it.partyAbbreviation,
-                        name = it.name
-                    ),
-                    it
-                )
-            }
-            .toMap()
-            .toMutableMap()
-    }
+  fun storeNominations(new: Collection<Nomination>): Flux<Nomination> {
+    return Flux.merge(new.map { storeNomination(it) })
+  }
+
+  private fun getNomination(id: NominationId): Mono<Nomination> {
+    return repository.findByElectionNameAndPartyAbbreviationAndName(
+        id.electionName,
+        id.partyAbbreviation,
+        id.name
+    )
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/PartyService.kt

@@ -1,66 +1,32 @@
 package de.twomartens.wahlrecht.service
 
-import de.twomartens.wahlrecht.model.db.Nomination
 import de.twomartens.wahlrecht.model.db.PartyInElection
-import de.twomartens.wahlrecht.model.internal.PartyId
 import de.twomartens.wahlrecht.repository.PartyRepository
 import org.springframework.http.HttpStatus
 import org.springframework.stereotype.Service
 import org.springframework.web.server.ResponseStatusException
+import reactor.core.publisher.Flux
+import reactor.core.publisher.Mono
+import reactor.util.function.Tuple2
 
 @Service
 class PartyService(
-    private val partyRepository: PartyRepository,
-    private val nominationService: NominationService
+    private val partyRepository: PartyRepository
 ) {
 
-    private val parties: MutableMap<PartyId, PartyInElection> by lazy {
-        fetchParties()
-    }
+  fun getPartiesByElectionName(electionName: String): Flux<PartyInElection> {
+    return partyRepository.findByElectionName(electionName)
+        .switchIfEmpty(Flux.error(
+            ResponseStatusException(HttpStatus.NOT_FOUND, "no party found for $electionName")
+        ))
+  }
 
-    fun getPartiesByElectionName(electionName: String): Collection<PartyInElection> {
-        val parties = partyRepository.findByElectionName(electionName)
-        if (parties.isEmpty()) {
-            throw ResponseStatusException(HttpStatus.NOT_FOUND, "no party found for $electionName")
-        }
-        return parties
-    }
+  fun getPartyByElectionNameAndAbbreviation(electionName: String,
+                                            abbreviation: String): Mono<PartyInElection> {
+    return partyRepository.findByElectionNameAndAbbreviation(electionName, abbreviation)
+  }
 
-    fun storeParty(partyInElection: PartyInElection): Boolean {
-        var result = partyInElection
-        var createdNew = true
-        val partyId = PartyId(
-            partyInElection.electionName,
-            partyInElection.abbreviation
-        )
-        val existing = parties[partyId]
-        val needsUpdate = partyInElection != existing
-        if (!needsUpdate) {
-            return false
-        }
-        val constituencyNominations: MutableMap<Int, Nomination> = mutableMapOf()
-        result.constituencyNominations
-            .forEach { constituencyNominations[it.key] = nominationService.storeNomination(it.value)!! }
-        if (existing != null) {
-            existing.name = partyInElection.name
-            if (constituencyNominations.isEmpty()) {
-                constituencyNominations.putAll(existing.constituencyNominations)
-            }
-            result = existing
-            createdNew = false
-        }
-        partyInElection.constituencyNominations = constituencyNominations
-        partyInElection.overallNomination = nominationService.storeNomination(partyInElection.overallNomination)!!
-        result = partyRepository.save(result)
-        parties[partyId] = result
-        return createdNew
-    }
-
-    private fun fetchParties(): MutableMap<PartyId, PartyInElection> {
-        val allParties = partyRepository.findAll()
-        return allParties.asSequence()
-            .map { Pair(PartyId(electionName = it.electionName, abbreviation = it.abbreviation), it) }
-            .toMap()
-            .toMutableMap()
-    }
+  fun storeParty(new: PartyInElection): Mono<Tuple2<Boolean, PartyInElection>> {
+    return partyRepository.findAndModify(new)
+  }
 }

module-server/src/main/kotlin/de/twomartens/wahlrecht/service/PropertyReloadService.kt

@@ -1,41 +0,0 @@
-package de.twomartens.wahlrecht.service
-
-import mu.KotlinLogging
-import org.apache.logging.log4j.message.StringMapMessage
-import org.springframework.beans.factory.annotation.Qualifier
-import org.springframework.cloud.context.refresh.ContextRefresher
-import org.springframework.scheduling.annotation.Scheduled
-import org.springframework.stereotype.Service
-import java.util.concurrent.TimeUnit
-
-/**
- * automatically reloads application*.yaml. reload can also be triggered manually by doing a post
- * request on http://localhost:12001/actuator/refresh
- */
-@Service
-class PropertyReloadService(@Qualifier("configDataContextRefresher") private val contextRefresher: ContextRefresher) {
-    @Scheduled(
-        fixedDelay = REFRESH_SECONDS.toLong(),
-        initialDelay = REFRESH_SECONDS.toLong(),
-        timeUnit = TimeUnit.SECONDS
-    )
-    fun refresh() {
-        val properties = contextRefresher.refresh()
-        if (properties.isNotEmpty()) {
-            log.info(
-                StringMapMessage()
-                    .with(PARAM_MESSAGE, "properties changed")
-                    .with(PARAM_PROPERTIES, properties.joinToString("\n"))
-                    .asString()
-            )
-        }
-    }
-
-    companion object {
-        const val REFRESH_SECONDS = 60
-        const val PARAM_MESSAGE = "message"
-        const val PARAM_PROPERTIES = "labels.properties"
-
-        private val log = KotlinLogging.logger {}
-    }
-}

module-server/src/main/resources/application-dev.yaml

@@ -1,2 +1,9 @@
 server.port: 12000
 management.server.port: 12001
+
+
+spring:
+  config:
+    import:
+      - "classpath:config/wahlrecht.yaml"
+      - "optional:configserver:http://localhost:8888/config"

module-server/src/main/resources/application-prod.yaml

@@ -0,0 +1,7 @@
+spring:
+  config:
+    import:
+      - "configserver:http://configserver:8888/config"
+  kafka:
+    bootstrap-servers:
+      - kafka:9092

module-server/src/main/resources/application.yaml

@@ -23,8 +23,9 @@ management:
     http.server.requests: true
 
 spring:
-  config:
-    import: "optional:configserver:http://localhost:8888/config"
+  cloud:
+    config:
+      name: wahlrecht
   main:
     banner-mode: off
   profiles:
@@ -40,17 +41,6 @@ spring:
   application:
     name: wahlrecht
 
-
-# properties for application
-de.twomartens.wahlrecht:
-  defaultTimeZone: Europe/Berlin
-  greeting: "Hello %s"
-  statusprobe:
-    scheduleDuration: 60
-    maxKafkaFailureDuration: 5
-    maxBlobFailureCount: 5
-    maxFailurePercent: 50
-
 springdoc:
   swagger-ui:
     display-request-duration: true

module-server/src/main/resources/config/wahlrecht-prod.yaml

@@ -0,0 +1,2 @@
+de.twomartens.wahlrecht:
+  greeting: "Moin %s, you are test"

module-server/src/main/resources/config/wahlrecht.yaml

@@ -0,0 +1,8 @@
+de.twomartens.wahlrecht:
+  defaultTimeZone: Europe/Berlin
+  greeting: "Hello %s, on millenium"
+  statusprobe:
+    scheduleDuration: 60
+    maxKafkaFailureDuration: 5
+    maxBlobFailureCount: 5
+    maxFailurePercent: 50