cameleer/cameleer-server
1
0
Fork 0
Code Issues 44 Pull Requests Actions Packages Projects Releases Wiki Activity

feat: stop container log capture when agent SSE connects

Browse Source 
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
hsiegeln
2026-04-14 23:19:17 +02:00
parent 4940bf3376
commit 49c7de7082
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cameleer3-server-app/src/main/java/com/cameleer3/server/app/agent/SseConnectionManager.java
View File

@@ -3,7 +3,9 @@ package com.cameleer3.server.app.agent;
import com.cameleer3.server.app.config.AgentRegistryConfig; import com.cameleer3.server.app.config.AgentRegistryConfig;
import com.cameleer3.server.core.agent.AgentCommand; import com.cameleer3.server.core.agent.AgentCommand;
import com.cameleer3.server.core.agent.AgentEventListener; import com.cameleer3.server.core.agent.AgentEventListener;
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.runtime.RuntimeOrchestrator;
import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import jakarta.annotation.PostConstruct; import jakarta.annotation.PostConstruct;
@@ -35,13 +37,16 @@ public class SseConnectionManager implements AgentEventListener {
private final AgentRegistryConfig config; private final AgentRegistryConfig config;
private final SsePayloadSigner ssePayloadSigner; private final SsePayloadSigner ssePayloadSigner;
private final ObjectMapper objectMapper; private final ObjectMapper objectMapper;
private final RuntimeOrchestrator runtimeOrchestrator;
public SseConnectionManager(AgentRegistryService registryService, AgentRegistryConfig config, public SseConnectionManager(AgentRegistryService registryService, AgentRegistryConfig config,
SsePayloadSigner ssePayloadSigner, ObjectMapper objectMapper) { SsePayloadSigner ssePayloadSigner, ObjectMapper objectMapper,
RuntimeOrchestrator runtimeOrchestrator) {
this.registryService = registryService; this.registryService = registryService;
this.config = config; this.config = config;
this.ssePayloadSigner = ssePayloadSigner; this.ssePayloadSigner = ssePayloadSigner;
this.objectMapper = objectMapper; this.objectMapper = objectMapper;
this.runtimeOrchestrator = runtimeOrchestrator;
} }
@PostConstruct @PostConstruct
@@ -81,6 +86,13 @@ public class SseConnectionManager implements AgentEventListener {
}); });
log.info("SSE connection established for agent {}", agentId); log.info("SSE connection established for agent {}", agentId);
// Stop container log capture — agent is now online and will send its own logs
AgentInfo agent = registryService.findById(agentId);
if (agent != null) {
runtimeOrchestrator.stopLogCaptureByApp(agent.applicationId(), agent.environmentId());
}
return emitter; return emitter;
} }