Merge pull request #102 from AxonIQ/feature/propagation-of-the-supported-features-limitations

Add SetupPayload DLQ and Domain Events Insights to supported features

Author: stefanmirkovic

console-framework-client-api/pom.xml

@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.axoniq.console</groupId>
         <artifactId>console-framework-client-parent</artifactId>
-        <version>1.9.3-SNAPSHOT</version>
+        <version>1.10.0-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

…sole/framework/AxoniqConsoleDlqMode.java …/framework/api/AxoniqConsoleDlqMode.javaconsole-framework-client/src/main/java/io/axoniq/console/framework/AxoniqConsoleDlqMode.java renamed to console-framework-client-api/src/main/java/io/axoniq/console/framework/api/AxoniqConsoleDlqMode.java console-framework-client/src/main/java/io/axoniq/console/framework/AxoniqConsoleDlqMode.java renamed to console-framework-client-api/src/main/java/io/axoniq/console/framework/api/AxoniqConsoleDlqMode.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2022-2024. AxonIQ B.V.
+ * Copyright (c) 2022-2025. AxonIQ B.V.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.axoniq.console.framework;
+package io.axoniq.console.framework.api;
 
 public enum AxoniqConsoleDlqMode {
     /**

…ole/framework/DomainEventAccessMode.java …framework/api/DomainEventAccessMode.javaconsole-framework-client/src/main/java/io/axoniq/console/framework/DomainEventAccessMode.java renamed to console-framework-client-api/src/main/java/io/axoniq/console/framework/api/DomainEventAccessMode.java console-framework-client/src/main/java/io/axoniq/console/framework/DomainEventAccessMode.java renamed to console-framework-client-api/src/main/java/io/axoniq/console/framework/api/DomainEventAccessMode.java

@@ -1,4 +1,4 @@
-package io.axoniq.console.framework;
+package io.axoniq.console.framework.api;
 
 public enum DomainEventAccessMode {
     /**

console-framework-client-api/src/main/java/io/axoniq/console/framework/api/clientIdentification.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2022-2024. AxonIQ B.V.
+ * Copyright (c) 2022-2025. AxonIQ B.V.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -85,13 +85,13 @@ data class ConsoleClientIdentifier(
 )
 
 data class SetupPayload(
-        val features: SupportedFeatures? = SupportedFeatures(),
         val commandBus: CommandBusInformation,
         val queryBus: QueryBusInformation,
         val eventStore: EventStoreInformation,
         val processors: List<EventProcessorInformation>,
         val versions: Versions,
         val upcasters: List<String>,
+        val features: SupportedFeatures = SupportedFeatures(),
 )
 
 data class SupportedFeatures(
@@ -102,7 +102,11 @@ data class SupportedFeatures(
         /* Whether the client supports pause/resume of reports.*/
         val pauseReports: Boolean? = false,
         /* Whether the client supports thread dumps.*/
-        val threadDump: Boolean? = false
+        val threadDump: Boolean? = false,
+        /* Whether the client supports DLQ insights. Can be FULL, LIMITED, MASKED, or NONE (default).*/
+        val deadLetterQueuesInsights: AxoniqConsoleDlqMode = AxoniqConsoleDlqMode.NONE,
+        /* Whether the client supports domain events insights. Can be FULL, LOAD_DOMAIN_STATE_ONLY, PREVIEW_PAYLOAD_ONLY, or NONE (default).*/
+        val domainEventsInsights: DomainEventAccessMode = DomainEventAccessMode.NONE,
 )
 
 data class Versions(

console-framework-client-spring-boot-starter/pom.xml

@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.axoniq.console</groupId>
         <artifactId>console-framework-client-parent</artifactId>
-        <version>1.9.3-SNAPSHOT</version>
+        <version>1.10.0-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

console-framework-client-spring-boot-starter/src/main/java/io/axoniq/console/framework/starter/AxoniqConsoleSpringProperties.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2022-2024. AxonIQ B.V.
+ * Copyright (c) 2022-2025. AxonIQ B.V.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -16,8 +16,8 @@
 
 package io.axoniq.console.framework.starter;
 
-import io.axoniq.console.framework.AxoniqConsoleDlqMode;
-import io.axoniq.console.framework.DomainEventAccessMode;
+import io.axoniq.console.framework.api.AxoniqConsoleDlqMode;
+import io.axoniq.console.framework.api.DomainEventAccessMode;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 import java.util.ArrayList;

console-framework-client/pom.xml

@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.axoniq.console</groupId>
         <artifactId>console-framework-client-parent</artifactId>
-        <version>1.9.3-SNAPSHOT</version>
+        <version>1.10.0-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

console-framework-client/src/main/java/io/axoniq/console/framework/AxoniqConsoleConfigurerModule.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2022-2024. AxonIQ B.V.
+ * Copyright (c) 2022-2025. AxonIQ B.V.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -19,6 +19,8 @@
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
 import com.fasterxml.jackson.annotation.PropertyAccessor;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import io.axoniq.console.framework.api.AxoniqConsoleDlqMode;
+import io.axoniq.console.framework.api.DomainEventAccessMode;
 import io.axoniq.console.framework.application.DomainEventStreamProvider;
 import io.axoniq.console.framework.application.ApplicationMetricRegistry;
 import io.axoniq.console.framework.application.ApplicationMetricReporter;
@@ -161,7 +163,11 @@ public void configureModule(@NotNull Configurer configurer) {
                                    )
                 )
                 .registerComponent(SetupPayloadCreator.class,
-                                   SetupPayloadCreator::new
+                                   c -> new SetupPayloadCreator(
+                                           c,
+                                           dlqMode,
+                                           domainEventAccessMode
+                                   )
                 )
                 .registerComponent(EventProcessorManager.class,
                                    c -> new EventProcessorManager(

console-framework-client/src/main/java/io/axoniq/console/framework/application/DomainEventStreamProvider.kt

@@ -34,8 +34,6 @@ class DomainEventStreamProvider(
                 .firstOrNull { it.aggregateType().simpleName == type }
                 ?: throw IllegalArgumentException("No domain entity found for type $type")
 
-        val eventStore = configuration.eventStore()
-
         val factory: AggregateFactory<T> = entityConfiguration.aggregateFactory() as AggregateFactory<T>
         val model: AggregateModel<T> = entityConfiguration.repository().getPropertyValue<AggregateModel<T>>("aggregateModel")
                 ?: throw IllegalArgumentException("No domain entity model found for type $type")
@@ -44,7 +42,7 @@ class DomainEventStreamProvider(
         val loadingEntity: EventSourcedAggregate<T> = EventSourcedAggregate
                 .initialize(factory.createAggregateRoot(entityIdentifier, stream.peek()),
                         model,
-                        eventStore,
+                        configuration.eventStore(),
                         object : RepositoryProvider {
                             override fun <T> repositoryFor(aggregateType: Class<T>): Repository<T> {
                                 return entityConfiguration.repository() as Repository<T>

console-framework-client/src/main/java/io/axoniq/console/framework/application/RSocketDomainEntityDataResponder.kt

@@ -1,6 +1,5 @@
 package io.axoniq.console.framework.application
 
-import io.axoniq.console.framework.DomainEventAccessMode
 import io.axoniq.console.framework.api.*
 import io.axoniq.console.framework.client.RSocketHandlerRegistrar
 import org.axonframework.lifecycle.Lifecycle