feat!: quarkus migration

.gitignore

@@ -77,3 +77,5 @@ tutorial/mimic_iii_demo/data/**
 /node_modules
 cypress/screenshots/
 cypress/videos/
+
+.codex

.mvn/wrapper/maven-wrapper.properties

@@ -0,0 +1,3 @@
+distributionType=bin
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.11/apache-maven-3.9.11-bin.zip
+wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.4/maven-wrapper-3.3.4.jar

README.md

@@ -79,6 +79,33 @@ configurations, such as:
 
 ## Development
 
+### Backend Development
+
+#### Dropwizard backend (current production backend)
+
+From the repository root:
+
+```bash
+./mvnw -pl backend -am test
+./mvnw -pl executable -am package
+java -jar executable/target/conquery.jar standalone <path-to-config.json>
+```
+
+#### Quarkus backend (migration target)
+
+From the repository root:
+
+```bash
+./mvnw -pl backend-quarkus quarkus:dev
+```
+
+Useful endpoints while running:
+
+- `http://localhost:8090/api/ping`
+- `http://localhost:8090/api/config/frontend`
+- `http://localhost:8090/q/health`
+- `http://localhost:8090/q/swagger-ui`
+
 ### Testing
 
 #### Integration Tests

backend-quarkus-plugin-api/README.md

@@ -0,0 +1,23 @@
+# Conquery Quarkus Plugin API
+
+This artifact is the compilation contract for third-party Conquery model plugins. A plugin should depend on
+`backend-quarkus-plugin-api` with Maven scope `provided`; it must not depend on the `backend-quarkus` application.
+
+The current stable surface covers metadata filters:
+
+- `FilterDefinition`, `AbstractFilterDefinition`, and `SingleColumnFilterDefinition` describe plugin metadata.
+- `FilterDefinitionProvider<T>` is the CDI discovery hook.
+- `FilterConversionContext` validates referenced columns without exposing backend repositories or IDs. It returns the
+  shared `dataset-model` contracts `ColumnDescriptor` and `ColumnType` rather than filter-specific column models.
+- `FilterResult` is the implementation-neutral result mapped to the backend catalog by the host.
+- `PolymorphicModelSubtype` declares the JSON/OpenAPI discriminator.
+
+Use frontend filter-value discriminator IDs such as `STRING` in `acceptedValueTypes()`. Include a Jandex index in the
+plugin JAR. The complete development, installation, reaugmentation, and test workflow is documented in
+[`backend-quarkus/README.md`](../backend-quarkus/README.md#polymorphic-model-plugins).
+
+Query filter-value, select, and condition contracts have not yet been extracted into this artifact and should be
+considered provisional.
+
+The plugin API exposes `dataset-model` transitively because dataset vocabulary is part of its public signatures. Plugin
+code imports those types from `com.bakdata.conquery.models.datasets`; it does not need a second explicit dependency.

backend-quarkus-plugin-api/pom.xml

@@ -0,0 +1,57 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.bakdata.conquery</groupId>
+        <artifactId>parent</artifactId>
+        <version>${revision}</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>backend-quarkus-plugin-api</artifactId>
+    <name>Conquery Quarkus Plugin API</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.bakdata.conquery</groupId>
+            <artifactId>dataset-model</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-annotations</artifactId>
+            <version>2.18.3</version>
+        </dependency>
+        <dependency>
+            <groupId>jakarta.validation</groupId>
+            <artifactId>jakarta.validation-api</artifactId>
+            <version>3.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.microprofile.openapi</groupId>
+            <artifactId>microprofile-openapi-api</artifactId>
+            <version>4.0.2</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>io.smallrye</groupId>
+                <artifactId>jandex-maven-plugin</artifactId>
+                <version>3.3.1</version>
+                <executions>
+                    <execution>
+                        <id>make-index</id>
+                        <goals>
+                            <goal>jandex</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/AbstractFilterDefinition.java

@@ -0,0 +1,52 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import com.fasterxml.jackson.annotation.JsonAlias;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import org.eclipse.microprofile.openapi.annotations.media.Schema;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public abstract class AbstractFilterDefinition implements FilterDefinition {
+
+	@Schema(description = "Filter implementation discriminator.")
+	private String type;
+	@Schema(description = "Stable local name used to form the filter id. Falls back to the label when omitted.", pattern = "^\\w+$")
+	private String name;
+	@Schema(description = "Label displayed to users.")
+	private String label;
+	@JsonAlias("description")
+	@Schema(description = "Additional explanation displayed for the filter.")
+	private String tooltip;
+	@Schema(description = "Unit displayed with filter values.")
+	private String unit;
+	@Schema(description = "Optional input validation pattern.")
+	private String pattern;
+	@Schema(description = "Whether values may be supplied using a dropped file.")
+	private Boolean allowDropFile;
+	@Schema(description = "Default frontend value.")
+	private Object defaultValue;
+	@Schema(description = "Optional minimum frontend value.")
+	private Integer min;
+	@Schema(description = "Optional maximum frontend value.")
+	private Integer max;
+
+	public String getType() { return type; }
+	public void setType(String type) { this.type = type; }
+	public String getName() { return name; }
+	public void setName(String name) { this.name = name; }
+	public String getLabel() { return label; }
+	public void setLabel(String label) { this.label = label; }
+	public String getTooltip() { return tooltip; }
+	public void setTooltip(String tooltip) { this.tooltip = tooltip; }
+	public String getUnit() { return unit; }
+	public void setUnit(String unit) { this.unit = unit; }
+	public String getPattern() { return pattern; }
+	public void setPattern(String pattern) { this.pattern = pattern; }
+	public Boolean getAllowDropFile() { return allowDropFile; }
+	public void setAllowDropFile(Boolean allowDropFile) { this.allowDropFile = allowDropFile; }
+	public Object getDefaultValue() { return defaultValue; }
+	public void setDefaultValue(Object defaultValue) { this.defaultValue = defaultValue; }
+	public Integer getMin() { return min; }
+	public void setMin(Integer min) { this.min = min; }
+	public Integer getMax() { return max; }
+	public void setMax(Integer max) { this.max = max; }
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/FilterConversionContext.java

@@ -0,0 +1,17 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import com.bakdata.conquery.models.datasets.ColumnDescriptor;
+
+/** Host services available while converting a plugin filter definition. */
+public interface FilterConversionContext {
+
+	/** Selects a stable local ID component and reports sanitized fallbacks through the host. */
+	String idPartFromPreferredOrFallback(String preferred, String fallback, String idType, Object fallbackContext);
+
+	/**
+	 * Resolves and validates a local connector-table column.
+	 *
+	 * @throws IllegalArgumentException when the name is invalid or the column does not exist
+	 */
+	ColumnDescriptor requireColumn(String columnName);
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/FilterDefinition.java

@@ -0,0 +1,22 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import com.bakdata.conquery.quarkus.plugin.api.models.PolymorphicModelBase;
+import com.fasterxml.jackson.annotation.JsonTypeInfo;
+import org.eclipse.microprofile.openapi.annotations.media.Schema;
+
+@JsonTypeInfo(
+		use = JsonTypeInfo.Id.NAME,
+		include = JsonTypeInfo.As.EXISTING_PROPERTY,
+		property = "type",
+		visible = true,
+		defaultImpl = UnknownFilterDefinition.class
+)
+@Schema(name = "MetadataFilterDefinition", description = "Filter definition used in connector metadata. The concrete model is selected by `type`.", discriminatorProperty = "type")
+@PolymorphicModelBase(
+		schemaName = "MetadataFilterDefinition",
+		description = "Filter definition used in connector metadata. The concrete model is selected by `type`."
+)
+public interface FilterDefinition {
+
+	String getType();
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/FilterDefinitionProvider.java

@@ -0,0 +1,29 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import java.util.Set;
+
+import com.bakdata.conquery.quarkus.plugin.api.models.PolymorphicModelTypeProvider;
+
+/**
+ * CDI discovery and conversion contract for one metadata filter model.
+ *
+ * @param <T> concrete, annotated filter definition contributed by the plugin
+ */
+public interface FilterDefinitionProvider<T extends FilterDefinition> extends PolymorphicModelTypeProvider<FilterDefinition, T> {
+
+	default String type() {
+		return typeId();
+	}
+
+	/**
+	 * Declares the frontend filter-value discriminator IDs emitted by this provider.
+	 *
+	 * @return non-empty set of registered IDs such as {@code STRING} or {@code INTEGER_RANGE}
+	 */
+	Set<String> acceptedValueTypes();
+
+	/**
+	 * Converts validated plugin metadata into an implementation-neutral filter description.
+	 */
+	FilterResult convert(FilterConversionContext context, T payload);
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/FilterResult.java

@@ -0,0 +1,32 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import java.util.List;
+
+/**
+ * Backend-independent filter description emitted by a plugin provider.
+ *
+ * <p>Required columns are local names. The host validates them again and creates its own IDs and repository records.</p>
+ */
+public record FilterResult(
+		String name,
+		String label,
+		String valueType,
+		String unit,
+		String tooltip,
+		List<Option> options,
+		Integer min,
+		Integer max,
+		String pattern,
+		boolean allowDropFile,
+		boolean creatable,
+		Object defaultValue,
+		List<String> requiredColumns
+) {
+	public FilterResult {
+		options = options == null ? List.of() : List.copyOf(options);
+		requiredColumns = requiredColumns == null ? List.of() : List.copyOf(requiredColumns);
+	}
+
+	public record Option(String value, String label, String optionValue) {
+	}
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/SingleColumnFilterDefinition.java

@@ -0,0 +1,20 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import jakarta.validation.constraints.NotBlank;
+import org.eclipse.microprofile.openapi.annotations.media.Schema;
+
+/** Convenience base for filter definitions referencing one local connector-table column. */
+public abstract class SingleColumnFilterDefinition extends AbstractFilterDefinition {
+
+	@NotBlank
+	@Schema(description = "Local name of a column in the connector table.", required = true, pattern = "^\\w+$")
+	private String column;
+
+	public String getColumn() {
+		return column;
+	}
+
+	public void setColumn(String column) {
+		this.column = column;
+	}
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/UnknownFilterDefinition.java

@@ -0,0 +1,32 @@
+package com.bakdata.conquery.quarkus.plugin.api.filters;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+
+public final class UnknownFilterDefinition implements FilterDefinition {
+
+	private String type;
+	private final Map<String, Object> properties = new LinkedHashMap<>();
+
+	@Override
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+
+	@JsonAnySetter
+	public void put(String name, Object value) {
+		properties.put(name, value);
+	}
+
+	@JsonAnyGetter
+	public Map<String, Object> properties() {
+		return Map.copyOf(properties);
+	}
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/filters/package-info.java

@@ -0,0 +1,7 @@
+/**
+ * Stable compilation contracts for metadata filter plugins.
+ *
+ * <p>Plugins provide a model and CDI {@link com.bakdata.conquery.quarkus.plugin.api.filters.FilterDefinitionProvider}
+ * without depending on backend implementation classes.</p>
+ */
+package com.bakdata.conquery.quarkus.plugin.api.filters;

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/models/PolymorphicModelBase.java

@@ -0,0 +1,16 @@
+package com.bakdata.conquery.quarkus.plugin.api.models;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Documented
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.TYPE)
+public @interface PolymorphicModelBase {
+	String discriminator() default "type";
+	String schemaName();
+	String description() default "";
+}

backend-quarkus-plugin-api/src/main/java/com/bakdata/conquery/quarkus/plugin/api/models/PolymorphicModelSubtype.java

@@ -0,0 +1,16 @@
+package com.bakdata.conquery.quarkus.plugin.api.models;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/** Declares the serialized identity of a concrete plugin model. */
+@Documented
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.TYPE)
+public @interface PolymorphicModelSubtype {
+	Class<?> base();
+	String id();
+}