libre.sh/keycloak-scim
3
0
Fork 0
Code Issues 15 Pull requests Releases Packages Activity Actions

Fix flaky test for concurrent client creation on H2 database

Browse source 
Closes #29290

Signed-off-by: Giuseppe Graziano <g.graziano94@gmail.com>
This commit is contained in:
Giuseppe Graziano 2024-10-28 11:05:54 +01:00 committed by Pedro Igor
parent de973de800
commit 3d663802bb
1 changed files with 26 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
testsuite/integration-arquillian/tests/base/src/test/java/org/keycloak/testsuite/admin/concurrency/ConcurrencyTest.java
View file

@ -35,12 +35,14 @@ import jakarta.ws.rs.core.Response;
import org.keycloak.representations.idm.UserRepresentation; import org.keycloak.representations.idm.UserRepresentation;
import org.keycloak.testsuite.admin.ApiUtil; import org.keycloak.testsuite.admin.ApiUtil;
import org.keycloak.testsuite.model.StoreProvider;
import org.keycloak.testsuite.util.UserBuilder; import org.keycloak.testsuite.util.UserBuilder;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.IntStream;
import org.junit.Ignore; import org.junit.Ignore;
@ -163,11 +165,18 @@ public class ConcurrencyTest extends AbstractConcurrencyTest {
c = realm.clients().get(id).toRepresentation(); c = realm.clients().get(id).toRepresentation();
assertNotNull(c); assertNotNull(c);
assertTrue("Client " + name + " not found in client list",
realm.clients().findAll().stream() int findAttempts = 1;
.map(ClientRepresentation::getClientId) if (StoreProvider.getCurrentProvider().equals(StoreProvider.DEFAULT)) {
.filter(Objects::nonNull) findAttempts = 5;
.anyMatch(name::equals)); }
boolean clientFound = IntStream.range(0, findAttempts)
.anyMatch(i -> realm.clients().findAll().stream()
.map(ClientRepresentation::getClientId)
.filter(Objects::nonNull)
.anyMatch(name::equals));
assertTrue("Client " + name + " not found in client list after " + findAttempts + " attempts", clientFound);
} }
} }
@ -193,11 +202,18 @@ public class ConcurrencyTest extends AbstractConcurrencyTest {
c = client.toRepresentation(); c = client.toRepresentation();
assertNotNull(c); assertNotNull(c);
assertTrue("Client " + name + " not found in client list",
clients.findAll().stream() int findAttempts = 1;
.map(ClientRepresentation::getClientId) if (StoreProvider.getCurrentProvider().equals(StoreProvider.DEFAULT)) {
.filter(Objects::nonNull) findAttempts = 5;
.anyMatch(name::equals)); }
boolean clientFound = IntStream.range(0, findAttempts)
.anyMatch(i -> clients.findAll().stream()
.map(ClientRepresentation::getClientId)
.filter(Objects::nonNull)
.anyMatch(name::equals));
assertTrue("Client " + name + " not found in client list after " + findAttempts + " attempts", clientFound);
client.remove(); client.remove();
try { try {