refactor: flip cameleer-common consumer from com.cameleer to io.cameleer
The agent team finished their groupId+package migration; this commit flips the corresponding consumer side here. Closes the dichotomy noted in the prior "Registry naming" doc — io.cameleer is now uniform across all three repos (server, agent, saas). - 46 .java files: import com.cameleer.common.* → io.cameleer.common.* - pom.xml + cameleer-server-core/pom.xml: cameleer-common dep groupId - CLAUDE.md: drop the obsolete "stays on com.cameleer until institutionalized" qualifier on Related Project; flip Key Conventions dep coordinate - cameleer-license-minter/README.md: GAV strings + main-class FQN Verification: full reactor mvn test -DskipITs — 416 unit tests pass. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -10,7 +10,7 @@ Cameleer Server — observability server that receives, stores, and serves Camel
|
||||
|
||||
- **cameleer** (`https://gitea.siegeln.net/cameleer/cameleer`) — the Java agent that instruments Camel applications
|
||||
- Protocol defined in `cameleer-common/PROTOCOL.md` in the agent repo
|
||||
- This server depends on `com.cameleer:cameleer-common` (shared models and graph API). The agent repo's groupId stays on `com.cameleer` until that project is institutionalized — this server's own modules are `io.cameleer.*`.
|
||||
- This server depends on `io.cameleer:cameleer-common` (shared models and graph API).
|
||||
|
||||
## Registry naming (buildtime vs public)
|
||||
|
||||
@@ -56,7 +56,7 @@ java -jar cameleer-server-app/target/cameleer-server-app-1.0-SNAPSHOT.jar
|
||||
|
||||
- Java 17+ required
|
||||
- Spring Boot 3.4.3 parent POM
|
||||
- Depends on `com.cameleer:cameleer-common` from Gitea Maven registry
|
||||
- Depends on `io.cameleer:cameleer-common` from Gitea Maven registry
|
||||
- Jackson `JavaTimeModule` for `Instant` deserialization
|
||||
- Communication: receives HTTP POST data from agents (executions, diagrams, metrics, logs), serves SSE event streams for config push/commands (config-update, deep-trace, replay, route-control)
|
||||
- URL taxonomy: user-facing data, config, and query endpoints live under `/api/v1/environments/{envSlug}/...`. Env is a path segment, resolved via the `@EnvPath` argument resolver (404 on unknown slug). Flat endpoints are only for: agent self-service (JWT-authoritative), cross-env admin (RBAC, OIDC, audit, license, thresholds, env CRUD), cross-env discovery (`/catalog`), content-addressed lookups (`/diagrams/{contentHash}/render`, `/executions/{id}`), and auth. See `.claude/rules/app-classes.md` for the full allow-list.
|
||||
|
||||
@@ -2,11 +2,11 @@
|
||||
|
||||
Standalone vendor-side tool for producing signed Ed25519 license tokens consumed by `cameleer-server`. The minter is intentionally **not** a runtime or compile-scope dependency of the server — the server only ships with the matching public key and validates tokens via `LicenseValidator`. The private signing key never leaves the vendor's environment.
|
||||
|
||||
- Module GAV: `com.cameleer:cameleer-license-minter:1.0-SNAPSHOT`
|
||||
- Maven coordinates of the runtime server (does **not** transitively pull this module): `com.cameleer:cameleer-server-app:1.0-SNAPSHOT`
|
||||
- Module GAV: `io.cameleer:cameleer-license-minter:1.0-SNAPSHOT`
|
||||
- Maven coordinates of the runtime server (does **not** transitively pull this module): `io.cameleer:cameleer-server-app:1.0-SNAPSHOT`
|
||||
- Build artifacts (after `mvn -pl cameleer-license-minter package`):
|
||||
- `target/cameleer-license-minter-1.0-SNAPSHOT.jar` — plain library JAR (consumable as a Maven `test` dependency or via the `LicenseMinter` API in custom tooling)
|
||||
- `target/cameleer-license-minter-1.0-SNAPSHOT-cli.jar` — fat CLI JAR with main class `com.cameleer.license.minter.cli.LicenseMinterCli`
|
||||
- `target/cameleer-license-minter-1.0-SNAPSHOT-cli.jar` — fat CLI JAR with main class `io.cameleer.license.minter.cli.LicenseMinterCli`
|
||||
|
||||
## Table of contents
|
||||
|
||||
@@ -50,15 +50,15 @@ Two JARs land in `cameleer-license-minter/target/`:
|
||||
| Artifact | Purpose |
|
||||
|---|---|
|
||||
| `cameleer-license-minter-1.0-SNAPSHOT.jar` | Plain library (the `repackage` execution for the main artifact is disabled; see `pom.xml:50-54`). Use this when embedding the minter inside your own tooling or a unit test that needs a fresh signed token. |
|
||||
| `cameleer-license-minter-1.0-SNAPSHOT-cli.jar` | Fat CLI JAR. Repackaged by Spring Boot's `spring-boot-maven-plugin` with classifier `cli`; main class is `com.cameleer.license.minter.cli.LicenseMinterCli`. |
|
||||
| `cameleer-license-minter-1.0-SNAPSHOT-cli.jar` | Fat CLI JAR. Repackaged by Spring Boot's `spring-boot-maven-plugin` with classifier `cli`; main class is `io.cameleer.license.minter.cli.LicenseMinterCli`. |
|
||||
|
||||
## Public Java API
|
||||
|
||||
`com.cameleer.license.minter.LicenseMinter` is the only entry point for the library. It is a final, stateless utility class:
|
||||
`io.cameleer.license.minter.LicenseMinter` is the only entry point for the library. It is a final, stateless utility class:
|
||||
|
||||
```java
|
||||
import com.cameleer.license.minter.LicenseMinter;
|
||||
import com.cameleer.license.LicenseInfo;
|
||||
import io.cameleer.license.minter.LicenseMinter;
|
||||
import io.cameleer.license.LicenseInfo;
|
||||
|
||||
LicenseInfo info = new LicenseInfo(
|
||||
java.util.UUID.randomUUID(),
|
||||
@@ -87,7 +87,7 @@ The method is thread-safe; the underlying Jackson `ObjectMapper` is configured o
|
||||
|
||||
## CLI usage
|
||||
|
||||
The CLI entry point is `com.cameleer.license.minter.cli.LicenseMinterCli`. Run it from the fat JAR produced by the build:
|
||||
The CLI entry point is `io.cameleer.license.minter.cli.LicenseMinterCli`. Run it from the fat JAR produced by the build:
|
||||
|
||||
```bash
|
||||
java -jar cameleer-license-minter/target/cameleer-license-minter-1.0-SNAPSHOT-cli.jar \
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.dto.AppConfigResponse;
|
||||
import io.cameleer.server.app.security.JwtAuthenticationFilter;
|
||||
import io.cameleer.server.app.storage.PostgresApplicationConfigRepository;
|
||||
|
||||
@@ -7,7 +7,7 @@ import io.cameleer.server.app.dto.AgentRefreshResponse;
|
||||
import io.cameleer.server.app.dto.AgentRegistrationRequest;
|
||||
import io.cameleer.server.app.dto.AgentRegistrationResponse;
|
||||
import io.cameleer.server.app.dto.ErrorResponse;
|
||||
import com.cameleer.common.model.HeartbeatRequest;
|
||||
import io.cameleer.common.model.HeartbeatRequest;
|
||||
import io.cameleer.server.app.security.BootstrapTokenValidator;
|
||||
import io.cameleer.server.app.security.JwtAuthenticationFilter;
|
||||
import io.cameleer.server.core.admin.AuditCategory;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.dto.DirtyStateResponse;
|
||||
import io.cameleer.server.app.storage.PostgresApplicationConfigRepository;
|
||||
import io.cameleer.server.app.storage.PostgresDeploymentRepository;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.dto.AppConfigResponse;
|
||||
import io.cameleer.server.app.dto.CommandGroupResponse;
|
||||
import io.cameleer.server.app.dto.ConfigUpdateResponse;
|
||||
|
||||
@@ -4,7 +4,7 @@ import io.cameleer.server.app.config.TenantProperties;
|
||||
import io.cameleer.server.app.dto.AgentSummary;
|
||||
import io.cameleer.server.app.dto.CatalogApp;
|
||||
import io.cameleer.server.app.dto.RouteSummary;
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.server.core.agent.AgentInfo;
|
||||
import io.cameleer.server.core.agent.AgentRegistryService;
|
||||
import io.cameleer.server.core.agent.AgentState;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import io.cameleer.server.core.ingestion.ChunkAccumulator;
|
||||
import com.cameleer.common.model.ExecutionChunk;
|
||||
import io.cameleer.common.model.ExecutionChunk;
|
||||
import com.fasterxml.jackson.core.type.TypeReference;
|
||||
import com.fasterxml.jackson.databind.DeserializationFeature;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.server.core.agent.AgentInfo;
|
||||
import io.cameleer.server.core.agent.AgentRegistryService;
|
||||
import io.cameleer.server.core.ingestion.IngestionService;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.server.app.web.EnvPath;
|
||||
import io.cameleer.server.core.diagram.DiagramLayout;
|
||||
import io.cameleer.server.core.diagram.DiagramRenderer;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.AgentEvent;
|
||||
import io.cameleer.common.model.AgentEvent;
|
||||
import io.cameleer.server.core.agent.AgentEventService;
|
||||
import io.cameleer.server.core.agent.AgentInfo;
|
||||
import io.cameleer.server.core.agent.AgentRegistryService;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.app.metrics.ServerMetrics;
|
||||
import io.cameleer.server.app.security.JwtAuthenticationFilter;
|
||||
import io.cameleer.server.core.ingestion.BufferedLogEntry;
|
||||
|
||||
@@ -4,7 +4,7 @@ import io.cameleer.server.app.dto.AgentSummary;
|
||||
import io.cameleer.server.app.dto.AppCatalogEntry;
|
||||
import io.cameleer.server.app.dto.RouteSummary;
|
||||
import io.cameleer.server.app.web.EnvPath;
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.server.core.agent.AgentInfo;
|
||||
import io.cameleer.server.core.agent.AgentRegistryService;
|
||||
import io.cameleer.server.core.agent.AgentState;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.dto.CommandGroupResponse;
|
||||
import io.cameleer.server.app.dto.SensitiveKeysRequest;
|
||||
import io.cameleer.server.app.dto.SensitiveKeysResponse;
|
||||
|
||||
@@ -1,9 +1,9 @@
|
||||
package io.cameleer.server.app.diagram;
|
||||
|
||||
import com.cameleer.common.graph.NodeType;
|
||||
import com.cameleer.common.graph.RouteEdge;
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import com.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.common.graph.NodeType;
|
||||
import io.cameleer.common.graph.RouteEdge;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.server.core.diagram.DiagramLayout;
|
||||
import io.cameleer.server.core.diagram.DiagramRenderer;
|
||||
import io.cameleer.server.core.diagram.PositionedEdge;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.dto;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.dto;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
|
||||
public record ConfigUpdateResponse(
|
||||
ApplicationConfig config,
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.runtime;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.app.search.ClickHouseLogStore;
|
||||
import io.cameleer.server.core.ingestion.BufferedLogEntry;
|
||||
import com.github.dockerjava.api.DockerClient;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.runtime;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.license.LicenseEnforcer;
|
||||
import io.cameleer.server.app.license.LicenseUsageReader;
|
||||
import io.cameleer.server.app.metrics.ServerMetrics;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.search;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.core.ingestion.BufferedLogEntry;
|
||||
import io.cameleer.server.core.search.LogSearchRequest;
|
||||
import io.cameleer.server.core.search.LogSearchResponse;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import com.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.server.core.ingestion.TaggedDiagram;
|
||||
import io.cameleer.server.core.storage.DiagramStore;
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
|
||||
@@ -3,7 +3,7 @@ package io.cameleer.server.app.storage;
|
||||
import io.cameleer.server.core.ingestion.ChunkAccumulator;
|
||||
import io.cameleer.server.core.ingestion.MergedExecution;
|
||||
import io.cameleer.server.core.storage.ExecutionStore;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import org.springframework.jdbc.core.JdbcTemplate;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import org.springframework.jdbc.core.JdbcTemplate;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.alerting;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.app.AbstractPostgresIT;
|
||||
import io.cameleer.server.app.TestSecurityHelper;
|
||||
import io.cameleer.server.app.alerting.eval.AlertEvaluatorJob;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.controller;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.AbstractPostgresIT;
|
||||
import io.cameleer.server.app.TestSecurityHelper;
|
||||
import io.cameleer.server.app.storage.PostgresApplicationConfigRepository;
|
||||
|
||||
@@ -1,9 +1,9 @@
|
||||
package io.cameleer.server.app.diagram;
|
||||
|
||||
import com.cameleer.common.graph.NodeType;
|
||||
import com.cameleer.common.graph.RouteEdge;
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import com.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.common.graph.NodeType;
|
||||
import io.cameleer.common.graph.RouteEdge;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.server.core.diagram.DiagramLayout;
|
||||
import io.cameleer.server.core.diagram.PositionedNode;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.runtime;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.AbstractPostgresIT;
|
||||
import io.cameleer.server.app.TestSecurityHelper;
|
||||
import io.cameleer.server.app.storage.PostgresDeploymentRepository;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.search;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.core.ingestion.BufferedLogEntry;
|
||||
import io.cameleer.server.core.search.LogSearchRequest;
|
||||
import io.cameleer.server.app.ClickHouseTestHelper;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.search;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.core.search.LogSearchRequest;
|
||||
import io.cameleer.server.core.search.LogSearchResponse;
|
||||
import io.cameleer.server.core.storage.LogEntryResult;
|
||||
|
||||
@@ -3,7 +3,7 @@ package io.cameleer.server.app.search;
|
||||
import io.cameleer.server.core.ingestion.BufferedLogEntry;
|
||||
import io.cameleer.server.core.search.LogSearchRequest;
|
||||
import io.cameleer.server.core.search.LogSearchResponse;
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.app.ClickHouseTestHelper;
|
||||
import com.zaxxer.hikari.HikariDataSource;
|
||||
import org.junit.jupiter.api.AfterEach;
|
||||
|
||||
@@ -6,8 +6,8 @@ import io.cameleer.server.core.search.AttributeFilter;
|
||||
import io.cameleer.server.core.search.ExecutionSummary;
|
||||
import io.cameleer.server.core.search.SearchRequest;
|
||||
import io.cameleer.server.core.search.SearchResult;
|
||||
import com.cameleer.common.model.ExecutionStatus;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.ExecutionStatus;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import com.zaxxer.hikari.HikariDataSource;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@@ -7,9 +7,9 @@ import io.cameleer.server.core.storage.DiagramStore;
|
||||
import io.cameleer.server.core.search.ExecutionSummary;
|
||||
import io.cameleer.server.core.search.SearchRequest;
|
||||
import io.cameleer.server.core.search.SearchResult;
|
||||
import com.cameleer.common.model.ExecutionChunk;
|
||||
import com.cameleer.common.model.ExecutionStatus;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.ExecutionChunk;
|
||||
import io.cameleer.common.model.ExecutionStatus;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import com.zaxxer.hikari.HikariDataSource;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import com.cameleer.common.graph.NodeType;
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import com.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.common.graph.NodeType;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteNode;
|
||||
import io.cameleer.server.core.ingestion.TaggedDiagram;
|
||||
import com.zaxxer.hikari.HikariDataSource;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import com.cameleer.common.model.ExecutionStatus;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.ExecutionStatus;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.server.core.detail.DetailService;
|
||||
import io.cameleer.server.core.detail.ExecutionDetail;
|
||||
import io.cameleer.server.core.detail.ProcessorNode;
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import io.cameleer.server.core.ingestion.MergedExecution;
|
||||
import com.cameleer.common.model.ExecutionStatus;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.ExecutionStatus;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import com.zaxxer.hikari.HikariDataSource;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.AbstractPostgresIT;
|
||||
import io.cameleer.server.core.admin.AppSettings;
|
||||
import io.cameleer.server.core.admin.AppSettingsRepository;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.app.storage;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.server.app.AbstractPostgresIT;
|
||||
import io.cameleer.server.core.runtime.Deployment;
|
||||
import io.cameleer.server.core.runtime.DeploymentConfigSnapshot;
|
||||
|
||||
@@ -20,7 +20,7 @@
|
||||
<artifactId>cameleer-license-api</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.cameleer</groupId>
|
||||
<groupId>io.cameleer</groupId>
|
||||
<artifactId>cameleer-common</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.detail;
|
||||
|
||||
import com.cameleer.common.model.ProcessorExecution;
|
||||
import io.cameleer.common.model.ProcessorExecution;
|
||||
import io.cameleer.server.core.storage.ExecutionStore;
|
||||
import io.cameleer.server.core.storage.ExecutionStore.ProcessorRecord;
|
||||
import com.fasterxml.jackson.core.type.TypeReference;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.diagram;
|
||||
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
|
||||
/**
|
||||
* Renders a route graph as SVG or as a positioned JSON layout.
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.ingestion;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
|
||||
/**
|
||||
* A log entry paired with its agent metadata, ready for buffered ClickHouse insertion.
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
package io.cameleer.server.core.ingestion;
|
||||
|
||||
import com.cameleer.common.model.ExchangeSnapshot;
|
||||
import com.cameleer.common.model.ExecutionChunk;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.ExchangeSnapshot;
|
||||
import io.cameleer.common.model.ExecutionChunk;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.server.core.storage.DiagramStore;
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.ingestion;
|
||||
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
|
||||
/**
|
||||
* Pairs a {@link RouteGraph} with the authenticated agent identity and environment.
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.runtime;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.runtime;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import com.fasterxml.jackson.databind.JsonNode;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.fasterxml.jackson.databind.node.ObjectNode;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.storage;
|
||||
|
||||
import com.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.common.graph.RouteGraph;
|
||||
import io.cameleer.server.core.ingestion.TaggedDiagram;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.storage;
|
||||
|
||||
import com.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.common.model.LogEntry;
|
||||
import io.cameleer.server.core.search.LogSearchRequest;
|
||||
import io.cameleer.server.core.search.LogSearchResponse;
|
||||
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
package io.cameleer.server.core.ingestion;
|
||||
|
||||
import com.cameleer.common.model.ExecutionChunk;
|
||||
import com.cameleer.common.model.ExecutionStatus;
|
||||
import com.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.common.model.ExecutionChunk;
|
||||
import io.cameleer.common.model.ExecutionStatus;
|
||||
import io.cameleer.common.model.FlatProcessorRecord;
|
||||
import io.cameleer.server.core.storage.DiagramStore;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
@@ -20,7 +20,7 @@ class ChunkAccumulatorTest {
|
||||
|
||||
private static final DiagramStore NO_OP_DIAGRAM_STORE = new DiagramStore() {
|
||||
public void store(io.cameleer.server.core.ingestion.TaggedDiagram d) {}
|
||||
public Optional<com.cameleer.common.graph.RouteGraph> findByContentHash(String h) { return Optional.empty(); }
|
||||
public Optional<io.cameleer.common.graph.RouteGraph> findByContentHash(String h) { return Optional.empty(); }
|
||||
public Optional<String> findContentHashForRoute(String r, String a) { return Optional.empty(); }
|
||||
public Optional<String> findLatestContentHashForAppRoute(String app, String r, String env) { return Optional.empty(); }
|
||||
public Map<String, String> findProcessorRouteMapping(String app, String env) { return Map.of(); }
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
package io.cameleer.server.core.runtime;
|
||||
|
||||
import com.cameleer.common.model.ApplicationConfig;
|
||||
import io.cameleer.common.model.ApplicationConfig;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
Reference in New Issue
Block a user