Skip to content

Commit b67ddd9

Browse files
committed
Merge branch 'OY-4836' into MERGE__OY-4799__OY-4780__OY-4797__OK-415__OY-4836
2 parents dca72f8 + 1e67fc5 commit b67ddd9

File tree

3 files changed

+35
-8
lines changed

3 files changed

+35
-8
lines changed

src/main/scala/fi/vm/sade/hakurekisteri/integration/henkilo/oppijaNumeroRekisteri.scala

Lines changed: 18 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,7 @@ case class LinkedHenkiloOids(
3434

3535
trait IOppijaNumeroRekisteri {
3636
def fetchLinkedHenkiloOidsMap(henkiloOids: Set[String]): Future[LinkedHenkiloOids]
37-
38-
def enrichWithAliases(henkiloOids: Set[String]): Future[PersonOidsWithAliases] = {
39-
fetchLinkedHenkiloOidsMap(henkiloOids)
40-
.map(_.oidToLinkedOids)
41-
.map(PersonOidsWithAliases(henkiloOids, _))
42-
}
37+
def enrichWithAliases(henkiloOids: Set[String]): Future[PersonOidsWithAliases]
4338

4439
def getByHetu(hetu: String): Future[Henkilo]
4540
def fetchHenkilotInBatches(henkiloOids: Set[String]): Future[Map[String, Henkilo]]
@@ -90,6 +85,12 @@ class OppijaNumeroRekisteri(client: VirkailijaRestClient, val system: ActorSyste
9085
}
9186
}
9287

88+
override def enrichWithAliases(henkiloOids: Set[String]): Future[PersonOidsWithAliases] = {
89+
fetchLinkedHenkiloOidsMap(henkiloOids)
90+
.map(_.oidToLinkedOids)
91+
.map(PersonOidsWithAliases(henkiloOids, _))
92+
}
93+
9394
override def fetchLinkedHenkiloOidsMap(henkiloOids: Set[String]): Future[LinkedHenkiloOids] = {
9495

9596
if (henkiloOids.isEmpty) {
@@ -187,6 +188,17 @@ object MockOppijaNumeroRekisteri extends IOppijaNumeroRekisteri {
187188
val henkiloOid = "1.2.246.562.24.58099330694"
188189
val linkedTestPersonOids = Seq(henkiloOid, masterOid)
189190

191+
implicit val ec: ExecutionContext = ExecutorUtil.createExecutor(
192+
1,
193+
getClass.getSimpleName
194+
)
195+
196+
override def enrichWithAliases(henkiloOids: Set[String]): Future[PersonOidsWithAliases] = {
197+
fetchLinkedHenkiloOidsMap(henkiloOids)
198+
.map(_.oidToLinkedOids)
199+
.map(PersonOidsWithAliases(henkiloOids, _))
200+
}
201+
190202
def fetchLinkedHenkiloOidsMap(henkiloOids: Set[String]): Future[LinkedHenkiloOids] = {
191203
Future.successful({
192204
val oidToLinkedOids = henkiloOids.map { queriedOid =>

src/test/scala/fi/vm/sade/hakurekisteri/rest/OppijaResourceSpec.scala

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@ import fi.vm.sade.hakurekisteri.integration.henkilo.{
1515
Henkilo,
1616
IOppijaNumeroRekisteri,
1717
LinkedHenkiloOids,
18-
MockPersonAliasesProvider
18+
MockPersonAliasesProvider,
19+
PersonOidsWithAliases
1920
}
2021
import fi.vm.sade.hakurekisteri.integration.tarjonta._
2122
import fi.vm.sade.hakurekisteri.integration.valintarekisteri.{
@@ -91,6 +92,13 @@ class OppijaResourceSpec
9192
)
9293
)
9394
}
95+
96+
override def enrichWithAliases(henkiloOids: Set[String]): Future[PersonOidsWithAliases] = {
97+
fetchLinkedHenkiloOidsMap(henkiloOids)
98+
.map(_.oidToLinkedOids)
99+
.map(PersonOidsWithAliases(henkiloOids, _))
100+
}
101+
94102
override def getByHetu(hetu: String): Future[Henkilo] = {
95103
throw new UnsupportedOperationException("Not implemented")
96104
}

src/test/scala/fi/vm/sade/hakurekisteri/rest/VirtaSuoritusResourceSpec.scala

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,8 @@ import fi.vm.sade.hakurekisteri.integration.hakemus.{
1010
import fi.vm.sade.hakurekisteri.integration.henkilo.{
1111
Henkilo,
1212
IOppijaNumeroRekisteri,
13-
LinkedHenkiloOids
13+
LinkedHenkiloOids,
14+
PersonOidsWithAliases
1415
}
1516
import fi.vm.sade.hakurekisteri.integration.virta.{
1617
VirtaClient,
@@ -143,6 +144,12 @@ class VirtaSuoritusResourceSpec extends ScalatraFunSuite with DispatchSupport wi
143144
}
144145
}
145146

147+
override def enrichWithAliases(henkiloOids: Set[String]): Future[PersonOidsWithAliases] = {
148+
fetchLinkedHenkiloOidsMap(henkiloOids)
149+
.map(_.oidToLinkedOids)
150+
.map(PersonOidsWithAliases(henkiloOids, _))
151+
}
152+
146153
override def getByOids(oids: Set[String]): Future[Map[String, Henkilo]] = Future.successful(
147154
Map(
148155
(

0 commit comments

Comments
 (0)