Packages
openai_ex
0.8.0
0.9.21
0.9.20
0.9.19
0.9.18
0.9.17
0.9.16
0.9.15
0.9.14
0.9.13
0.9.12
0.9.11
0.9.10
0.9.9
0.9.8
0.9.7
0.9.6
0.9.5
0.9.4
0.9.3
0.9.2
0.9.1
0.9.0
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.0
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.9
0.5.8
0.5.7
0.5.6
0.5.5
0.5.4
0.5.3
0.5.2
0.5.1
0.5.0
0.4.2
0.4.1
0.4.0
0.3.0
0.2.3
0.2.2
0.2.1
0.2.0
0.1.9
0.1.8
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
Community maintained Elixir library for OpenAI API
Current section
Files
Jump to
Current section
Files
lib/openai_ex/http_finch.ex
defmodule OpenaiEx.Http.Finch do
@moduledoc false
alias OpenaiEx.Error
def get(openai = %OpenaiEx{}, url) do
build_req(:get, openai, url) |> request(openai)
end
def delete(openai = %OpenaiEx{}, url) do
build_req(:delete, openai, url) |> request(openai)
end
def post(openai = %OpenaiEx{}, url, multipart: multipart) do
build_multipart(openai, url, multipart) |> request(openai)
end
def post(openai = %OpenaiEx{}, url, json: json) do
build_post(openai, url, json: json) |> request(openai)
end
def request_options(openai = %OpenaiEx{}) do
[receive_timeout: openai |> Map.get(:receive_timeout)]
end
defp headers(openai = %OpenaiEx{}) do
openai._http_headers
end
def stream(request, openai = %OpenaiEx{}, fun) do
Finch.stream(request, Map.get(openai, :finch_name), nil, fun, request_options(openai))
end
def request(request, openai = %OpenaiEx{}) do
case Finch.request(request, Map.get(openai, :finch_name), request_options(openai)) do
{:ok, response} -> to_response(response)
{:error, %{reason: reason}} -> to_error(reason, request)
end
end
defp build_req(method, openai = %OpenaiEx{}, url) do
Finch.build(method, openai.base_url <> url, headers(openai))
end
def build_post(openai = %OpenaiEx{}, url, json: json) do
Finch.build(
:post,
openai.base_url <> url,
headers(openai) ++ [{"Content-Type", "application/json"}],
Jason.encode_to_iodata!(json)
)
end
def build_multipart(openai = %OpenaiEx{}, url, multipart) do
Finch.build(
:post,
openai.base_url <> url,
headers(openai) ++
[
{"Content-Type", Multipart.content_type(multipart, "multipart/form-data")},
{"Content-Length", to_string(Multipart.content_length(multipart))}
],
{:stream, Multipart.body_stream(multipart)}
)
end
defp to_response(%Finch.Response{
status: status,
headers: headers,
body: body,
trailers: trailers
})
when status in 200..299 do
{:ok, %{status: status, headers: headers, body: body, trailers: trailers}}
end
defp to_response(r = %Finch.Response{status: status, body: body})
when is_integer(status) do
{:error, Error.status_error(status, r, Jason.decode!(body))}
end
def to_error(:timeout, request), do: {:error, Error.api_timeout_error(request)}
end