codex_live_steering

Process-local routing from live platform replies to active Codex turns.

class codex_live_steering.CodexLiveSteeringRegistry

Bases: object

Map visible stream messages to the SDK handle that produced them.

The handle cannot survive an inference-process restart, so persistence would create stale routes rather than useful recovery. All mutations run on the inference event loop and contain no await points.

attach_turn(session_id, *, owner_subject, platform, channel_id, turn_handle)
Return type:

bool

Parameters:

  • session_id (str)

  • owner_subject (str)

  • platform (str)

  • channel_id (str)

  • turn_handle (Any)

bind_message(session_id, message_id)
Return type:

bool

Parameters:

  • session_id (str)

  • message_id (str)

unbind_message(session_id, message_id)
Return type:

None

Parameters:

  • session_id (str)

  • message_id (str)

close_session(session_id)
Return type:

None

Parameters:

session_id (str)

async steer_reply(*, platform, channel_id, reply_to_id, owner_subject, text, source_message_id, allow_non_owner=False)
Return type:

str

Parameters:

  • platform (str)

  • channel_id (str)

  • reply_to_id (str)

  • owner_subject (str)

  • text (str)

  • source_message_id (str)

  • allow_non_owner (bool)