Support moonshot models via anthropic API.

Author: ericdallo

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- Support moonshot models via anthropic API.
+
 ## 0.97.4
 
 - Fix openai request when using non codex models but using openai subscription.

src/eca/llm_util.clj

@@ -46,7 +46,8 @@
                     (if (= data-str "[DONE]")
                       (recur event-line) ; skip [DONE]
                       (let [event-type (if event-line
-                                         (subs event-line 7)
+                                         ;; Handle both "event: foo" and "event:foo" formats
+                                         (string/triml (subs event-line 6))
                                          (-> (json/parse-string data-str true)
                                              :type))]
                         (cons [event-type (json/parse-string data-str true)]

test/eca/llm_util_test.clj

@@ -54,6 +54,20 @@
       (is (match?
            [["foo.bar" {:type "foo.bar"}]
             ["foo.baz" {:type "foo.baz"}]]
+           (llm-util/event-data-seq r)))))
+  (testing "when no extra space after event: (moonshot/kimi format)"
+    (with-open [r (io/reader (ByteArrayInputStream. (.getBytes (str "event:content_block_start\n"
+                                                                    "data:{\"type\":\"content_block_start\",\"index\":0}\n"
+                                                                    "\n"
+                                                                    "event:content_block_delta\n"
+                                                                    "data:{\"type\":\"content_block_delta\",\"index\":0}\n"
+                                                                    "\n"
+                                                                    "event:message_delta\n"
+                                                                    "data:{\"type\":\"message_delta\"}"))))]
+      (is (match?
+           [["content_block_start" {:type "content_block_start" :index 0}]
+            ["content_block_delta" {:type "content_block_delta" :index 0}]
+            ["message_delta" {:type "message_delta"}]]
            (llm-util/event-data-seq r))))))
 
 (deftest provider-api-key-with-key-rc-test