refactor: standardize chat streaming API

Author: loong10k

src/main/java/io/github/easy4j/opencode/OpenCodeClient.java

@@ -10,6 +10,7 @@
 import io.github.easy4j.opencode.api.OpenCodeChatClient;
 import io.github.easy4j.opencode.api.OpenCodeRequestContext;
 import io.github.easy4j.opencode.api.OpenCodeSseClient;
+import io.github.easy4j.opencode.api.sse.StreamingChatResponse;
 import lombok.extern.slf4j.Slf4j;
 import okhttp3.OkHttpClient;
 
@@ -184,7 +185,7 @@ private void runStartupChecks(OpenCodeHttpClientConfig httpConfig, OpenCodeCliCo
         if (httpConfig.isEnabled() && httpConfig.isStartupCheckEnabled()) {
             try {
                 httpClient.health();
-                log.info("OpenCode HTTP health check passed: {}", httpConfig.getServerUrl());
+                log.info("OpenCode HTTP health check passed: {}", httpConfig.getBaseUrl());
             } catch (Exception e) {
                 if (httpConfig.isFailFastOnUnavailable()) {
                     throw new IllegalStateException(
@@ -235,7 +236,7 @@ private void copyHttpConfig(OpenCodeHttpClientConfig src) {
         this.config.getHttp().setEnabled(src.isEnabled());
         this.config.getHttp().setStartupCheckEnabled(src.isStartupCheckEnabled());
         this.config.getHttp().setFailFastOnUnavailable(src.isFailFastOnUnavailable());
-        this.config.getHttp().setServerUrl(src.getServerUrl());
+        this.config.getHttp().setBaseUrl(src.getBaseUrl());
         this.config.getHttp().setUsername(src.getUsername());
         this.config.getHttp().setPassword(src.getPassword());
         this.config.getHttp().setConnectTimeoutMillis(src.getConnectTimeoutMillis());
@@ -360,25 +361,25 @@ public ChatResponse chatCompletionWithSession(ChatRequest request, String sessio
         return ChatMessageMapper.toChatResponse(result);
     }
 
-    public ChatStreamingResponse chatCompletionStream(ChatRequest request, String sessionKey) {
+    public StreamingChatResponse chatCompletionStream(ChatRequest request, String sessionKey) {
         return chatCompletionStream(request, sessionKey, null);
     }
 
-    public ChatStreamingResponse chatCompletionStream(ChatRequest request, String sessionKey,
+    public StreamingChatResponse chatCompletionStream(ChatRequest request, String sessionKey,
                                                        OpenCodeRequestContext context) {
         return chatCompletionStream(request, sessionKey, context, null);
     }
 
     /**
      * 流式对话，并在订阅启动前绑定增量回调，避免丢失首批分片。
      */
-    public ChatStreamingResponse chatCompletionStream(ChatRequest request, String sessionKey,
+    public StreamingChatResponse chatCompletionStream(ChatRequest request, String sessionKey,
                                                        OpenCodeRequestContext context,
                                                        Consumer<String> deltaConsumer) {
         String sessionId = httpClient.ensureSession(sessionKey, context);
         PromptRequest promptRequest = ChatMessageMapper.toPromptRequest(request);
 
-        ChatStreamingResponse stream = new ChatStreamingResponse().onDelta(deltaConsumer);
+        StreamingChatResponse stream = new StreamingChatResponse().onDelta(deltaConsumer);
 
         OpenCodeSseClient.QueueSubscription subscription =
                 sseClient.subscribeQueueSubscription(context);
@@ -522,12 +523,6 @@ public OpenCodeChatClient chat() {
         return chatClient;
     }
 
-    /** @deprecated 业务聊天请使用 {@link #chat()}，这里只保留原始事件订阅兼容入口。 */
-    @Deprecated
-    public OpenCodeSseClient sse() {
-        return sseClient;
-    }
-
     public OpenCodeSseClient eventStream() {
         return sseClient;
     }

src/main/java/io/github/easy4j/opencode/OpenCodeHttpClientConfig.java

@@ -36,18 +36,6 @@ public class OpenCodeHttpClientConfig {
      */
     private String baseUrl = "http://localhost:4096";
 
-    /** @deprecated 使用 {@link #getBaseUrl()}。 */
-    @Deprecated
-    public String getServerUrl() {
-        return baseUrl;
-    }
-
-    /** @deprecated 使用 {@link #setBaseUrl(String)}。 */
-    @Deprecated
-    public void setServerUrl(String value) {
-        this.baseUrl = value;
-    }
-
     /**
      * HTTP Basic Auth 用户名（对应 {@code OPENCODE_SERVER_USERNAME}，默认 {@code opencode}）。
      */
@@ -120,18 +108,6 @@ public void setServerUrl(String value) {
      */
     private boolean retryOnConnectionFailure = true;
 
-    /** @deprecated 使用 {@link #getStreamEventQueueCapacity()}。 */
-    @Deprecated
-    public int getSseEventQueueCapacity() {
-        return streamEventQueueCapacity;
-    }
-
-    /** @deprecated 使用 {@link #setStreamEventQueueCapacity(int)}。 */
-    @Deprecated
-    public void setSseEventQueueCapacity(int value) {
-        this.streamEventQueueCapacity = value;
-    }
-
     /**
      * 是否校验 HTTPS 证书；为 false 时关闭校验（仅建议开发环境）。
      */

src/main/java/io/github/easy4j/opencode/api/OpenCodeHttpClient.java

@@ -725,7 +725,7 @@ public ObjectMapper getObjectMapper() {
     // ============================================================
 
     private String url(String path) {
-        return config.getServerUrl() + path;
+        return config.getBaseUrl() + path;
     }
 
     private Request.Builder authedRequest(String url) {

src/main/java/io/github/easy4j/opencode/api/OpenCodeSseClient.java

@@ -69,7 +69,7 @@ public EventSource subscribe(Consumer<Event> consumer, OpenCodeRequestContext co
         EventSourceListener listener = new EventSourceListener() {
             @Override
             public void onOpen(EventSource es, Response response) {
-                log.info("SSE connected to {}/event", config.getServerUrl());
+                log.info("SSE connected to {}/event", config.getBaseUrl());
             }
 
             @Override
@@ -207,7 +207,7 @@ private static Consumer<Event> filterByTypes(Set<String> types, Consumer<Event>
     }
 
     private Request buildRequest(OpenCodeRequestContext context) {
-        String url = config.getServerUrl() + "/event";
+        String url = config.getBaseUrl() + "/event";
         Request.Builder builder = new Request.Builder().url(url)
                 .header("Accept", "text/event-stream")
                 .header("Cache-Control", "no-cache");

src/main/java/io/github/easy4j/opencode/api/model/ChatStreamingResponse.java

@@ -13,8 +13,8 @@ class OpenCodeChatClientArchitectureTest {
     void shouldExposeUnifiedConfigAndChatScenarioClient() {
         OpenCodeHttpClientConfig config = new OpenCodeHttpClientConfig();
         assertEquals(HttpResponseMode.BLOCKING, config.getMode());
-        config.setServerUrl("http://legacy-opencode");
-        assertEquals("http://legacy-opencode", config.getBaseUrl());
+        config.setBaseUrl("http://opencode");
+        assertEquals("http://opencode", config.getBaseUrl());
 
         try (OpenCodeChatClient client = new OpenCodeChatClient(config)) {
             assertEquals(OpenCodeHttpClient.class, client.getClass().getSuperclass());

src/test/java/io/github/easy4j/opencode/OpenCodeChatClientArchitectureTest.java

@@ -37,7 +37,7 @@ void setUp() throws IOException {
         server = new MockWebServer();
         server.start();
         OpenCodeHttpClientConfig config = new OpenCodeHttpClientConfig();
-        config.setServerUrl(server.url("/").toString().replaceAll("/$", ""));
+        config.setBaseUrl(server.url("/").toString().replaceAll("/$", ""));
         client = new OpenCodeHttpClient(config, null, null);
     }
 
@@ -96,7 +96,7 @@ void shouldRouteEventStreamToDirectory() throws InterruptedException {
                 .setHeader("Content-Type", "text/event-stream")
                 .setBody("data: {\"type\":\"server.connected\",\"properties\":{}}\n\n"));
         OpenCodeHttpClientConfig config = new OpenCodeHttpClientConfig();
-        config.setServerUrl(server.url("/").toString().replaceAll("/$", ""));
+        config.setBaseUrl(server.url("/").toString().replaceAll("/$", ""));
         OpenCodeSseClient sseClient = new OpenCodeSseClient(
                 config, client.getObjectMapper(), client.getOkHttpClient());
         try {