Skip to content

Commit

Permalink
Et par convencience-metoder newGET og newPostJson (#1181)
Browse files Browse the repository at this point in the history
  • Loading branch information
jolarsen authored Sep 19, 2022
1 parent cb534e9 commit 9fd04fd
Show file tree
Hide file tree
Showing 7 changed files with 26 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public List<ArbeidsfordelingResponse> finnEnhet(ArbeidsfordelingRequest request)

private List<ArbeidsfordelingResponse> hentEnheterFor(ArbeidsfordelingRequest request, URI uri) {
try {
var restrequest = RestRequest.newRequest(RestRequest.Method.postJson(request), uri, ArbeidsfordelingNativeRestKlient.class);
var restrequest = RestRequest.newPOSTJson(request, uri, ArbeidsfordelingNativeRestKlient.class);
var respons = restKlient.send(restrequest, ArbeidsfordelingResponse[].class);
return Arrays.stream(respons)
.filter(response -> "AKTIV".equalsIgnoreCase(response.status()))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,14 +35,14 @@ public OrganisasjonNativeRestKlient(RestClient restKlient) {
@Override
public OrganisasjonEReg hentOrganisasjon(String orgnummer) {
var uri = lagURI(orgnummer);
var request = RestRequest.newRequest(RestRequest.Method.get(), uri, OrganisasjonNativeRestKlient.class);
var request = RestRequest.newGET(uri, OrganisasjonNativeRestKlient.class);
return restKlient.send(request, OrganisasjonEReg.class);
}

@Override
public OrganisasjonAdresse hentOrganisasjonAdresse(String orgnummer) {
var uri = lagURI(orgnummer);
var request = RestRequest.newRequest(RestRequest.Method.get(), uri, OrganisasjonNativeRestKlient.class);
var request = RestRequest.newGET(uri, OrganisasjonNativeRestKlient.class);
return restKlient.send(request, OrganisasjonAdresse.class);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public List<Medlemskapsunntak> finnMedlemsunntak(String aktørId, LocalDate fom,
.queryParam(PARAM_TIL_OG_MED, d2s(tom))
.queryParam(PARAM_STATUSER, KODE_PERIODESTATUS_GYLD)
.queryParam(PARAM_STATUSER, KODE_PERIODESTATUS_UAVK);
var request = RestRequest.newRequest(RestRequest.Method.get(), uri.build(), MedlemsunntakNativeRestKlient.class)
var request = RestRequest.newGET(uri.build(), MedlemsunntakNativeRestKlient.class)
.otherCallId(NavHeaders.HEADER_NAV_CALL_ID)
.header(NavHeaders.HEADER_NAV_PERSONIDENT, aktørId);
var match = restKlient.send(request, Medlemskapsunntak[].class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ public OppgaveNativeKlient(RestClient restKlient) {

@Override
public Oppgave opprettetOppgave(OpprettOppgave oppgave) {
var request = RestRequest.newRequest(RestRequest.Method.postJson(oppgave), endpoint, OppgaveNativeKlient.class);
var request = RestRequest.newPOSTJson(oppgave, endpoint, OppgaveNativeKlient.class);
return restKlient.send(request, Oppgave.class);
}

Expand All @@ -49,7 +49,7 @@ public List<Oppgave> finnAlleOppgaver(String aktørId, String tema, List<String>
if (tema != null)
builder.queryParam("tema", tema);
oppgaveTyper.forEach(ot -> builder.queryParam("oppgavetype", ot));
var request = RestRequest.newRequest(RestRequest.Method.get(), builder.build(), OppgaveNativeKlient.class);
var request = RestRequest.newGET(builder.build(), OppgaveNativeKlient.class);
return restKlient.send(addCorrelation(request), FinnOppgaveResponse.class).oppgaver();
}

Expand All @@ -61,7 +61,7 @@ public List<Oppgave> finnAlleOppgaver(String aktørId, String tema, List<String>
if (tema != null)
builder.queryParam("tema", tema);
oppgaveTyper.forEach(ot -> builder.queryParam("oppgavetype", ot));
var request = RestRequest.newRequest(RestRequest.Method.get(), builder.build(), OppgaveNativeKlient.class);
var request = RestRequest.newGET(builder.build(), OppgaveNativeKlient.class);
return restKlient.send(addCorrelation(request), FinnOppgaveResponse.class).oppgaver();
}

Expand All @@ -85,7 +85,7 @@ public void feilregistrerOppgave(String oppgaveId) {

@Override
public Oppgave hentOppgave(String oppgaveId) {
var request = RestRequest.newRequest(RestRequest.Method.get(), getEndpointForOppgaveId(oppgaveId), OppgaveNativeKlient.class);
var request = RestRequest.newGET(getEndpointForOppgaveId(oppgaveId), OppgaveNativeKlient.class);
return restKlient.send(addCorrelation(request), Oppgave.class);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,14 @@ public static HttpRequest.BodyPublisher jsonPublisher(Object object) {
return HttpRequest.BodyPublishers.ofString(DefaultJsonMapper.toJson(object));
}

public static RestRequest newGET(URI target, Class<?> clazz) {
return newRequest(Method.get(), target, clazz);
}

public static RestRequest newPOSTJson(Object body, URI target, Class<?> clazz) {
return newRequest(Method.postJson(body), target, clazz);
}

public static RestRequest newRequest(Method method, URI target, Class<?> clazz) {
var tokenConfig = RestConfig.tokenConfigFromAnnotation(clazz);
var scopes = tokenConfig.isAzureAD() ? RestConfig.scopesFromAnnotation(clazz) : null;
Expand All @@ -85,6 +93,14 @@ public static RestRequest newRequest(Method method, URI target, TokenFlow tokenC
return newRequest(method, target, tokenConfig, null);
}

public static RestRequest newGET(URI target, TokenFlow tokenConfig, String scopes) {
return newRequest(Method.get(), target, tokenConfig, scopes);
}

public static RestRequest newPOSTJson(Object body, URI target, TokenFlow tokenConfig, String scopes) {
return newRequest(Method.postJson(body), target, tokenConfig, scopes);
}

public static RestRequest newRequest(Method method, URI target, TokenFlow tokenConfig, String scopes) {
var httpRequestBuilder = getHttpRequestBuilder(method, target);
return new RestRequest(httpRequestBuilder, tokenConfig, scopes, CONTEXT_SUPPLIER);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ public byte[] hentDokument(HentDokumentQuery q) {
.resolveTemplate("dokumentInfoId", q.dokumentId())
.resolveTemplate("variantFormat", q.variantFormat())
.build();
var request = RestRequest.newRequest(RestRequest.Method.get(), path, TokenFlow.ADAPTIVE, scopes);
var request = RestRequest.newGET(path, TokenFlow.ADAPTIVE, scopes);
var doc = restKlient.sendReturnByteArray(request);
LOG.info("Hentet dokument OK");
return doc;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ public List<SykepengeVedtak> hentGrunnlag(String fnr) {
var path = UriBuilder.fromUri(uri)
.queryParam("fodselsnummer", fnr)
.build();
var request = RestRequest.newRequest(RestRequest.Method.get(), path, SpøkelseNativeKlient.class);
var request = RestRequest.newGET(path, SpøkelseNativeKlient.class);
var grunnlag = restKlient.send(request, SykepengeVedtak[].class);
return Arrays.asList(grunnlag);
} catch (Exception e) {
Expand Down

0 comments on commit 9fd04fd

Please sign in to comment.