Skip to content

Commit

Permalink
Implement deletion methods for PDL artifacts
Browse files Browse the repository at this point in the history
#deploy-test-pdl-forvalter

The implementation deletes selected PDL artifacts and event IDs associated with them. It also modifies the methods for deleting event IDs from multiple to single. Additionally, it provides error handling for failed fetches and checks whether a person ID is Testnorge before initiating a deletion process. This commit impacts PdlTestdataConsumer, HendelseIdService, and ArtifactDeleteService.
  • Loading branch information
krharum committed Apr 23, 2024
1 parent fbfcda4 commit d1b9e97
Show file tree
Hide file tree
Showing 4 changed files with 161 additions and 37 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
import no.nav.pdl.forvalter.dto.ArtifactValue;
import no.nav.pdl.forvalter.dto.OpprettIdent;
import no.nav.pdl.forvalter.dto.OrdreRequest;
import no.nav.testnav.libs.data.pdlforvalter.v1.DbVersjonDTO;
import no.nav.testnav.libs.data.pdlforvalter.v1.FolkeregistermetadataDTO;
import no.nav.testnav.libs.data.pdlforvalter.v1.Identtype;
import no.nav.testnav.libs.data.pdlforvalter.v1.OrdreResponseDTO;
Expand Down Expand Up @@ -111,15 +110,15 @@ public Mono<List<OrdreResponseDTO.HendelseDTO>> delete(Set<String> identer) {
.collectList();
}

public Mono<List<OrdreResponseDTO.HendelseDTO>> deleteHendelser(String ident, List<DbVersjonDTO> hendelser) {
public Mono<OrdreResponseDTO.HendelseDTO> deleteHendelse(String ident, String hendelseId) {

return tokenExchange
.exchange(serverProperties)
.flatMapMany(accessToken -> Flux.fromIterable(hendelser)
.map(DbVersjonDTO::getHendelseId)
.flatMap(hendelseId -> new PdlDeleteHendelseIdCommandPdl(webClient,
getBestillingUrl().get(PDL_SLETTING_HENDELSEID), ident, hendelseId, accessToken.getTokenValue()).call()))
.collectList();
.flatMapMany(accessToken -> new PdlDeleteHendelseIdCommandPdl(webClient,
getBestillingUrl().get(PDL_SLETTING_HENDELSEID),
ident, hendelseId, accessToken.getTokenValue()).call())
.collectList()
.map(List::getFirst);
}

public Flux<OrdreResponseDTO.HendelseDTO> send(ArtifactValue value, AccessToken accessToken) {
Expand Down
Loading

0 comments on commit d1b9e97

Please sign in to comment.