diff --git a/.github/ISSUE_TEMPLATE/---bug-report.md b/.github/ISSUE_TEMPLATE/---bug-report.md index fe7fbff935..959da01e7c 100644 --- a/.github/ISSUE_TEMPLATE/---bug-report.md +++ b/.github/ISSUE_TEMPLATE/---bug-report.md @@ -6,27 +6,32 @@ labels: bug assignees: "" --- -**Describe the bug** +## Describe the bug + A clear and concise description of what the bug is. -**To Reproduce** +## To Reproduce + Steps to reproduce the behavior: 1. I installed Airy using '...' 2. When I ran command / did this in the UI 3. See error -**Expected behavior** +## Expected behavior + A clear and concise description of what you expected to happen. -**Screenshots** +## Screenshots + If applicable, add screenshots to help explain your problem. -**Desktop (please complete the following information):** +## Environment - OS: [e.g. iOS] -- Browser [e.g. Chrome, Safari] -- Version [e.g. 22] +- Browser: [e.g. Chrome, Safari] +- Version: [e.g. 22] + +## Additional context -**Additional context** Add any other context about the problem here. diff --git a/.github/ISSUE_TEMPLATE/---feature-request.md b/.github/ISSUE_TEMPLATE/---feature-request.md index 7340299129..bb3769891f 100644 --- a/.github/ISSUE_TEMPLATE/---feature-request.md +++ b/.github/ISSUE_TEMPLATE/---feature-request.md @@ -6,14 +6,18 @@ labels: feature, needs discussion assignees: "" --- -**Is your feature request related to a problem? Please describe.** +## Is your feature request related to a problem? Please describe. + A clear and concise description of what the problem is. Ex. I'm always frustrated when [...] -**Describe the solution you'd like** +## Describe the solution you'd like + A clear and concise description of what you want to happen. -**Describe alternatives you've considered** +## Describe alternatives you've considered + A clear and concise description of any alternative solutions or features you've considered. -**Additional context** +## Additional context + Add any other context or screenshots about the feature request here. diff --git a/VERSION b/VERSION index 48f7a71df4..ae6dd4e203 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -0.28.1 +0.29.0 diff --git a/WORKSPACE b/WORKSPACE index 472f42dcad..e0b5612d34 100644 --- a/WORKSPACE +++ b/WORKSPACE @@ -9,9 +9,9 @@ load("@bazel_tools//tools/build_defs/repo:git.bzl", "git_repository") # Airy Bazel tools git_repository( name = "com_github_airyhq_bazel_tools", - commit = "2b34bc2b2c6fed64e4bb223d4624e06eda390e4d", + commit = "583a2e52c6941945ab5934585d5df8fff61b112f", remote = "https://github.com/airyhq/bazel-tools.git", - shallow_since = "1625065439 +0200", + shallow_since = "1629796332 +0200", ) load("@com_github_airyhq_bazel_tools//:repositories.bzl", "airy_bazel_tools_dependencies", "airy_jvm_deps") diff --git a/backend/api/admin/BUILD b/backend/api/admin/BUILD index a51240b54f..0ff228bab7 100644 --- a/backend/api/admin/BUILD +++ b/backend/api/admin/BUILD @@ -11,6 +11,7 @@ app_deps = [ "//backend:webhook", "//backend/model/metadata", "//backend/model/template", + "//backend/model/event", "//lib/java/uuid", "//lib/java/spring/auth:spring-auth", "//lib/java/spring/web:spring-web", diff --git a/backend/api/admin/src/main/java/co/airy/core/api/admin/Stores.java b/backend/api/admin/src/main/java/co/airy/core/api/admin/Stores.java index 0f712873ce..91512a614c 100644 --- a/backend/api/admin/src/main/java/co/airy/core/api/admin/Stores.java +++ b/backend/api/admin/src/main/java/co/airy/core/api/admin/Stores.java @@ -47,13 +47,9 @@ public class Stores implements HealthIndicator, ApplicationListener v.getConnectionState().equals(ChannelConnectionState.CONNECTED)) .leftJoin(metadataTable, ChannelContainer::new, Materialized.as(connectedChannelsStore)); - builder.stream(applicationCommunicationWebhooks) - .groupBy((webhookId, webhook) -> allWebhooksKey) - .reduce((oldValue, newValue) -> newValue, Materialized.as(webhooksStore)); + builder.table(applicationCommunicationWebhooks, Materialized.as(webhooksStore)); builder.table(applicationCommunicationTags, Materialized.as(tagsStore)); @@ -99,8 +93,7 @@ public ReadOnlyKeyValueStore getTagsStore() { } public void storeWebhook(Webhook webhook) throws ExecutionException, InterruptedException { - webhook.setId(allWebhooksKey); - producer.send(new ProducerRecord<>(applicationCommunicationWebhooks, allWebhooksKey, webhook)).get(); + producer.send(new ProducerRecord<>(applicationCommunicationWebhooks, webhook.getId(), webhook)).get(); } public void storeChannelContainer(ChannelContainer container) throws ExecutionException, InterruptedException { @@ -172,9 +165,16 @@ public List