Merge pull request #7 from atuinsh/mkt/bump-ai-core-v0.2.5

Bump atuin_ai_core to v0.2.5

Author: BinaryMuse

mix.exs

@@ -155,7 +155,7 @@ defmodule AtuinAI.Server.MixProject do
     [
       {:atuin_ai_core,
        git: "https://github.com/atuinsh/atuin-ai-core.git",
-       branch: "mkt/observer-port",
+       tag: "v0.2.5",
        compile: false,
        app: false},
       {:bandit, "~> 1.5"},

mix.lock

@@ -1,5 +1,5 @@
 %{
-  "atuin_ai_core": {:git, "https://github.com/atuinsh/atuin-ai-core.git", "0bb2f8c1c23feb80604fe3365f4af1ae5257e26e", [branch: "mkt/observer-port"]},
+  "atuin_ai_core": {:git, "https://github.com/atuinsh/atuin-ai-core.git", "73292e7296849d30aebeecaad42d8142faa5059a", [tag: "v0.2.5"]},
   "bandit": {:hex, :bandit, "1.12.0", "6c5214daa2469644ac4ab0113b98abc24f75e348378e6a974c6343b3e5da22ef", [:mix], [{:hpax, "~> 1.0", [hex: :hpax, repo: "hexpm", optional: false]}, {:plug, "~> 1.18", [hex: :plug, repo: "hexpm", optional: false]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}, {:thousand_island, "~> 1.5", [hex: :thousand_island, repo: "hexpm", optional: false]}, {:websock, "~> 0.5", [hex: :websock, repo: "hexpm", optional: false]}], "hexpm", "45dac82dc86f45cf4a196dee9cc5a8b791d9c9469d996055f055e6ee36c66e20"},
   "hpax": {:hex, :hpax, "1.0.4", "777de5d433b0fbdc7c418159c8055910faa8047ffdb3d6b31098d2a46cd7685c", [:mix], [], "hexpm", "afc7cb142ebcc2d01ce7816190b98ce5dd49e799111b24249f3443d730f377ca"},
   "mime": {:hex, :mime, "2.0.7", "b8d739037be7cd402aee1ba0306edfdef982687ee7e9859bee6198c1e7e2f128", [:mix], [], "hexpm", "6171188e399ee16023ffc5b76ce445eb6d9672e2e241d2df6050f3c771e80ccd"},

test/atuin_ai_server_test.exs

@@ -169,7 +169,7 @@ defmodule AtuinAI.ServerTest do
     assert Plug.Conn.get_req_header(upstream_conn, "authorization") == []
   end
 
-  test "an upstream HTTP error fails the turn fast with the status and body", %{
+  test "an upstream HTTP error fails the turn fast with a generic error event", %{
     server_port: port
   } do
     body =
@@ -193,8 +193,14 @@ defmodule AtuinAI.ServerTest do
     {:ok, {{_, 200, _}, _headers, response}} = Task.await(task, 5000)
     response = to_string(response)
 
-    assert response =~ "HTTP 404"
-    assert response =~ "not found, try pulling it first"
+    assert response =~ "event: error"
+    assert response =~ ~s("code":"upstream_error")
+    assert response =~ "LLM request failed, please retry"
+
+    # Since core v0.2.5 the upstream status and body are operator detail
+    # (logged via the Failed outcome); they must not reach the client.
+    refute response =~ "HTTP 404"
+    refute response =~ "not found, try pulling it first"
   end
 
   test "unknown model alias is a 400", %{server_port: port} do