yjtPdZddlmZddlmZmZeGddZdS)uPer-attempt recovery bookkeeping for the conversation turn loop. The inner retry loop in ``run_conversation`` (``while retry_count < max_retries``) makes several distinct recovery attempts on a single model API call: a credential-pool 429 retry, a per-provider OAuth refresh (codex, anthropic, nous, copilot), a long-context compression restart, a length- continuation restart, and a handful of format-recovery branches (thinking- signature stripping, multimodal-tool-content stripping, llama.cpp grammar fallback, image shrink, invalid-encrypted-content, 1M-beta header). Each of those branches is guarded by a one-shot boolean so it fires at most once per attempt. They used to be ~16 bare ``*_attempted`` / ``has_retried_*`` / ``restart_with_*`` locals declared inline before the loop and threaded through its 2,400-line body. ``TurnRetryState`` collapses them into one object the loop mutates in place (``state.codex_auth_retry_attempted = True``), giving the recovery bookkeeping a single named, testable home. Loop-control variables (``retry_count``, ``max_retries``, ``max_compression_attempts``) intentionally stay as plain locals — they are the ``while`` mechanics, not recovery bookkeeping, and putting them on the object would add indirection without clarifying anything. This module is dependency-free so it can be unit-tested in isolation and imported by the turn loop without an import cycle. ) annotations) dataclassfieldsc@eZdZUdZdZded<dZded<dZded<dZded<dZ ded<dZ ded <dZ ded <dZ ded <dZ ded <dZded <dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZdS)TurnRetryStateaqOne-shot recovery guards + restart signals for a single API-call attempt. A fresh instance is created for each iteration of the outer turn loop (once per ``api_call_count``). Each guard fires its recovery branch at most once; the ``restart_with_*`` signals are read by the loop after the attempt to decide whether to rebuild the request and retry. Fboolcodex_auth_retry_attemptedanthropic_auth_retry_attemptednous_auth_retry_attempted'nous_paid_entitlement_refresh_attemptedcopilot_auth_retry_attempted"copilot_stale_cred_retry_attemptedvertex_auth_retry_attemptedthinking_sig_retry_attempted)invalid_encrypted_content_retry_attempted(native_compaction_reject_retry_attemptedimage_shrink_retry_attempted'multimodal_tool_content_retry_attemptedoauth_1m_beta_retry_attempted!llama_cpp_grammar_retry_attemptedprimary_recovery_attemptedhas_retried_429auth_failover_attempted restart_with_compressed_messages restart_with_length_continuationrestart_with_rebuilt_messages restart_with_redirected_messagesc#jKt|D] }|jt||jfV!dS)N)rnamegetattr)selffs r.sy4#""""")))))))) <0<0<0<0<0<0<0 <0<0<0r%