Marmelator/persistence-service
1
0
Fork 0
Code Issues Pull Requests 17 Actions Packages Projects Releases 1.1k Wiki Activity

RED-8702

Browse Source
This commit is contained in:
maverickstuder 2024-03-14 09:17:12 +01:00
parent 540129a051
commit f8741b54d3
14 changed files with 92 additions and 222 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/EntityLogMergeService.java
View File

@ -81,7 +81,7 @@ public class EntityLogMergeService {
List<EntityLogEntry> matchingEntities = entityLog.getEntityLogEntry() List<EntityLogEntry> matchingEntities = entityLog.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry -> manualChangesIds.contains(entityLogEntry.getEntryId())) .filter(entityLogEntry -> manualChangesIds.contains(entityLogEntry.getId()))
.collect(Collectors.toList()); .collect(Collectors.toList());
final int analysisNumber = entityLog.getAnalysisNumber(); final int analysisNumber = entityLog.getAnalysisNumber();
@ -143,7 +143,7 @@ public class EntityLogMergeService {
private EntityLogEntry findMatchingEntry(String annotationId, List<EntityLogEntry> matchingEntities) { private EntityLogEntry findMatchingEntry(String annotationId, List<EntityLogEntry> matchingEntities) {
return matchingEntities.stream() return matchingEntities.stream()
.filter(entityLogEntry -> entityLogEntry.getEntryId().equals(annotationId)) .filter(entityLogEntry -> entityLogEntry.getId().equals(annotationId))
.findAny() .findAny()
.orElseThrow(() -> new NotFoundException("No matching EntityLogEntry found for id " + annotationId)); .orElseThrow(() -> new NotFoundException("No matching EntityLogEntry found for id " + annotationId));
} }
@ -182,7 +182,7 @@ public class EntityLogMergeService {
boolean isHint = isHint(manualRedactionEntry.getType(), dossier); boolean isHint = isHint(manualRedactionEntry.getType(), dossier);
EntityLogEntry entityLogEntry = EntityLogEntry.builder() EntityLogEntry entityLogEntry = EntityLogEntry.builder()
.entryId(manualRedactionEntry.getAnnotationId()) .id(manualRedactionEntry.getAnnotationId())
.type(manualRedactionEntry.getType()) .type(manualRedactionEntry.getType())
.value(manualRedactionEntry.getValue()) .value(manualRedactionEntry.getValue())
.legalBasis(manualRedactionEntry.getLegalBasis()) .legalBasis(manualRedactionEntry.getLegalBasis())
@ -237,7 +237,7 @@ public class EntityLogMergeService {
private void mergeIdsToRemove(IdRemoval idRemoval, List<EntityLogEntry> entityLogEntries, int analysisNumber) { private void mergeIdsToRemove(IdRemoval idRemoval, List<EntityLogEntry> entityLogEntries, int analysisNumber) {
var entity = entityLogEntries.stream() var entity = entityLogEntries.stream()
.filter(entityLogEntry -> entityLogEntry.getEntryId().equals(idRemoval.getAnnotationId())) .filter(entityLogEntry -> entityLogEntry.getId().equals(idRemoval.getAnnotationId()))
.findAny(); .findAny();
entity.ifPresent(entityLogEntry -> { entity.ifPresent(entityLogEntry -> {
entityLogEntry.setState(EntryState.IGNORED); entityLogEntry.setState(EntryState.IGNORED);
@ -258,7 +258,7 @@ public class EntityLogMergeService {
private void mergeResizeRedactions(ManualResizeRedaction manualResizeRedaction, List<EntityLogEntry> entityLogEntries, int analysisNumber) { private void mergeResizeRedactions(ManualResizeRedaction manualResizeRedaction, List<EntityLogEntry> entityLogEntries, int analysisNumber) {
var entity = entityLogEntries.stream() var entity = entityLogEntries.stream()
.filter(entityLogEntry -> entityLogEntry.getEntryId().equals(manualResizeRedaction.getAnnotationId())) .filter(entityLogEntry -> entityLogEntry.getId().equals(manualResizeRedaction.getAnnotationId()))
.findAny(); .findAny();
entity.ifPresent(entityLogEntry -> { entity.ifPresent(entityLogEntry -> {
entityLogEntry.setTextAfter(manualResizeRedaction.getTextAfter()); entityLogEntry.setTextAfter(manualResizeRedaction.getTextAfter());
@ -283,7 +283,7 @@ public class EntityLogMergeService {
private void mergeLegalBasisChanges(ManualLegalBasisChange manualLegalBasisChange, List<EntityLogEntry> entityLogEntries, int analysisNumber) { private void mergeLegalBasisChanges(ManualLegalBasisChange manualLegalBasisChange, List<EntityLogEntry> entityLogEntries, int analysisNumber) {
var entity = entityLogEntries.stream() var entity = entityLogEntries.stream()
.filter(entityLogEntry -> entityLogEntry.getEntryId().equals(manualLegalBasisChange.getAnnotationId())) .filter(entityLogEntry -> entityLogEntry.getId().equals(manualLegalBasisChange.getAnnotationId()))
.findAny(); .findAny();
entity.ifPresent(entityLogEntry -> { entity.ifPresent(entityLogEntry -> {
entityLogEntry.setLegalBasis(manualLegalBasisChange.getLegalBasis()); entityLogEntry.setLegalBasis(manualLegalBasisChange.getLegalBasis());
@ -325,7 +325,7 @@ public class EntityLogMergeService {
boolean isHint = isHint(recategorization.getType(), dossier); boolean isHint = isHint(recategorization.getType(), dossier);
var entity = entityLogEntries.stream() var entity = entityLogEntries.stream()
.filter(entityLogEntry -> entityLogEntry.getEntryId().equals(recategorization.getAnnotationId())) .filter(entityLogEntry -> entityLogEntry.getId().equals(recategorization.getAnnotationId()))
.findAny(); .findAny();
entity.ifPresent(entityLogEntry -> { entity.ifPresent(entityLogEntry -> {
entityLogEntry.setType(recategorization.getType()); entityLogEntry.setType(recategorization.getType());
@ -348,7 +348,7 @@ public class EntityLogMergeService {
private void mergeForceRedactions(ManualForceRedaction forceRedaction, List<EntityLogEntry> entityLogEntries, int analysisNumber) { private void mergeForceRedactions(ManualForceRedaction forceRedaction, List<EntityLogEntry> entityLogEntries, int analysisNumber) {
var entity = entityLogEntries.stream() var entity = entityLogEntries.stream()
.filter(entityLogEntry -> entityLogEntry.getEntryId().equals(forceRedaction.getAnnotationId())) .filter(entityLogEntry -> entityLogEntry.getId().equals(forceRedaction.getAnnotationId()))
.findAny(); .findAny();
entity.ifPresent(entityLogEntry -> { entity.ifPresent(entityLogEntry -> {
entityLogEntry.setLegalBasis(forceRedaction.getLegalBasis()); entityLogEntry.setLegalBasis(forceRedaction.getLegalBasis());

2
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/EntityLogService.java
View File

@ -80,7 +80,7 @@ public class EntityLogService {
Map<String, Integer> commentCountPerAnnotationId = commentService.getCommentCounts(fileId); Map<String, Integer> commentCountPerAnnotationId = commentService.getCommentCounts(fileId);
entityLog.getEntityLogEntry() entityLog.getEntityLogEntry()
.forEach(entityLogEntry -> entityLogEntry.setNumberOfComments(commentCountPerAnnotationId.getOrDefault(entityLogEntry.getEntryId(), 0))); .forEach(entityLogEntry -> entityLogEntry.setNumberOfComments(commentCountPerAnnotationId.getOrDefault(entityLogEntry.getId(), 0)));
return entityLog; return entityLog;
} }

3
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/manualredactions/ManualRedactionMapper.java
View File

@ -10,6 +10,7 @@ import java.util.Set;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.iqser.red.service.persistence.management.v1.processor.exception.BadRequestException;
import com.iqser.red.service.persistence.management.v1.processor.exception.NotFoundException; import com.iqser.red.service.persistence.management.v1.processor.exception.NotFoundException;
import com.iqser.red.service.persistence.management.v1.processor.service.EntityLogService; import com.iqser.red.service.persistence.management.v1.processor.service.EntityLogService;
import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntityLog; import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntityLog;
@ -186,7 +187,7 @@ public class ManualRedactionMapper {
return entityLog.getEntityLogEntry() return entityLog.getEntityLogEntry()
.stream() .stream()
.filter(entry -> entry.getEntryId().equals(annotationId)) .filter(entry -> entry.getId().equals(annotationId))
.findFirst() .findFirst()
.orElseThrow(() -> new NotFoundException("Annotation does not exist in entity log.")); .orElseThrow(() -> new NotFoundException("Annotation does not exist in entity log."));
} }

2
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/manualredactions/ManualRedactionService.java
View File

@ -348,7 +348,7 @@ public class ManualRedactionService {
return entityLog.getEntityLogEntry() return entityLog.getEntityLogEntry()
.stream() .stream()
.filter(entry -> entry.getEntryId().equals(annotationId)) .filter(entry -> entry.getId().equals(annotationId))
.findFirst() .findFirst()
.orElseThrow(() -> new NotFoundException("Annotation does not exist in entity log.")); .orElseThrow(() -> new NotFoundException("Annotation does not exist in entity log."));
} }

2
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/manualredactions/ManualRedactionUndoService.java
View File

@ -343,7 +343,7 @@ public class ManualRedactionUndoService {
return entityLog.getEntityLogEntry() return entityLog.getEntityLogEntry()
.stream() .stream()
.filter(entry -> entry.getEntryId().equals(annotationId)) .filter(entry -> entry.getId().equals(annotationId))
.findFirst() .findFirst()
.orElseThrow(() -> new NotFoundException("Annotation does not exist in entity log.")); .orElseThrow(() -> new NotFoundException("Annotation does not exist in entity log."));
} }

8
persistence-service-v1/persistence-service-processor-v1/src/main/java/com/iqser/red/service/persistence/management/v1/processor/service/manualredactions/PendingDictionaryEntryFactory.java
View File

@ -35,7 +35,7 @@ public class PendingDictionaryEntryFactory {
.propertyChanges(Map.of("value", manualRedactionEntry.getValue())) .propertyChanges(Map.of("value", manualRedactionEntry.getValue()))
.build()); .build());
return EntityLogEntry.builder() return EntityLogEntry.builder()
.entryId(manualRedactionEntry.getAnnotationId()) .id(manualRedactionEntry.getAnnotationId())
.value(manualRedactionEntry.getValue()) .value(manualRedactionEntry.getValue())
.type(manualRedactionEntry.getType()) .type(manualRedactionEntry.getType())
.entryType(Optional.ofNullable(manualRedactionEntry.getDictionaryEntryType()) .entryType(Optional.ofNullable(manualRedactionEntry.getDictionaryEntryType())
@ -82,7 +82,7 @@ public class PendingDictionaryEntryFactory {
.build()); .build());
return EntityLogEntry.builder() return EntityLogEntry.builder()
.entryId(originalEntry.getEntryId()) .id(originalEntry.getId())
.value(originalEntry.getValue()) .value(originalEntry.getValue())
.type(originalEntry.getType()) .type(originalEntry.getType())
.entryType(originalEntry.getEntryType()) .entryType(originalEntry.getEntryType())
@ -121,7 +121,7 @@ public class PendingDictionaryEntryFactory {
.propertyChanges(propertyChanges) .propertyChanges(propertyChanges)
.build()); .build());
return EntityLogEntry.builder() return EntityLogEntry.builder()
.entryId(originalEntry.getEntryId()) .id(originalEntry.getId())
.value(manualChange.getValue()) .value(manualChange.getValue())
.type(originalEntry.getType()) .type(originalEntry.getType())
.entryType(originalEntry.getEntryType()) .entryType(originalEntry.getEntryType())
@ -171,7 +171,7 @@ public class PendingDictionaryEntryFactory {
.build()); .build());
return EntityLogEntry.builder() return EntityLogEntry.builder()
.entryId(originalEntry.getEntryId()) .id(originalEntry.getId())
.value(originalEntry.getValue()) .value(originalEntry.getValue())
.type(manualChange.getType()) .type(manualChange.getType())
.entryType(originalEntry.getEntryType()) .entryType(originalEntry.getEntryType())

6
persistence-service-v1/persistence-service-server-v1/src/test/java/com/iqser/red/service/peristence/v1/server/integration/service/FileTesterAndProvider.java
View File

@ -67,12 +67,10 @@ public class FileTesterAndProvider {
fileManagementStorageService.storeJSONObject(dossier.getId(), fileManagementStorageService.storeJSONObject(dossier.getId(),
file.getFileId(), file.getFileId(),
FileType.ENTITY_LOG, FileType.ENTITY_LOG,
new EntityLog(dossier.getId(), new EntityLog(1,
fileId,
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entryId("annotationId") .id("annotationId")
.type("manual") .type("manual")
.value("value entry") .value("value entry")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)

36
persistence-service-v1/persistence-service-server-v1/src/test/java/com/iqser/red/service/peristence/v1/server/integration/tests/EntityLogMergeTest.java
View File

@ -120,7 +120,7 @@ public class EntityLogMergeTest {
ManualRedactions manualRedactions = provideManualRedactions(entryToAddId, entryToRemoveId, entryToResizeId, entryLegalBasisId, forceRedactionId, fileId, rectangleToAddId); ManualRedactions manualRedactions = provideManualRedactions(entryToAddId, entryToRemoveId, entryToResizeId, entryLegalBasisId, forceRedactionId, fileId, rectangleToAddId);
var entityLog = provideEntityLog(dossierId, fileId, entryToRemoveId, entryToResizeId, entryLegalBasisId, forceRedactionId); var entityLog = provideEntityLog(entryToRemoveId, entryToResizeId, entryLegalBasisId, forceRedactionId);
when(manualRedactionProviderService.getManualRedactions(any(), any())).thenReturn(manualRedactions); when(manualRedactionProviderService.getManualRedactions(any(), any())).thenReturn(manualRedactions);
when(fileStatusService.getStatus(fileId)).thenReturn(FileModel.builder().excluded(false).dossierStatusId(dossierTemplateId).id(fileId).build()); when(fileStatusService.getStatus(fileId)).thenReturn(FileModel.builder().excluded(false).dossierStatusId(dossierTemplateId).id(fileId).build());
@ -137,7 +137,7 @@ public class EntityLogMergeTest {
var optionalEntityLogEntry = response.getEntityLogEntry() var optionalEntityLogEntry = response.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry1 -> entityLogEntry1.getEntryId().equals(entryToAddId)) .filter(entityLogEntry1 -> entityLogEntry1.getId().equals(entryToAddId))
.findFirst(); .findFirst();
assertTrue(optionalEntityLogEntry.isPresent()); assertTrue(optionalEntityLogEntry.isPresent());
var entityLogEntry = optionalEntityLogEntry.get(); var entityLogEntry = optionalEntityLogEntry.get();
@ -152,7 +152,7 @@ public class EntityLogMergeTest {
var optionalRemoveEntryLogEntry = response.getEntityLogEntry() var optionalRemoveEntryLogEntry = response.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry1 -> entityLogEntry1.getEntryId().equals(entryToRemoveId)) .filter(entityLogEntry1 -> entityLogEntry1.getId().equals(entryToRemoveId))
.findFirst(); .findFirst();
assertTrue(optionalRemoveEntryLogEntry.isPresent()); assertTrue(optionalRemoveEntryLogEntry.isPresent());
var removeEntryLogEntry = optionalRemoveEntryLogEntry.get(); var removeEntryLogEntry = optionalRemoveEntryLogEntry.get();
@ -166,7 +166,7 @@ public class EntityLogMergeTest {
var optionalResizeEntryLogEntry = response.getEntityLogEntry() var optionalResizeEntryLogEntry = response.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry1 -> entityLogEntry1.getEntryId().equals(entryToResizeId)) .filter(entityLogEntry1 -> entityLogEntry1.getId().equals(entryToResizeId))
.findFirst(); .findFirst();
assertTrue(optionalResizeEntryLogEntry.isPresent()); assertTrue(optionalResizeEntryLogEntry.isPresent());
var resizeEntryLogEntry = optionalResizeEntryLogEntry.get(); var resizeEntryLogEntry = optionalResizeEntryLogEntry.get();
@ -190,7 +190,7 @@ public class EntityLogMergeTest {
var optionalLegalBasisEntryLogEntry = response.getEntityLogEntry() var optionalLegalBasisEntryLogEntry = response.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry1 -> entityLogEntry1.getEntryId().equals(entryLegalBasisId)) .filter(entityLogEntry1 -> entityLogEntry1.getId().equals(entryLegalBasisId))
.findFirst(); .findFirst();
assertTrue(optionalLegalBasisEntryLogEntry.isPresent()); assertTrue(optionalLegalBasisEntryLogEntry.isPresent());
var legalBasisEntryLogEntry = optionalLegalBasisEntryLogEntry.get(); var legalBasisEntryLogEntry = optionalLegalBasisEntryLogEntry.get();
@ -205,7 +205,7 @@ public class EntityLogMergeTest {
var optionalForceRedactionEntryLogEntry = response.getEntityLogEntry() var optionalForceRedactionEntryLogEntry = response.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry1 -> entityLogEntry1.getEntryId().equals(forceRedactionId)) .filter(entityLogEntry1 -> entityLogEntry1.getId().equals(forceRedactionId))
.findFirst(); .findFirst();
assertTrue(optionalForceRedactionEntryLogEntry.isPresent()); assertTrue(optionalForceRedactionEntryLogEntry.isPresent());
var forceRedactionEntryLogEntry = optionalForceRedactionEntryLogEntry.get(); var forceRedactionEntryLogEntry = optionalForceRedactionEntryLogEntry.get();
@ -220,7 +220,7 @@ public class EntityLogMergeTest {
var optionalRectangleEntryLogEntry = response.getEntityLogEntry() var optionalRectangleEntryLogEntry = response.getEntityLogEntry()
.stream() .stream()
.filter(entityLogEntry1 -> entityLogEntry1.getEntryId().equals(rectangleToAddId)) .filter(entityLogEntry1 -> entityLogEntry1.getId().equals(rectangleToAddId))
.findFirst(); .findFirst();
assertTrue(optionalRectangleEntryLogEntry.isPresent()); assertTrue(optionalRectangleEntryLogEntry.isPresent());
var rectangleEntryLogEntry = optionalRectangleEntryLogEntry.get(); var rectangleEntryLogEntry = optionalRectangleEntryLogEntry.get();
@ -236,24 +236,22 @@ public class EntityLogMergeTest {
} }
private EntityLog provideEntityLog(String dossierId, String fileId, String entryToRemoveId, String entryToResizeId, String entryLegalBasisId, String forceRedactionId) { private EntityLog provideEntityLog(String entryToRemoveId, String entryToResizeId, String entryLegalBasisId, String forceRedactionId) {
List<Position> positions = new ArrayList<>(); List<Position> positions = new ArrayList<>();
positions.add(new Position(1, 1, 1, 1, 1)); positions.add(new Position(1, 1, 1, 1, 1));
return new EntityLog(dossierId, return new EntityLog(1,
fileId,
1, 1,
1, Lists.newArrayList(EntityLogEntry.builder()
Lists.newArrayList(EntityLogEntry.builder().entityLogId(EntityLog.getId(dossierId, fileId)) .id(entryToRemoveId)
.entryId(entryToRemoveId)
.type("manual") .type("manual")
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.dictionaryEntry(true) .dictionaryEntry(true)
.build(), .build(),
EntityLogEntry.builder().entityLogId(EntityLog.getId(dossierId, fileId)) EntityLogEntry.builder()
.entryId(entryToResizeId) .id(entryToResizeId)
.type("manual") .type("manual")
.value("Darth Vader") .value("Darth Vader")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -261,8 +259,8 @@ public class EntityLogMergeTest {
.dictionaryEntry(true) .dictionaryEntry(true)
.positions(positions) .positions(positions)
.build(), .build(),
EntityLogEntry.builder().entityLogId(EntityLog.getId(dossierId, fileId)) EntityLogEntry.builder()
.entryId(entryLegalBasisId) .id(entryLegalBasisId)
.type("manual") .type("manual")
.value("Darth Luke") .value("Darth Luke")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -270,8 +268,8 @@ public class EntityLogMergeTest {
.dictionaryEntry(true) .dictionaryEntry(true)
.positions(positions) .positions(positions)
.build(), .build(),
EntityLogEntry.builder().entityLogId(EntityLog.getId(dossierId, fileId)) EntityLogEntry.builder()
.entryId(forceRedactionId) .id(forceRedactionId)
.type("manual") .type("manual")
.value("Darth Luke") .value("Darth Luke")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)

7
persistence-service-v1/persistence-service-server-v1/src/test/java/com/iqser/red/service/peristence/v1/server/integration/tests/FileTest.java
View File

@ -369,13 +369,10 @@ public class FileTest extends AbstractPersistenceServerServiceTest {
var type = typeProvider.testAndProvideType(dossierTemplate, null, "manual"); var type = typeProvider.testAndProvideType(dossierTemplate, null, "manual");
var annotationId = "imagine_this_makes_sense"; var annotationId = "imagine_this_makes_sense";
EntityLog entityLog = new EntityLog(dossierId, EntityLog entityLog = new EntityLog(1,
fileId,
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id(annotationId)
.entryId(annotationId)
.type(type.getType()) .type(type.getType())
.value("value entry") .value("value entry")
.state(EntryState.APPLIED) .state(EntryState.APPLIED)

166
persistence-service-v1/persistence-service-server-v1/src/test/java/com/iqser/red/service/peristence/v1/server/integration/tests/ManualRedactionTest.java
View File

@ -45,7 +45,10 @@ import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog
import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntityLogEntry; import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntityLogEntry;
import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntryState; import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntryState;
import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntryType; import com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog.EntryType;
import com.iqser.red.service.persistence.service.v1.api.shared.model.annotations.AddRedactionRequest;
import com.iqser.red.service.persistence.service.v1.api.shared.model.annotations.ManualRedactions;
import com.iqser.red.service.persistence.service.v1.api.shared.model.annotations.Rectangle; import com.iqser.red.service.persistence.service.v1.api.shared.model.annotations.Rectangle;
import com.iqser.red.service.persistence.service.v1.api.shared.model.annotations.entitymapped.ManualRedactionEntry;
import com.iqser.red.service.persistence.service.v1.api.shared.model.dossiertemplate.dossier.file.FileType; import com.iqser.red.service.persistence.service.v1.api.shared.model.dossiertemplate.dossier.file.FileType;
import com.iqser.red.service.persistence.service.v1.api.shared.model.dossiertemplate.type.DictionaryEntryType; import com.iqser.red.service.persistence.service.v1.api.shared.model.dossiertemplate.type.DictionaryEntryType;
import com.iqser.red.service.persistence.service.v1.api.shared.model.manual.AddRedactionRequestModel; import com.iqser.red.service.persistence.service.v1.api.shared.model.manual.AddRedactionRequestModel;
@ -121,13 +124,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY); dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type(type.getType()) .type(type.getType())
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -318,13 +318,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
Dictionary dossierDictionary = dictionaryClient.getDictionaryForType(type.getType(), type.getDossierTemplateId(), dossier.getId()); Dictionary dossierDictionary = dictionaryClient.getDictionaryForType(type.getType(), type.getDossierTemplateId(), dossier.getId());
assertThat(dossierDictionary.getEntries()).containsExactlyInAnyOrder("Luke Skywalker"); assertThat(dossierDictionary.getEntries()).containsExactlyInAnyOrder("Luke Skywalker");
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type("test") .type("test")
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -381,13 +378,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
// CreateTypeValue dossierDictionaryType = MagicConverter.convert(type, CreateTypeValue.class); // CreateTypeValue dossierDictionaryType = MagicConverter.convert(type, CreateTypeValue.class);
// dictionaryClient.addType(dossierDictionaryType, dossier.getId()); // dictionaryClient.addType(dossierDictionaryType, dossier.getId());
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type("test") .type("test")
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -439,13 +433,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
// dictionaryClient.addType(dossierDictionaryType, dossier.getId()); // dictionaryClient.addType(dossierDictionaryType, dossier.getId());
dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY); dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type("test") .type("test")
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -529,13 +520,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict)); var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict));
var loadedRedactionsFile1 = manualRedactionClient.getManualRedactions(file1.getDossierId(), file1.getFileId(), false, true); var loadedRedactionsFile1 = manualRedactionClient.getManualRedactions(file1.getDossierId(), file1.getFileId(), false, true);
var entityLog1 = new EntityLog(dossier1.getId(), var entityLog1 = new EntityLog(1,
file1.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(0).getAnnotationId())
.entryId(addRedactions.get(0).getAnnotationId())
.type(typeDosDict.getType()) .type(typeDosDict.getType())
.value("test redaction in dossier") .value("test redaction in dossier")
.dossierDictionaryEntry(true) .dossierDictionaryEntry(true)
@ -543,8 +531,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template") .value("test redaction in dossier template")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -560,13 +547,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build(); var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build();
when(entityLogService.getEntityLog(eq(file1.getDossierId()), eq(file1.getFileId()), any(), anyBoolean())).thenReturn(entityLog1); when(entityLogService.getEntityLog(eq(file1.getDossierId()), eq(file1.getFileId()), any(), anyBoolean())).thenReturn(entityLog1);
var entityLog2 = new EntityLog(dossier2.getId(), var entityLog2 = new EntityLog(1,
file2.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier2.getId(), file2.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template") .value("test redaction in dossier template")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -701,13 +685,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict)); var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict));
var loadedRedactionsFile1 = manualRedactionClient.getManualRedactions(file1.getDossierId(), file1.getFileId(), false, true); var loadedRedactionsFile1 = manualRedactionClient.getManualRedactions(file1.getDossierId(), file1.getFileId(), false, true);
var entityLog1 = new EntityLog(dossier1.getId(), var entityLog1 = new EntityLog(1,
file1.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(0).getAnnotationId())
.entryId(addRedactions.get(0).getAnnotationId())
.type(typeDosDict.getType()) .type(typeDosDict.getType())
.value("test redaction in dossier yayy") .value("test redaction in dossier yayy")
.dossierDictionaryEntry(true) .dossierDictionaryEntry(true)
@ -715,8 +696,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template yayy") .value("test redaction in dossier template yayy")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -732,13 +712,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build(); var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build();
when(entityLogService.getEntityLog(eq(file1.getDossierId()), eq(file1.getFileId()), any(), anyBoolean())).thenReturn(entityLog1); when(entityLogService.getEntityLog(eq(file1.getDossierId()), eq(file1.getFileId()), any(), anyBoolean())).thenReturn(entityLog1);
var entityLog2 = new EntityLog(dossier2.getId(), var entityLog2 = new EntityLog(1,
file2.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier2.getId(), file2.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template yayy") .value("test redaction in dossier template yayy")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -877,13 +854,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict)); var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict));
var entityLog1 = new EntityLog(dossier1.getId(), var entityLog1 = new EntityLog(1,
file1.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(0).getAnnotationId())
.entryId(addRedactions.get(0).getAnnotationId())
.type(typeDosDict.getType()) .type(typeDosDict.getType())
.value("test redaction in dossier") .value("test redaction in dossier")
.dossierDictionaryEntry(true) .dossierDictionaryEntry(true)
@ -891,8 +865,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template") .value("test redaction in dossier template")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -908,13 +881,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build(); var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build();
when(entityLogService.getEntityLog(file1.getDossierId(), file1.getFileId())).thenReturn(entityLog1); when(entityLogService.getEntityLog(file1.getDossierId(), file1.getFileId())).thenReturn(entityLog1);
var entityLog2 = new EntityLog(dossier2.getId(), var entityLog2 = new EntityLog(1,
file2.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier2.getId(), file2.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template") .value("test redaction in dossier template")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1050,13 +1020,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict)); var addRedactions = manualRedactionClient.addRedactionBulk(dossier1.getId(), file1.getId(), Set.of(redactionDos, redactionDosTempDict));
var entityLog1 = new EntityLog(dossier1.getId(), var entityLog1 = new EntityLog(1,
file1.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(0).getAnnotationId())
.entryId(addRedactions.get(0).getAnnotationId())
.type(typeDosDict.getType()) .type(typeDosDict.getType())
.value("test redaction in dossier yayy") .value("test redaction in dossier yayy")
.dossierDictionaryEntry(true) .dossierDictionaryEntry(true)
@ -1064,8 +1031,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier1.getId(), file1.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template yayy") .value("test redaction in dossier template yayy")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1081,13 +1047,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build(); var redactionRequest1 = RedactionRequest.builder().dossierId(file1.getDossierId()).fileId(file1.getFileId()).dossierTemplateId(file1.getDossierTemplateId()).build();
when(entityLogService.getEntityLog(file1.getDossierId(), file1.getFileId())).thenReturn(entityLog1); when(entityLogService.getEntityLog(file1.getDossierId(), file1.getFileId())).thenReturn(entityLog1);
var entityLog2 = new EntityLog(dossier2.getId(), var entityLog2 = new EntityLog(1,
file2.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier2.getId(), file2.getFileId())) .id(addRedactions.get(1).getAnnotationId())
.entryId(addRedactions.get(1).getAnnotationId())
.type(typeDosTempDict.getType()) .type(typeDosTempDict.getType())
.value("test redaction in dossier template yayy") .value("test redaction in dossier template yayy")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1208,13 +1171,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
assertThat(dossierDictionary2.getEntries()).isEmpty(); assertThat(dossierDictionary2.getEntries()).isEmpty();
var annotationId = "AnnotationId"; var annotationId = "AnnotationId";
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id(annotationId)
.entryId(annotationId)
.type(type.getType()) .type(type.getType())
.value(lukeSkywalker) .value(lukeSkywalker)
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1295,13 +1255,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
assertThat(dossierDictionary2.getEntries()).isEmpty(); assertThat(dossierDictionary2.getEntries()).isEmpty();
var annotationId = "AnnotationId"; var annotationId = "AnnotationId";
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id(annotationId)
.entryId(annotationId)
.type(type.getType()) .type(type.getType())
.value(lukeSkywalker) .value(lukeSkywalker)
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1469,13 +1426,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Anakin"), false, dossier.getId(), DictionaryEntryType.ENTRY); dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Anakin"), false, dossier.getId(), DictionaryEntryType.ENTRY);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type(type.getType()) .type(type.getType())
.value("Anakin") .value("Anakin")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1483,8 +1437,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.dictionaryEntry(false) .dictionaryEntry(false)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId2")
.entryId("AnnotationId2")
.type(type.getType()) .type(type.getType())
.value("Anakin2") .value("Anakin2")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1672,13 +1625,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Darth Vader"), false, dossier.getId(), DictionaryEntryType.ENTRY); dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Darth Vader"), false, dossier.getId(), DictionaryEntryType.ENTRY);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("dv")
.entryId("dv")
.type(type.getType()) .type(type.getType())
.value("Darth Vader") .value("Darth Vader")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1686,8 +1636,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.dictionaryEntry(false) .dictionaryEntry(false)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("dv2")
.entryId("dv2")
.type(type.getType()) .type(type.getType())
.value("Vader Darth") .value("Vader Darth")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1782,13 +1731,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY); dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type(type.getType()) .type(type.getType())
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1796,8 +1742,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.dictionaryEntry(false) .dictionaryEntry(false)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId2")
.entryId("AnnotationId2")
.type(type.getType()) .type(type.getType())
.value("Skywalker Luke") .value("Skywalker Luke")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1896,13 +1841,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY); dictionaryClient.addEntry(type.getType(), type.getDossierTemplateId(), List.of("Luke Skywalker"), false, dossier.getId(), DictionaryEntryType.ENTRY);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId")
.entryId("AnnotationId")
.type(type.getType()) .type(type.getType())
.value("Luke Skywalker") .value("Luke Skywalker")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1910,8 +1852,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.dictionaryEntry(false) .dictionaryEntry(false)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("AnnotationId2")
.entryId("AnnotationId2")
.type(type.getType()) .type(type.getType())
.value("Skywalker Luke") .value("Skywalker Luke")
.entryType(EntryType.ENTITY) .entryType(EntryType.ENTITY)
@ -1976,13 +1917,10 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
var type = typeProvider.testAndProvideType(dossierTemplate, null, "type", false); var type = typeProvider.testAndProvideType(dossierTemplate, null, "type", false);
var entityLog = new EntityLog(dossier.getId(), var entityLog = new EntityLog(1,
file.getFileId(),
1,
1, 1,
List.of(EntityLogEntry.builder() List.of(EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("annotationId")
.entryId("annotationId")
.type(type.getType()) .type(type.getType())
.value("lukeSkywalker") .value("lukeSkywalker")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1990,8 +1928,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("annotationId2")
.entryId("annotationId2")
.type(type.getType()) .type(type.getType())
.value("Johannesbrotkernmehl") .value("Johannesbrotkernmehl")
.dictionaryEntry(true) .dictionaryEntry(true)
@ -1999,8 +1936,7 @@ public class ManualRedactionTest extends AbstractPersistenceServerServiceTest {
.state(EntryState.APPLIED) .state(EntryState.APPLIED)
.build(), .build(),
EntityLogEntry.builder() EntityLogEntry.builder()
.entityLogId(EntityLog.getId(dossier.getId(), file.getFileId())) .id("annotationId3")
.entryId("annotationId3")
.type(type.getType()) .type(type.getType())
.value("Baustelle") .value("Baustelle")
.dictionaryEntry(true) .dictionaryEntry(true)

6
persistence-service-v1/persistence-service-server-v1/src/test/java/com/iqser/red/service/peristence/v1/server/integration/utils/AbstractPersistenceServerServiceTest.java
View File

@ -249,10 +249,8 @@ public abstract class AbstractPersistenceServerServiceTest {
// doNothing().when(pdfTronRedactionClient).testDigitalCurrentSignature(Mockito.any()); // doNothing().when(pdfTronRedactionClient).testDigitalCurrentSignature(Mockito.any());
when(amqpAdmin.getQueueInfo(Mockito.any())).thenReturn(null); when(amqpAdmin.getQueueInfo(Mockito.any())).thenReturn(null);
when(entityLogService.getEntityLog(Mockito.any(), Mockito.any())).thenReturn(new EntityLog("", "", 1, 1, Lists.newArrayList(), null, 0, 0, 0, 0)); when(entityLogService.getEntityLog(Mockito.any(), Mockito.any())).thenReturn(new EntityLog(1, 1, Lists.newArrayList(), null, 0, 0, 0, 0));
when(entityLogService.getEntityLog(Mockito.any(), Mockito.any(), Mockito.any(), Mockito.anyBoolean())).thenReturn(new EntityLog("", when(entityLogService.getEntityLog(Mockito.any(), Mockito.any(), Mockito.any(), Mockito.anyBoolean())).thenReturn(new EntityLog(1,
"",
1,
1, 1,
Lists.newArrayList(), Lists.newArrayList(),
null, null,

12
persistence-service-v1/persistence-service-shared-api-v1/src/main/java/com/iqser/red/service/persistence/service/v1/api/shared/model/analysislog/entitylog/CascadeSave.java
View File

@ -1,12 +0,0 @@
package com.iqser.red.service.persistence.service.v1.api.shared.model.analysislog.entitylog;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.FIELD)
public @interface CascadeSave {
//
}

42
persistence-service-v1/persistence-service-shared-api-v1/src/main/java/com/iqser/red/service/persistence/service/v1/api/shared/model/analysislog/entitylog/EntityLog.java
View File

@ -3,10 +3,6 @@ package com.iqser.red.service.persistence.service.v1.api.shared.model.analysislo
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.DBRef;
import org.springframework.data.mongodb.core.mapping.Document;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;
@ -14,15 +10,8 @@ import lombok.NoArgsConstructor;
@Data @Data
@AllArgsConstructor @AllArgsConstructor
@NoArgsConstructor @NoArgsConstructor
@Document(collection = "entity-logs")
public class EntityLog { public class EntityLog {
@Id
private String id;
private String dossierId;
private String fileId;
/** /**
* Version 0 Redaction Logs have manual redactions merged inside them * Version 0 Redaction Logs have manual redactions merged inside them
* Version 1 Redaction Logs only contain system ( rule/dictionary ) redactions. Manual Redactions are merged in at runtime. * Version 1 Redaction Logs only contain system ( rule/dictionary ) redactions. Manual Redactions are merged in at runtime.
@ -34,8 +23,6 @@ public class EntityLog {
*/ */
private int analysisNumber; private int analysisNumber;
@DBRef
@CascadeSave
private List<EntityLogEntry> entityLogEntry = new ArrayList<>(); private List<EntityLogEntry> entityLogEntry = new ArrayList<>();
private List<EntityLogLegalBasis> legalBasis = new ArrayList<>(); private List<EntityLogLegalBasis> legalBasis = new ArrayList<>();
@ -44,33 +31,4 @@ public class EntityLog {
private long rulesVersion = -1; private long rulesVersion = -1;
private long legalBasisVersion = -1; private long legalBasisVersion = -1;
public EntityLog(String dossierId,
String fileId,
long analysisVersion,
int analysisNumber,
List<EntityLogEntry> entityLogEntry,
List<EntityLogLegalBasis> legalBasis,
long dictionaryVersion,
long dossierDictionaryVersion,
long rulesVersion,
long legalBasisVersion) {
this.id = getId(dossierId, fileId);
this.dossierId = dossierId;
this.fileId = fileId;
this.analysisVersion = analysisVersion;
this.analysisNumber = analysisNumber;
this.entityLogEntry = entityLogEntry;
this.legalBasis = legalBasis;
this.dictionaryVersion = dictionaryVersion;
this.dossierDictionaryVersion = dossierDictionaryVersion;
this.rulesVersion = rulesVersion;
this.legalBasisVersion = legalBasisVersion;
}
public static String getId(String dossierId, String fileId) {
return dossierId + "/" + fileId;
}
} }

6
persistence-service-v1/persistence-service-shared-api-v1/src/main/java/com/iqser/red/service/persistence/service/v1/api/shared/model/analysislog/entitylog/EntityLogEntry.java
View File

@ -5,8 +5,6 @@ import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
import org.springframework.data.mongodb.core.mapping.Document;
import lombok.AccessLevel; import lombok.AccessLevel;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Builder; import lombok.Builder;
@ -21,11 +19,9 @@ import lombok.experimental.FieldDefaults;
@AllArgsConstructor @AllArgsConstructor
@EqualsAndHashCode @EqualsAndHashCode
@FieldDefaults(level = AccessLevel.PRIVATE) @FieldDefaults(level = AccessLevel.PRIVATE)
@Document(collection = "entity-log-entries")
public class EntityLogEntry { public class EntityLogEntry {
String entryId; String id;
String entityLogId;
String type; String type;
EntryType entryType; EntryType entryType;
EntryState state; EntryState state;