Skip to content

Commit

Permalink
OK-356 Parannettu testejä
Browse files Browse the repository at this point in the history
  • Loading branch information
@jkorri
jkorri committed Jan 12, 2024
1 parent d113d86 commit c05652c
Show file tree
Hide file tree
Showing 2 changed files with 68 additions and 13 deletions.
18 changes: 17 additions & 1 deletion integraatio/src/test/scala/fi/oph/viestinvalitys/BaseIntegraatioTesti.scala
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import com.fasterxml.jackson.databind.ObjectMapper
import com.github.dockerjava.api.model.{ExposedPort, HostConfig, PortBinding, Ports}
import com.nimbusds.jose.util.StandardCharset
import fi.oph.viestinvalitys.BaseIntegraatioTesti.*
import fi.oph.viestinvalitys.business.{Kieli, Prioriteetti, SisallonTyyppi, VastaanottajanTila}
import fi.oph.viestinvalitys.business.{KantaOperaatiot, Kieli, Prioriteetti, SisallonTyyppi, VastaanottajanTila}
import fi.oph.viestinvalitys.util.{AwsUtil, DbUtil}
import fi.oph.viestinvalitys.vastaanotto.model.Viesti.Vastaanottaja
import fi.oph.viestinvalitys.vastaanotto.model.*
Expand Down Expand Up @@ -37,6 +37,8 @@ import org.testcontainers.containers.{GenericContainer, PostgreSQLContainer}
import org.testcontainers.containers.localstack.LocalStackContainer
import org.testcontainers.containers.localstack.LocalStackContainer.Service
import org.testcontainers.utility.DockerImageName
import org.postgresql.ds.PGSimpleDataSource
import slick.jdbc.JdbcBackend.Database

import java.util.{Optional, UUID}
import scala.concurrent.ExecutionContext.Implicits.global
Expand Down Expand Up @@ -87,6 +89,17 @@ class BaseIntegraatioTesti {
.withCreateContainerCmdModifier(m => m.withHostConfig(new HostConfig()
.withPortBindings(new PortBinding(Ports.Binding.bindPort(redisPort), new ExposedPort(6379)))))

private def getDatasource() =
val ds: PGSimpleDataSource = new PGSimpleDataSource()
ds.setServerNames(Array("localhost"))
ds.setDatabaseName("viestinvalitys")
ds.setPortNumbers(Array(postgres.getMappedPort(5432)))
ds.setUser("app")
ds.setPassword("app")
ds

var kantaOperaatiot: KantaOperaatiot = null

// kontteja ei voi käynnistää vasta @BeforeAll-metodissa koska spring-konteksti rakennetaan ennen sitä
val setupDone = {
localstack.start()
Expand All @@ -98,6 +111,9 @@ class BaseIntegraatioTesti {
System.setProperty("spring.data.redis.port", redis.getMappedPort(6379).toString)

LocalUtil.setupLocal()

val database = Database.forDataSource(getDatasource(), Option.empty)
kantaOperaatiot = KantaOperaatiot(database)
true
}

Expand Down
63 changes: 51 additions & 12 deletions integraatio/src/test/scala/fi/oph/viestinvalitys/IntegraatioTest.scala
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ package fi.oph.viestinvalitys
import com.fasterxml.jackson.databind.ObjectMapper
import com.nimbusds.jose.util.StandardCharset
import fi.oph.viestinvalitys.util.{AwsUtil, DbUtil}
import fi.oph.viestinvalitys.business.{Kieli, Kontakti, Prioriteetti, SisallonTyyppi, VastaanottajanTila}
import fi.oph.viestinvalitys.business.{Kieli, Kontakti, Lahetys, Liite, LiitteenTila, Prioriteetti, SisallonTyyppi, VastaanottajanTila, Viesti}
import fi.oph.viestinvalitys.vastaanotto.model.Viesti.Vastaanottaja
import fi.oph.viestinvalitys.vastaanotto.model.{LahettajaImpl, LahetysImpl, VastaanottajaImpl, ViestiImpl, ViestiValidator}
import fi.oph.viestinvalitys.vastaanotto.model.{LahettajaImpl, LahetysImpl, LahetysValidator, MaskiImpl, VastaanottajaImpl, ViestiImpl, ViestiValidator}
import fi.oph.viestinvalitys.vastaanotto.resource.{APIConstants, HealthcheckResource, LuoLahetysFailureResponseImpl, LuoLahetysSuccessResponseImpl, LuoLiiteFailureResponseImpl, LuoLiiteSuccessResponseImpl, LuoViestiFailureResponseImpl, LuoViestiSuccessResponseImpl, PalautaLahetysSuccessResponse, PalautaViestiSuccessResponse, VastaanottajatSuccessResponse}
import fi.oph.viestinvalitys.vastaanotto.security.SecurityConstants
import org.junit.Before
Expand Down Expand Up @@ -40,6 +40,7 @@ import scala.concurrent.{Await, ExecutionContext, Future}
import scala.concurrent.duration.DurationInt
import concurrent.ExecutionContext.Implicits.global
import scala.jdk.CollectionConverters.*
import scala.jdk.OptionConverters.*

/**
* Lähetysapin integraatiotestit. Testeissä on pyritty kattamaan kaikkien endpointtien kaikki eri paluuarvoihin
Expand Down Expand Up @@ -67,27 +68,27 @@ class IntegraatioTest extends BaseIntegraatioTesti {
sisalto = Optional.of("Sisalto"),
sisallonTyyppi = Optional.of(SisallonTyyppi.TEXT.toString.toLowerCase),
kielet = Optional.of(java.util.List.of("fi")),
maskit = Optional.empty(),
lahettavanVirkailijanOid = Optional.empty(),
maskit = Optional.of(java.util.List.of(MaskiImpl(Optional.of("salaisuus"), Optional.of("maskattu")))),
lahettavanVirkailijanOid = Optional.of(LahetysValidator.VALIDATION_OPH_OID_PREFIX + ".111"),
lahettaja = Optional.of(LahettajaImpl(Optional.empty(), Optional.of("[email protected]"))),
replyTo = Optional.empty,
replyTo = Optional.of("[email protected]"),
vastaanottajat = Optional.of(vastaanottajat),
liitteidenTunnisteet = liitteidenTunnisteet,
lahettavaPalvelu = Optional.of("hakemuspalvelu"),
lahetysTunniste = Optional.empty(),
prioriteetti = Optional.of(prioriteetti),
sailytysaika = Optional.of(1),
kayttooikeusRajoitukset = Optional.empty(),
metadata = Optional.empty()
kayttooikeusRajoitukset = Optional.of(java.util.List.of("RAJOITUS1_1.2.3")),
metadata = Optional.of(java.util.Map.of("avain", java.util.List.of("arvo1", "arvo2")))
)

def getLahetys(): LahetysImpl =
LahetysImpl(
Optional.of("Otsikko"),
Optional.of("Palvelu"),
Optional.empty(),
Optional.of(LahetysValidator.VALIDATION_OPH_OID_PREFIX + ".111"),
Optional.of(LahettajaImpl(Optional.empty(), Optional.of("[email protected]"))),
Optional.empty(),
Optional.of("[email protected]"),
Optional.of(LahetysImpl.LAHETYS_PRIORITEETTI_NORMAALI),
Optional.of(1)
)
Expand Down Expand Up @@ -153,11 +154,25 @@ class IntegraatioTest extends BaseIntegraatioTesti {
@WithMockUser(value = "kayttaja", authorities = Array(SecurityConstants.SECURITY_ROOLI_LAHETYS_FULL))
@Test def testLuoLahetysAllowed(): Unit =
// käyttäjälle VIESTINVALITYS_LAHETYS-oikeus ja viesti validi, joten lähetys onnistuu
val result = mvc.perform(jsonPost(APIConstants.LUO_LAHETYS_PATH, getLahetys()))
val lahetys = getLahetys();
val result = mvc.perform(jsonPost(APIConstants.LUO_LAHETYS_PATH, lahetys))
.andExpect(status().isOk).andReturn()

val luoLahetysResponse = objectMapper.readValue(result.getResponse.getContentAsString(StandardCharset.UTF_8), classOf[LuoLahetysSuccessResponseImpl])

// varmistetaan että kentät tulevat kantaan oikein
val entiteetti = Lahetys(
luoLahetysResponse.lahetysTunniste,
lahetys.otsikko.get,
"kayttaja",
lahetys.lahettavaPalvelu.get,
lahetys.lahettavanVirkailijanOid.toScala,
Kontakti(lahetys.lahettaja.get.getNimi.toScala, lahetys.lahettaja.get.getSahkopostiOsoite.get),
lahetys.replyTo.toScala,
Prioriteetti.valueOf(lahetys.prioriteetti.get.toUpperCase)
)
Assertions.assertEquals(Some(entiteetti), kantaOperaatiot.getLahetys(luoLahetysResponse.lahetysTunniste))

/**
* Testataan lähetyksen haku
*/
Expand Down Expand Up @@ -368,6 +383,10 @@ class IntegraatioTest extends BaseIntegraatioTesti {
.andExpect(status().isOk).andReturn()
val response = objectMapper.readValue(result.getResponse.getContentAsString, classOf[LuoLiiteSuccessResponseImpl])

// varmistetaan että kentät tallentuvat kantaan oikein
val entiteetti = Liite(response.liiteTunniste, "filename.txt", "text/plain", "sisältö".getBytes.length, "kayttaja", LiitteenTila.SKANNAUS)
Assertions.assertEquals(entiteetti, kantaOperaatiot.getLiitteet(Seq(response.liiteTunniste)).find(l => true).get)

/**
* Testataan viestin luonti
*/
Expand Down Expand Up @@ -404,8 +423,28 @@ class IntegraatioTest extends BaseIntegraatioTesti {
@WithMockUser(value = "kayttaja", authorities=Array(SecurityConstants.SECURITY_ROOLI_LAHETYS_FULL))
@Test def testLuoViestiAllowed(): Unit =
// käyttäjällä VIESTINVALITUS_LAHETYS-oikeus ja viesti validi joten luonti onnistuu
mvc.perform(jsonPost(APIConstants.LUO_VIESTI_PATH, getViesti()))
.andExpect(status().isOk())
val viesti = getViesti()
val result = mvc.perform(jsonPost(APIConstants.LUO_VIESTI_PATH, viesti))
.andExpect(status().isOk()).andReturn()
val response = objectMapper.readValue(result.getResponse.getContentAsString, classOf[LuoViestiSuccessResponseImpl])

// varmistetaan että kentät tallentuvat oikein kantaan
val entiteetti = Viesti(
response.viestiTunniste,
response.lahetysTunniste,
viesti.otsikko.get,
viesti.sisalto.get,
SisallonTyyppi.valueOf(viesti.sisallonTyyppi.get.toUpperCase),
viesti.kielet.get.asScala.map(k => Kieli.valueOf(k.toUpperCase)).toSet,
viesti.maskit.map(l => l.asScala.map(m => m.getSalaisuus.get -> m.getMaski.toScala).toMap).get,
viesti.lahettavaPalvelu.get,
viesti.lahettavanVirkailijanOid.toScala,
Kontakti(viesti.lahettaja.get.getNimi.toScala, viesti.lahettaja.get.getSahkopostiOsoite.get),
viesti.replyTo.toScala,
"kayttaja",
Prioriteetti.valueOf(viesti.prioriteetti.get.toUpperCase)
)
Assertions.assertEquals(entiteetti, kantaOperaatiot.getViestit(Seq(response.viestiTunniste)).find(v => true).get)

@WithMockUser(value = "kayttaja", authorities = Array(SecurityConstants.SECURITY_ROOLI_LAHETYS_FULL))
@Test def testLuoViestiRateLimiter(): Unit =
Expand Down

0 comments on commit c05652c

Please sign in to comment.