}j<UddlmZddlZddlZddlZddlZddlZddlmZm Z m Z m Z m Z m Z mZmZmZmZddlmZmZmZmZmZddlZddlZddlZddlmZddlmZmZm Z ddl!m"Z"m#Z#dd l$m%Z%dd l&m'Z'm(Z(m)Z)m*Z*dd l+m,Z,er dd l!m-Z-dd l.m/Z/edZ0e dZ1e dZ2ejfe4Z5de6d<Gdde e1Z7Gdde8Z9ddZ:ddZ;GddZr.|t<j>k7r tAd tt|St1j2|r5t5|tBs%t5|tDjBr t d |tFurr|tHurj|tJurb|tLurZt5|tBsJt;d |d tBd tJd tHd tLd t$d t&dt<j>d|jNjQddjSd^}}|dk7rxtU|r/ |jW}|jjY|||S|jjbrte|d|d|j(|j(S|jW}|jjY|||S#tZ$r*} t\j_dta| | Yd} ~ d} ~ wwxYw)Nrz/Expected custom parse type to be a subclass of z or zUExpected custom stream type to be passed with a type argument, e.g. Stream[ChunkType])failure_message)r8responser9r/z+Unexpected state - cast_to is `APIResponse`z:Subclasses of httpx.Response cannot be passed to `cast_to`zVPydantic models must subclass our base model type, e.g. `from openai import BaseModel`zUnsupported type, expected z to be a subclass of z, .z content-type*;zapplication/json)datar8riz5Could not read JSON from response data due to %s - %szMExpected Content-Type response header to be `application/json` but received `z ` instead.)rimessagebody)3rrr.r TypeErrorrrr r$rr3rr+r0r#_default_stream_clsMissingStreamClassErrorr)rstrr`intfloatrinspectisclass issubclassHttpxBinaryResponseContentr' RuntimeErrorhttpxResponse ValueErrorrpydanticobjectlistdictrrArBsplitrjson_process_response_data Exceptionr%debugtype_strict_response_validationr) r6rGr;r8riorigin content_type_rmexcs r=rMzLegacyAPIResponse._parsesY #B'!"a(B <<+B/#&UV\U]]abman$opp 9-D!"&!3!3#C6   $$ 9$:J:J K!%!3!3#C6%QSWS_S_SsSstJ!-// MM!//T\\2 "DMM W %&w2G h 4= %% c>8==) ) c>3x}}-. . e 5/0 0G$/ ??6 "z&:T'U78,- - & &LM M ??6 "z&%..'I %..( #]__8$ $ ??6 ":fi+HZX^`h`r`rMstu u 6 !dNdNeOvy1-gY6KI;VXY]X^^`ae`ffhinhooqrzq{{}B~CCGHMHVHVGWWXY  $++//DJJ3O q - -G$ #==?D <<>>! '!)? ||770%klxkyzDE!== }}||223  /!gIIUW[\_W`beffgs*R R7 R22R7cjd|jd|jjd|jdS)Nz)rXr3 reason_phraser)rCs r=__repr__zLegacyAPIResponse.__repr__8s; 0 0143E3E3S3S2TT[\`\i\i[jjkllr?)r7r2r8r(r9r*r:r-r;r/r<r returnNonerz str | None)rGztype[_T]rr$)rr#)rGztype[_T] | NonerzR | _T)rz httpx.Headers)rz httpx.Request)rrt)rz httpx.URLrrsrbytes)rr-)rzdatetime.timedelta)__name__ __module__ __qualname____doc____annotations__r>propertyrDr rHrArVrXrZr\r^r`rbrdrfrMrrrFr?r=r'r'"s  !!)) MBB!!!!!! ! % !  !F!%! !$>>    .2*X****..&&((**''//,,**/3B Hmmr?r'c eZdZdfd ZxZS)rrc$t|dy)NzzThe `stream` argument was set to `True` but the `stream_cls` argument was not given. See `openai._streaming` for reference)superr>)r6 __class__s r=r>z MissingStreamClassError.__init__>s  I r?rr)rrrr> __classcell__)rs@r=rrrr=s   r?rrcDtjdfd }|S)Higher order function that takes one of our bound API methods and wraps it to support returning the raw `APIResponse` object directly. citt|jdxsi}d|t<||d<ttt |i|SN extra_headerstruer rrBrr'r#argskwargsrfuncs r=wrappedz(to_raw_response_wrapper..wrappedIsU(ZDfjj6Q,R,XVX(Z -3 )*"/%a($*?*?@@r?rzP.argsrzP.kwargsrzLegacyAPIResponse[R] functoolswrapsrrs` r=to_raw_response_wrapperrDs) __TAA Nr?cDtjdfd }|S)rcKitt|jdxsi}d|t<||d<ttt |i|d{S7wrrrs r=rz.async_to_raw_response_wrapper..wrappedZs_(ZDfjj6Q,R,XVX(Z -3 )*"/%a(d0Ef0E*EFF*EsAAA  Arrrs` r=async_to_raw_response_wrapperrUs) __TGG Nr?cHeZdZUded<ddZeddZeddZeddZeddZ ddZ dd Z d d!d Z d d"d Z d#d Zd d!dZ d$dZedd d d%dZd&dZddZd d'dZd d(dZd)dZd d'dZedd d d%dZd&dZy )*ryr2ric||_yr5)ri)r6ris r=r>z#HttpxBinaryResponseContent.__init__is   r?c.|jjSr5)rir^rCs r=r^z"HttpxBinaryResponseContent.contentls}}$$$r?c.|jjSr5)rir`rCs r=r`zHttpxBinaryResponseContent.textps}}!!!r?c.|jjSr5)riencodingrCs r=rz#HttpxBinaryResponseContent.encodingts}}%%%r?c.|jjSr5)richarset_encodingrCs r=rz+HttpxBinaryResponseContent.charset_encodingxs}}---r?c :|jjdi|S)NrF)rir)r6rs r=rzHttpxBinaryResponseContent.json|s!t}}!!+F++r?c6|jjSr5)rireadrCs r=rzHttpxBinaryResponseContent.reads}}!!##r?Nc8|jj|Sr5)ri iter_bytesr6 chunk_sizes r=rz%HttpxBinaryResponseContent.iter_bytess}}'' 33r?c8|jj|Sr5)ri iter_textrs r=rz$HttpxBinaryResponseContent.iter_texts}}&&z22r?c6|jjSr5)ri iter_linesrCs r=rz%HttpxBinaryResponseContent.iter_liness}}''))r?c8|jj|Sr5)riiter_rawrs r=rz#HttpxBinaryResponseContent.iter_raws}}%%j11r?ct|d5}|jjD]}|j| dddy#1swYyxYw)avWrite the output to the given file. Accepts a filename or any path-like object, e.g. pathlib.Path Note: if you want to stream the data to the file instead of writing all at once then you should use `.with_streaming_response` when making the API request, e.g. `client.with_streaming_response.foo().stream_to_file('my_filename.txt')` wbmodeNopenrirwrite)r6filefrms r= write_to_filez(HttpxBinaryResponseContent.write_to_filesL$T " a 002      s 1A  AzDue to a bug, this method doesn't actually stream the response content, `.with_streaming_response.method()` should be used instead)rct|d5}|jj|D]}|j| dddy#1swYyxYwNrrr)r6rrrrms r=stream_to_filez)HttpxBinaryResponseContent.stream_to_filesN$T " a 00<      s 2A  Ac6|jjSr5)ricloserCs r=rz HttpxBinaryResponseContent.closes}}""$$r?cRK|jjd{S7wr5)riareadrCs r=rz HttpxBinaryResponseContent.areads]]((**** '%'c@K|jj|Swr5)ri aiter_bytesrs r=rz&HttpxBinaryResponseContent.aiter_bytess}}((44c@K|jj|Swr5)ri aiter_textrs r=rz%HttpxBinaryResponseContent.aiter_texts}}'' 33rc>K|jjSwr5)ri aiter_linesrCs r=rz&HttpxBinaryResponseContent.aiter_liness}}((**sc@K|jj|Swr5)ri aiter_rawrs r=rz$HttpxBinaryResponseContent.aiter_raws}}&&z22rcVKtj|}|jdd{4d{}|jj |23d{}|j |d{#7K7D7"7 6dddd{7y#1d{7swYyxYwwr)anyioPathrrirr)r6rrpathrrms r=astream_to_filez*HttpxBinaryResponseContent.astream_to_fileszz$-- $ $"mm77 C $ $dggdm##. $ $#D $ $ $ $ $s+B)A9B)A;B)BBA=BB3A?4B9B);B)=B?BB B) BB)B&B B&"B)cRK|jjd{S7wr5)riacloserCs r=rz!HttpxBinaryResponseContent.acloses]]))++++r)rir2rrrrr)rrrrr5)r int | NonerzIterator[bytes])rrr Iterator[str])rr)rstr | os.PathLike[str]rr)rrrrrrr)rrrzAsyncIterator[bytes])rrrAsyncIterator[str])rr)rrrrr>rr^r`rrrrrrrrrrrrrrrrrrrrFr?r=ryryfs5!%%""&&..,$43*2$   M"& $   %+54+3 M"& $$ $ $  $ $,r?ry)rzCallable[P, R]rz!Callable[P, LegacyAPIResponse[R]])rzCallable[P, Awaitable[R]]rz,Callable[P, Awaitable[LegacyAPIResponse[R]]])= __future__rosrvloggingdatetimertypingrrrrrr r r r r typing_extensionsrrrrrrr{r~_typesr_utilsrrr_modelsrr _constantsr _streamingrrrr _exceptionsrr _base_clientr!r"r#r$ getLoggerrr%rr'rprrrrryrFr?r=rs" qqqTT AA,+\\3,(cN CL T]'g''1^1Xm Xmv i ""f,f,r?