OK-751 käyttöoikeuskäsittelyn tehostamista

lambdat/raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/configuration/SecurityConfiguration.scala

@@ -1,7 +1,6 @@
 package fi.oph.viestinvalitys.raportointi.configuration
 
 import com.zaxxer.hikari.HikariDataSource
-import fi.oph.viestinvalitys.raportointi.App
 import fi.oph.viestinvalitys.raportointi.resource.RaportointiAPIConstants
 import fi.oph.viestinvalitys.util.DbUtil
 import fi.vm.sade.javautils.kayttooikeusclient.OphUserDetailsServiceImpl

lambdat/raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OnrService.scala

@@ -4,7 +4,6 @@ import fi.oph.viestinvalitys.util.ConfigurationUtil
 import fi.vm.sade.javautils.nio.cas.{CasClient, CasClientBuilder}
 import org.asynchttpclient.RequestBuilder
 import org.slf4j.LoggerFactory
-import upickle.default.*
 
 import java.util.concurrent.TimeUnit
 import scala.concurrent.Await

lambdat/raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OrganisaatioCache.scala

@@ -22,6 +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")
       val uri: Uri = uri"https://virkailija.$opintopolkuDomain/organisaatio-service/api/$oid/childoids?$queryParams"
       quickRequest
         .headers(headers)

lambdat/raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/integration/OrganisaatioService.scala

@@ -11,6 +11,7 @@ class OrganisaatioService {
   val LOG = LoggerFactory.getLogger(classOf[OrganisaatioService])
 
   def getAllChildOidsFlat(oid: String): Set[String] =
+    LOG.info(s"Haetaan lapsiorganisaatiot cachesta oidille $oid")
     if (!OrganisaatioOid.isValid(oid))
       LOG.error(s"Organisaation oid $oid on virheellinen")
       throw new RuntimeException(s"Organisaation oid $oid on virheellinen")

lambdat/raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/resource/HenkiloResource.scala

@@ -1,10 +1,11 @@
 package fi.oph.viestinvalitys.raportointi.resource
 
-import fi.oph.viestinvalitys.raportointi.integration.{ONRService}
+import fi.oph.viestinvalitys.raportointi.integration.ONRService
 import fi.oph.viestinvalitys.raportointi.security.SecurityOperaatiot
 import io.swagger.v3.oas.annotations.Operation
 import io.swagger.v3.oas.annotations.responses.ApiResponse
 import io.swagger.v3.oas.annotations.tags.Tag
+import jakarta.servlet.http.{HttpServletRequest, HttpSession}
 import org.slf4j.LoggerFactory
 import org.springframework.http.{HttpStatus, MediaType, ResponseEntity}
 import org.springframework.web.bind.annotation.{GetMapping, RequestMapping, RestController}
@@ -27,8 +28,10 @@ class HenkiloResource {
     responses = Array(
       new ApiResponse(responseCode = "200", description = "Palauttaa asiointikielen"),
     ))
-  def getAsiointikieli() = {
+  def getAsiointikieli(request: HttpServletRequest) = {
     LOG.info("Haetaan asiointikieli")
+    val session: HttpSession = request.getSession(false)
+    LOG.warn(s"sessio: ${session}")
     val securityOperaatiot = new SecurityOperaatiot
     val result = OnrService.haeAsiointikieli(securityOperaatiot.getIdentiteetti())
     result match

lambdat/raportointi/src/main/scala/fi/oph/viestinvalitys/raportointi/security/SecurityOperaatiot.scala

@@ -1,8 +1,10 @@
 package fi.oph.viestinvalitys.raportointi.security
 
-import fi.oph.viestinvalitys.business.Kayttooikeus
+import fi.oph.viestinvalitys.business.{KantaOperaatiot, Kayttooikeus}
 import fi.oph.viestinvalitys.raportointi.integration.OrganisaatioService
-import fi.oph.viestinvalitys.raportointi.security.SecurityConstants.OPH_ORGANISAATIO_OID
+import fi.oph.viestinvalitys.raportointi.security.SecurityConstants.{OPH_ORGANISAATIO_OID, SESSION_ATTR_KAYTTOOIKEUDET, SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET, SESSION_ATTR_UUSIN_KAYTTOOIKEUSTUNNISTE}
+import fi.oph.viestinvalitys.util.DbUtil
+import jakarta.servlet.http.HttpSession
 import org.slf4j.LoggerFactory
 import org.springframework.security.core.context.SecurityContextHolder
 
@@ -24,12 +26,18 @@ object SecurityConstants {
 
   final val LAHETYS_ROLES = Set(SECURITY_ROOLI_LAHETYS_OIKEUS, SECURITY_ROOLI_PAAKAYTTAJA_OIKEUS)
   final val KATSELU_ROLES = Set(SECURITY_ROOLI_KATSELU_OIKEUS, SECURITY_ROOLI_PAAKAYTTAJA_OIKEUS)
+
+  final val SESSION_ATTR_KAYTTOOIKEUDET = "kayttooikeudet"
+  final val SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET = "kayttooikeustunnisteet"
+  final val SESSION_ATTR_UUSIN_KAYTTOOIKEUSTUNNISTE = "uusintunniste"
 }
 
 class SecurityOperaatiot(
-  getOikeudet: () => Seq[String] = () => SecurityContextHolder.getContext.getAuthentication.getAuthorities.asScala.map(a => a.getAuthority).toSeq,
-  getUsername: () => String = () => SecurityContextHolder.getContext.getAuthentication.getName(),
-  organisaatioClient: OrganisaatioService = OrganisaatioService) {
+                          getOikeudet: () => Seq[String] = () => SecurityContextHolder.getContext.getAuthentication.getAuthorities.asScala.map(a => a.getAuthority).toSeq,
+                          getUsername: () => String = () => SecurityContextHolder.getContext.getAuthentication.getName(),
+                          organisaatioClient: OrganisaatioService = OrganisaatioService,
+                          kantaOperaatiot: KantaOperaatiot = new KantaOperaatiot(DbUtil.database),
+                          optionalHttpSession: Option[HttpSession] = None) {
 
   val LOG = LoggerFactory.getLogger(classOf[SecurityOperaatiot])
   final val SECURITY_ROOLI_PREFIX_PATTERN = "^ROLE_"
@@ -45,19 +53,57 @@ class SecurityOperaatiot(
       })
       .toSet
   }
+
+  // säilytetään käyttöoikeudet sessiossa
+  // koska niiden parsiminen aliorganisaatiotasolle kestää jos on runsaasti aliorganisaatiotasoja
   private lazy val kayttajanOikeudet: Set[Kayttooikeus] = {
     val pk = onPaakayttaja()
     if(onPaakayttaja())
       kayttajanCasOikeudet // ei tarvitse mapata kaikkia lapsiorganisaatioita
     else
-      val lapsioikeudet = kayttajanCasOikeudet
-        .filter(kayttajanOikeus => kayttajanOikeus.organisaatio.isDefined)
-        .map(kayttajanOikeus =>
-          organisaatioClient.getAllChildOidsFlat(kayttajanOikeus.organisaatio.get)
-            .map(o => Kayttooikeus(kayttajanOikeus.oikeus, Some(o)))
-        ).flatten
-      kayttajanCasOikeudet ++ lapsioikeudet
+      optionalHttpSession match {
+        case Some(n) if optionalHttpSession.get.getAttribute(SESSION_ATTR_KAYTTOOIKEUDET) != null =>
+          LOG.warn("oikat sessiosta!")
+          parseTypedKayttooikeusSetFromSession(optionalHttpSession.get, SESSION_ATTR_KAYTTOOIKEUDET).getOrElse(Set.empty)
+        case _ =>
+          LOG.warn("parsitaan oikat!")
+          LOG.info("Haetaan käyttöoikeuksien organisaatioiden aliorganisaatiot")
+          val lapsioikeudet = kayttajanCasOikeudet
+            .filter(kayttajanOikeus => kayttajanOikeus.organisaatio.isDefined)
+            .map(kayttajanOikeus =>
+              organisaatioClient.getAllChildOidsFlat(kayttajanOikeus.organisaatio.get)
+                .map(o => Kayttooikeus(kayttajanOikeus.oikeus, Some(o)))).flatten
+          if(optionalHttpSession.isDefined)
+            optionalHttpSession.get.setAttribute(SESSION_ATTR_KAYTTOOIKEUDET, kayttajanCasOikeudet ++ lapsioikeudet)
+          kayttajanCasOikeudet ++ lapsioikeudet
+      }
   }
+
+  // säilytetään käyttöoikeustunnisteet sessiossa
+  // ja virkistetään kannasta vain jos on tullut uusia sen jälkeen kun tunnisteet laitettiin sessioon
+  private lazy val kayttajanKayttooikeustunnisteet: Option[Set[Int]] = {
+    val pk = onPaakayttaja()
+    if (onPaakayttaja())
+      Option.empty
+    else
+      optionalHttpSession match {
+        case None =>
+          LOG.warn("ei sessiota, oikkatunnisteet kannasta!")
+          Option.apply(kantaOperaatiot.getKayttooikeusTunnisteet(kayttajanOikeudet.toSeq))
+        case Some(n) if optionalHttpSession.get.getAttribute(SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET) != null
+          && eiUusiaTunnisteitaKannassa(optionalHttpSession.get, kantaOperaatiot) =>
+          LOG.warn("oikkatunnisteet sessiosta!")
+          parseTypedTunnisteAttributeFromSession(optionalHttpSession.get, SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET)
+        case _ =>
+          LOG.warn("oikkatunnisteet kannasta ja laitetaan sessioon!")
+          val tunnisteet = kantaOperaatiot.getKayttooikeusTunnisteet(kayttajanOikeudet.toSeq)
+          val uusinTunniste = kantaOperaatiot.getUusinKayttooikeusTunniste()
+          optionalHttpSession.get.setAttribute(SESSION_ATTR_KAYTTOOIKEUSTUNNISTEET, tunnisteet)
+          optionalHttpSession.get.setAttribute(SESSION_ATTR_UUSIN_KAYTTOOIKEUSTUNNISTE, uusinTunniste)
+          Some(tunnisteet)
+      }
+  }
+
   val identiteetti = getUsername()
 
   def getIdentiteetti(): String =
@@ -93,9 +139,35 @@ class SecurityOperaatiot(
 
   def getKayttajanOikeudet(): Set[Kayttooikeus] = kayttajanOikeudet
 
+  def getKayttajanKayttooikeustunnisteet(): Option[Set[Int]] = kayttajanKayttooikeustunnisteet
+
   /**
    * Palauttaa käyttäjän käyttöoikeuksien organisaatiot ilman lapsihierarkiaa
    */
   def getCasOrganisaatiot(): Set[String] =
     kayttajanCasOikeudet.filter(kayttooikeus => kayttooikeus.organisaatio.isDefined).map(ko => ko.organisaatio.get)
+
+  def parseTypedTunnisteAttributeFromSession(session: HttpSession, attributeName: String): Option[Set[Int]] = {
+    Option(session.getAttribute(attributeName)) match {
+      case Some(value: Set[_]) =>
+        // Safely cast elements to Int, filter out invalid ones
+        Some(value.collect { case i: Int => i })
+      case _ =>
+        None
+    }
+  }
+
+  def parseTypedKayttooikeusSetFromSession(session: HttpSession, attributeName: String): Option[Set[Kayttooikeus]] = {
+    Option(session.getAttribute(attributeName)) match {
+      case Some(value: Set[_]) =>
+        // Safely cast elements to Kayttooikeus, filter out invalid ones
+        Some(value.collect { case i: Kayttooikeus => i })
+      case _ =>
+        None
+    }
+  }
+
+  def eiUusiaTunnisteitaKannassa(session: HttpSession, kantaOperaatiot: KantaOperaatiot): Boolean =
+    val uusin = kantaOperaatiot.getUusinKayttooikeusTunniste()
+    uusin == session.getAttribute(SESSION_ATTR_UUSIN_KAYTTOOIKEUSTUNNISTE).asInstanceOf[Int]
 }