From e5c003698502596f0a49124b98a4c09d40af6402 Mon Sep 17 00:00:00 2001 From: sttk Date: Sat, 11 Apr 2026 17:51:13 +0900 Subject: [PATCH] style: adjusted the indentations --- .../sttk/sabi_redis/StandaloneAsyncTest.java | 124 +++++++++--------- .../sttk/sabi_redis/StandaloneSyncTest.java | 124 +++++++++--------- .../sttk/sabi_redis/StandaloneTest.java | 48 ++++--- 3 files changed, 151 insertions(+), 145 deletions(-) diff --git a/src/test/java/com/github/sttk/sabi_redis/StandaloneAsyncTest.java b/src/test/java/com/github/sttk/sabi_redis/StandaloneAsyncTest.java index 5c26fde..4a532f8 100644 --- a/src/test/java/com/github/sttk/sabi_redis/StandaloneAsyncTest.java +++ b/src/test/java/com/github/sttk/sabi_redis/StandaloneAsyncTest.java @@ -206,91 +206,91 @@ class SampleDataHub extends DataHub implements SampleData, RedisSampleDataAcc {} @Test void test_TxnAndForceBack() { try (var data = new SampleDataHub()) { - data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/3")); - try { - data.txn(sampleLogicWithForceBackOk); - } catch (Err err) { - fail(err); - } + data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/3")); + try { + data.txn(sampleLogicWithForceBackOk); + } catch (Err err) { + fail(err); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/3"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/3"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_force_back"); - cmd.del("sample_force_back"); - assertThat(s).isEqualTo("Good Morning"); + var s = cmd.get("sample_force_back"); + cmd.del("sample_force_back"); + assertThat(s).isEqualTo("Good Morning"); - s = cmd.get("sample_force_back_2"); - cmd.del("sample_force_back_2"); - assertThat(s).isEqualTo("Good Morning"); - } + s = cmd.get("sample_force_back_2"); + cmd.del("sample_force_back_2"); + assertThat(s).isEqualTo("Good Morning"); + } - try { - data.txn(sampleLogicWithForceBackErr); - fail(); - } catch (Err err) { - assertThat(err.getReason()).isEqualTo("XXX"); - } + try { + data.txn(sampleLogicWithForceBackErr); + fail(); + } catch (Err err) { + assertThat(err.getReason()).isEqualTo("XXX"); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/3"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/3"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_force_back"); - cmd.del("sample_force_back"); - assertThat(s).isNull(); + var s = cmd.get("sample_force_back"); + cmd.del("sample_force_back"); + assertThat(s).isNull(); - s = cmd.get("sample_force_back_2"); - cmd.del("sample_force_back_2"); - assertThat(s).isNull(); - } + s = cmd.get("sample_force_back_2"); + cmd.del("sample_force_back_2"); + assertThat(s).isNull(); + } } } @Test void test_TxnAndPreCommit() { try (var data = new SampleDataHub()) { - data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/4")); - try { - data.txn(sampleLogicWithPreCommit); - } catch (Err err) { - fail(err); - } + data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/4")); + try { + data.txn(sampleLogicWithPreCommit); + } catch (Err err) { + fail(err); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/4"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/4"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_pre_commit"); - cmd.del("sample_pre_commit"); - assertThat(s).isEqualTo("Good Evening"); - } + var s = cmd.get("sample_pre_commit"); + cmd.del("sample_pre_commit"); + assertThat(s).isEqualTo("Good Evening"); + } } } @Test void test_TxnAndPostCommit() { try (var data = new SampleDataHub()) { - data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/5")); - try { - data.txn(sampleLogicWithPostCommit); - } catch (Err err) { - fail(err); - } + data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/5")); + try { + data.txn(sampleLogicWithPostCommit); + } catch (Err err) { + fail(err); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/5"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/5"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_post_commit"); - cmd.del("sample_post_commit"); - assertThat(s).isEqualTo("Good Night"); - } + var s = cmd.get("sample_post_commit"); + cmd.del("sample_post_commit"); + assertThat(s).isEqualTo("Good Night"); + } } } } diff --git a/src/test/java/com/github/sttk/sabi_redis/StandaloneSyncTest.java b/src/test/java/com/github/sttk/sabi_redis/StandaloneSyncTest.java index 4e34b47..70964b1 100644 --- a/src/test/java/com/github/sttk/sabi_redis/StandaloneSyncTest.java +++ b/src/test/java/com/github/sttk/sabi_redis/StandaloneSyncTest.java @@ -169,91 +169,91 @@ class SampleDataHub extends DataHub implements SampleData, RedisSampleDataAcc {} @Test void test_TxnAndForceBack() { try (var data = new SampleDataHub()) { - data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/3")); - try { - data.txn(sampleLogicWithForceBackOk); - } catch (Err err) { - fail(err); - } + data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/3")); + try { + data.txn(sampleLogicWithForceBackOk); + } catch (Err err) { + fail(err); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/3"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/3"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_force_back"); - cmd.del("sample_force_back"); - assertThat(s).isEqualTo("Good Morning"); + var s = cmd.get("sample_force_back"); + cmd.del("sample_force_back"); + assertThat(s).isEqualTo("Good Morning"); - s = cmd.get("sample_force_back_2"); - cmd.del("sample_force_back_2"); - assertThat(s).isEqualTo("Good Morning"); - } + s = cmd.get("sample_force_back_2"); + cmd.del("sample_force_back_2"); + assertThat(s).isEqualTo("Good Morning"); + } - try { - data.txn(sampleLogicWithForceBackErr); - fail(); - } catch (Err err) { - assertThat(err.getReason()).isEqualTo("XXX"); - } + try { + data.txn(sampleLogicWithForceBackErr); + fail(); + } catch (Err err) { + assertThat(err.getReason()).isEqualTo("XXX"); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/3"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/3"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_force_back"); - cmd.del("sample_force_back"); - assertThat(s).isNull(); + var s = cmd.get("sample_force_back"); + cmd.del("sample_force_back"); + assertThat(s).isNull(); - s = cmd.get("sample_force_back_2"); - cmd.del("sample_force_back_2"); - assertThat(s).isNull(); - } + s = cmd.get("sample_force_back_2"); + cmd.del("sample_force_back_2"); + assertThat(s).isNull(); + } } } @Test void test_TxnAndPreCommit() { try (var data = new SampleDataHub()) { - data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/4")); - try { - data.txn(sampleLogicWithPreCommit); - } catch (Err err) { - fail(err); - } + data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/4")); + try { + data.txn(sampleLogicWithPreCommit); + } catch (Err err) { + fail(err); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/4"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/4"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_pre_commit"); - cmd.del("sample_pre_commit"); - assertThat(s).isEqualTo("Good Evening"); - } + var s = cmd.get("sample_pre_commit"); + cmd.del("sample_pre_commit"); + assertThat(s).isEqualTo("Good Evening"); + } } } @Test void test_TxnAndPostCommit() { try (var data = new SampleDataHub()) { - data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/5")); - try { - data.txn(sampleLogicWithPostCommit); - } catch (Err err) { - fail(err); - } + data.uses("redis", new RedisDataSrc("redis://127.0.0.1:6379/5")); + try { + data.txn(sampleLogicWithPostCommit); + } catch (Err err) { + fail(err); + } - { - var client = RedisClient.create("redis://127.0.0.1:6379/5"); - var conn = client.connect(); - var cmd = conn.sync(); + { + var client = RedisClient.create("redis://127.0.0.1:6379/5"); + var conn = client.connect(); + var cmd = conn.sync(); - var s = cmd.get("sample_post_commit"); - cmd.del("sample_post_commit"); - assertThat(s).isEqualTo("Good Night"); - } + var s = cmd.get("sample_post_commit"); + cmd.del("sample_post_commit"); + assertThat(s).isEqualTo("Good Night"); + } } } } diff --git a/src/test/java/com/github/sttk/sabi_redis/StandaloneTest.java b/src/test/java/com/github/sttk/sabi_redis/StandaloneTest.java index 9b5e47e..77a8611 100644 --- a/src/test/java/com/github/sttk/sabi_redis/StandaloneTest.java +++ b/src/test/java/com/github/sttk/sabi_redis/StandaloneTest.java @@ -5,15 +5,12 @@ import com.github.sttk.errs.Err; import com.github.sttk.sabi.DataHub; -import com.github.sttk.sabi.AsyncGroup; +import io.lettuce.core.RedisURI; +import io.lettuce.core.resource.DefaultClientResources; import java.net.URI; import java.net.URISyntaxException; -import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Nested; -import io.lettuce.core.RedisURI; -import io.lettuce.core.resource.DefaultClientResources; -import io.lettuce.core.resource.SocketAddressResolver; -import io.lettuce.core.resource.DnsResolver; +import org.junit.jupiter.api.Test; public class StandaloneTest { private StandaloneTest() {} @@ -71,7 +68,8 @@ void test_NewRedisDataSrcWithUriStringButNotFoundAddr() { case RedisDataSrc.FailToCreateClientFromUriString reason2 -> { assertThat(reason2.uri()).isEqualTo("redis://127.0.0.1:9999/0"); assertThat(err2.getCause().toString()) - .isEqualTo("io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); + .isEqualTo( + "io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); } default -> fail(err); } @@ -146,7 +144,8 @@ void test_NewRedisDataSrcWithURIButNotFoundAddr() { case RedisDataSrc.FailToCreateClientFromURI reason2 -> { assertThat(reason2.uri().toString()).isEqualTo("redis://127.0.0.1:9999/0"); assertThat(err2.getCause().toString()) - .isEqualTo("io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); + .isEqualTo( + "io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); } default -> fail(err); } @@ -183,7 +182,8 @@ void test_NewRedisDataSrcWithRedisURIButInvalidAddr() { case RedisDataSrc.FailToCreateClientFromRedisURI reason2 -> { assertThat(reason2.redisURI().toString()).isEqualTo("redis://127.0.0.1:9999/1"); assertThat(err2.getCause().toString()) - .isEqualTo("io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); + .isEqualTo( + "io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); } default -> fail(err); } @@ -249,7 +249,8 @@ void test_NewRedisDataSrcWithClientResourcesAndUriStringButNotFoundAddr() { case RedisDataSrc.FailToCreateClientFromClientResourcesAndUriString reason2 -> { assertThat(reason2.uri()).isEqualTo("redis://127.0.0.1:9999/0"); assertThat(err2.getCause().toString()) - .isEqualTo("io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); + .isEqualTo( + "io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); } default -> fail(err); } @@ -327,7 +328,8 @@ void test_NewRedisDataSrcWithClientResourcesAndURIButNotFoundAddr() { case RedisDataSrc.FailToCreateClientFromClientResourcesAndURI reason2 -> { assertThat(reason2.uri().toString()).isEqualTo("redis://127.0.0.1:9999/0"); assertThat(err2.getCause().toString()) - .isEqualTo("io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); + .isEqualTo( + "io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); } default -> fail(err); } @@ -366,7 +368,8 @@ void test_NewRedisDataSrcWithClientResourcesAndRedisURIButInvalidAddr() { case RedisDataSrc.FailToCreateClientFromClientResourcesAndRedisURI reason2 -> { assertThat(reason2.redisURI().toString()).isEqualTo("redis://127.0.0.1:9999/1"); assertThat(err2.getCause().toString()) - .isEqualTo("io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); + .isEqualTo( + "io.lettuce.core.RedisConnectionException: Unable to connect to 127.0.0.1/:9999"); } default -> fail(err); } @@ -383,9 +386,10 @@ void testRedisDataConn() { var conn = new RedisDataConn(null); conn.rollback(null); - conn.addPreCommit(_conn -> { - throw new Err("bad"); - }); + conn.addPreCommit( + _conn -> { + throw new Err("bad"); + }); try { conn.preCommit(null); fail(); @@ -393,14 +397,16 @@ void testRedisDataConn() { assertThat(err.getReason()).isEqualTo("bad"); } - conn.addPostCommit(_conn -> { - throw new Err("bad"); - }); + conn.addPostCommit( + _conn -> { + throw new Err("bad"); + }); conn.postCommit(null); - conn.addForceBack(_conn -> { - throw new Err("bad"); - }); + conn.addForceBack( + _conn -> { + throw new Err("bad"); + }); conn.forceBack(null); }