Fjerner bruk av callback url og scope. (#2540)

mrsladek · web-flow · commit e98085db3998 · 2024-03-18T14:52:41.000+01:00
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/InnhentingSamletTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/InnhentingSamletTjeneste.java
@@ -8,12 +8,11 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
-import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.inject.Inject;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
 import no.nav.abakus.iaygrunnlag.kodeverk.InntektskildeType;
 import no.nav.abakus.iaygrunnlag.kodeverk.YtelseStatus;
 import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
@@ -44,8 +43,6 @@ public class InnhentingSamletTjeneste {
     private static final Logger LOG = LoggerFactory.getLogger(InnhentingSamletTjeneste.class);
     private static final Set<YtelseType> LØNNSKOMP_FOR_YTELSER = Set.of(YtelseType.FORELDREPENGER, YtelseType.SVANGERSKAPSPENGER);
     private final boolean isDev = Environment.current().isDev();
-    private final boolean isLocal = Environment.current().isLocal();
-
     private ArbeidsforholdTjeneste arbeidsforholdTjeneste;
     private InntektTjeneste inntektTjeneste;
     private FpwsproxyKlient fpwsproxyKlient;
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/RegisterdataInnhentingTask.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/RegisterdataInnhentingTask.java
@@ -57,7 +57,7 @@ private IAYRegisterInnhentingTjeneste finnInnhenter(YtelseType ytelseType) {
 
     @Override
     protected void prosesser(ProsessTaskData prosessTaskData) {
-        String nyKoblingId = prosessTaskData.getPropertyValue(TaskConstants.NY_KOBLING_ID);
+        String nyKoblingId = prosessTaskData.getPropertyValue(TaskConstants.KOBLING_ID);
         Long koblingId = nyKoblingId != null ? Long.valueOf(nyKoblingId) : Long.valueOf(prosessTaskData.getBehandlingId());
         Kobling kobling = koblingTjeneste.hent(koblingId);
         LOG.info("Starter registerinnhenting for sak=[{}, {}] med behandling='{}'", kobling.getSaksnummer(), kobling.getYtelseType(),
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/callback/CallbackTask.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/callback/CallbackTask.java
@@ -1,27 +1,16 @@
 package no.nav.foreldrepenger.abakus.registerdata.callback;
 
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.util.LinkedHashMap;
-import java.util.Map;
-import java.util.Optional;
 import java.util.UUID;
 
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
 import no.nav.abakus.callback.registerdata.CallbackDto;
 import no.nav.abakus.callback.registerdata.Grunnlag;
 import no.nav.abakus.callback.registerdata.ReferanseDto;
-import no.nav.foreldrepenger.abakus.domene.iay.InntektArbeidYtelseGrunnlag;
 import no.nav.foreldrepenger.abakus.iay.InntektArbeidYtelseTjeneste;
 import no.nav.foreldrepenger.abakus.kobling.Kobling;
 import no.nav.foreldrepenger.abakus.kobling.KoblingTjeneste;
 import no.nav.foreldrepenger.abakus.kobling.TaskConstants;
-import no.nav.vedtak.exception.TekniskException;
-import no.nav.vedtak.felles.integrasjon.rest.RestClient;
-import no.nav.vedtak.felles.integrasjon.rest.RestConfig;
-import no.nav.vedtak.felles.integrasjon.rest.RestRequest;
-import no.nav.vedtak.felles.integrasjon.rest.TokenFlow;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTask;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskHandler;
@@ -32,27 +21,23 @@ public class CallbackTask implements ProsessTaskHandler {
 
     public static final String EKSISTERENDE_GRUNNLAG_REF = "grunnlag.ref.old";
 
-    private static final Map<String, RestConfig> CALLBACK_MAP = new LinkedHashMap<>(2);
-
-    private RestClient restClient;
+    private FpsakKlient fpsakKlient;
     private KoblingTjeneste koblingTjeneste;
     private InntektArbeidYtelseTjeneste inntektArbeidYtelseTjeneste;
 
     CallbackTask() {
     }
 
     @Inject
-    public CallbackTask(KoblingTjeneste koblingTjeneste, InntektArbeidYtelseTjeneste inntektArbeidYtelseTjeneste) {
-        this.restClient = RestClient.client();
+    public CallbackTask(FpsakKlient fpsakKlient, KoblingTjeneste koblingTjeneste, InntektArbeidYtelseTjeneste inntektArbeidYtelseTjeneste) {
+        this.fpsakKlient = fpsakKlient;
         this.koblingTjeneste = koblingTjeneste;
         this.inntektArbeidYtelseTjeneste = inntektArbeidYtelseTjeneste;
     }
 
     @Override
     public void doTask(ProsessTaskData data) {
-        String callbackUrl = data.getPropertyValue(TaskConstants.CALLBACK_URL);
-        String callbackScope = data.getPropertyValue(TaskConstants.CALLBACK_SCOPE);
-        String nyKoblingId = data.getPropertyValue(TaskConstants.NY_KOBLING_ID);
+        String nyKoblingId = data.getPropertyValue(TaskConstants.KOBLING_ID);
         Long koblingId = nyKoblingId != null ? Long.valueOf(nyKoblingId) : Long.valueOf(data.getBehandlingId());
         Kobling kobling = koblingTjeneste.hent(koblingId);
 
@@ -63,8 +48,7 @@ public void doTask(ProsessTaskData data) {
         setInformasjonOmEksisterendeGrunnlag(data, callbackDto);
         setInformasjonOmNyttGrunnlag(kobling, data, callbackDto);
 
-        var restConfig = getRestConfigFor(callbackUrl, callbackScope);
-        restClient.sendReturnOptional(RestRequest.newPOSTJson(callbackDto, restConfig.endpoint(), restConfig), String.class);
+        fpsakKlient.sendCallback(callbackDto);
     }
 
     private void setInformasjonOmAvsenderRef(Kobling kobling, CallbackDto callbackDto) {
@@ -84,7 +68,7 @@ private void setInformasjonOmEksisterendeGrunnlag(ProsessTaskData data, Callback
     }
 
     private void setInformasjonOmNyttGrunnlag(Kobling kobling, ProsessTaskData data, CallbackDto callbackDto) {
-        Optional<InntektArbeidYtelseGrunnlag> grunnlag = inntektArbeidYtelseTjeneste.hentGrunnlagFor(kobling.getKoblingReferanse());
+        var grunnlag = inntektArbeidYtelseTjeneste.hentGrunnlagFor(kobling.getKoblingReferanse());
         grunnlag.ifPresent(gr -> {
             ReferanseDto grunnlagRef = new ReferanseDto();
             grunnlagRef.setReferanse(gr.getGrunnlagReferanse().getReferanse());
@@ -96,17 +80,4 @@ private void setInformasjonOmNyttGrunnlag(Kobling kobling, ProsessTaskData data,
         }
     }
 
-    private RestConfig getRestConfigFor(String url, String scope) {
-        var key = url + scope;
-        if (CALLBACK_MAP.get(key) == null) {
-            try {
-                var uri = new URI(url);
-                var restConfig = new RestConfig(TokenFlow.ADAPTIVE, uri, scope, null);
-                CALLBACK_MAP.put(key, restConfig);
-            } catch (URISyntaxException e) {
-                throw new TekniskException("FP-349977", String.format("Ugyldig callback url ved callback etter registerinnhenting: %s", url));
-            }
-        }
-        return CALLBACK_MAP.get(key);
-    }
 }
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/callback/FpsakKlient.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/callback/FpsakKlient.java
@@ -0,0 +1,46 @@
+package no.nav.foreldrepenger.abakus.registerdata.callback;
+
+import java.net.URI;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.ws.rs.core.UriBuilder;
+import jakarta.ws.rs.core.UriBuilderException;
+import no.nav.abakus.callback.registerdata.CallbackDto;
+import no.nav.vedtak.felles.integrasjon.rest.FpApplication;
+import no.nav.vedtak.felles.integrasjon.rest.RestClient;
+import no.nav.vedtak.felles.integrasjon.rest.RestClientConfig;
+import no.nav.vedtak.felles.integrasjon.rest.RestConfig;
+import no.nav.vedtak.felles.integrasjon.rest.RestRequest;
+import no.nav.vedtak.felles.integrasjon.rest.TokenFlow;
+
+@ApplicationScoped
+@RestClientConfig(tokenConfig = TokenFlow.AZUREAD_CC, application = FpApplication.FPSAK)
+public class FpsakKlient {
+
+    private static final Logger LOG = LoggerFactory.getLogger(FpsakKlient.class);
+    protected static final String CALLBACK_PATH = "/api/registerdata/iay/callback";
+
+    private final RestClient restClient;
+    private final RestConfig restConfig;
+    private final URI endpointFpsak;
+
+    public FpsakKlient() {
+        this.restClient = RestClient.client();
+        this.restConfig = RestConfig.forClient(this.getClass());
+        this.endpointFpsak = UriBuilder.fromUri(restConfig.endpoint()).path(CALLBACK_PATH).build();
+    }
+
+    public void sendCallback(CallbackDto callbackDto) {
+        try {
+            LOG.info("Sender callback til fpsak.");
+            restClient.sendReturnOptional(RestRequest.newPOSTJson(callbackDto, endpointFpsak, restConfig), String.class);
+            LOG.info("Callback sendt OK til fpsak.");
+        } catch (UriBuilderException | IllegalArgumentException e) {
+            throw new IllegalArgumentException("Ugyldig callback url ved callback etter registerinnhenting.");
+        }
+    }
+
+}
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/tjeneste/InnhentRegisterdataTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/tjeneste/InnhentRegisterdataTjeneste.java
@@ -111,24 +111,19 @@ public String triggAsyncInnhent(InnhentRegisterdataRequest dto) {
         var innhentingTask = ProsessTaskData.forProsessTask(RegisterdataInnhentingTask.class);
         var callbackTask = ProsessTaskData.forProsessTask(CallbackTask.class);
         innhentingTask.setAktørId(kobling.getAktørId().getId());
-        innhentingTask.setProperty(TaskConstants.GAMMEL_KOBLING_ID, kobling.getId().toString());
-        innhentingTask.setProperty(TaskConstants.NY_KOBLING_ID, kobling.getId().toString());
+        innhentingTask.setProperty(TaskConstants.KOBLING_ID, kobling.getId().toString());
         try {
             innhentingTask.setPayload(JsonObjectMapper.getMapper().writeValueAsString(dto));
         } catch (JsonProcessingException e) {
             throw new RuntimeException("Feil i serialisering av innhentingrequest", e);
         }
         callbackTask.setAktørId(kobling.getAktørId().getId());
-        callbackTask.setProperty(TaskConstants.GAMMEL_KOBLING_ID, kobling.getId().toString());
-        callbackTask.setProperty(TaskConstants.NY_KOBLING_ID, kobling.getId().toString());
+        callbackTask.setProperty(TaskConstants.KOBLING_ID, kobling.getId().toString());
 
         Optional<GrunnlagReferanse> eksisterendeGrunnlagRef = hentSisteReferanseFor(kobling.getKoblingReferanse());
         eksisterendeGrunnlagRef.map(GrunnlagReferanse::getReferanse)
             .ifPresent(ref -> callbackTask.setProperty(EKSISTERENDE_GRUNNLAG_REF, ref.toString()));
 
-        callbackTask.setProperty(TaskConstants.CALLBACK_URL, dto.getCallbackUrl());
-        callbackTask.setProperty(TaskConstants.CALLBACK_SCOPE, dto.getCallbackScope());
-
         taskGruppe.addNesteSekvensiell(innhentingTask);
         taskGruppe.addNesteSekvensiell(callbackTask);
         taskGruppe.setCallIdFraEksisterende();
diff --git a/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/tjeneste/RegisterdataRestTjeneste.java b/domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/registerdata/tjeneste/RegisterdataRestTjeneste.java
@@ -77,9 +77,6 @@ public RegisterdataRestTjeneste(InnhentRegisterdataTjeneste innhentTjeneste, Kob
     @SuppressWarnings({"findsecbugs:JAXRS_ENDPOINT", "resource"})
     public Response innhentOgLagreRegisterdataAsync(@Parameter(name = "innhent") @Valid InnhentRegisterdataAbacDto dto) {
         Response response;
-        if (dto.getCallbackUrl() == null || dto.getCallbackScope() == null) {
-            return Response.status(HttpURLConnection.HTTP_FORBIDDEN).build();
-        }
         if (!YtelseType.abakusYtelser().contains(dto.getYtelseType())) {
             return Response.status(HttpURLConnection.HTTP_BAD_REQUEST).build();
         }
diff --git a/domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/KoblingTask.java b/domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/KoblingTask.java
@@ -3,7 +3,6 @@
 import no.nav.foreldrepenger.abakus.kobling.repository.LåsRepository;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskData;
 import no.nav.vedtak.felles.prosesstask.api.ProsessTaskHandler;
-import no.nav.vedtak.log.mdc.MdcExtendedLogContext;
 
 public abstract class KoblingTask implements ProsessTaskHandler {
 
@@ -18,7 +17,7 @@ public KoblingTask(LåsRepository låsRepository) {
 
     @Override
     public void doTask(ProsessTaskData prosessTaskData) {
-        String nyKoblingId = prosessTaskData.getPropertyValue(TaskConstants.NY_KOBLING_ID);
+        String nyKoblingId = prosessTaskData.getPropertyValue(TaskConstants.KOBLING_ID);
         Long koblingId = nyKoblingId != null ? Long.valueOf(nyKoblingId) : Long.valueOf(prosessTaskData.getBehandlingId());
 
         KoblingLås koblingLås = låsRepository.taLås(koblingId);
diff --git a/domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/TaskConstants.java b/domenetjenester/kobling/src/main/java/no/nav/foreldrepenger/abakus/kobling/TaskConstants.java
@@ -1,10 +1,7 @@
 package no.nav.foreldrepenger.abakus.kobling;
 
 public final class TaskConstants {
-    public static final String GAMMEL_KOBLING_ID = "behandlingId";
-    public static final String NY_KOBLING_ID = "koblingId";
-    public static final String CALLBACK_URL = "callbackUrl";
-    public static final String CALLBACK_SCOPE = "callbackScope";
+    public static final String KOBLING_ID = "koblingId";
     private TaskConstants() {
     }
 }
diff --git a/kontrakt/src/main/java/no/nav/abakus/iaygrunnlag/request/InnhentRegisterdataRequest.java b/kontrakt/src/main/java/no/nav/abakus/iaygrunnlag/request/InnhentRegisterdataRequest.java
@@ -3,10 +3,6 @@
 import java.util.Set;
 import java.util.UUID;
 
-import jakarta.validation.Valid;
-import jakarta.validation.constraints.NotNull;
-import jakarta.validation.constraints.Pattern;
-
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
 import com.fasterxml.jackson.annotation.JsonAutoDetect.Visibility;
 import com.fasterxml.jackson.annotation.JsonCreator;
@@ -15,6 +11,9 @@
 import com.fasterxml.jackson.annotation.JsonInclude.Include;
 import com.fasterxml.jackson.annotation.JsonProperty;
 
+import jakarta.validation.Valid;
+import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Pattern;
 import no.nav.abakus.iaygrunnlag.Periode;
 import no.nav.abakus.iaygrunnlag.PersonIdent;
 import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
@@ -72,16 +71,6 @@ public class InnhentRegisterdataRequest {
     private Set<RegisterdataType> elementer = Set.of(RegisterdataType.ARBEIDSFORHOLD, RegisterdataType.INNTEKT_PENSJONSGIVENDE,
         RegisterdataType.YTELSE);
 
-    @JsonProperty(value = "callbackUrl")
-    @Valid
-    @Pattern(regexp = URL_PATTERN, message = "callbackUrl [${validatedValue}] matcher ikke tillatt url pattern [{regexp}]")
-    private String callbackUrl;
-
-    @JsonProperty(value = "callbackScope")
-    @Valid
-    @Pattern(regexp = SCOPE_PATTERN, message = "callbackScope [${validatedValue}] matcher ikke tillatt scope pattern [{regexp}]")
-    private String callbackScope;
-
     public InnhentRegisterdataRequest(@JsonProperty(value = "saksnummer", required = true) @Valid @NotNull String saksnummer,
                                       @JsonProperty(value = "referanse", required = true) @Valid @NotNull UUID referanse,
                                       @JsonProperty(value = "ytelseType", required = true) @NotNull YtelseType ytelseType,
@@ -141,22 +130,6 @@ public void setOpptjeningsperiode(Periode opptjeningsperiode) {
         this.opptjeningsperiode = opptjeningsperiode;
     }
 
-    public String getCallbackUrl() {
-        return callbackUrl;
-    }
-
-    public void setCallbackUrl(String callbackUrl) {
-        this.callbackUrl = callbackUrl;
-    }
-
-    public String getCallbackScope() {
-        return callbackScope;
-    }
-
-    public void setCallbackScope(String callbackScope) {
-        this.callbackScope = callbackScope;
-    }
-
     public Set<RegisterdataType> getElementer() {
         return elementer;
     }

Original file line number	Diff line number	Diff line change
`@@ -1,10 +1,7 @@`
`1`	`1`	`package no.nav.foreldrepenger.abakus.kobling;`
`2`	`2`
`3`	`3`	`public final class TaskConstants {`
`4`		`- public static final String GAMMEL_KOBLING_ID = "behandlingId";`
`5`		`- public static final String NY_KOBLING_ID = "koblingId";`
`6`		`- public static final String CALLBACK_URL = "callbackUrl";`
`7`		`- public static final String CALLBACK_SCOPE = "callbackScope";`
	`4`	`+ public static final String KOBLING_ID = "koblingId";`
`8`	`5`	`private TaskConstants() {`
`9`	`6`	`}`
`10`	`7`	`}`