integraatiotesti raportointi-apille

Opetushallitus · Dec 5, 2024 · d56d2b8 · d56d2b8
1 parent 6daad69
commit d56d2b8
Show file tree

Hide file tree

Showing 8 changed files with 432 additions and 45 deletions.
diff --git a/integraatio/src/test/scala/fi/oph/viestinvalitys/BaseIntegraatioTesti.scala b/integraatio/src/test/scala/fi/oph/viestinvalitys/BaseIntegraatioTesti.scala
@@ -37,7 +37,7 @@ class BaseIntegraatioTesti {
 
   val LOG = LoggerFactory.getLogger(this.getClass)
 
-  val localstack: LocalStackContainer = new LocalStackContainer(new DockerImageName("localstack/localstack:2.2.0"))
+  val localstack: LocalStackContainer = new LocalStackContainer(DockerImageName.parse("localstack/localstack:2.2.0"))
     .withServices(Service.SQS, Service.SES, Service.CLOUDWATCH)
     .withLogConsumer(frame => LOG.info(frame.getUtf8StringWithoutLineEnding))
     .withExposedPorts(4566)

diff --git a/integraatio/src/test/scala/fi/oph/viestinvalitys/RaportointiApiIntegraatioTest.scala b/integraatio/src/test/scala/fi/oph/viestinvalitys/RaportointiApiIntegraatioTest.scala
diff --git a/...raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OnrService.scala b/...raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OnrService.scala
@@ -36,7 +36,7 @@ class RealONRService() extends ONRService {
     "JSESSIONID"))
 
   def haeAsiointikieli(personOid: String): Either[Throwable, String] =
-    LOG.info("Haetaan tiedot oppijanumerorekisteristä")
+    LOG.debug(s"Haetaan tiedot oppijanumerorekisteristä oidille $personOid")
     val url = s"https://virkailija.$opintopolkuDomain/oppijanumerorekisteri-service/henkilo/$personOid/asiointiKieli"
     fetch(url) match
       case Left(e) => Left(e)

diff --git a/...inti/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OrganisaatioCache.scala b/...inti/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OrganisaatioCache.scala
@@ -22,7 +22,7 @@ class OrganisaatioCache {
 
   val childOidsLoader = new CacheLoader[String, Response[String]] {
     def load(oid: String): Response[String] =
-      LOG.info(s"Ladataan lapsiorganisaatio-cache oidille $oid")
+      LOG.debug(s"Ladataan lapsiorganisaatio-cache oidille $oid")
       val uri: Uri = uri"https://virkailija.$opintopolkuDomain/organisaatio-service/api/$oid/childoids?$queryParams"
       quickRequest
         .headers(headers)
@@ -34,7 +34,7 @@ class OrganisaatioCache {
 
   val parentOidsLoader = new CacheLoader[String, Response[String]] {
     def load(oid: String): Response[String] =
-      LOG.info(s"Ladataan parentorganisaatio-cache oidille $oid")
+      LOG.debug(s"Ladataan parentorganisaatio-cache oidille $oid")
       val uri: Uri = uri"https://virkailija.$opintopolkuDomain/organisaatio-service/api/$oid/parentoids"
       quickRequest
         .headers(headers)

diff --git a/...portointi/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/HenkiloResource.scala b/...portointi/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/HenkiloResource.scala
@@ -30,9 +30,8 @@ class HenkiloResource {
       new ApiResponse(responseCode = "200", description = "Palauttaa asiointikielen"),
     ))
   def getAsiointikieli(request: HttpServletRequest) = {
-    LOG.info("Haetaan asiointikieli")
+    LOG.debug("Haetaan käyttäjän asiointikieli")
     val session: HttpSession = request.getSession(false)
-    LOG.warn(s"sessio: ${session}")
     val result = OnrService.haeAsiointikieli(SecurityContextHolder.getContext.getAuthentication.getName())
     result match
       case Left(e) =>

diff --git a/...portointi/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/LahetysResource.scala b/...portointi/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/LahetysResource.scala
diff --git a/...inti/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/OrganisaatioResource.scala b/...inti/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/OrganisaatioResource.scala
@@ -29,7 +29,7 @@ class OrganisaatioResource {
       new ApiResponse(responseCode = "200", description = "Palauttaa listan organisaatio-oideja"),
     ))
   def getOrganisaatiot(request: HttpServletRequest) = {
-    LOG.info("Haetaan käyttöoikeuksien organisaatiot")
+    LOG.debug("Haetaan käyttöoikeuksien organisaatiot")
     val securityOperaatiot = new SecurityOperaatiot(httpSession = request.getSession(false))
     try
       ResponseEntity.status(HttpStatus.OK).body(write[List[String]](securityOperaatiot.getCasOrganisaatiot().toList))

diff --git a/...tointi/src/main/scala/fi/oph/viestinvalitys/raportointi/security/SecurityOperaatiot.scala b/...tointi/src/main/scala/fi/oph/viestinvalitys/raportointi/security/SecurityOperaatiot.scala
@@ -56,7 +56,6 @@ class SecurityOperaatiot(
     else
       Option(httpSession.getAttribute(SESSION_ATTR_KAYTTOOIKEUDET)) match {
         case Some(_) =>
-          LOG.warn("oikat sessiosta!")
           parseTypedKayttooikeusSetFromSession(httpSession, SESSION_ATTR_KAYTTOOIKEUDET).getOrElse(Set.empty)
 
         case None =>
@@ -84,10 +83,8 @@ class SecurityOperaatiot(
     else
       if (httpSession.getAttribute(SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET) != null
         && eiUusiaTunnisteitaKannassa(httpSession, kantaOperaatiot))
-        LOG.warn("oikkatunnisteet sessiosta!")
         parseTypedTunnisteAttributeFromSession(httpSession, SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET)
       else
-        LOG.warn("oikkatunnisteet kannasta ja laitetaan sessioon!")
         val (tunnisteet, uusinTunniste) = kantaOperaatiot.getKayttooikeusTunnisteet(kayttajanOikeudet.toSeq)
         httpSession.setAttribute(SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET, tunnisteet)
         httpSession.setAttribute(SESSION_ATTR_UUSIN_KAYTTOOIKEUSTUNNISTE, uusinTunniste)