diff --git a/VERSION b/VERSION index 5c4503b704..564edf82dd 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -0.49.0 +0.50.0 diff --git a/WORKSPACE b/WORKSPACE index 22130018c4..81de75c22e 100644 --- a/WORKSPACE +++ b/WORKSPACE @@ -10,9 +10,9 @@ load("@bazel_tools//tools/build_defs/repo:git.bzl", "git_repository") git_repository( name = "com_github_airyhq_bazel_tools", - commit = "f33ecc4e2e3349f7f7634bb8491b2e431dd41fa6", + commit = "f499013901107a0462e7fbe6043b84b8cd260e3a", remote = "https://github.com/airyhq/bazel-tools.git", - shallow_since = "1660918023 +0200", + shallow_since = "1664876567 +0200", ) load("@com_github_airyhq_bazel_tools//:repositories.bzl", "airy_bazel_tools_dependencies", "airy_jvm_deps") diff --git a/backend/components/admin/BUILD b/backend/components/admin/BUILD index 38e9acc358..815eee69fb 100644 --- a/backend/components/admin/BUILD +++ b/backend/components/admin/BUILD @@ -36,7 +36,7 @@ springboot( custom_java_library( name = "test-util", - srcs = ["src/test/java/co/airy/core/api/admin/util/Topics.java"], + srcs = ["src/test/java/co/airy/core/admin/util/Topics.java"], deps = app_deps, ) diff --git a/backend/components/admin/src/main/java/co/airy/core/api/admin/ChannelsController.java b/backend/components/admin/src/main/java/co/airy/core/admin/ChannelsController.java similarity index 98% rename from backend/components/admin/src/main/java/co/airy/core/api/admin/ChannelsController.java rename to backend/components/admin/src/main/java/co/airy/core/admin/ChannelsController.java index de3d28edf7..62e3f1b821 100644 --- a/backend/components/admin/src/main/java/co/airy/core/api/admin/ChannelsController.java +++ b/backend/components/admin/src/main/java/co/airy/core/admin/ChannelsController.java @@ -1,9 +1,9 @@ -package co.airy.core.api.admin; +package co.airy.core.admin; import co.airy.avro.communication.Channel; import co.airy.avro.communication.ChannelConnectionState; import co.airy.avro.communication.Metadata; -import co.airy.core.api.admin.payload.ChannelsResponsePayload; +import co.airy.core.admin.payload.ChannelsResponsePayload; import co.airy.model.channel.ChannelPayload; import co.airy.model.channel.dto.ChannelContainer; import co.airy.model.metadata.MetadataKeys; diff --git a/backend/components/admin/src/main/java/co/airy/core/api/admin/Stores.java b/backend/components/admin/src/main/java/co/airy/core/admin/Stores.java similarity index 90% rename from backend/components/admin/src/main/java/co/airy/core/api/admin/Stores.java rename to backend/components/admin/src/main/java/co/airy/core/admin/Stores.java index df3b8f734a..2525dee6b4 100644 --- a/backend/components/admin/src/main/java/co/airy/core/api/admin/Stores.java +++ b/backend/components/admin/src/main/java/co/airy/core/admin/Stores.java @@ -1,4 +1,4 @@ -package co.airy.core.api.admin; +package co.airy.core.admin; import co.airy.avro.communication.Channel; import co.airy.avro.communication.ChannelConnectionState; @@ -39,7 +39,7 @@ import java.util.Optional; import java.util.concurrent.ExecutionException; -import static co.airy.core.api.admin.TimestampExtractor.timestampExtractor; +import static co.airy.core.admin.TimestampExtractor.timestampExtractor; import static co.airy.model.metadata.MetadataRepository.getId; import static co.airy.model.metadata.MetadataRepository.getSubject; @@ -189,19 +189,21 @@ public Template getTemplate(String templateId) { public List getChannels() { final ReadOnlyKeyValueStore store = getConnectedChannelsStore(); - final KeyValueIterator iterator = store.all(); - - List channels = new ArrayList<>(); - iterator.forEachRemaining(kv -> channels.add(kv.value)); + List channels; + try (KeyValueIterator iterator = store.all()) { + channels = new ArrayList<>(); + iterator.forEachRemaining(kv -> channels.add(kv.value)); + } return channels; } public List