Added unit tests

user-manager-server/src/test/java/de/itvsh/kop/user/UserRepositoryTest.java

+/*
+ * Copyright (C) 2022 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.itvsh.kop.user;
+
+import static org.assertj.core.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.*;
+import static org.mockito.Mockito.*;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Optional;
+
+import org.assertj.core.api.Condition;
+import org.bson.types.ObjectId;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Nested;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mock;
+import org.mockito.Spy;
+
+import de.itvsh.kop.user.common.errorhandling.ResourceNotFoundException;
+import io.quarkus.mongodb.panache.PanacheQuery;
+import io.quarkus.mongodb.panache.common.PanacheUpdate;
+
+class UserRepositoryTest {
+	@Spy
+	UserRepository userRepository;
+
+	@Mock
+	PanacheQuery<User> panacheQuery;
+
+	User user = UserTestFactory.create();
+
+	@DisplayName("Test updating users")
+	@Nested
+	class TestUpdate {
+
+		@Test
+		void shouldCallUpdate() {
+			doReturn(UserTestFactory.create()).when(userRepository).findById(any(ObjectId.class));
+			doNothing().when(userRepository).update(any(User.class));
+
+			userRepository.updateUser(UserTestFactory.create());
+
+			verify(userRepository, times(2)).findById(any(ObjectId.class));
+			verify(userRepository).update(any(User.class));
+		}
+
+		@Test
+		void shouldMarkUserAsDeleted() {
+			PanacheUpdate update = mock(PanacheUpdate.class);
+			doReturn(update).when(userRepository).update(anyString(), anyBoolean());
+			long timestamp = new Date().getTime();
+
+			userRepository.updateUnsyncedUsers(timestamp);
+
+			verify(userRepository).update(User.DELETED_FIELD, true);
+			verify(update).where("lastSyncTimestamp < ?1", timestamp);
+		}
+	}
+
+	@DisplayName("Test loading users")
+	@Nested
+	class TestFind {
+
+		@Test
+		void shouldFindByExternalId() {
+			doReturn(Optional.of(user)).when(panacheQuery).firstResultOptional();
+			doReturn(panacheQuery).when(userRepository).find(anyString(), anyString());
+
+			var userOpt = userRepository.findByExternalId(UserTestFactory.EXTERNAL_ID);
+
+			assertThat(userOpt).isPresent().get().isEqualTo(user);
+		}
+
+		@Test
+		void shouldFindByEmail() {
+			doReturn(Optional.of(user)).when(panacheQuery).firstResultOptional();
+			doReturn(panacheQuery).when(userRepository).find(anyString(), anyString());
+
+			var userOpt = userRepository.findByEmail(UserTestFactory.EMAIL);
+
+			assertThat(userOpt).isPresent().get().isEqualTo(user);
+		}
+
+		@Test
+		void shouldFindById() {
+			doReturn(Optional.of(user)).when(userRepository).findByIdOptional(UserTestFactory.ID);
+
+			var userOpt = userRepository.findById(UserTestFactory.ID.toHexString());
+
+			assertThat(userOpt).isPresent().get().isEqualTo(user);
+		}
+
+		@DisplayName("handle loading list of users")
+		@Nested
+		class TestFindUsers {
+			Condition<User> cond = new Condition<>(value -> value.equals(user), "User expected");
+
+			@Mock
+			PanacheQuery<?> rangeQuery;
+
+			@BeforeEach
+			void init() {
+				doReturn(List.of(UserTestFactory.create()).stream()).when(rangeQuery).stream();
+				doReturn(rangeQuery).when(panacheQuery).range(anyInt(), anyInt());
+			}
+
+			@Test
+			void shouldFindUsers() {
+				doReturn(panacheQuery).when(userRepository).find(anyString(), anyString());
+
+				var userStream = userRepository.findUsers(UserTestFactory.USER_NAME, 1);
+
+				assertThat(userStream).areExactly(0, cond);
+			}
+
+			@Test
+			void shouldFindDeletedUsers() {
+				doReturn(panacheQuery).when(userRepository).find(anyString(), anyString(), anyBoolean());
+
+				var userStream = userRepository.findUsers(UserTestFactory.USER_NAME, true, 1);
+
+				assertThat(userStream).areExactly(0, cond);
+			}
+		}
+	}
+
+	@DisplayName("Test refreshing a user")
+	@Nested
+	class TestRefresh {
+		@Test
+		void shouldRefreshUserById() {
+			doReturn(Optional.of(user)).when(userRepository).findByIdOptional(UserTestFactory.ID);
+			doReturn(Optional.of(user)).when(panacheQuery).firstResultOptional();
+			doReturn(panacheQuery).when(userRepository).find(anyString(), anyString());
+
+			var refreshedUser = userRepository.refresh(user);
+
+			assertThat(refreshedUser).isEqualTo(user);
+		}
+
+		@Test
+		void shouldRefreshUserByExternalId() {
+			doReturn(Optional.empty()).when(userRepository).findByIdOptional(any(ObjectId.class));
+			doReturn(Optional.of(user)).when(userRepository).findByExternalId(anyString());
+
+			var refreshedUser = userRepository.refresh(UserTestFactory.create());
+
+			assertThat(refreshedUser).isEqualTo(user);
+		}
+
+		@Test
+		void shouldThrowResourceNotFound() {
+			doReturn(Optional.empty()).when(userRepository).findByIdOptional(any(ObjectId.class));
+			doReturn(Optional.empty()).when(userRepository).findByExternalId(anyString());
+
+			assertThatExceptionOfType(ResourceNotFoundException.class).isThrownBy(() -> userRepository.refresh(UserTestFactory.create())); // NOSONAR
+		}
+	}
+}

user-manager-server/src/test/java/de/itvsh/kop/user/common/lock/LockRepositoryTest.java

+/*
+ * Copyright (C) 2022 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.itvsh.kop.user.common.lock;
+
+import static org.assertj.core.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.*;
+import static org.mockito.Mockito.*;
+
+import java.time.Instant;
+import java.util.Optional;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Nested;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mock;
+import org.mockito.Spy;
+
+import io.quarkus.mongodb.panache.PanacheQuery;
+
+class LockRepositoryTest {
+	@Spy
+	LockRepository lockRepository;
+
+	@Mock
+	PanacheQuery<Lock> panacheFindQuery;
+
+	@DisplayName("Test loading sync lock")
+	@Nested
+	class TestGetLock {
+		private static final Lock LOCK = LockTestFactory.create();
+
+		@BeforeEach
+		void init() {
+			doReturn(panacheFindQuery).when(lockRepository).find(anyString(), anyLong());
+			doReturn(Optional.of(LOCK)).when(panacheFindQuery).firstResultOptional();
+		}
+
+		@Test
+		void shouldGetOldLock() {
+			var lockOptional = lockRepository.findLockBefore(Instant.ofEpochMilli(LOCK.getTimestamp()));
+
+			assertThat(lockOptional).isPresent().get().hasFieldOrPropertyWithValue(Lock.TIMESTAMP_FIELD, LOCK.getTimestamp());
+		}
+
+		@Test
+		void shouldGetLock() {
+			var lockOptional = lockRepository.findLock(Instant.ofEpochMilli(LOCK.getTimestamp()));
+
+			assertThat(lockOptional).isPresent().get().hasFieldOrPropertyWithValue(Lock.TIMESTAMP_FIELD, LOCK.getTimestamp());
+		}
+	}
+}

user-manager-server/src/test/java/de/itvsh/kop/user/keycloak/KeycloakProviderTest.java

+/*
+ * Copyright (C) 2022 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.itvsh.kop.user.keycloak;
+
+import static org.assertj.core.api.Assertions.*;
+import static org.mockito.Mockito.*;
+
+import java.lang.reflect.Field;
+
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.DisplayName;
+import org.junit.jupiter.api.Nested;
+import org.junit.jupiter.api.Test;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+
+import lombok.SneakyThrows;
+
+class KeycloakProviderTest {
+	@InjectMocks
+	KeycloakProvider keycloakProvider;
+	@Mock
+	KeycloakApiProperties properties;
+
+	@DisplayName("Test providing keycloak admin client")
+	@Nested
+	class TestProvider {
+		@BeforeEach
+		void initProperties() {
+			setServerUrl();
+			when(properties.realm()).thenReturn("realm");
+			when(properties.user()).thenReturn("user");
+			when(properties.password()).thenReturn("password");
+		}
+
+		@SneakyThrows
+		private void setServerUrl() {
+			Field url = keycloakProvider.getClass().getDeclaredField("keycloakUrl");
+			url.set(keycloakProvider, "url");
+		}
+
+		@Test
+		void shouldCreateRealmResource() {
+			var resource = keycloakProvider.provide();
+
+			assertThat(resource).isNotNull();
+		}
+	}
+}