Create a new response.

When the argument is a string, it is used as the input text. Otherwise, the argument is expected to be a keyword list of options that OpenAI expects, such as input, model, temperature, max_tokens, etc.

Streaming

Pass a stream: option with a callback function to stream the response. The callback receives results wrapped in {:ok, chunk} or {:error, reason} tuples:

Responses.create(
  input: "Write a story",
  stream: fn
    {:ok, %{event: "response.output_text.delta", data: %{"delta" => text}}} ->
      IO.write(text)
      :ok
    {:error, reason} ->
      IO.puts("Stream error: #{inspect(reason)}")
      :ok  # Continue despite errors
    _ ->
      :ok
  end
)

The callback should return :ok to continue or {:error, reason} to stop the stream.

For simpler text streaming, use the delta/1 helper:

Responses.create(
  input: "Write a story",
  stream: Responses.Stream.delta(&IO.write/1)
)

If no model is specified, the default model is used.

Create a response based on a previous response.

This allows creating follow-up responses that maintain context from a previous response. The previous response's ID is automatically included in the request.

Examples

{:ok, first} = Responses.create("What is Elixir?")
{:ok, followup} = Responses.create(first, input: "Tell me more about its concurrency model")

Same as create/1 but raises an error on failure.

Returns the response directly instead of an {:ok, response} tuple.

Examples

response = Responses.create!("Hello, world!")
IO.puts(response.text)

Same as create/2 but raises an error on failure.

Returns the response directly instead of an {:ok, response} tuple.

Examples

first = Responses.create!("What is Elixir?")
followup = Responses.create!(first, input: "Tell me more")

List available models.

Accepts an optional match string to filter by model ID.

Request a response from the OpenAI API.

Used as a building block by other functions in this module. Accepts that same arguments as Req.request/1. You should provide url, json, method, and other options as needed.

Run a conversation with automatic function calling.

This function automates the process of handling function calls by repeatedly calling the provided functions and feeding their results back to the model until a final response without function calls is received.

Parameters

• options - Keyword list of options to pass to create/1
• functions - A map or keyword list where:
  • Keys are function names (as atoms or strings)
  • Values are functions that accept the parsed arguments and return the result

Returns

Returns a list of all responses generated during the conversation, in chronological order. The last response in the list will be the final answer without function calls.

Examples

# Define available functions
functions = %{
  "get_weather" => fn %{"location" => location} ->
    # Simulate weather API call
    "The weather in #{location} is 72°F and sunny"
  end,
  "get_time" => fn %{} ->
    DateTime.utc_now() |> to_string()
  end
}

# Create function tools
weather_tool = Responses.Schema.build_function(
  "get_weather",
  "Get current weather for a location",
  %{location: :string}
)

time_tool = Responses.Schema.build_function(
  "get_time",
  "Get the current UTC time",
  %{}
)

# Run the conversation
responses = Responses.run(
  [input: "What's the weather in Paris and what time is it?",
   tools: [weather_tool, time_tool]],
  functions
)

# The last response contains the final answer
final_response = List.last(responses)
IO.puts(final_response.text)

Same as run/2 but raises an error on failure.

Returns the list of responses directly instead of an {:ok, responses} tuple.

Stream a response from the OpenAI API as an Enumerable.

Returns a Stream that yields chunks with event and data keys.

Examples

# Stream and handle all results
for result <- Responses.stream("Tell me a story") do
  case result do
    {:ok, chunk} -> IO.inspect(chunk)
    {:error, reason} -> IO.puts("Error: #{inspect(reason)}")
  end
end

# Process only text deltas, ignoring errors
Responses.stream("Write a poem")
|> Stream.filter(fn
  {:ok, %{event: "response.output_text.delta"}} -> true
  _ -> false
end)
|> Stream.map(fn {:ok, chunk} -> chunk.data["delta"] end)
|> Enum.each(&IO.write/1)

# Accumulate all text with error handling
result = Responses.stream(input: "Explain quantum physics")
         |> Enum.reduce(%{text: "", errors: []}, fn
           {:ok, %{event: "response.output_text.delta", data: %{"delta" => delta}}}, acc ->
             %{acc | text: acc.text <> delta}
           {:error, reason}, acc ->
             %{acc | errors: [reason | acc.errors]}
           _, acc ->
             acc
         end)