fix streaming api

troubleshoot and fix publishing to websockets

lib/console/ai/provider/openai.ex

@@ -49,7 +49,7 @@ defmodule Console.AI.OpenAI do
       access_key: opts.access_token,
       model: opts.model,
       base_url: opts.base_url,
-      stream: Stream.stream()
+      stream: Stream.stream() |> IO.inspect()
     }
   end
 

lib/console/ai/stream.ex

@@ -12,7 +12,7 @@ defmodule Console.AI.Stream do
   def publish(%__MODULE__{topic: topic}, chunk) when is_binary(topic) do
     Absinthe.Subscription.publish(
       ConsoleWeb.Endpoint,
-      chunk,
+      IO.inspect(chunk),
       [ai_stream: topic]
     )
   end

lib/console/ai/stream/exec.ex

@@ -12,7 +12,7 @@ defmodule Console.AI.Stream.Exec do
       %AIStream.SSE.Event{data: data}, acc ->
         case reducer.(data) do
           c when is_binary(c) ->
-            AIStream.publish(stream, c)
+            AIStream.publish(stream, c) |> IO.inspect()
             {:cont, [c | acc]}
           _ -> {:cont, acc}
         end