ޠj_%SrSSKJr SSKrSSKrSSKrSSKJrJr SSK J r SSK J r J r Jr SSKJrJr SSKJr SS KJrJr \(aSS KJr SS KJr SS KJr SS KJrJr \R@"\!5r"Sr#Sr$Sr%Sr&Sr'Sr(Sr)Sq*\+"SS15r,S(Sjr-S)Sjr.S*Sjr/S+Sjr0S,Sjr1Sr2SSSS.r3S \4S!'"S"S#\5r5"S$S%5r6/r7S&\4S''g)-a`_ChatOpenAICodex`: experimental OAuth-backed chat model. Wraps `ChatOpenAI` to target the ChatGPT codex backend (`https://chatgpt.com/backend-api/codex`) and supplies refresh-aware `Authorization` and `ChatGPT-Account-Id` headers from a `_ChatGPTOAuthTokenProvider`. The standard `ChatOpenAI` (API-key) flow is untouched. !!! warning "Experimental and unofficial" `_ChatOpenAICodex` is not an official OpenAI API integration. Use it only where your OpenAI account, workspace, plan, and applicable OpenAI terms permit ChatGPT-authenticated Codex access. You are responsible for ensuring your implementation complies with OpenAI's terms, usage policies, account restrictions, rate limits, and safeguards. ) annotationsN) TYPE_CHECKINGAny)LangSmithParams) BaseMessage ChatMessage SystemMessage)Fieldmodel_validator) ChatOpenAI)_ChatGPTOAuthTokenProvider_FileChatGPTOAuthTokenProvider) AsyncIterator)AsyncCallbackManagerForLLMRun)LanguageModelInput)ChatGenerationChunk ChatResultz%https://chatgpt.com/backend-api/codex originator langchainLANGCHAIN_CODEX_ORIGINATORzChatGPT-Account-Id_codex_headersat`_ChatOpenAICodex` is experimental and unofficial. It uses ChatGPT subscription OAuth against Codex endpoints and must only be used where permitted by your OpenAI account, workspace, plan, and applicable OpenAI terms and policies. You are responsible for implementing and operating it responsibly, including respecting OpenAI's usage policies, rate limits, and safeguards.Fsystem developercb[RR[5=(d [$)zGResolve the `originator` header default, honoring the env-var override.)osenvirongetORIGINATOR_ENV_VARORIGINATOR_VALUE\/var/www/html/gaurav/venv/lib/python3.13/site-packages/langchain_openai/chat_models/codex.py_default_originatorr#Os ::>>, - A1AAr!c\[(agSq[R"[[SS9 g)zAWarn once that `_ChatOpenAICodex` is experimental and unofficial.NT) stacklevel)_experimental_warning_emittedwarningswarnEXPERIMENTAL_UNOFFICIAL_WARNING UserWarningr r!r"_warn_experimental_unofficialr,Ts$%$$(! MM1;1Mr!c[U[5(ag[U[5(a [U5$[U[[ 45(aUHn[U[5(a[U5(a g[U[ 5(aURS5[;a g[U[ 5(dMqU(dMz[US[5(dMUS[;dM g gg)aQReturn `True` if `input_` *could* contain a system-role message. Cheap structural probe used to skip the full `_convert_input` pipeline when there is no chance the lift logic will fire. False positives only cost an extra conversion; false negatives would silently skip the lift, so the probe is biased toward `True` for unknown shapes. FTroler) isinstancestrr_is_instruction_messagelisttupledictr_INSTRUCTION_ROLES)input_items r"_maybe_has_system_messagesr8]s&#&+&&&v..&4-((D$ ,,1H1N1N$%%$((6*:>P*P4''DtAw,,G11 r!c[U[5=(d* [U[5=(a UR[;$N)r/r rr.r5)messages r"r1r1{s/ g} - 7K(OW\\=O-Or!c /n[U5GHUup#[U5RnURn[ U[ 5(aUR U5 MO[ U[5(d+SUSUS[U5R<S3n[U5e/n[U5Hup[ U [5(aU RS5S:waSUSUSUS3n[U5eU RSS 5n [ U [ 5(dSUSUS US 3n[U5eUR U 5 M UR S RU55 GMX S RU5$) aJoin system/developer message content into a single `instructions` string. Codex rejects system-role entries in the input list, so their content is lifted into the top-level `instructions` field. Content that uses list-of-content-blocks form is accepted only when every block is `{"type": "text", ...}`; anything else cannot be flattened into the string-typed `instructions` field. Raises: ValueError: A system/developer message carries a non-text content block. `z ` at index z has unsupported content type zH; only `str` and list-of-text-blocks are accepted by `_ChatOpenAICodex`.typetextz/ contains a non-text content block at position u (Codex `instructions` is a string field — only `{"type": "text", "text": "..."}` blocks can be lifted into it). Move the non-text content to a `HumanMessage`, or pass plain instructions via the constructor or `instructions=` kwarg.z has a text block at position z whose `text` is not a string.z ) enumerater>__name__contentr/r0appendr2 ValueErrorr4rjoin) system_messagespartsindexr; message_namerCmsg text_parts block_indexblock text_values r"_flatten_system_message_contentrPsE#O4G}-- // gs # # LL ! '4((L>UG4W ..12JJ  S/ ! " "+G"4 KeT**eii.?6.I ~[8::EG<<!o%62.Jj#.. ~[8##.-0 !o%   j ))#5*  RWWZ()G5H ;;u r!z:You are ChatGPT, a large language model trained by OpenAI.T)use_responses_apistore streamingdict[str, Any]_FORCED_VALUESc~^\rSrSr%Sr\"SSS9rS\S'\"\S9r S \S '\"\ S 9r S \S '\ "SS9\ SSj55rSSjrSSjrSSjrSS.S U4SjjjrS!S"U4SjjjrS!S#U4SjjjrS$S%U4Sjjjr\S&Sj5r\ S'Sj5rSrU=r$)(_ChatOpenAICodexu Experimental `ChatOpenAI` variant authed by ChatGPT OAuth. This integration is unofficial and should only be used where your OpenAI account, workspace, plan, and applicable OpenAI terms permit ChatGPT-authenticated Codex access. Users are responsible for implementing and operating it in compliance with OpenAI's terms, usage policies, account restrictions, rate limits, and safeguards. Routes requests to `https://chatgpt.com/backend-api/codex` and forces the wire-level fields the Codex backend requires (`use_responses_api=True`, `store=False`, `streaming=True`). These values are forced — passing a conflicting value to the constructor raises. `output_version` (a client-side `AIMessage` projection) is not forced; pick whichever projection you want. Authorization and `ChatGPT-Account-Id` headers are taken from `token_provider` on every request so a freshly-refreshed access token is always used. Example: ```python from langchain_openai.chat_models.codex import _ChatOpenAICodex from langchain_openai.chatgpt_oauth import login_chatgpt # One-time setup. The returned provider writes to the default store # at `~/.langchain/chatgpt-auth.json`, which `_ChatOpenAICodex` also # reads from by default — so subsequent constructions need no # explicit `token_provider`. login_chatgpt() model = _ChatOpenAICodex( model="gpt-5.5", instructions="You are a senior Python reviewer. Be terse.", ) response = model.invoke("hello") ``` !!! tip "Override `instructions`" The Codex backend requires a top-level `instructions` value on every request. A generic default keeps zero-config use working, but most callers should override it via the constructor (above) or per call (`model.invoke(..., instructions=...)`). See the field's docstring for the full resolution rules. !!! note Token storage is handled by `_FileChatGPTOAuthTokenProvider`, which defaults to `~/.langchain/chatgpt-auth.json` so it does not collide with the Codex CLI / VS Code session at `~/.codex/auth.json`. !!! note "Always streams over the wire" The Codex backend only accepts streaming requests, so `streaming=True` is forced. `invoke` still returns a single aggregated `AIMessage` — chunks are collected internally — but the underlying HTTP request is a stream either way. Expect every call to show up as a streamed request in network logs and LangSmith traces. NT)defaultexcludertoken_provider)default_factory str | Noner)rYr0 instructionsbefore)modec [5 [U[5(dU$[R 5H>up#UR U5nUb!XC:waSUSU<SUSU<S3 n[ U5eX1U'M@ SHInUR U5nUb*U[:wa SUS[<SUSU<S3 n[ U5e[X'MK UR S5nUc[R"5nXaS'[U[5(d Sn[U5eS H&nUR U5cMS US 3n[ U5e [U5US 'U$) z?Apply Codex-specific defaults before the parent validator runs.z`_ChatOpenAICodex` requires `=z`; got `z2`. Use `ChatOpenAI` if you need to customize this.)base_urlopenai_api_basez?`. Use `ChatOpenAI` if you need to target a different endpoint.r[zJ`token_provider` must implement the `_ChatGPTOAuthTokenProvider` protocol.)api_keyopenai_api_keyzS`_ChatOpenAICodex` manages authentication via `token_provider`; drop the explicit `z8=`. Use `ChatOpenAI` if you want API-key authentication.re) r,r/r4rUitemsrrECHATGPT_CODEX_BASE_URLrfrom_default_storer TypeError_SyncTokenCallable)clsvalueskeyforcedsuppliedrKproviders r"_apply_codex_defaults&_ChatOpenAICodex._apply_codex_defaultsZs &'&$''M)//1KCzz#H#(:3C5&D5(... !o% 3K23Czz#H#4J(J3C5:P9ST5(.33 !o%0FK3::./  5HHJH'/# $($>??9 C. 1Czz#*<UR[S5nUn[U5(aURU5R 5nUVs/sHn[ U5(dMUPM nnU(ahUVs/sHn[ U5(aMUPM n n[ U5n URS5n U b [RS[U 55 OXS'U n[TU]0"U4SU0UD6n U RS5cURU S'UbUOUR5n URX5$s snfs snf)uBuild the request payload and attach Codex auth headers. Lifts any `SystemMessage` content out of the input list into the top-level `instructions` field, since Codex rejects `SystemMessage` chat turns. See the `instructions` field docstring for the precedence rules. Fast path: when the input can't carry a `SystemMessage`, skip the local conversion and delegate `input_` straight to super — that way `_convert_input` only runs once (inside super) instead of once here and again there. Nr^zBoth `instructions=` and a `SystemMessage` were provided; the explicit `instructions=` kwarg wins and the `SystemMessage` content is discarded for this call. Discarded length: %d.r)pop_CODEX_HEADERS_KWARGr8_convert_input to_messagesr1rPrloggerwarninglensuper_get_request_payloadr^rzr)rxr6rkwargs codex_headers payload_inputmessagesmrG non_systemliftedexplicitrr __class__s r"r%_ChatOpenAICodex._get_request_payloads3& #7> ,2 %f - -**62>>@H*2Q(Q6Ma6Pq(OQ)1TA9PQR9Sa T8I!::n5'NN;F .4>* * '.}R4R6R ;;~ & .&*&7&7GN #+6MD# URR5IShvN nURUR5U['[ TU]"U4X#S.UD6IShvN $NAN7fN)r run_manager)r[ aget_tokenrvrwrr _agenerate)rxrrrrryrs r"r_ChatOpenAICodex._agenerateso))4466'+':':5;K;K'L#$W'   # URR5IShvN nURUR5U['[ TU]"U4X#S.UD6ShvN nU7v MNIN g7fr)r[rrvrwrr_astream)rxrrrrrychunkrs r"r_ChatOpenAICodex._astreamsx))4466'+':':5;K;K'L#$ 7+   [TU]"SSU0UD6nSUS'U$)Nrz openai-codex ls_providerr )r_get_ls_params)rxrrparamsrs r"r_ChatOpenAICodex._get_ls_params s+'   "& 8;"8; 8;  8;  8;8;z"&<@  #  :       *"&<@ #:    , "(,$7: ##r!rWc0\rSrSrSrSrSSjrSSjrSrg) rkiaSync callable wrapper around a token provider for the OpenAI SDK. The OpenAI Python SDK accepts a callable returning a string for `api_key`. Wrapping the provider lets the SDK fetch a freshly-refreshed access token on every request without exposing the provider's other methods.  _providercXlgr:r)rxrqs r"__init___SyncTokenCallable.__init__&s!r!c6URR5$r:)rget_access_tokenrs r"__call___SyncTokenCallable.__call__)s~~..00r!N)rqr rNoner) rBrrrr __slots__rrrr r!r"rkrksI"1r!rkz list[str]__all__r)rr)r6rrr)r;rrr)rGrrr0)8r __future__rloggingrr(typingrr*langchain_core.language_models.chat_modelsrlangchain_core.messagesrrr pydanticr r !langchain_openai.chat_models.baser langchain_openai.chatgpt_oauthr rcollections.abcrlangchain_core.callbacksrlangchain_core.language_modelsrlangchain_core.outputsrr getLoggerrBrrhr~rrr}rr*r' frozensetr5r#r,r8r1rPrrUrrWrkrr r!r"rs$# %FKK+8 -FAF   8 $A  2(' !&+67B N< 1hT " 6|z|~ 11"r!