Skip to content

Commit bd866f9

Browse files
committed
Refactor identer query handling and streamline tag processing logic #deploy-test-dolly-search-service
1 parent 79f893d commit bd866f9

File tree

2 files changed

+4
-14
lines changed

2 files changed

+4
-14
lines changed

apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/service/TagsService.java

+1-6
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
import lombok.RequiredArgsConstructor;
55
import lombok.extern.slf4j.Slf4j;
66
import no.nav.testnav.dollysearchservice.consumer.PdlProxyConsumer;
7-
import no.nav.testnav.dollysearchservice.dto.TagsOpprettingResponse;
87
import org.springframework.stereotype.Service;
98
import reactor.core.publisher.Flux;
109
import reactor.core.publisher.Mono;
@@ -38,10 +37,6 @@ public Mono<String> setDollyTagAlleTestnorgeIdenter() {
3837
return l1;
3938
})
4039
.doOnNext(tags -> log.info("Identer som mangler Dolly-tags: {}", String.join(", ", tags)))
41-
.filter(tags -> !tags.isEmpty())
42-
.flatMap(pdlProxyConsumer::setTags)
43-
.filter(response -> response.getStatus().is2xxSuccessful())
44-
.map(TagsOpprettingResponse::getIdenter)
4540
.map(resultat -> "Følgende identer mangler DOLLY-tag: %s".formatted(String.join(", ", resultat)))
4641
.switchIfEmpty(Mono.just("Fant ingen personer som mangler Dolly-tag"));
4742
}
@@ -53,4 +48,4 @@ private static List<String> filterTags(Map<String, List<String>> tags) {
5348
.map(Map.Entry::getKey)
5449
.toList();
5550
}
56-
}
51+
}

apps/dolly-search-service/src/main/java/no/nav/testnav/dollysearchservice/utils/OpenSearchIdenterQueryUtils.java

+3-8
Original file line numberDiff line numberDiff line change
@@ -62,8 +62,8 @@ private static void addNameQuery(BoolQueryBuilder queryBuilder, IdentSearch sear
6262
queryBuilder.must(QueryBuilders.nestedQuery(
6363
"hentPerson.navn",
6464
QueryBuilders.boolQuery()
65-
.should(regexpQuery(PERSON_FORNAVN, ".*" + values.get(0) + ".*"))
66-
.should(regexpQuery(PERSON_ETTERNAVN, ".*" + values.get(0) + ".*"))
65+
.should(regexpQuery(PERSON_FORNAVN, ".*" + values.getFirst() + ".*"))
66+
.should(regexpQuery(PERSON_ETTERNAVN, ".*" + values.getFirst() + ".*"))
6767
.minimumShouldMatch(1),
6868
ScoreMode.Avg));
6969

@@ -85,13 +85,8 @@ private static void addNameQuery(BoolQueryBuilder queryBuilder, IdentSearch sear
8585

8686
public static void addIdenterQuery(BoolQueryBuilder queryBuilder, Set<String> identer) {
8787

88-
var now = System.currentTimeMillis();
89-
var arr = new String[identer.size()];
90-
9188
queryBuilder
92-
.must(nestedTermsQuery(HENT_IDENTER, "ident", identer.toArray(arr)));
93-
94-
log.info("Konvertering av liste til array tok {} ms", System.currentTimeMillis() - now);
89+
.must(nestedTermsQuery(HENT_IDENTER, "ident", identer.toArray(String[]::new)));
9590
}
9691

9792
private static void addIdentQuery(BoolQueryBuilder queryBuilder, IdentSearch search) {

0 commit comments

Comments
 (0)