feat: merge global sensitive keys into app config GET and SSE push

- GET /config/{app} now returns AppConfigResponse with globalSensitiveKeys and mergedSensitiveKeys alongside the config
- PUT /config/{app} merges global + per-app sensitive keys before pushing CONFIG_UPDATE to agents via SSE
- extractSensitiveKeys() uses JsonNode reflection to avoid compile-time dependency on cameleer3-common getSensitiveKeys()
- SensitiveKeysRepository injected as new constructor parameter

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
hsiegeln
2026-04-14 18:19:59 +02:00
parent 28e38e4dee
commit 2fad8811c6
2 changed files with 72 additions and 13 deletions

View File

@@ -1,6 +1,7 @@
package com.cameleer3.server.app.controller; package com.cameleer3.server.app.controller;
import com.cameleer3.common.model.ApplicationConfig; import com.cameleer3.common.model.ApplicationConfig;
import com.cameleer3.server.app.dto.AppConfigResponse;
import com.cameleer3.server.app.dto.CommandGroupResponse; import com.cameleer3.server.app.dto.CommandGroupResponse;
import com.cameleer3.server.app.dto.ConfigUpdateResponse; import com.cameleer3.server.app.dto.ConfigUpdateResponse;
import com.cameleer3.server.app.dto.TestExpressionRequest; import com.cameleer3.server.app.dto.TestExpressionRequest;
@@ -9,6 +10,9 @@ import com.cameleer3.server.app.storage.PostgresApplicationConfigRepository;
import com.cameleer3.server.core.admin.AuditCategory; import com.cameleer3.server.core.admin.AuditCategory;
import com.cameleer3.server.core.admin.AuditResult; import com.cameleer3.server.core.admin.AuditResult;
import com.cameleer3.server.core.admin.AuditService; import com.cameleer3.server.core.admin.AuditService;
import com.cameleer3.server.core.admin.SensitiveKeysConfig;
import com.cameleer3.server.core.admin.SensitiveKeysMerger;
import com.cameleer3.server.core.admin.SensitiveKeysRepository;
import com.cameleer3.server.core.agent.AgentInfo; import com.cameleer3.server.core.agent.AgentInfo;
import com.cameleer3.server.core.agent.AgentRegistryService; import com.cameleer3.server.core.agent.AgentRegistryService;
import com.cameleer3.server.core.agent.AgentState; import com.cameleer3.server.core.agent.AgentState;
@@ -52,17 +56,20 @@ public class ApplicationConfigController {
private final ObjectMapper objectMapper; private final ObjectMapper objectMapper;
private final AuditService auditService; private final AuditService auditService;
private final DiagramStore diagramStore; private final DiagramStore diagramStore;
private final SensitiveKeysRepository sensitiveKeysRepository;
public ApplicationConfigController(PostgresApplicationConfigRepository configRepository, public ApplicationConfigController(PostgresApplicationConfigRepository configRepository,
AgentRegistryService registryService, AgentRegistryService registryService,
ObjectMapper objectMapper, ObjectMapper objectMapper,
AuditService auditService, AuditService auditService,
DiagramStore diagramStore) { DiagramStore diagramStore,
SensitiveKeysRepository sensitiveKeysRepository) {
this.configRepository = configRepository; this.configRepository = configRepository;
this.registryService = registryService; this.registryService = registryService;
this.objectMapper = objectMapper; this.objectMapper = objectMapper;
this.auditService = auditService; this.auditService = auditService;
this.diagramStore = diagramStore; this.diagramStore = diagramStore;
this.sensitiveKeysRepository = sensitiveKeysRepository;
} }
@GetMapping @GetMapping
@@ -76,14 +83,20 @@ public class ApplicationConfigController {
@GetMapping("/{application}") @GetMapping("/{application}")
@Operation(summary = "Get application config", @Operation(summary = "Get application config",
description = "Returns the current configuration for an application. Returns defaults if none stored.") description = "Returns the current configuration for an application with merged sensitive keys.")
@ApiResponse(responseCode = "200", description = "Config returned") @ApiResponse(responseCode = "200", description = "Config returned")
public ResponseEntity<ApplicationConfig> getConfig(@PathVariable String application, public ResponseEntity<AppConfigResponse> getConfig(@PathVariable String application,
HttpServletRequest httpRequest) { HttpServletRequest httpRequest) {
auditService.log("view_app_config", AuditCategory.CONFIG, application, null, AuditResult.SUCCESS, httpRequest); auditService.log("view_app_config", AuditCategory.CONFIG, application, null, AuditResult.SUCCESS, httpRequest);
return ResponseEntity.ok( ApplicationConfig config = configRepository.findByApplication(application)
configRepository.findByApplication(application) .orElse(defaultConfig(application));
.orElse(defaultConfig(application)));
List<String> globalKeys = sensitiveKeysRepository.find()
.map(SensitiveKeysConfig::keys)
.orElse(null);
List<String> merged = SensitiveKeysMerger.merge(globalKeys, extractSensitiveKeys(config));
return ResponseEntity.ok(new AppConfigResponse(config, globalKeys, merged));
} }
@PutMapping("/{application}") @PutMapping("/{application}")
@@ -100,7 +113,15 @@ public class ApplicationConfigController {
config.setApplication(application); config.setApplication(application);
ApplicationConfig saved = configRepository.save(application, config, updatedBy); ApplicationConfig saved = configRepository.save(application, config, updatedBy);
CommandGroupResponse pushResult = pushConfigToAgents(application, environment, saved); // Merge global + per-app sensitive keys for the SSE push payload
List<String> globalKeys = sensitiveKeysRepository.find()
.map(SensitiveKeysConfig::keys)
.orElse(null);
List<String> perAppKeys = extractSensitiveKeys(saved);
List<String> mergedKeys = SensitiveKeysMerger.merge(globalKeys, perAppKeys);
// Push with merged sensitive keys injected into the payload
CommandGroupResponse pushResult = pushConfigToAgentsWithMergedKeys(application, environment, saved, mergedKeys);
log.info("Config v{} saved for '{}', pushed to {} agent(s), {} responded", log.info("Config v{} saved for '{}', pushed to {} agent(s), {} responded",
saved.getVersion(), application, pushResult.total(), pushResult.responded()); saved.getVersion(), application, pushResult.total(), pushResult.responded());
@@ -180,12 +201,37 @@ public class ApplicationConfigController {
} }
} }
private CommandGroupResponse pushConfigToAgents(String application, String environment, ApplicationConfig config) { /**
* Extracts sensitiveKeys from ApplicationConfig via JsonNode to avoid compile-time
* dependency on getSensitiveKeys() which may not be in the published cameleer3-common jar yet.
*/
private List<String> extractSensitiveKeys(ApplicationConfig config) {
try {
com.fasterxml.jackson.databind.JsonNode node = objectMapper.valueToTree(config);
com.fasterxml.jackson.databind.JsonNode keysNode = node.get("sensitiveKeys");
if (keysNode == null || keysNode.isNull() || !keysNode.isArray()) {
return null;
}
return objectMapper.convertValue(keysNode, new com.fasterxml.jackson.core.type.TypeReference<List<String>>() {});
} catch (Exception e) {
return null;
}
}
/**
* Push config to agents with merged sensitive keys injected into the JSON payload.
*/
private CommandGroupResponse pushConfigToAgentsWithMergedKeys(String application, String environment,
ApplicationConfig config, List<String> mergedKeys) {
String payloadJson; String payloadJson;
try { try {
payloadJson = objectMapper.writeValueAsString(config); // Serialize config to a mutable map, inject merged keys
} catch (JsonProcessingException e) { @SuppressWarnings("unchecked")
log.error("Failed to serialize config for push", e); Map<String, Object> configMap = objectMapper.convertValue(config, Map.class);
configMap.put("sensitiveKeys", mergedKeys);
payloadJson = objectMapper.writeValueAsString(configMap);
} catch (Exception e) {
log.error("Failed to serialize config with merged keys for push", e);
return new CommandGroupResponse(false, 0, 0, List.of(), List.of()); return new CommandGroupResponse(false, 0, 0, List.of(), List.of());
} }
@@ -196,7 +242,6 @@ public class ApplicationConfigController {
return new CommandGroupResponse(true, 0, 0, List.of(), List.of()); return new CommandGroupResponse(true, 0, 0, List.of(), List.of());
} }
// Wait with shared 10-second deadline
long deadline = System.currentTimeMillis() + 10_000; long deadline = System.currentTimeMillis() + 10_000;
List<CommandGroupResponse.AgentResponse> responses = new ArrayList<>(); List<CommandGroupResponse.AgentResponse> responses = new ArrayList<>();
List<String> timedOut = new ArrayList<>(); List<String> timedOut = new ArrayList<>();

View File

@@ -0,0 +1,14 @@
package com.cameleer3.server.app.dto;
import com.cameleer3.common.model.ApplicationConfig;
import java.util.List;
/**
* Wraps ApplicationConfig with additional server-computed fields for the UI.
*/
public record AppConfigResponse(
ApplicationConfig config,
List<String> globalSensitiveKeys,
List<String> mergedSensitiveKeys
) {}