Fix spring boot start mode, make it runnable with 1.0

Change-Id: I9bc2d9249faf91041160647e9e4212cfb6ffda15

Author: chickenlj

core/src/test/java/io/agentscope/runtime/adapters/agentscope/AgentScopeStreamAdapterTest.java

@@ -22,6 +22,7 @@
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.AfterEach;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
 
 import static org.junit.jupiter.api.Assertions.*;
 
@@ -36,6 +37,7 @@
  *   <li>If port conflicts occur, SandboxManager will automatically retry</li>
  * </ul>
  */
+@EnabledIfDockerAvailable
 public class ContainerPoolTest {
 
     private SandboxManager manager;

core/src/test/java/io/agentscope/runtime/sandbox/manager/ContainerPoolTest.java

@@ -27,6 +27,8 @@
 
 import io.agentscope.runtime.sandbox.manager.model.container.SandboxType;
 import io.agentscope.runtime.sandbox.manager.model.container.ContainerModel;
+import org.junit.jupiter.api.condition.EnabledIf;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
 
 import java.util.UUID;
 
@@ -35,6 +37,8 @@
  * Docker Sandbox Lifecycle Test
  * Tests sandbox creation, startup, status checking, stopping and cleanup functionality in Docker environment
  */
+@EnabledIfDockerAvailable
+@EnabledIf(value = "isCI", disabledReason = "this test is designed to run only in the GitHub CI environment.")
 public class DockerLifecycleTest {
 
     private SandboxManager sandboxManager;

core/src/test/java/io/agentscope/runtime/sandbox/manager/DockerLifecycleTest.java

@@ -23,6 +23,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.AfterEach;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
 
 import java.io.File;
 import java.io.FileWriter;
@@ -42,6 +43,7 @@
  * Environment Variable Configuration:
  * - LOCAL_STORAGE_PATH: Local storage root directory path (optional, defaults to ./test_storage)
  */
+@EnabledIfDockerAvailable
 public class LocalFileSystemTest {
 
     private String localStoragePath;

core/src/test/java/io/agentscope/runtime/sandbox/manager/LocalFileSystemTest.java

@@ -24,8 +24,11 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
+
 import static org.junit.jupiter.api.Assertions.*;
 
+@EnabledIfDockerAvailable
 public class BaseToolsTest {
 
     private SandboxManager sandboxManager;

core/src/test/java/io/agentscope/runtime/sandbox/tools/BaseToolsTest.java

@@ -24,12 +24,15 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
+
 import static org.junit.jupiter.api.Assertions.*;
 
 /**
  * Test browser tools that require page element interaction
  * These tests require pages with specific elements to work properly
  */
+@EnabledIfDockerAvailable
 public class BrowserInteractiveToolsTest {
 
     private SandboxManager sandboxManager;

core/src/test/java/io/agentscope/runtime/sandbox/tools/BrowserInteractiveToolsTest.java

@@ -24,9 +24,11 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
 
 import static org.junit.jupiter.api.Assertions.*;
 
+@EnabledIfDockerAvailable
 public class BrowserToolsTest{
 
     private SandboxManager sandboxManager;

core/src/test/java/io/agentscope/runtime/sandbox/tools/BrowserToolsTest.java

@@ -24,8 +24,11 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.testcontainers.junit.jupiter.EnabledIfDockerAvailable;
+
 import static org.junit.jupiter.api.Assertions.*;
 
+@EnabledIfDockerAvailable
 public class FilesystemToolsTest{
 
     private SandboxManager sandboxManager;

core/src/test/java/io/agentscope/runtime/sandbox/tools/FilesystemToolsTest.java

@@ -65,6 +65,8 @@ public class AgentscopeBrowserUseAgent extends AgentScopeAgentHandler {
     private String baseUrl;
     private String runtimeToken;
 
+    private volatile boolean connected = false;
+
     /**
      * Creates a new AgentscopeBrowserUseAgent.
      */
@@ -83,7 +85,7 @@ public AgentscopeBrowserUseAgent() {
     /**
      * Connect and initialize the agent
      */
-    public Sandbox connect(String sessionId, String userId) {
+    public synchronized Sandbox connect(String sessionId, String userId) {
         logger.info("Initializing sand box...");
         Sandbox sandbox = null;
         // Get browser WebSocket URL and VNC info
@@ -180,7 +182,7 @@ public Flux<Event> streamQuery(AgentRequest request, Object messages) {
                     .model(
                             DashScopeChatModel.builder()
                                     .apiKey(apiKey)
-                                    .modelName("qwen-plus")
+                                    .modelName("qwen-max")
                                     .stream(true)
                                     .enableThinking(true)
                                     .formatter(new DashScopeChatFormatter())
@@ -255,7 +257,7 @@ public Flux<Event> streamQuery(AgentRequest request, Object messages) {
             // Return raw framework stream - Runner will handle conversion via StreamAdapter
             return agentScopeEvents
                     .doOnNext(event -> {
-                        logger.debug("Agent event: {}", event);
+                        logger.info("Agent event: {}", event);
                     })
                     .doFinally(signalType -> {
                         // Step 9: Save state after completion

examples/browser_use_fullstack_runtime/backend/src/main/java/io/agentscope/browser/agent/AgentscopeBrowserUseAgent.java

@@ -17,10 +17,13 @@
 package io.agentscope.browser.controller;
 
 import io.agentscope.browser.agent.AgentscopeBrowserUseAgent;
+import io.agentscope.core.agent.EventType;
 import io.agentscope.core.message.ContentBlock;
 import io.agentscope.core.message.Msg;
 import io.agentscope.core.message.MsgRole;
 import io.agentscope.core.message.TextBlock;
+import io.agentscope.core.message.ThinkingBlock;
+import io.agentscope.core.message.ToolResultBlock;
 import io.agentscope.core.message.ToolUseBlock;
 import io.agentscope.runtime.engine.schemas.AgentRequest;
 import org.slf4j.Logger;
@@ -36,6 +39,8 @@
 import java.util.List;
 import java.util.Map;
 
+import javax.annotation.PostConstruct;
+
 /**
  * REST controller for browser agent chat endpoints
  */
@@ -54,6 +59,11 @@ public ChatController(AgentscopeBrowserUseAgent agent) {
         this.agent = agent;
     }
 
+    @PostConstruct
+    public void init() {
+        this.agent.start();
+    }
+
     /**
      * Stream chat completions endpoint (OpenAI-compatible)
      */
@@ -81,16 +91,24 @@ public Flux<String> streamChatCompletions(@RequestBody Map<String, Object> reque
 
         return agent.streamQuery(agentRequest, convertedMessages)
                 .flatMap(event -> {
+                    EventType type = event.getType();
+                    boolean isLast = false;
+                    if (event.isLast() || type == EventType.AGENT_RESULT) {
+                        isLast = true;
+                    }
+
                     Msg msgGenerated = event.getMessage();
-                    if (msgGenerated == null || msgGenerated.getContent() == null || msgGenerated.getContent().isEmpty()) {
+                    if (msgGenerated == null || msgGenerated.getContent() == null || msgGenerated.getContent()
+                            .isEmpty()) {
                         return Flux.just(simpleYield("", "content"));
                     }
 
                     List<ContentBlock> contentList = msgGenerated.getContent();
                     StringBuilder responseBuilder = new StringBuilder();
+                    StringBuilder thinkingBuilder = new StringBuilder();
 
                     for (ContentBlock item : contentList) {
-                        if (item instanceof TextBlock textContent) {
+                        if (item instanceof TextBlock textContent && !isLast) {
                             String text = textContent.getText();
                             if (text != null && !text.isEmpty()) {
                                 responseBuilder.append(text);
@@ -99,15 +117,28 @@ public Flux<String> streamChatCompletions(@RequestBody Map<String, Object> reque
                         }
                         else if (item instanceof ToolUseBlock toolUseBlock) {
                             responseBuilder.append("Using tool: ").append(toolUseBlock.getName()).append("\n");
+                        } else if (item instanceof ToolResultBlock toolResultBlock) {
+                            responseBuilder.append("Tool result: ").append(toolResultBlock.getOutput()).append("\n");
+                        } else if (item instanceof ThinkingBlock thinkingBlock) {
+                            String thought = thinkingBlock.getThinking();
+                            if (thought != null && !thought.isEmpty()) {
+                                thinkingBuilder.append("[Thinking]: ").append(thought).append("\n");
+                            }
                         }
                     }
 
                     String response = responseBuilder.toString();
                     if (!response.isEmpty()) {
                         return Flux.just(simpleYield(response, "content"));
-                    } else {
-                        return Flux.just(simpleYield("", "content"));
                     }
+
+                    String thinking = thinkingBuilder.toString();
+                    if (!thinking.isEmpty()) {
+                        return Flux.just(simpleYield(thinking, "think"));
+                    }
+
+                    return Flux.just(simpleYield("", "content"));
+
                 })
                 .onErrorResume(error -> {
                     logger.error("Error during chat completion", error);
@@ -122,6 +153,8 @@ else if (item instanceof ToolUseBlock toolUseBlock) {
     public ResponseEntity<Map<String, String>> getEnvInfo() {
         logger.info("Received env_info request");
 
+        agent.connect(SESSION_ID, USER_ID);
+
         String baseUrl = agent.getBaseUrl();
         String runtimeToken = agent.getRuntimeToken();