OZG-5681 fix missing user id in call context

bescheid-manager/src/main/java/de/ozgcloud/bescheid/common/callcontext/BescheidManagerCallContextProvider.java

+/*
+ * Copyright (C) 2024 Das Land Schleswig-Holstein vertreten durch den
+ * Ministerpräsidenten des Landes Schleswig-Holstein
+ * Staatskanzlei
+ * Abteilung Digitalisierung und zentrales IT-Management der Landesregierung
+ *
+ * Lizenziert unter der EUPL, Version 1.2 oder - sobald
+ * diese von der Europäischen Kommission genehmigt wurden -
+ * Folgeversionen der EUPL ("Lizenz");
+ * Sie dürfen dieses Werk ausschließlich gemäß
+ * dieser Lizenz nutzen.
+ * Eine Kopie der Lizenz finden Sie hier:
+ *
+ * https://joinup.ec.europa.eu/collection/eupl/eupl-text-eupl-12
+ *
+ * Sofern nicht durch anwendbare Rechtsvorschriften
+ * gefordert oder in schriftlicher Form vereinbart, wird
+ * die unter der Lizenz verbreitete Software "so wie sie
+ * ist", OHNE JEGLICHE GEWÄHRLEISTUNG ODER BEDINGUNGEN -
+ * ausdrücklich oder stillschweigend - verbreitet.
+ * Die sprachspezifischen Genehmigungen und Beschränkungen
+ * unter der Lizenz sind dem Lizenztext zu entnehmen.
+ */
+package de.ozgcloud.bescheid.common.callcontext;
+
+import org.springframework.context.annotation.Primary;
+import org.springframework.stereotype.Component;
+
+import de.ozgcloud.apilib.common.callcontext.CallContext;
+import de.ozgcloud.apilib.common.callcontext.OzgCloudCallContextProvider;
+import de.ozgcloud.apilib.user.OzgCloudUserId;
+import de.ozgcloud.common.errorhandling.TechnicalException;
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+@Primary
+public class BescheidManagerCallContextProvider implements OzgCloudCallContextProvider {
+
+	private final CurrentUserService currentUserService;
+
+	@Override
+	public CallContext provideContext() {
+		return CallContext.builder()
+				.userId(getUserId())
+				.clientName(currentUserService.getUser().getClientName())
+				.build();
+	}
+
+	OzgCloudUserId getUserId() {
+		return currentUserService.getUser().getUserId().map(OzgCloudUserId::from)
+				.orElseThrow(() -> new TechnicalException("No user id found in current user profile"));
+	}
+}

bescheid-manager/src/test/java/de/ozgcloud/bescheid/common/callcontext/BescheidManagerCallContextProviderTest.java

+/*
+ * Copyright (C) 2024 Das Land Schleswig-Holstein vertreten durch den
+ * Ministerpräsidenten des Landes Schleswig-Holstein
+ * Staatskanzlei
+ * Abteilung Digitalisierung und zentrales IT-Management der Landesregierung
+ *
+ * Lizenziert unter der EUPL, Version 1.2 oder - sobald
+ * diese von der Europäischen Kommission genehmigt wurden -
+ * Folgeversionen der EUPL ("Lizenz");
+ * Sie dürfen dieses Werk ausschließlich gemäß
+ * dieser Lizenz nutzen.
+ * Eine Kopie der Lizenz finden Sie hier:
+ *
+ * https://joinup.ec.europa.eu/collection/eupl/eupl-text-eupl-12
+ *
+ * Sofern nicht durch anwendbare Rechtsvorschriften
+ * gefordert oder in schriftlicher Form vereinbart, wird
+ * die unter der Lizenz verbreitete Software "so wie sie
+ * ist", OHNE JEGLICHE GEWÄHRLEISTUNG ODER BEDINGUNGEN -
+ * ausdrücklich oder stillschweigend - verbreitet.
+ * Die sprachspezifischen Genehmigungen und Beschränkungen
+ * unter der Lizenz sind dem Lizenztext zu entnehmen.
+ */
+package de.ozgcloud.bescheid.common.callcontext;
+
+import static org.assertj.core.api.Assertions.*;
+import static org.mockito.Mockito.*;
+
+import java.util.Optional;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Nested;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.Spy;
+
+import de.ozgcloud.apilib.user.OzgCloudUserId;
+import de.ozgcloud.common.errorhandling.TechnicalException;
+
+class BescheidManagerCallContextProviderTest {
+
+	@Spy
+	@InjectMocks
+	private BescheidManagerCallContextProvider provider;
+
+	@Mock
+	private CurrentUserService currentUserService;
+	@Mock
+	private CallContextUser contextUser;
+	@Mock
+	private OzgCloudUserId userId;
+
+	@BeforeEach
+	void init() {
+		when(currentUserService.getUser()).thenReturn(contextUser);
+	}
+
+	@Nested
+	class TestProvideContext {
+
+		private static final String CLIENT_NAME = "clientName";
+
+		@BeforeEach
+		void init() {
+			doReturn(userId).when(provider).getUserId();
+			when(contextUser.getClientName()).thenReturn(CLIENT_NAME);
+		}
+
+		@Test
+		void shouldCallGetUserId() {
+			provider.provideContext();
+
+			verify(provider).getUserId();
+		}
+
+		@Test
+		void shouldSetUserId() {
+			var result = provider.provideContext();
+
+			assertThat(result.getUserId()).isSameAs(userId);
+		}
+
+		@Test
+		void shouldSetClientName() {
+			var result = provider.provideContext();
+
+			assertThat(result.getClientName()).isEqualTo(CLIENT_NAME);
+		}
+	}
+
+	@Nested
+	class TestGetUserId {
+
+		private static final String USER_ID = "userId";
+
+		@Test
+		void shouldReturnUserId() {
+			when(contextUser.getUserId()).thenReturn(Optional.of(USER_ID));
+
+			var result = provider.getUserId();
+
+			assertThat(result).hasToString(USER_ID);
+		}
+
+		@Test
+		void shouldThrowExceptionWhenUserIdMissing() {
+			Assertions.assertThrows(TechnicalException.class, provider::getUserId);
+		}
+	}
+}
\ No newline at end of file

vorgang-manager-base/src/test/java/de/ozgcloud/vorgang/callcontext/CallContextAuthenticationTokenTestFactory.java

+/*
+ * Copyright (C) 2024 Das Land Schleswig-Holstein vertreten durch den
+ * Ministerpräsidenten des Landes Schleswig-Holstein
+ * Staatskanzlei
+ * Abteilung Digitalisierung und zentrales IT-Management der Landesregierung
+ *
+ * Lizenziert unter der EUPL, Version 1.2 oder - sobald
+ * diese von der Europäischen Kommission genehmigt wurden -
+ * Folgeversionen der EUPL ("Lizenz");
+ * Sie dürfen dieses Werk ausschließlich gemäß
+ * dieser Lizenz nutzen.
+ * Eine Kopie der Lizenz finden Sie hier:
+ *
+ * https://joinup.ec.europa.eu/collection/eupl/eupl-text-eupl-12
+ *
+ * Sofern nicht durch anwendbare Rechtsvorschriften
+ * gefordert oder in schriftlicher Form vereinbart, wird
+ * die unter der Lizenz verbreitete Software "so wie sie
+ * ist", OHNE JEGLICHE GEWÄHRLEISTUNG ODER BEDINGUNGEN -
+ * ausdrücklich oder stillschweigend - verbreitet.
+ * Die sprachspezifischen Genehmigungen und Beschränkungen
+ * unter der Lizenz sind dem Lizenztext zu entnehmen.
+ */
+package de.ozgcloud.vorgang.callcontext;
+
+public class CallContextAuthenticationTokenTestFactory {
+
+	public static CallContextAuthenticationToken create() {
+		return CallContextAuthenticationToken.authenticate(CallContextUserTestFactory.create());
+	}
+}

vorgang-manager-server/src/test/java/de/ozgcloud/bescheid/BescheidEventListenerITCase.java

@@ -29,16 +29,14 @@ import static org.awaitility.Awaitility.*;
 import static org.mockito.Mockito.*;
 
 import java.util.Map;
-import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 
+import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 import org.mockito.ArgumentCaptor;
 import org.mockito.Captor;
-import org.mockito.Mock;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.test.mock.mockito.MockBean;
@@ -48,14 +46,15 @@ import org.springframework.data.mongodb.core.MongoOperations;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.gridfs.GridFsTemplate;
+import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.test.annotation.DirtiesContext;
 
 import com.mongodb.client.gridfs.model.GridFSFile;
 
+import de.ozgcloud.apilib.user.OzgCloudUserId;
+import de.ozgcloud.apilib.user.OzgCloudUserProfile;
+import de.ozgcloud.apilib.user.OzgCloudUserProfileService;
 import de.ozgcloud.bescheid.attacheditem.AttachedItemService;
-import de.ozgcloud.bescheid.common.callcontext.CallContextUser;
-import de.ozgcloud.bescheid.common.callcontext.CurrentUserService;
-import de.ozgcloud.bescheid.common.callcontext.UserProfile;
 import de.ozgcloud.command.Command;
 import de.ozgcloud.command.CommandCreatedEvent;
 import de.ozgcloud.command.CommandStatus;
@@ -68,6 +67,7 @@ import de.ozgcloud.nachrichten.postfach.PostfachRemoteService;
 import de.ozgcloud.vorgang.VorgangManagerServerApplication;
 import de.ozgcloud.vorgang.attached_item.VorgangAttachedItem;
 import de.ozgcloud.vorgang.attached_item.VorgangAttachedItemTestFactory;
+import de.ozgcloud.vorgang.callcontext.CallContextAuthenticationTokenTestFactory;
 import de.ozgcloud.vorgang.command.CommandService;
 import de.ozgcloud.vorgang.command.CommandTestFactory;
 import de.ozgcloud.vorgang.command.CreateCommandRequest;
@@ -87,7 +87,6 @@ import de.ozgcloud.vorgang.vorgang.VorgangTestFactory;
 })
 @DataITCase
 @DirtiesContext
-@Disabled("fix later")
 class BescheidEventListenerITCase {
 
 	@Autowired
@@ -105,11 +104,7 @@ class BescheidEventListenerITCase {
 	@MockBean
 	private PostfachRemoteService postfachRemoteService;
 	@MockBean
-	private CurrentUserService currentUserService;
-	@Mock
-	private CallContextUser callContextUser;
-	@Mock
-	private UserProfile userProfile;
+	private OzgCloudUserProfileService userProfileService;
 
 	@Captor
 	private ArgumentCaptor<BescheidDocumentCreatedEvent> bescheidDocumentCreatedEventCaptor;
@@ -118,9 +113,8 @@ class BescheidEventListenerITCase {
 	void init() {
 		mongoOperations.dropCollection(VorgangAttachedItem.COLLECTION_NAME);
 		mongoOperations.dropCollection(Vorgang.COLLECTION_NAME);
-		when(currentUserService.getUser()).thenReturn(callContextUser);
-		when(currentUserService.getUserProfile()).thenReturn(userProfile);
 		when(postfachRemoteService.getPostfachType()).thenReturn("dummy");
+		when(userProfileService.getById(any())).thenReturn(OzgCloudUserProfile.builder().id(OzgCloudUserId.from("user-id")).build());
 	}
 
 	@Nested
@@ -270,10 +264,14 @@ class BescheidEventListenerITCase {
 		private String vorgangId;
 		private VorgangAttachedItem bescheidItem;
 
+		@AfterAll
+		static void cleanup() {
+			SecurityContextHolder.clearContext();
+		}
+
 		@BeforeEach
 		void init() {
-			when(userProfile.getId()).thenReturn(UserId.from("user-id"));
-			when(callContextUser.getUserId()).thenReturn(Optional.of("user-id"));
+			SecurityContextHolder.getContext().setAuthentication(CallContextAuthenticationTokenTestFactory.create());
 			vorgangId = mongoOperations.save(VorgangTestFactory.createBuilder().id(null).build()).getId();
 			var documentFileId = mongoOperations.save(createBescheidDocumentAttachedItem(vorgangId)).getId();
 			bescheidItem = mongoOperations.save(createBescheidAttachedItemWithDocument(vorgangId, documentFileId));
@@ -291,9 +289,9 @@ class BescheidEventListenerITCase {
 
 		@Test
 		void shouldSetBescheidStatusToSent() {
-			eventPublisher.publishEvent(buildCommandCreatedEvent(vorgangId, bescheidItem));
+			commandService.createCommand(buildCreateCommandRequest(vorgangId, bescheidItem));
 
-			await().atMost(1, TimeUnit.SECONDS).untilAsserted(() -> {
+			await().atMost(60, TimeUnit.SECONDS).untilAsserted(() -> {
 				verify(bescheiTestEventListener).onBescheidSentEvent(bescheidSentEventCaptor.capture());
 				assertThat(loadBescheid(bescheidItem.getId()).getItem()).containsEntry(Bescheid.FIELD_STATUS, Bescheid.Status.SENT.name());
 			});
@@ -365,18 +363,6 @@ class BescheidEventListenerITCase {
 					.build();
 		}
 
-		private CommandCreatedEvent buildCommandCreatedEvent(String vorgangId, VorgangAttachedItem bescheidItem) {
-			var command = CommandTestFactory.createBuilder()
-					.vorgangId(vorgangId)
-					.relationId(bescheidItem.getId())
-					.relationVersion(bescheidItem.getVersion())
-					.order(SEND_BESCHEID_ORDER)
-					.bodyObject(Map.of(BESCHEID_VOM_BODYKEY, "2024-01-01",
-							GENEHMIGT_BODYKEY, true))
-					.build();
-			return new CommandCreatedEvent(command);
-		}
-
 		private CreateCommandRequest buildCreateCommandRequest(String vorgangId, VorgangAttachedItem bescheidItem) {
 			return CreateCommandRequest.builder()
 					.vorgangId(vorgangId)