Skip to content

Commit d8357bb

Browse files
Alex-pvlAlex-pvl
committed
test: update tt3 version
1 parent 56531ae commit d8357bb

30 files changed

Lines changed: 454 additions & 127 deletions

File tree

‎.github/workflows/tests.yml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ jobs:
6868
strategy:
6969
fail-fast: false
7070
matrix:
71-
tarantool-version: [ "2.11.8-ubuntu20.04", "3.0.1-old" ]
71+
tarantool-version: [ "2.11.8-ubuntu20.04", "3.5.0" ]
7272
timeout-minutes: 40
7373
steps:
7474
- uses: actions/checkout@v6
@@ -127,7 +127,7 @@ jobs:
127127
strategy:
128128
fail-fast: false
129129
matrix:
130-
tarantool-version: [ "2.11.8-ubuntu20.04", "3.0.1-old" ]
130+
tarantool-version: [ "2.11.8-ubuntu20.04", "3.5.0" ]
131131
timeout-minutes: 40
132132
steps:
133133
- uses: actions/checkout@v6

‎tarantool-balancer/src/test/java/io/tarantool/balancer/integration/BaseTest.java‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,16 +17,13 @@
1717
import io.netty.util.Timer;
1818
import org.msgpack.value.ArrayValue;
1919
import org.msgpack.value.ValueFactory;
20-
import org.testcontainers.containers.tarantool.TarantoolContainer;
2120

2221
import io.tarantool.core.ManagedResource;
2322
import io.tarantool.core.connection.ConnectionFactory;
2423
import io.tarantool.pool.HeartbeatOpts;
2524

2625
public abstract class BaseTest {
2726

28-
protected static TarantoolContainer<?> container;
29-
3027
protected static final Bootstrap bootstrap =
3128
new Bootstrap()
3229
.group(new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory()))
@@ -69,6 +66,10 @@ public abstract class BaseTest {
6966
protected static final int INVALID_PINGS = 2;
7067
protected static final long INVALIDATION_TIMEOUT =
7168
((long) (INVALID_PINGS + 1) * (PING_INTERVAL + TIMER_ERROR_MS));
69+
70+
/** Longer wait for invalidation (e.g. Tarantool 3 with more connections). */
71+
protected static final long EXTENDED_INVALIDATION_TIMEOUT = INVALIDATION_TIMEOUT * 3;
72+
7273
protected static final long RESTORE_TIMEOUT =
7374
(WINDOW_SIZE + 1) * (PING_INTERVAL + TIMER_ERROR_MS);
7475
protected static final ArrayValue emptyArgs = ValueFactory.emptyArray();

‎tarantool-balancer/src/test/java/io/tarantool/balancer/integration/DistributingRoundRobinBalancerTest.java‎

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import static org.junit.jupiter.api.Assertions.assertThrows;
1717
import static org.junit.jupiter.api.Assertions.assertTrue;
1818
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.createTarantoolContainer;
19+
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.execInitScript;
1920
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.executeCommandDecoded;
2021
import io.micrometer.core.instrument.MeterRegistry;
2122
import io.netty.util.HashedWheelTimer;
@@ -40,7 +41,7 @@
4041
import io.tarantool.pool.IProtoClientPoolImpl;
4142
import io.tarantool.pool.InstanceConnectionGroup;
4243

43-
@Timeout(value = 15)
44+
@Timeout(value = 25)
4445
public class DistributingRoundRobinBalancerTest extends BaseTest {
4546

4647
private static final Logger log =
@@ -51,11 +52,14 @@ public class DistributingRoundRobinBalancerTest extends BaseTest {
5152

5253
@BeforeEach
5354
public void setUp() {
54-
tt1 = createTarantoolContainer().withEnv(ENV_MAP).withExposedPorts(3301, 3305);
55-
tt2 = createTarantoolContainer().withEnv(ENV_MAP).withExposedPorts(3301, 3305);
55+
tt1 = createTarantoolContainer().withEnv(ENV_MAP).withExposedPorts(3305);
56+
tt2 = createTarantoolContainer().withEnv(ENV_MAP).withExposedPorts(3305);
5657

5758
tt1.start();
5859
tt2.start();
60+
61+
execInitScript(tt1);
62+
execInitScript(tt2);
5963
do {
6064
count1 = ThreadLocalRandom.current().nextInt(MIN_CONNECTION_COUNT, MAX_CONNECTION_COUNT + 1);
6165
count2 = ThreadLocalRandom.current().nextInt(MIN_CONNECTION_COUNT, MAX_CONNECTION_COUNT + 1);
@@ -178,8 +182,10 @@ public void testDistributingRoundRobinWithUnavailableNodeA() throws Exception {
178182
execLua(tt2, "reset_call_counter()");
179183

180184
log.info("waiting for invalidation");
181-
Thread.sleep(INVALIDATION_TIMEOUT);
185+
Thread.sleep(EXTENDED_INVALIDATION_TIMEOUT);
182186

187+
execLua(tt1, "reset_call_counter()");
188+
execLua(tt2, "reset_call_counter()");
183189
log.info("walk on node B only");
184190
walkAndJoin(rrBalancer, nodeVisits * 2);
185191
assertEquals(0, getCallCounter(tt1));
@@ -235,8 +241,10 @@ public void testDistributingRoundRobinWithUnavailableNodeANoUnlock() throws Exce
235241
execLua(tt2, "reset_call_counter()");
236242

237243
log.info("waiting for invalidation");
238-
Thread.sleep(INVALIDATION_TIMEOUT);
244+
Thread.sleep(EXTENDED_INVALIDATION_TIMEOUT);
239245

246+
execLua(tt1, "reset_call_counter()");
247+
execLua(tt2, "reset_call_counter()");
240248
log.info("walk on node B only");
241249
walkAndJoin(rrBalancer, nodeVisits * 2);
242250
assertEquals(0, getCallCounter(tt1));
@@ -290,7 +298,7 @@ public void testDistributingRoundRobinNoAvailableClients() throws Exception {
290298
execLua(tt2, "lock_pipe(true); reset_call_counter()");
291299

292300
log.info("waiting for invalidation");
293-
Thread.sleep(INVALIDATION_TIMEOUT);
301+
Thread.sleep(EXTENDED_INVALIDATION_TIMEOUT);
294302

295303
Throwable exc = assertThrows(ExecutionException.class, () -> rrBalancer.getNext().get());
296304
assertEquals(NoAvailableClientsException.class, exc.getCause().getClass());

‎tarantool-balancer/src/test/java/io/tarantool/balancer/integration/RoundRobinBalancerTest.java‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111

1212
import static org.junit.jupiter.api.Assertions.assertEquals;
1313
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.createTarantoolContainer;
14+
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.execInitScript;
1415
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.executeCommandDecoded;
1516
import org.junit.jupiter.api.AfterAll;
1617
import org.junit.jupiter.api.BeforeAll;
@@ -40,6 +41,9 @@ public static void setUp() {
4041
tt1.start();
4142
tt2.start();
4243

44+
execInitScript(tt1);
45+
execInitScript(tt2);
46+
4347
count1 = ThreadLocalRandom.current().nextInt(MIN_CONNECTION_COUNT, MAX_CONNECTION_COUNT + 1);
4448
count2 = ThreadLocalRandom.current().nextInt(MIN_CONNECTION_COUNT, MAX_CONNECTION_COUNT + 1);
4549
}

‎tarantool-client/src/test/java/io/tarantool/client/integration/TarantoolBoxClientTest.java‎

Lines changed: 4 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import static org.junit.jupiter.api.Assertions.assertThrows;
3434
import static org.junit.jupiter.api.Assertions.assertTrue;
3535
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.createTarantoolContainer;
36+
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.execInitScript;
3637
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.executeCommand;
3738
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.executeCommandDecoded;
3839
import com.fasterxml.jackson.core.type.TypeReference;
@@ -98,6 +99,7 @@ public void truncateSpaces() throws Exception {
9899
public static void setUp() throws Exception {
99100
tt = createTarantoolContainer().withEnv(ENV_MAP);
100101
tt.start();
102+
execInitScript(tt);
101103

102104
client =
103105
TarantoolFactory.box()
@@ -1352,26 +1354,14 @@ void testClientType() {
13521354
assertEquals(ClientType.BOX, client.getType());
13531355
}
13541356

1355-
@Test
1356-
void testUserWithNullPassword() throws Exception {
1357-
TarantoolBoxClient serviceClient =
1358-
TarantoolFactory.box()
1359-
.withHost(tt.getHost())
1360-
.withPort(tt.getFirstMappedPort())
1361-
.withUser("service_user")
1362-
.withPassword("")
1363-
.build();
1364-
assertEquals(Collections.singletonList(123), serviceClient.eval("return 123").join().get());
1365-
}
1366-
13671357
@Test
13681358
void testGetServerVersion() throws Exception {
13691359
TarantoolBoxClient client =
13701360
TarantoolFactory.box()
13711361
.withHost(tt.getHost())
13721362
.withPort(tt.getFirstMappedPort())
1373-
.withUser("service_user")
1374-
.withPassword("")
1363+
.withUser("api_user")
1364+
.withPassword("secret")
13751365
.build();
13761366

13771367
TarantoolVersion version = client.getServerVersion().join();

‎tarantool-client/src/test/java/io/tarantool/client/integration/TarantoolClientTest.java‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import static org.junit.jupiter.api.Assertions.assertThrows;
2626
import static org.junit.jupiter.api.Assertions.assertTrue;
2727
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.createTarantoolContainer;
28+
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.execInitScript;
2829
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.executeCommand;
2930
import com.fasterxml.jackson.core.type.TypeReference;
3031
import org.junit.jupiter.api.AfterAll;
@@ -60,6 +61,7 @@ public class TarantoolClientTest extends BaseTest {
6061
public static void setUp() throws Exception {
6162
tt = createTarantoolContainer().withEnv(ENV_MAP);
6263
tt.start();
64+
execInitScript(tt);
6365

6466
client = getClientAndConnect();
6567
client.getPool().forEach(c -> c.authorize(API_USER, CREDS.get(API_USER)).join());
@@ -353,7 +355,7 @@ public void testServerInformation() {
353355
int serverFeatureAmount = 4;
354356

355357
if (tarantoolVersion == '3') {
356-
serverFeatureAmount = 7;
358+
serverFeatureAmount = 10;
357359
}
358360
IProtoClient iprotoClient = client.getPool().get("default", 0).join();
359361
if (tarantoolVersion != '3') {

‎tarantool-client/src/test/java/io/tarantool/client/integration/TarantoolCrudClientTest.java‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -89,8 +89,8 @@
8989
@Testcontainers
9090
public class TarantoolCrudClientTest extends BaseTest {
9191

92-
public static final String SECRET_CLUSTER_COOKIE = "secret-cluster-cookie";
93-
public static final String ADMIN = "admin";
92+
public static final String SECRET_CLUSTER_COOKIE = "secret";
93+
public static final String ADMIN = "api_user";
9494
public static final int PERSON_COUNT = 1000;
9595
public static final Map<String, Object> OPTIONS =
9696
new HashMap<String, Object>() {
@@ -138,7 +138,9 @@ public static void setUp() throws Exception {
138138
"tarantool/tarantool");
139139

140140
if (!vshardClusterContainer.isRunning()) {
141-
vshardClusterContainer.withPrivilegedMode(true);
141+
vshardClusterContainer
142+
.withCreateContainerCmdModifier(cmd -> cmd.withUser("root"))
143+
.withPrivilegedMode(true);
142144
vshardClusterContainer.start();
143145
}
144146
clusterContainer = vshardClusterContainer;

‎tarantool-client/src/test/java/io/tarantool/client/integration/TarantoolCrudClientWithRetryTest.java‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,13 +102,15 @@ private void execute() {
102102
@BeforeAll
103103
public static void setUp() throws Exception {
104104
if (isCartridgeAvailable()) {
105-
tt.start();
105+
if (!tt.isRunning()) {
106+
tt.start();
107+
}
106108
client =
107109
TarantoolFactory.crud()
108110
.withHost(tt.getHost())
109111
.withPort(tt.getPort())
110-
.withUser("admin")
111-
.withPassword("secret-cluster-cookie")
112+
.withUser("api_user")
113+
.withPassword("secret")
112114
.build();
113115
}
114116
}

‎tarantool-core/src/test/java/io/tarantool/core/integration/ConnectionCloseOnClientSideTest.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import static org.junit.jupiter.api.Assertions.assertEquals;
1313
import static org.junit.jupiter.api.Assertions.assertThrows;
1414
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.createTarantoolContainer;
15+
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.execInitScript;
1516
import org.junit.jupiter.api.AfterAll;
1617
import org.junit.jupiter.api.BeforeAll;
1718
import org.junit.jupiter.api.Test;
@@ -32,6 +33,7 @@ public class ConnectionCloseOnClientSideTest extends BaseTest {
3233
static void setUp() {
3334
tt = createTarantoolContainer().withEnv(ENV_MAP);
3435
tt.start();
36+
execInitScript(tt);
3537
}
3638

3739
@AfterAll

‎tarantool-core/src/test/java/io/tarantool/core/integration/ConnectionCloseOnServerSideTest.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import static org.junit.jupiter.api.Assertions.assertThrows;
1717
import static org.junit.jupiter.api.Assertions.assertTrue;
1818
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.createTarantoolContainer;
19+
import static org.testcontainers.containers.utils.TarantoolContainerClientHelper.execInitScript;
1920
import org.junit.jupiter.api.AfterAll;
2021
import org.junit.jupiter.api.BeforeAll;
2122
import org.junit.jupiter.api.Test;
@@ -36,6 +37,7 @@ public class ConnectionCloseOnServerSideTest extends BaseTest {
3637
static void setUp() {
3738
tt = createTarantoolContainer().withEnv(ENV_MAP);
3839
tt.start();
40+
execInitScript(tt);
3941
}
4042

4143
@AfterAll

0 commit comments

Comments
 (0)