Feature: VSDSPUB-349: Add Gone status to soft deleted fragments

Informatievlaanderen · Nov 17, 2022 · adf29cb · adf29cb
1 parent a3c3130
commit adf29cb
Show file tree

Hide file tree

Showing 14 changed files with 52 additions and 50 deletions.
diff --git a/...aanderen/informatievlaanderen/ldes/server/domain/exceptions/DeletedFragmentException.java b/...aanderen/informatievlaanderen/ldes/server/domain/exceptions/DeletedFragmentException.java
@@ -0,0 +1,16 @@
+package be.vlaanderen.informatievlaanderen.ldes.server.domain.exceptions;
+
+public class DeletedFragmentException extends RuntimeException {
+	private final String fragmentId;
+
+	public DeletedFragmentException(String fragmentId) {
+		super();
+		this.fragmentId = fragmentId;
+	}
+
+	@Override
+	public String getMessage() {
+		return "Fragment with following identifier has been deleted: " + fragmentId;
+	}
+
+}
diff --git a/...laanderen/informatievlaanderen/ldes/server/domain/ldesfragment/entities/LdesFragment.java b/...laanderen/informatievlaanderen/ldes/server/domain/ldesfragment/entities/LdesFragment.java
@@ -60,10 +60,6 @@ public void setSoftDeleted(boolean softDeleted) {
 		this.fragmentInfo.setSoftDeleted(softDeleted);
 	}
 
-	public void setSoftDeleted(boolean softDeleted) {
-		this.fragmentInfo.setSoftDeleted(softDeleted);
-	}
-
 	public boolean isImmutable() {
 		return this.fragmentInfo.getImmutable();
 	}
@@ -75,4 +71,8 @@ public LdesFragment createChild(FragmentPair fragmentPair) {
 	public void removeRelation(TreeRelation treeRelation) {
 		relations.remove(treeRelation);
 	}
+
+	public boolean isSoftDeleted() {
+		return this.getFragmentInfo().getSoftDeleted();
+	}
 }
diff --git a/...formatievlaanderen/ldes/server/domain/ldesfragment/repository/LdesFragmentRepository.java b/...formatievlaanderen/ldes/server/domain/ldesfragment/repository/LdesFragmentRepository.java
@@ -21,7 +21,7 @@ Optional<LdesFragment> retrieveMutableFragment(String viewName,
 
 	Optional<LdesFragment> retrieveRootFragment(String viewName);
 
-	Stream<LdesFragment> retrieveImmutableFragmentsOfView(String viewName);
+	Stream<LdesFragment> retrieveNonDeletedImmutableFragmentsOfView(String viewName);
 
 	Optional<LdesFragment> retrieveNonDeletedChildFragment(String viewName,
 			List<FragmentPair> fragmentPairList);

diff --git a/...formatievlaanderen/ldes/server/domain/ldesfragment/services/FragmentFetchServiceImpl.java b/...formatievlaanderen/ldes/server/domain/ldesfragment/services/FragmentFetchServiceImpl.java
@@ -1,6 +1,7 @@
 package be.vlaanderen.informatievlaanderen.ldes.server.domain.ldesfragment.services;
 
 import be.vlaanderen.informatievlaanderen.ldes.server.domain.config.LdesConfig;
+import be.vlaanderen.informatievlaanderen.ldes.server.domain.exceptions.DeletedFragmentException;
 import be.vlaanderen.informatievlaanderen.ldes.server.domain.exceptions.MissingFragmentException;
 import be.vlaanderen.informatievlaanderen.ldes.server.domain.ldesfragment.entities.LdesFragment;
 import be.vlaanderen.informatievlaanderen.ldes.server.domain.ldesfragment.repository.LdesFragmentRepository;
@@ -22,12 +23,16 @@ public FragmentFetchServiceImpl(LdesConfig ldesConfig,
 
 	@Override
 	public LdesFragment getFragment(LdesFragmentRequest ldesFragmentRequest) {
-		return ldesFragmentRepository
+		LdesFragment ldesFragment = ldesFragmentRepository
 				.retrieveFragment(ldesFragmentRequest)
 				.orElseThrow(
 						() -> new MissingFragmentException(
-
 								ldesConfig.getHostName() + new FragmentInfo(ldesFragmentRequest.viewName(),
 										ldesFragmentRequest.fragmentPairs()).generateFragmentId()));
+		if (ldesFragment.isSoftDeleted())
+			throw new DeletedFragmentException(
+					ldesConfig.getHostName() + new FragmentInfo(ldesFragmentRequest.viewName(),
+							ldesFragmentRequest.fragmentPairs()).generateFragmentId());
+		return ldesFragment;
 	}
 }
diff --git a/...en/informatievlaanderen/ldes/server/domain/ldesfragment/services/TreeNodeRemoverImpl.java b/...en/informatievlaanderen/ldes/server/domain/ldesfragment/services/TreeNodeRemoverImpl.java
@@ -35,7 +35,7 @@ public TreeNodeRemoverImpl(LdesFragmentRepository ldesFragmentRepository,
 	public void removeTreeNodes() {
 		retentionPolicyMap.forEach((view, retentionPolicies) -> {
 			List<LdesFragment> ldesFragments = ldesFragmentRepository
-					.retrieveImmutableFragmentsOfView(view)
+					.retrieveNonDeletedImmutableFragmentsOfView(view)
 					.filter(ldesFragment -> retentionPolicies
 							.stream()
 							.allMatch(retentionPolicy -> retentionPolicy.matchesPolicy(ldesFragment)))

diff --git a/...deren/informatievlaanderen/ldes/server/domain/ldesfragment/valueobjects/FragmentInfo.java b/...deren/informatievlaanderen/ldes/server/domain/ldesfragment/valueobjects/FragmentInfo.java
@@ -71,14 +71,6 @@ public void setSoftDeleted(Boolean softDeleted) {
 		this.softDeleted = softDeleted;
 	}
 
-	public Boolean getSoftDeleted() {
-		return softDeleted;
-	}
-
-	public void setSoftDeleted(Boolean softDeleted) {
-		this.softDeleted = softDeleted;
-	}
-
 	public FragmentInfo createChild(FragmentPair fragmentPair) {
 		ArrayList<FragmentPair> childFragmentPairs = new ArrayList<>(this.fragmentPairs.stream().toList());
 		childFragmentPairs.add(fragmentPair);

diff --git a/...n/informatievlaanderen/ldes/server/domain/tree/member/services/TreeMemberRemoverImpl.java b/...n/informatievlaanderen/ldes/server/domain/tree/member/services/TreeMemberRemoverImpl.java
@@ -19,6 +19,7 @@ public TreeMemberRemoverImpl(MemberReferencesRepository memberReferencesReposito
 	public void tryRemovingMember(String memberId) {
 		if (!memberReferencesRepository.hasMemberReferences(memberId)) {
 			memberRepository.deleteMember(memberId);
+			memberReferencesRepository.deleteMemberReference(memberId);
 		}
 	}
 }
diff --git a/...anderen/ldes/server/domain/tree/memberreferences/entities/MemberReferencesRepository.java b/...anderen/ldes/server/domain/tree/memberreferences/entities/MemberReferencesRepository.java
@@ -8,4 +8,5 @@ public interface MemberReferencesRepository {
 
 	boolean hasMemberReferences(final String memberId);
 
+	void deleteMemberReference(String memberId);
 }
diff --git a/...nformatievlaanderen/ldes/server/domain/ldesfragment/services/TreeNodeRemoverImplTest.java b/...nformatievlaanderen/ldes/server/domain/ldesfragment/services/TreeNodeRemoverImplTest.java
@@ -32,12 +32,12 @@ class TreeNodeRemoverImplTest {
 	void when_NodeIsImmutableAndSatisfiesRetentionPoliciesOfView_NodeCanBeSoftDeleted() {
 		LdesFragment notReadyToDeleteFragment = notReadyToDeleteFragment();
 		LdesFragment readyToDeleteFragment = readyToDeleteFragment();
-		when(fragmentRepository.retrieveImmutableFragmentsOfView("view"))
+		when(fragmentRepository.retrieveNonDeletedImmutableFragmentsOfView("view"))
 				.thenReturn(Stream.of(notReadyToDeleteFragment, readyToDeleteFragment));
 
 		treeNodeRemover.removeTreeNodes();
 
-		verify(fragmentRepository, times(1)).retrieveImmutableFragmentsOfView("view");
+		verify(fragmentRepository, times(1)).retrieveNonDeletedImmutableFragmentsOfView("view");
 		verify(fragmentRepository, times(1)).saveFragment(readyToDeleteFragment);
 		assertTrue(readyToDeleteFragment.getFragmentInfo().getSoftDeleted());
 		verifyNoMoreInteractions(fragmentRepository);

diff --git a/.../vlaanderen/informatievlaanderen/ldes/server/infra/mongo/LdesFragmentMongoRepository.java b/.../vlaanderen/informatievlaanderen/ldes/server/infra/mongo/LdesFragmentMongoRepository.java
@@ -69,9 +69,9 @@ public Optional<LdesFragment> retrieveRootFragment(String viewName) {
 	}
 
 	@Override
-	public Stream<LdesFragment> retrieveImmutableFragmentsOfView(String viewName) {
+	public Stream<LdesFragment> retrieveNonDeletedImmutableFragmentsOfView(String viewName) {
 		return repository
-				.findAllByImmutableAndViewName(true, viewName)
+				.findAllByImmutableAndSoftDeletedAndViewName(true, false, viewName)
 				.stream()
 				.map(LdesFragmentEntity::toLdesFragment);
 	}

diff --git a/...anderen/informatievlaanderen/ldes/server/infra/mongo/MemberReferencesMongoRepository.java b/...anderen/informatievlaanderen/ldes/server/infra/mongo/MemberReferencesMongoRepository.java
@@ -39,4 +39,9 @@ public synchronized boolean hasMemberReferences(String memberId) {
 				.map(MemberReferencesEntity::hasMemberReferences)
 				.orElseThrow(() -> new MemberNotFoundException(memberId));
 	}
+
+	@Override
+	public synchronized void deleteMemberReference(String memberId) {
+		repository.deleteById(memberId);
+	}
 }
diff --git a/...laanderen/informatievlaanderen/ldes/server/infra/mongo/entities/MemberRefencesEntity.java b/...laanderen/informatievlaanderen/ldes/server/infra/mongo/entities/MemberRefencesEntity.java
diff --git a/...formatievlaanderen/ldes/server/infra/mongo/repositories/LdesFragmentEntityRepository.java b/...formatievlaanderen/ldes/server/infra/mongo/repositories/LdesFragmentEntityRepository.java
@@ -18,5 +18,8 @@ Optional<LdesFragmentEntity> findLdesFragmentEntityByRootAndViewName(
 	List<LdesFragmentEntity> findAllByImmutableAndViewName(
 			Boolean immutable, String viewName);
 
+	List<LdesFragmentEntity> findAllByImmutableAndSoftDeletedAndViewName(Boolean immutable, Boolean softDeleted,
+			String viewName);
+
 	List<LdesFragmentEntity> findAllBySoftDeletedAndViewName(Boolean softDeleted, String viewName);
 }
diff --git a/...atievlaanderen/ldes/server/rest/exceptionhandling/RestResponseEntityExceptionHandler.java b/...atievlaanderen/ldes/server/rest/exceptionhandling/RestResponseEntityExceptionHandler.java
@@ -1,5 +1,6 @@
 package be.vlaanderen.informatievlaanderen.ldes.server.rest.exceptionhandling;
 
+import be.vlaanderen.informatievlaanderen.ldes.server.domain.exceptions.DeletedFragmentException;
 import be.vlaanderen.informatievlaanderen.ldes.server.domain.exceptions.MissingFragmentException;
 import be.vlaanderen.informatievlaanderen.ldes.server.domain.exceptions.RdfFormatException;
 import org.springframework.http.HttpHeaders;
@@ -22,6 +23,14 @@ protected ResponseEntity<Object> handleMissingFragmentException(
 				new HttpHeaders(), HttpStatus.NOT_FOUND, request);
 	}
 
+	@ExceptionHandler(value = { DeletedFragmentException.class })
+	protected ResponseEntity<Object> handleDeletedFragmentException(
+			RuntimeException ex, WebRequest request) {
+		String bodyOfResponse = ex.getMessage();
+		return handleExceptionInternal(ex, bodyOfResponse,
+				new HttpHeaders(), HttpStatus.GONE, request);
+	}
+
 	@ExceptionHandler(value = { RdfFormatException.class })
 	protected ResponseEntity<Object> handleRdfFormatException(
 			RuntimeException ex, WebRequest request) {
Original file line number	Diff line number	Diff line change
Expand Up		@@ -8,4 +8,5 @@ public interface MemberReferencesRepository {

		boolean hasMemberReferences(final String memberId);

		void deleteMemberReference(String memberId);
		}