Skip to content

Commit d7fafdc

Browse files
jolarsenjolarsen
authored
TFP-5952 egen tilgang, oppdater rest (#781)
1 parent 5a765f7 commit d7fafdc

File tree

6 files changed

+18
-17
lines changed

6 files changed

+18
-17
lines changed

‎pom.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@
5353
<sonar.projectName>fp-prosesstask</sonar.projectName>
5454
<sonar.projectKey>navikt_fp-prosesstask</sonar.projectKey>
5555

56-
<felles.version>7.4.7</felles.version>
56+
<felles.version>7.4.8</felles.version>
5757

5858
<jakarta.jakartaee-bom.version>10.0.0</jakarta.jakartaee-bom.version>
5959
<hibernate-core.version>6.6.6.Final</hibernate-core.version>

‎rest/src/main/java/no/nav/vedtak/felles/prosesstask/rest/ProsessTaskRestTjeneste.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@
4444
import no.nav.vedtak.sikkerhet.abac.BeskyttetRessurs;
4545
import no.nav.vedtak.sikkerhet.abac.TilpassetAbacAttributt;
4646
import no.nav.vedtak.sikkerhet.abac.beskyttet.ActionType;
47+
import no.nav.vedtak.sikkerhet.abac.beskyttet.ResourceType;
4748

4849
@OpenAPIDefinition(tags = @Tag(name = "prosesstask", description = "Håndtering av asynkrone oppgaver i form av prosesstask"))
4950
@Path("/prosesstask")
@@ -53,7 +54,6 @@
5354
public class ProsessTaskRestTjeneste {
5455

5556
private static final Logger LOG = LoggerFactory.getLogger(ProsessTaskRestTjeneste.class);
56-
private static final String ABAC_DRIFT_ATTRIBUTT = "abac.attributt.drift";
5757

5858
private ProsessTaskApplikasjonTjeneste prosessTaskApplikasjonTjeneste;
5959

@@ -73,7 +73,7 @@ public ProsessTaskRestTjeneste(ProsessTaskApplikasjonTjeneste prosessTaskApplika
7373
@ApiResponse(responseCode = "202", description = "Prosesstaskens oppdatert informasjon", content = @Content(mediaType = "application/json", schema = @Schema(implementation = ProsessTaskDataDto.class))),
7474
@ApiResponse(responseCode = "500", description = "Feilet pga ukjent feil eller tekniske/funksjonelle feil")
7575
})
76-
@BeskyttetRessurs(actionType = ActionType.CREATE, property = ABAC_DRIFT_ATTRIBUTT)
76+
@BeskyttetRessurs(actionType = ActionType.CREATE, resourceType = ResourceType.DRIFT)
7777
public ProsessTaskDataDto createProsessTask(@Parameter(description = "Informasjon for restart en eksisterende prosesstask") @TilpassetAbacAttributt(supplierClass = AbacEmptySupplier.class) @Valid ProsessTaskOpprettInputDto inputDto) {
7878
// kjøres manuelt for å avhjelpe feilsituasjon, da er det veldig greit at det blir logget!
7979
LOG.info("Oppretter prossess task {}", LoggerUtils.toStringWithoutLineBreaks(inputDto.getTaskType()));
@@ -88,7 +88,7 @@ public ProsessTaskDataDto createProsessTask(@Parameter(description = "Informasjo
8888
@ApiResponse(responseCode = "200", description = "Prosesstaskens oppdatert informasjon", content = @Content(mediaType = "application/json", schema = @Schema(implementation = ProsessTaskRestartResultatDto.class))),
8989
@ApiResponse(responseCode = "500", description = "Feilet pga ukjent feil eller tekniske/funksjonelle feil")
9090
})
91-
@BeskyttetRessurs(actionType = ActionType.CREATE, property = ABAC_DRIFT_ATTRIBUTT, sporingslogg = false)
91+
@BeskyttetRessurs(actionType = ActionType.CREATE, resourceType = ResourceType.DRIFT, sporingslogg = false)
9292
public ProsessTaskRestartResultatDto restartProsessTask(@Parameter(description = "Informasjon for restart en eksisterende prosesstask") @TilpassetAbacAttributt(supplierClass = AbacEmptySupplier.class) @Valid @BeanParam ProsessTaskRestartInputDto restartInputDto) {
9393
// kjøres manuelt for å avhjelpe feilsituasjon, da er det veldig greit at det blir logget!
9494
LOG.info("Restarter prossess task {}", restartInputDto.getProsessTaskId());
@@ -102,7 +102,7 @@ public ProsessTaskRestartResultatDto restartProsessTask(@Parameter(description =
102102
@ApiResponse(responseCode = "200", description = "Response med liste av prosesstasks som restartes", content = @Content(mediaType = "application/json", schema = @Schema(implementation = ProsessTaskRetryAllResultatDto.class))),
103103
@ApiResponse(responseCode = "500", description = "Feilet pga ukjent feil eller tekniske/funksjonelle feil")
104104
})
105-
@BeskyttetRessurs(actionType = ActionType.CREATE, property = ABAC_DRIFT_ATTRIBUTT, sporingslogg = false)
105+
@BeskyttetRessurs(actionType = ActionType.CREATE, resourceType = ResourceType.DRIFT, sporingslogg = false)
106106
public ProsessTaskRetryAllResultatDto retryAllProsessTask() {
107107
// kjøres manuelt for å avhjelpe feilsituasjon, da er det veldig greit at det blir logget!
108108
LOG.info("Restarter alle prossess task i status FEILET");
@@ -115,7 +115,7 @@ public ProsessTaskRetryAllResultatDto retryAllProsessTask() {
115115
@Operation(description = "Lister prosesstasker med angitt status.", tags = "prosesstask", responses = {
116116
@ApiResponse(responseCode = "200", description = "Liste over prosesstasker, eller tom liste når angitt/default søkefilter ikke finner noen prosesstasker", content = @Content(mediaType = "application/json", schema = @Schema(implementation = ProsessTaskDataDto.class)))
117117
})
118-
@BeskyttetRessurs(actionType = ActionType.READ, property = ABAC_DRIFT_ATTRIBUTT)
118+
@BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.DRIFT)
119119
public List<ProsessTaskDataDto> finnProsessTasks(@Parameter(description = "Liste av statuser som skal hentes.") @TilpassetAbacAttributt(supplierClass = AbacEmptySupplier.class) @Valid @PathParam("prosessTaskStatus")
120120
IkkeFerdigProsessTaskStatusEnum finnTaskStatus) {
121121
var status = Optional.ofNullable(mapToProsessTaskStatus(finnTaskStatus)).map(List::of).orElseGet(List::of);
@@ -128,7 +128,7 @@ public List<ProsessTaskDataDto> finnProsessTasks(@Parameter(description = "Liste
128128
@Operation(description = "Søker etter prosesstask med angitt tekst i properties.", tags = "prosesstask", responses = {
129129
@ApiResponse(responseCode = "200", description = "Liste over prosesstasker, eller tom liste når angitt/default søkefilter ikke finner noen prosesstasker", content = @Content(mediaType = "application/json", schema = @Schema(implementation = ProsessTaskDataDto.class)))
130130
})
131-
@BeskyttetRessurs(actionType = ActionType.READ, property = ABAC_DRIFT_ATTRIBUTT)
131+
@BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.DRIFT)
132132
public List<ProsessTaskDataDto> searchProsessTasks(@Parameter(description = "Søkefilter for å begrense resultatet av returnerte prosesstask.") @TilpassetAbacAttributt(supplierClass = AbacEmptySupplier.class) @Valid SokeFilterDto sokeFilterDto) {
133133
return prosessTaskApplikasjonTjeneste.søk(sokeFilterDto);
134134
}
@@ -141,7 +141,7 @@ public List<ProsessTaskDataDto> searchProsessTasks(@Parameter(description = "Sø
141141
@ApiResponse(responseCode = "404", description = "Tom respons når angitt prosesstask-id ikke finnes"),
142142
@ApiResponse(responseCode = "400", description = "Feil input")
143143
})
144-
@BeskyttetRessurs(actionType = ActionType.READ, property = ABAC_DRIFT_ATTRIBUTT)
144+
@BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.DRIFT)
145145
public Response finnFeiletProsessTask(@NotNull @Parameter(description = "Prosesstask-id for feilet prosesstask") @TilpassetAbacAttributt(supplierClass = AbacEmptySupplier.class) @Valid @BeanParam ProsessTaskIdDto prosessTaskIdDto) {
146146
var resultat = prosessTaskApplikasjonTjeneste.finnFeiletProsessTask(prosessTaskIdDto.getProsessTaskId());
147147
if (resultat.isPresent()) {
@@ -157,7 +157,7 @@ public Response finnFeiletProsessTask(@NotNull @Parameter(description = "Prosess
157157
@ApiResponse(responseCode = "200", description = "Angitt prosesstask-id satt til status FERDIG"),
158158
@ApiResponse(responseCode = "500", description = "Feilet pga ukjent feil eller tekniske/funksjonelle feil")
159159
})
160-
@BeskyttetRessurs(actionType = ActionType.CREATE, property = ABAC_DRIFT_ATTRIBUTT)
160+
@BeskyttetRessurs(actionType = ActionType.CREATE, resourceType = ResourceType.DRIFT)
161161
public Response setFeiletProsessTaskFerdig(@NotNull @Parameter(description = "Prosesstask-id for feilet prosesstask") @TilpassetAbacAttributt(supplierClass = AbacEmptySupplier.class) @Valid @BeanParam ProsessTaskSetFerdigInputDto prosessTaskIdDto) {
162162
prosessTaskApplikasjonTjeneste.setProsessTaskFerdig(prosessTaskIdDto.getProsessTaskId(), mapToProsessTaskStatus(prosessTaskIdDto.getNaaVaaerendeStatus()));
163163
return Response.ok().build();

‎rest/src/main/java/no/nav/vedtak/felles/prosesstask/rest/dto/ProsessTaskIdDto.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public ProsessTaskIdDto(Long prosessTaskId) {
3434
this.prosessTaskId = prosessTaskId;
3535
}
3636

37-
@Schema(required = true, description = "Prosesstask-id for en eksisterende prosesstask")
37+
@Schema(requiredMode = Schema.RequiredMode.REQUIRED, description = "Prosesstask-id for en eksisterende prosesstask")
3838
public Long getProsessTaskId() {
3939
return prosessTaskId;
4040
}

‎task/src/main/java/no/nav/vedtak/felles/prosesstask/impl/TaskManagerRepositoryImpl.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ private Session getEntityManagerAsSession() {
163163

164164
var now = LocalDateTime.now();
165165
var status = taskStatus.getDbKode();
166-
var tasks = getEntityManagerAsSession().createNativeQuery(updateSql)
166+
var tasks = getEntityManagerAsSession().createNativeMutationQuery(updateSql)
167167
.setParameter("id", prosessTaskId)
168168
.setParameter(STATUS, status)
169169
.setParameter("status_ts", now)
@@ -193,7 +193,7 @@ void oppdaterStatus(Long prosessTaskId, ProsessTaskStatus taskStatus) {
193193
var status = taskStatus.getDbKode();
194194
var now = LocalDateTime.now();
195195
@SuppressWarnings({ "unused", "resource" })
196-
var tasks = getEntityManagerAsSession().createNativeQuery(updateSql)
196+
var tasks = getEntityManagerAsSession().createNativeMutationQuery(updateSql)
197197
.setParameter("id", prosessTaskId)
198198
.setParameter(STATUS, status)
199199
.setParameter("status_ts", now)
@@ -210,7 +210,7 @@ void oppdaterTaskUnderArbeid(Long prosessTaskId, LocalDateTime now) {
210210
" WHERE id = :id";
211211

212212
@SuppressWarnings("unused")
213-
var tasks = getEntityManagerAsSession().createNativeQuery(updateSql)
213+
var tasks = getEntityManagerAsSession().createNativeMutationQuery(updateSql)
214214
.setParameter("id", prosessTaskId)
215215
.setParameter("naa", now)
216216
.executeUpdate();

‎task/src/test/java/no/nav/vedtak/felles/prosesstask/impl/TaskManagerGenerateRunnableTasksITTest.java

+4-3
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@
1919
@ExtendWith(JpaOracleTestcontainerExtension.class)
2020
class TaskManagerGenerateRunnableTasksITTest extends EntityManagerAwareTest {
2121

22-
private static MemoryAppender logSniffer = MemoryAppender.sniff(TaskManagerGenerateRunnableTasks.class);
22+
private static final MemoryAppender LOG_SNIFFER = MemoryAppender.sniff(TaskManagerGenerateRunnableTasks.class);
2323

2424
@AfterEach
2525
public void afterEach() {
26-
logSniffer.reset();
26+
LOG_SNIFFER.reset();
2727
}
2828

2929
@Test
@@ -61,6 +61,7 @@ public void doRun(RunTaskInfo taskInfo) {
6161

6262
@Override
6363
void handleErrorCallback(IdentRunnable errorCallback) {
64+
// Do nothing
6465
}
6566

6667
};
@@ -74,7 +75,7 @@ void handleErrorCallback(IdentRunnable errorCallback) {
7475
// Act
7576
sut.run();
7677

77-
assertThat(logSniffer.search("PT-876628", Level.WARN)).isNotEmpty();
78+
assertThat(LOG_SNIFFER.search("PT-876628", Level.WARN)).isNotEmpty();
7879

7980
assertThat(errorFuncException.get()).isInstanceOf(PersistenceException.class);
8081

‎task/src/test/java/no/nav/vedtak/felles/prosesstask/impl/feilhåndtering/DefaultForsinkelseStrategiTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ static class ForsinkelseDummyProsessTask implements ProsessTaskHandler {
6262

6363
@Override
6464
public void doTask(ProsessTaskData data) {
65-
65+
// Do nothing
6666
}
6767
}
6868

0 commit comments

Comments
 (0)