Claudio Ortolina
8d38512712
- Add Task.Supervisor to app supervision tree - Use tagged tuples instead of rescue for error handling - Pass embedding_text from parent LiveView as prop - Remove dead Completion struct fields - Extract socket assigns before Task closure - Log errors server-side, show generic user message - Make build_system_prompt private, remove thin wrapper - Extract do_send_message for retry reuse Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
135 lines
3.7 KiB
Elixir
135 lines
3.7 KiB
Elixir
defmodule OpenAI.API do
|
|
# Lifted from https://fly.io/phoenix-files/streaming-openai-responses/
|
|
def gpt_stream(completion, api_key, cb) do
|
|
fun = fn request, finch_request, finch_name, finch_options ->
|
|
fun = fn
|
|
{:status, status}, response ->
|
|
%{response | status: status}
|
|
|
|
{:headers, headers}, response ->
|
|
%{response | headers: headers}
|
|
|
|
{:data, data}, response ->
|
|
body =
|
|
data
|
|
|> String.split("data: ")
|
|
|> Enum.map(fn str ->
|
|
str
|
|
|> String.trim()
|
|
|> decode_body(cb)
|
|
end)
|
|
|> Enum.filter(fn d -> d != :ok end)
|
|
|
|
old_body = if response.body == "", do: [], else: response.body
|
|
|
|
%{response | body: old_body ++ body}
|
|
end
|
|
|
|
case Finch.stream(finch_request, finch_name, Req.Response.new(), fun, finch_options) do
|
|
{:ok, response} -> {request, response}
|
|
{:error, exception, _response} -> {request, exception}
|
|
end
|
|
end
|
|
|
|
Req.post!("https://api.openai.com/v1/chat/completions",
|
|
receive_timeout: 1000,
|
|
connect_options: [
|
|
timeout: 2500
|
|
],
|
|
json: %{
|
|
model: completion.model,
|
|
messages: [Map.take(completion, [:content, :role])],
|
|
response_format: %{type: "json_object"},
|
|
stream: true,
|
|
temperature: completion.temperature
|
|
},
|
|
auth: {:bearer, api_key},
|
|
finch_request: fun
|
|
)
|
|
end
|
|
|
|
def chat_stream(messages, model, temperature, api_key, cb) do
|
|
fun = fn request, finch_request, finch_name, finch_options ->
|
|
fun = fn
|
|
{:status, status}, response ->
|
|
%{response | status: status}
|
|
|
|
{:headers, headers}, response ->
|
|
%{response | headers: headers}
|
|
|
|
{:data, data}, response ->
|
|
data
|
|
|> String.split("data: ")
|
|
|> Enum.each(fn str ->
|
|
str
|
|
|> String.trim()
|
|
|> decode_chat_chunk(cb)
|
|
end)
|
|
|
|
response
|
|
end
|
|
|
|
case Finch.stream(finch_request, finch_name, Req.Response.new(), fun, finch_options) do
|
|
{:ok, response} -> {request, response}
|
|
{:error, exception, _response} -> {request, exception}
|
|
end
|
|
end
|
|
|
|
case Req.post("https://api.openai.com/v1/chat/completions",
|
|
receive_timeout: 30_000,
|
|
connect_options: [
|
|
timeout: 5_000
|
|
],
|
|
json: %{
|
|
model: model,
|
|
messages: messages,
|
|
stream: true,
|
|
temperature: temperature
|
|
},
|
|
auth: {:bearer, api_key},
|
|
finch_request: fun
|
|
) do
|
|
{:ok, %{status: status}} when status in 200..299 ->
|
|
:ok
|
|
|
|
{:ok, %{body: body}} ->
|
|
{:error, "OpenAI API error: #{inspect(body)}"}
|
|
|
|
{:error, exception} ->
|
|
{:error, "Connection error: #{Exception.message(exception)}"}
|
|
end
|
|
end
|
|
|
|
def get_embeddings(text, api_key) do
|
|
resp =
|
|
Req.post!("https://api.openai.com/v1/embeddings",
|
|
json: %{
|
|
input: text,
|
|
model: "text-embedding-3-small"
|
|
},
|
|
auth: {:bearer, api_key}
|
|
)
|
|
|
|
if resp.status == 200 do
|
|
embeddings = get_in(resp.body, ["data", Access.at(0), "embedding"])
|
|
{:ok, embeddings}
|
|
else
|
|
{:error, resp.body}
|
|
end
|
|
end
|
|
|
|
defp decode_body("", _), do: :ok
|
|
defp decode_body("[DONE]", _), do: :ok
|
|
defp decode_body(json, cb), do: cb.(JSON.decode!(json))
|
|
|
|
defp decode_chat_chunk("", _cb), do: :ok
|
|
defp decode_chat_chunk("[DONE]", _cb), do: :ok
|
|
|
|
defp decode_chat_chunk(json, cb) do
|
|
case get_in(JSON.decode!(json), ["choices", Access.at(0), "delta", "content"]) do
|
|
nil -> :ok
|
|
content -> cb.(content)
|
|
end
|
|
end
|
|
end
|