Publiserer ForelderBarnRelasjon hendelser ved fødselshendelser.

kontrakter/src/main/java/no/nav/foreldrepenger/vtp/kontrakter/ForelderBarnRelasjonHendelseDto.java

@@ -0,0 +1,14 @@
+package no.nav.foreldrepenger.vtp.kontrakter;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import io.swagger.v3.oas.annotations.media.Schema;
+
+@Schema(name = "FamilierelasjonHendelseDto")
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record ForelderBarnRelasjonHendelseDto(@Schema String endringstype,
+                                              @Schema String fnr,
+                                              @Schema String relatertPersonsFnr,
+                                              @Schema String relatertPersonsRolle,
+                                              @Schema String minRolleForPerson) implements PersonhendelseDto {
+
+}

kontrakter/src/main/java/no/nav/foreldrepenger/vtp/kontrakter/PersonhendelseDto.java

@@ -11,7 +11,8 @@
         @JsonSubTypes.Type(value = FødselshendelseDto.class, name = "fødselshendelse"),
         @JsonSubTypes.Type(value = FamilierelasjonHendelseDto.class, name = "familierelasjonshendelse"),
         @JsonSubTypes.Type(value = DødshendelseDto.class, name = "dødshendelse"),
-        @JsonSubTypes.Type(value = DødfødselhendelseDto.class, name = "dødfødselhendelse")
+        @JsonSubTypes.Type(value = DødfødselhendelseDto.class, name = "dødfødselhendelse"),
+        @JsonSubTypes.Type(value = ForelderBarnRelasjonHendelseDto.class, name = "forelderBarnRelasjonHendelse"),
 })
 public interface PersonhendelseDto {
 

server/src/main/java/no/nav/foreldrepenger/vtp/server/api/pdl/PdlLeesahRestTjeneste.java

@@ -3,6 +3,7 @@
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.List;
@@ -19,13 +20,15 @@
 import jakarta.ws.rs.POST;
 import jakarta.ws.rs.Path;
 import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.QueryParam;
 import jakarta.ws.rs.core.Context;
 import jakarta.ws.rs.core.MediaType;
 import jakarta.ws.rs.core.Response;
 import no.nav.foreldrepenger.vtp.kafkaembedded.LocalKafkaProducer;
 import no.nav.foreldrepenger.vtp.kontrakter.DødfødselhendelseDto;
 import no.nav.foreldrepenger.vtp.kontrakter.DødshendelseDto;
 import no.nav.foreldrepenger.vtp.kontrakter.FamilierelasjonHendelseDto;
+import no.nav.foreldrepenger.vtp.kontrakter.ForelderBarnRelasjonHendelseDto;
 import no.nav.foreldrepenger.vtp.kontrakter.FødselshendelseDto;
 import no.nav.foreldrepenger.vtp.kontrakter.PersonhendelseDto;
 import no.nav.foreldrepenger.vtp.testmodell.personopplysning.BarnModell;
@@ -39,6 +42,7 @@
 import no.nav.person.pdl.leesah.doedsfall.Doedsfall;
 import no.nav.person.pdl.leesah.familierelasjon.Familierelasjon;
 import no.nav.person.pdl.leesah.foedselsdato.Foedselsdato;
+import no.nav.person.pdl.leesah.forelderbarnrelasjon.ForelderBarnRelasjon;
 
 @Tag(name = "Legge hendelser på PDL topic")
 @Path("/api/pdl/leesah")
@@ -52,9 +56,11 @@
     private static final String ENDRINGSTYPE = "endringstype";
     private static final String TIDLIGERE_HENDELSE_ID = "tidligereHendelseId";
     private static final String TOPICS = Optional.ofNullable(System.getenv("CREATE_TOPICS")).orElse("");
-    private static final String LEESAH_TOPIC =  Arrays.stream((TOPICS).split(","))
-            .map(String::trim).filter(s -> s.toLowerCase().contains("leesah"))
-            .findFirst().orElse("aapen-person-pdl-leesah-v1-vtp");
+    private static final String LEESAH_TOPIC = Arrays.stream((TOPICS).split(","))
+            .map(String::trim)
+            .filter(s -> s.toLowerCase().contains("leesah"))
+            .findFirst()
+            .orElse("aapen-person-pdl-leesah-v1-vtp");
 
     @Context
     private LocalKafkaProducer localKafkaProducer;
@@ -72,18 +78,21 @@
     @POST
     @Produces(MediaType.APPLICATION_JSON)
     @Operation(description = "Legg til hendelse")
-    public Response leggTilHendelse(PersonhendelseDto personhendelseDto) {
+    public Response leggTilHendelse(PersonhendelseDto personhendelseDto,
+                                    @QueryParam("publiserForelderBarnRelasjonMedFoedselshendelser") Boolean publiserForelderBarnRelasjonMedFoedselshendelser) {
         try {
-            if (personhendelseDto instanceof FødselshendelseDto fødselshendelseDto) {
-                produserFødselshendelse(fødselshendelseDto);
-            } else if (personhendelseDto instanceof DødshendelseDto dødshendelseDto) {
-                produserDødshendelse(dødshendelseDto);
-            } else if (personhendelseDto instanceof DødfødselhendelseDto dødfødselhendelseDto) {
-                produserDødfødselshendelse(dødfødselhendelseDto);
-            } else if (personhendelseDto instanceof FamilierelasjonHendelseDto familierelasjonHendelseDto) {
-                produserFamilierelasjonHendelse(familierelasjonHendelseDto);
-            } else {
-                return Response.status(Response.Status.BAD_REQUEST).entity("{\"error\": \"Ukjent hendelsestype\"}").build();
+            switch (personhendelseDto) {
+                case FødselshendelseDto fødselshendelseDto ->
+                        produserFødselshendelse(fødselshendelseDto, publiserForelderBarnRelasjonMedFoedselshendelser);
+                case DødshendelseDto dødshendelseDto -> produserDødshendelse(dødshendelseDto);
+                case DødfødselhendelseDto dødfødselhendelseDto -> produserDødfødselshendelse(dødfødselhendelseDto);
+                case FamilierelasjonHendelseDto familierelasjonHendelseDto ->
+                        produserFamilierelasjonHendelse(familierelasjonHendelseDto);
+                case ForelderBarnRelasjonHendelseDto forelderBarnRelasjonHendelseDto ->
+                        produserForelderBarnRelasjonHendelse(forelderBarnRelasjonHendelseDto);
+                case null, default -> {
+                    return Response.status(Response.Status.BAD_REQUEST).entity("{\"error\": \"Ukjent hendelsestype\"}").build();
+                }
             }
 
         } catch (RuntimeException e) {
@@ -93,12 +102,47 @@
         return Response.status(201).entity("{\"success\": \"Personhendelse opprettet\"}").build();
     }
 
-    private void produserFødselshendelse(FødselshendelseDto fødselshendelseDto) {
+    private void produserForelderBarnRelasjonHendelse(ForelderBarnRelasjonHendelseDto forelderBarnRelasjonHendelseDto) {
+        if (forelderBarnRelasjonHendelseDto == null) {
+            LOG.warn("ForelderBarnRelasjonHendelseDto er null, kan ikke produsere hendelse");
+            return;
+        }
+
+        GenericRecordBuilder personhendelse = new GenericRecordBuilder(Personhendelse.SCHEMA$);
+
+        personhendelse.set(HENDELSE_ID, UUID.randomUUID().toString());
+        personhendelse.set(MASTER_FIELD, "Freg");
+        personhendelse.set(OPPRETTET, LocalDateTime.now().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000);
+        personhendelse.set(OPPLYSNINGSTYPE, "FORELDERBARNRELASJON_V1");
+        personhendelse.set(ENDRINGSTYPE, Endringstype.valueOf(forelderBarnRelasjonHendelseDto.endringstype()));
+
+        String fnr = forelderBarnRelasjonHendelseDto.fnr();
+        personhendelse.set(PERSONIDENTER, List.of(fnr, testscenarioRepository.getPersonIndeks().finnByIdent(fnr).getAktørIdent()));
+
+        if (!Endringstype.ANNULLERT.toString().equals(forelderBarnRelasjonHendelseDto.endringstype())) {
+            GenericRecordBuilder forelderBarnRelasjon = new GenericRecordBuilder(ForelderBarnRelasjon.SCHEMA$);
+            String relatertPersonsFnr = forelderBarnRelasjonHendelseDto.relatertPersonsFnr();
+            forelderBarnRelasjon.set("relatertPersonsIdent", relatertPersonsFnr);
+            forelderBarnRelasjon.set("relatertPersonsRolle", forelderBarnRelasjonHendelseDto.relatertPersonsRolle());
+            forelderBarnRelasjon.set("minRolleForPerson", forelderBarnRelasjonHendelseDto.minRolleForPerson());
+            personhendelse.set("forelderBarnRelasjon", forelderBarnRelasjon.build());
+        }
+
+        LOG.info(
+                "Publiserer FORELDERBARNRELASJON_V1 hendelse med minRolle: {}, minFnr: {}, relatertPersonRolle: {}, relatertPersonFnr: {}",
+                forelderBarnRelasjonHendelseDto.minRolleForPerson(), forelderBarnRelasjonHendelseDto.fnr(),
+                forelderBarnRelasjonHendelseDto.relatertPersonsRolle(), forelderBarnRelasjonHendelseDto.relatertPersonsFnr());
+        sendHendelsePåKafka(personhendelse.build());
+    }
+
+    private void produserFødselshendelse(FødselshendelseDto fødselshendelseDto,
+                                         Boolean publiserForelderBarnRelasjonMedFoedselshendelser) {
         var barnIdent = registererNyttBarnPåForeldre(fødselshendelseDto);
         GenericRecordBuilder personhendelse = new GenericRecordBuilder(Personhendelse.SCHEMA$);
 
         personhendelse.set(HENDELSE_ID, UUID.randomUUID().toString());
-        personhendelse.set(PERSONIDENTER, List.of(barnIdent, testscenarioRepository.getPersonIndeks().finnByIdent(barnIdent).getAktørIdent()));
+        personhendelse.set(PERSONIDENTER,
+                List.of(barnIdent, testscenarioRepository.getPersonIndeks().finnByIdent(barnIdent).getAktørIdent()));
         personhendelse.set(MASTER_FIELD, "Freg");
         personhendelse.set(OPPRETTET, LocalDateTime.now().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000);
         personhendelse.set(OPPLYSNINGSTYPE, "FOEDSELSDATO_V1");
@@ -113,9 +157,39 @@
             personhendelse.set("foedselsdato", fødselsdato.build());
         }
 
+        LOG.info("Publiserer FOEDSELSDATO_V1 på kafka for barn med ident {}, født: {}", barnIdent, fødselshendelseDto.fødselsdato());
         sendHendelsePåKafka(personhendelse.build());
+
+        if (publiserForelderBarnRelasjonMedFoedselshendelser) {
+            produserForelderBarnRelasjon(fødselshendelseDto, barnIdent);
+        }
+    }
+
+    private void produserForelderBarnRelasjon(FødselshendelseDto fødselshendelseDto, String barnIdent) {
+        List<ForelderBarnRelasjonHendelseDto> forelderBarnRelasjonHendelseDtos = new ArrayList<>();
+        if (fødselshendelseDto.fnrMor() != null) {
+            // Legg til relasjoner for mor
+            leggTilForelderBarnRelasjon(forelderBarnRelasjonHendelseDtos, fødselshendelseDto.endringstype(),
+                    fødselshendelseDto.fnrMor(), barnIdent, "MOR");
+        } else if (fødselshendelseDto.fnrFar() != null) {
+            // Legg til relasjoner for far
+            leggTilForelderBarnRelasjon(forelderBarnRelasjonHendelseDtos, fødselshendelseDto.endringstype(),
+                    fødselshendelseDto.fnrFar(), barnIdent, "FAR");
+        }
+
+        forelderBarnRelasjonHendelseDtos.forEach(this::produserForelderBarnRelasjonHendelse);
     }
 
+    private void leggTilForelderBarnRelasjon(List<ForelderBarnRelasjonHendelseDto> dtos,
+                                             String endringstype,
+                                             String forelderFnr,
+                                             String barnFnr,
+                                             String forelderRolle) {
+        dtos.add(new ForelderBarnRelasjonHendelseDto(endringstype, forelderFnr, barnFnr, "BARN", "MOR"));
+        dtos.add(new ForelderBarnRelasjonHendelseDto(endringstype, barnFnr, forelderFnr, forelderRolle, "BARN"));
+    }
+
+
     public void sendHendelsePåKafka(GenericData.Record rekord) {
         localKafkaProducer.sendMelding(LEESAH_TOPIC, rekord);
     }
@@ -125,7 +199,8 @@
         GenericRecordBuilder personhendelse = new GenericRecordBuilder(Personhendelse.SCHEMA$);
 
         personhendelse.set(HENDELSE_ID, UUID.randomUUID().toString());
-        personhendelse.set(PERSONIDENTER, List.of(dødshendelseDto.fnr(), testscenarioRepository.getPersonIndeks().finnByIdent(dødshendelseDto.fnr()).getAktørIdent()));
+        personhendelse.set(PERSONIDENTER, List.of(dødshendelseDto.fnr(),
+                testscenarioRepository.getPersonIndeks().finnByIdent(dødshendelseDto.fnr()).getAktørIdent()));
         personhendelse.set(MASTER_FIELD, "Freg");
         personhendelse.set(OPPRETTET, LocalDateTime.now().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000);
         personhendelse.set(OPPLYSNINGSTYPE, "DOEDSFALL_V1");
@@ -140,6 +215,8 @@
             personhendelse.set("doedsfall", dødsfall.build());
         }
 
+        LOG.info("Publiserer DOEDSFALL_V1 hendelse på kafka for person med ident {}, dødsdato: {}", dødshendelseDto.fnr(),
+                dødshendelseDto.doedsdato());
         sendHendelsePåKafka(personhendelse.build());
     }
 
@@ -148,7 +225,8 @@
         GenericRecordBuilder personhendelse = new GenericRecordBuilder(Personhendelse.SCHEMA$);
 
         personhendelse.set(HENDELSE_ID, UUID.randomUUID().toString());
-        personhendelse.set(PERSONIDENTER, List.of(dødfødselhendelseDto.fnr(), testscenarioRepository.getPersonIndeks().finnByIdent(dødfødselhendelseDto.fnr()).getAktørIdent()));
+        personhendelse.set(PERSONIDENTER, List.of(dødfødselhendelseDto.fnr(),
+                testscenarioRepository.getPersonIndeks().finnByIdent(dødfødselhendelseDto.fnr()).getAktørIdent()));
         personhendelse.set(MASTER_FIELD, "Freg");
         personhendelse.set(OPPRETTET, LocalDateTime.now().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000);
         personhendelse.set(OPPLYSNINGSTYPE, "DOEDFOEDT_BARN_V1");
@@ -163,14 +241,17 @@
             personhendelse.set("doedfoedtBarn", dødfødtBarn.build());
         }
 
+        LOG.info("Publiserer DOEDFOEDT_BARN_V1 hendelse på kafka for barn med ident {}, dødsdato: {}", dødfødselhendelseDto.fnr(),
+                dødfødselhendelseDto.doedfoedselsdato());
         sendHendelsePåKafka(personhendelse.build());
     }
 
     private void produserFamilierelasjonHendelse(FamilierelasjonHendelseDto familierelasjonHendelseDto) {
         var personhendelse = new GenericRecordBuilder(Personhendelse.SCHEMA$);
 
         personhendelse.set(HENDELSE_ID, UUID.randomUUID().toString());
-        personhendelse.set(PERSONIDENTER, List.of(familierelasjonHendelseDto.fnr(), testscenarioRepository.getPersonIndeks().finnByIdent(familierelasjonHendelseDto.fnr()).getAktørIdent()));
+        personhendelse.set(PERSONIDENTER, List.of(familierelasjonHendelseDto.fnr(),
+                testscenarioRepository.getPersonIndeks().finnByIdent(familierelasjonHendelseDto.fnr()).getAktørIdent()));
         personhendelse.set(MASTER_FIELD, "Freg");
         personhendelse.set(OPPRETTET, LocalDateTime.now().atZone(ZoneId.systemDefault()).toEpochSecond() * 1000);
         personhendelse.set(OPPLYSNINGSTYPE, "FAMILIERELASJON_V1");
@@ -184,6 +265,9 @@
             personhendelse.set("familierelasjon", familierelasjon.build());
         }
 
+        LOG.info("Publiserer FAMILIERELASJON_V1 hendelse med minRolle: {}, minFnr: {}, relatertPersonRolle: {}, relatertPersonFnr: {}",
+                familierelasjonHendelseDto.minRolleForPerson(), familierelasjonHendelseDto.fnr(),
+                familierelasjonHendelseDto.relatertPersonsRolle(), familierelasjonHendelseDto.relatertPersonsFnr());
         sendHendelsePåKafka(personhendelse.build());
     }
 
@@ -226,7 +310,7 @@
         setDødsdatoerIIndeksene(personopplysninger, dødshendelseDto);
     }
 
-    private void setDødsdatoerIIndeksene(Personopplysninger personopplysninger, DødshendelseDto dødshendelseDto){
+    private void setDødsdatoerIIndeksene(Personopplysninger personopplysninger, DødshendelseDto dødshendelseDto) {
         if (dødshendelseDto.fnr().equalsIgnoreCase(personopplysninger.getSøker().getIdent())) {
             personopplysninger.getSøker().setDødsdato(dødshendelseDto.doedsdato());
         } else if (dødshendelseDto.fnr().equalsIgnoreCase(personopplysninger.getAnnenPart().getIdent())) {
@@ -237,7 +321,8 @@
         setDødsdatoForFamilirelasjoner(personopplysninger.getFamilierelasjonerForBarnet(), dødshendelseDto);
     }
 
-    private void setDødsdatoForFamilirelasjoner(Collection<FamilierelasjonModell> familierelasjonModell, DødshendelseDto dødshendelseDto) {
+    private void setDødsdatoForFamilirelasjoner(Collection<FamilierelasjonModell> familierelasjonModell,
+                                                DødshendelseDto dødshendelseDto) {
         familierelasjonModell.stream()
                 .filter(fr -> fr.getTil().getIdent().equalsIgnoreCase(dødshendelseDto.fnr()))
                 .map(fr -> (PersonModell) fr.getTil())

server/src/main/resources/avro/leesah/Personhendelse.avdl

@@ -5,6 +5,7 @@ protocol PersonhendelseProto {
   import idl "foedsel/Foedsel.avdl";
   import idl "foedselsdato/Foedselsdato.avdl";
   import idl "familierelasjon/Familierelasjon.avdl";
+  import idl "forelderbarnrelasjon/ForelderBarnRelasjon.avdl";
 
   enum Endringstype {
     OPPRETTET,
@@ -29,5 +30,6 @@ protocol PersonhendelseProto {
     union { null, no.nav.person.pdl.leesah.foedsel.Foedsel } foedsel = null;
     union { null, no.nav.person.pdl.leesah.foedselsdato.Foedselsdato } foedselsdato = null;
     union { null, no.nav.person.pdl.leesah.familierelasjon.Familierelasjon } familierelasjon = null;
+    union { null, no.nav.person.pdl.leesah.forelderbarnrelasjon.ForelderBarnRelasjon } forelderBarnRelasjon = null;
   }
 }

server/src/main/resources/avro/leesah/forelderbarnrelasjon/ForelderBarnRelasjon.avdl

@@ -0,0 +1,11 @@
+/*https://github.com/navikt/pdl/blob/master/libs/contract-pdl-avro/src/main/avro/no/nav/person/pdl/leesah/forelderbarnrelasjon/ForelderBarnRelasjon.avdl*/
+
+@namespace("no.nav.person.pdl.leesah.forelderbarnrelasjon")
+protocol ForelderBarnRelasjonV1 {
+
+	record ForelderBarnRelasjon {
+		union { null, string } relatertPersonsIdent = null;
+		string relatertPersonsRolle;
+		union { null, string } minRolleForPerson = null;
+	}
+}

server/src/test/java/no/nav/foreldrepenger/fpmock/server/HendelseTest.java

@@ -70,7 +70,7 @@ public void test() {
         assertEquals(4, testscenario.getPersonopplysninger().getFamilierelasjoner().size());
         assertEquals(3, testscenario.getPersonopplysninger().getFamilierelasjonerForAnnenPart().size());
 
-        pdlLeesahRestTjeneste.leggTilHendelse(fødselshendelseDto);
+        pdlLeesahRestTjeneste.leggTilHendelse(fødselshendelseDto, false);
 
         // Henter identen
         var barnIdent = hentUtIdentPåDetSisteBarneSomErRegistert(testscenario.getVariabelContainer());
@@ -93,7 +93,7 @@ public void test() {
 
         var dødshendelse = new DødshendelseDto(Endringstype.OPPRETTET.name(), null, søkerIdent,dødsdato);
 
-        pdlLeesahRestTjeneste.leggTilHendelse(dødshendelse);
+        pdlLeesahRestTjeneste.leggTilHendelse(dødshendelse, false);
 
         verifiserDødsdatoErSattForFamilierelasjonsmodell(testscenario.getPersonopplysninger().getFamilierelasjoner(), søkerIdent);
         verifiserDødsdatoErSattForFamilierelasjonsmodell(testscenario.getPersonopplysninger().getFamilierelasjonerForAnnenPart(), søkerIdent);
@@ -115,7 +115,7 @@ public void test() {
         assertEquals(4, testscenario.getPersonopplysninger().getFamilierelasjoner().size());
         assertEquals(3, testscenario.getPersonopplysninger().getFamilierelasjonerForAnnenPart().size());
 
-        pdlLeesahRestTjeneste.leggTilHendelse(dødfødselshendelse);
+        pdlLeesahRestTjeneste.leggTilHendelse(dødfødselshendelse, false);
 
         // Verifiserer riktig format på identen til barn
         var barnIdent = hentUtIdentPåDetSisteBarneSomErRegistert(testscenario.getVariabelContainer());