Merge pull request #1001 from navikt/grensesnittavstemming-controller

Skal kunne trigge oppstart av grensesnittavstemming via endepunkt. Sj…

Author: charliemidtlyng

src/main/kotlin/no/nav/familie/ef/iverksett/økonomi/grensesnitt/GrensesnittavstemmingController.kt

@@ -0,0 +1,44 @@
+package no.nav.familie.ef.iverksett.økonomi.grensesnitt
+
+import com.fasterxml.jackson.module.kotlin.readValue
+import java.time.LocalDate
+import java.time.LocalDateTime
+import no.nav.familie.ef.iverksett.infrastruktur.advice.ApiFeil
+import no.nav.familie.kontrakter.felles.ef.StønadType
+import no.nav.familie.kontrakter.felles.objectMapper
+import no.nav.familie.prosessering.domene.Status
+import no.nav.familie.prosessering.internal.TaskService
+import no.nav.security.token.support.core.api.ProtectedWithClaims
+import org.springframework.http.HttpStatus
+import org.springframework.validation.annotation.Validated
+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
+
+@RestController
+@RequestMapping("/api/grensesnittavstemming")
+@ProtectedWithClaims(issuer = "azuread")
+@Validated
+class GrensesnittavstemmingController(
+    private val taskService: TaskService,
+) {
+    @PostMapping
+    fun startGrensesnittavstemmingForStønad(
+        @RequestBody grensesnittavstemmingRequest: GrensesnittavstemmingRequestDto,
+    ) {
+        val stønadType = grensesnittavstemmingRequest.stønadType
+        val eksisterendeGrensesnittAvstemmingTasker = taskService.finnTasksMedStatus(listOf(Status.UBEHANDLET, Status.KLAR_TIL_PLUKK), GrensesnittavstemmingTask.TYPE)
+        eksisterendeGrensesnittAvstemmingTasker.forEach { task ->
+            val payload = objectMapper.readValue<GrensesnittavstemmingPayload>(task.payload)
+            if (payload.stønadstype == stønadType) {
+                throw ApiFeil("Det finnes allerede en task for grensesnittavstemming for stønad=$stønadType", HttpStatus.BAD_REQUEST)
+            }
+        }
+        val grensesnittavstemmingDto = GrensesnittavstemmingDto(grensesnittavstemmingRequest.stønadType, LocalDate.now(), LocalDateTime.now())
+        taskService.save(grensesnittavstemmingDto.tilTask())
+    }
+}
+
+data class GrensesnittavstemmingRequestDto(val stønadType: StønadType)
+

src/test/kotlin/no/nav/familie/ef/iverksett/økonomi/grensesnitt/GrensesnittavstemmingControllerTest.kt

@@ -0,0 +1,51 @@
+package no.nav.familie.ef.iverksett.økonomi.grensesnitt
+
+import no.nav.familie.ef.iverksett.ServerTest
+import no.nav.familie.kontrakter.felles.Ressurs
+import no.nav.familie.kontrakter.felles.ef.StønadType
+import no.nav.familie.prosessering.domene.Status
+import no.nav.familie.prosessering.internal.TaskService
+import org.assertj.core.api.Assertions.assertThat
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.web.client.exchange
+import org.springframework.http.HttpEntity
+import org.springframework.http.HttpHeaders
+import org.springframework.http.HttpMethod
+import org.springframework.http.HttpStatus
+import org.springframework.http.MediaType
+import org.springframework.http.ResponseEntity
+
+class GrensesnittavstemmingControllerTest : ServerTest() {
+
+    @Autowired
+    private lateinit var taskService: TaskService
+
+    @BeforeEach
+    fun setUp() {
+        headers.setBearerAuth(søkerBearerToken())
+        headers.set(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
+    }
+
+    @Test
+    fun `skal opprette grensesnittavstemming for overgangsstønad, barnetilsyn og skolepenger`() {
+        StønadType.values().forEachIndexed { index, stønadType ->
+            val antall = index + 1
+            val grensesnittAvstemmingRequest = GrensesnittavstemmingRequestDto(stønadType = stønadType)
+
+            val responsOk: ResponseEntity<Ressurs<Unit>> = startGrensesnittavstemming(grensesnittAvstemmingRequest)
+            val responsDuplikat: ResponseEntity<Ressurs<Unit>> = startGrensesnittavstemming(grensesnittAvstemmingRequest)
+
+            assertThat(responsOk.statusCode.value()).isEqualTo(HttpStatus.OK.value())
+            assertThat(responsDuplikat.statusCode.value()).isEqualTo(HttpStatus.BAD_REQUEST.value())
+            assertThat(taskService.finnTasksMedStatus(listOf(Status.UBEHANDLET, Status.KLAR_TIL_PLUKK), GrensesnittavstemmingTask.TYPE)).hasSize(antall)
+        }
+    }
+
+    private fun startGrensesnittavstemming(grensesnittAvstemmingRequest: GrensesnittavstemmingRequestDto): ResponseEntity<Ressurs<Unit>> = restTemplate.exchange(
+        localhostUrl("/api/grensesnittavstemming"),
+        HttpMethod.POST,
+        HttpEntity(grensesnittAvstemmingRequest, headers),
+    )
+}