Packages

codex_sdk

0.11.0
0.17.0 0.16.1 0.16.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.1 0.10.0 0.9.0 0.8.0 0.7.2 0.7.1 0.7.0 0.6.0 0.5.0 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.0 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.0

Idiomatic Elixir SDK for OpenAI's Codex agent. Provides a complete, production-ready interface with streaming support, comprehensive event handling, and robust testing utilities.

HexDocs

Current section

Files

Jump to
Readme
30 Versions
8 Dependencies
Dependants
Files
Activity
codex_sdk lib codex transport exec_jsonl.ex
Raw

lib/codex/transport/exec_jsonl.ex 

defmodule Codex.Transport.ExecJsonl do

  @moduledoc false



  @behaviour Codex.Transport



  alias Codex.Thread

  alias Codex.Transport.Support



  @impl true

  def run_turn(%Thread{} = thread, input, turn_opts) when is_binary(input) do

    turn_opts = Support.normalize_turn_opts(turn_opts)



    Support.with_retry_and_rate_limit(

      fn -> Thread.run_turn_exec_jsonl(thread, input, turn_opts) end,

      thread.thread_opts,

      turn_opts

    )

  end



  def run_turn(%Thread{}, _input, _turn_opts), do: {:error, {:unsupported_input, :exec}}



  @impl true

  def run_turn_streamed(%Thread{} = thread, input, turn_opts) when is_binary(input) do

    turn_opts = Support.normalize_turn_opts(turn_opts)



    Support.with_retry_and_rate_limit(

      fn -> Thread.run_turn_streamed_exec_jsonl(thread, input, turn_opts) end,

      thread.thread_opts,

      turn_opts

    )

  end



  def run_turn_streamed(%Thread{}, _input, _turn_opts),

    do: {:error, {:unsupported_input, :exec}}

end