feat(protocol): integrate typed prompt request with ACP

Author: loong10k

src/main/java/io/github/easy4j/kimi/acp/KimiAcpClient.java

@@ -41,6 +41,8 @@
 import org.slf4j.LoggerFactory;
 
 import io.github.easy4j.kimi.KimiException;
+import io.github.easy4j.kimi.model.KimiPromptRequest;
+import io.github.easy4j.kimi.model.KimiPromptResult;
 import tools.jackson.databind.JsonNode;
 import tools.jackson.databind.ObjectMapper;
 import tools.jackson.databind.json.JsonMapper;
@@ -349,6 +351,28 @@ public CompletableFuture<KimiAcpTurnResult> promptAsync(String sessionId, String
         return future;
     }
 
+    /**
+     * Runs one typed prompt turn asynchronously while preserving the legacy
+     * string-based ACP API.
+     */
+    public CompletableFuture<KimiPromptResult> promptAsync(
+            KimiPromptRequest request, Consumer<String> onDelta) {
+        Objects.requireNonNull(request, "request");
+        return promptAsync(request.getSessionId(), request.getText(), onDelta)
+                .thenApply(result -> KimiPromptResult.of(
+                        result.getSessionId(), result.getStopReason(), result.getContent()));
+    }
+
+    /**
+     * Runs one typed prompt turn while preserving the legacy string-based ACP API.
+     */
+    public KimiPromptResult prompt(KimiPromptRequest request, Consumer<String> onDelta) {
+        Objects.requireNonNull(request, "request");
+        KimiAcpTurnResult result = prompt(request.getSessionId(), request.getText(), onDelta);
+        return KimiPromptResult.of(
+                result.getSessionId(), result.getStopReason(), result.getContent());
+    }
+
     /**
      * Runs one prompt turn, blocking until it completes.
      *

src/main/java/io/github/easy4j/kimi/model/KimiPromptRequest.java

@@ -0,0 +1,56 @@
+/*
+ * Copyright (c) 2018-present, easy-4-java.
+ * Licensed under the Apache License, Version 2.0.
+ */
+package io.github.easy4j.kimi.model;
+
+/**
+ * Immutable typed prompt request for an existing Kimi session.
+ */
+public final class KimiPromptRequest {
+
+    private final String sessionId;
+    private final String text;
+
+    private KimiPromptRequest(Builder builder) {
+        this.sessionId = builder.sessionId;
+        this.text = builder.text;
+    }
+
+    public static Builder builder() {
+        return new Builder();
+    }
+
+    public String getSessionId() {
+        return sessionId;
+    }
+
+    public String getText() {
+        return text;
+    }
+
+    public static final class Builder {
+        private String sessionId;
+        private String text;
+
+        public Builder sessionId(String sessionId) {
+            this.sessionId = sessionId;
+            return this;
+        }
+
+        public Builder text(String text) {
+            this.text = text;
+            return this;
+        }
+
+        public KimiPromptRequest build() {
+            if (sessionId == null || sessionId.trim().isEmpty()) {
+                throw new IllegalStateException("sessionId is required");
+            }
+            if (text == null) {
+                throw new IllegalStateException("text is required");
+            }
+            return new KimiPromptRequest(this);
+        }
+    }
+}

src/main/java/io/github/easy4j/kimi/model/KimiPromptResult.java

@@ -24,6 +24,11 @@ public final class KimiPromptResult {
         this.extensions = KimiSession.immutableExtensions(extensions);
     }
 
+    public static KimiPromptResult of(String sessionId, String stopReason, String content) {
+        return new KimiPromptResult(sessionId, KimiStopReason.of(stopReason),
+                content, null, java.util.Collections.<String, JsonNode>emptyMap());
+    }
+
     public String getSessionId() { return sessionId; }
     public KimiStopReason getStopReason() { return stopReason; }
     public String getContent() { return content; }