tj"UdZddlmZddlZddlZddlZddlmZddlm Z ddl m Z m Z m Z ddlmZmZddlZddlZddlmZe rdd lmZd Ze deZefd9dZd:dZd;dZejdZdd"Z!d?d%Z"d@d)Z#dAd-Z$dBd/Z%gZ&d0e'd1<dCd4Z(ej)d56dDd8Z*dS)Ez4Shared utility functions for async and sync clients.) annotationsN)Mapping)tzinfo) TYPE_CHECKINGAnycast)quoteurlparse)RunCreateMetadata)ZoneInfo) x-api-keyapi_key str | Nonereturnct|tr|S|turZdD]W}tj|dx}r<|ddcSXdS)aGet the API key from the environment. Precedence: 1. explicit string argument 2. LANGGRAPH_API_KEY (if api_key not provided) 3. LANGSMITH_API_KEY (if api_key not provided) 4. LANGCHAIN_API_KEY (if api_key not provided) Args: api_key: The API key to use. Can be: - A string: use this exact API key - None: explicitly skip loading from environment - NOT_PROVIDED (default): auto-load from environment variables ) LANGGRAPH LANGSMITH LANGCHAIN_API_KEY"'N) isinstancestr NOT_PROVIDEDosgetenvstrip)rprefixenvs ]/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph_sdk/_shared/utilities.py _get_api_keyr!s'3,= 9 9Fi6 3 3 3444s 9yy{{((--33C88888 9 4custom_headersMapping[str, str] | Nonedict[str, str]c|pi}tD]}||vrtd|dddtji|}t |}|r||d<|S)z1Combine api_key and custom user-provided headers.zCannot set reserved header 'rz User-Agentzlanggraph-sdk-py/r )RESERVED_HEADERS ValueError langgraph_sdk __version__r!)rr#headerheadersresolved_api_keys r _get_headersr.3s $)rN"GG ^ # #EFEEEFF F $ E-*CEE G$G,,0/  Nr"objrct|t}t|dr?t|jr+|rt d|d||St|dr?t|jr+|rt d|d||St|ttfrt|St dt|d)N model_dumpz#Cannot JSON-serialize type object: zI. Did you mean to pass an instance of the object instead? Received type: dictzObject of type z is not JSON serializable) rtypehasattrcallabler1 TypeErrorr2set frozensetlist)r/is_classs r _orjson_defaultr;Hs1#t$$HsL!!Phs~&>&>P  ,c,,$',, ~~ f   P(38"4"4 P  ,c,,$',, xxzz C#y) * *PCyyN$s))NNNOOOr"z5(\/threads\/(?P.+))?\/runs\/(?P.+)responsehttpx.ResponseRunCreateMetadata | Nonec|jdx}rUt|x}r9t |d|dpdSdS)z/Extract run metadata from the response headers.zContent-Locationrun_id thread_idN)r@rA)r,get_RUN_METADATA_PATTERNsearchr group)r<content_locationmatchs r _get_run_metadata_from_responserHds%,001CDDD &--.>??? !;;x((kk+..6$    4r"eventrdatadict[str, Any] | Nonec|dkrdS|d}|d}t|dkr |ddng}|||d}|dkr/t|tr|dg|d <ng|d <|S) z}Convert an SSE event+data pair into a v2 stream part dict. Returns None for ``end`` events (signals end of stream). endN|r)r3nsrJvalues __interrupt__ interrupts)splitlenrr2pop)rIrJparts event_typerPresults r _sse_to_v2_dictrZss  ~~t KK  EqJ%jj1nnqrr"B&0DIIFX*T4"8"8#xx<<|!| Mr"tzstr | tzinfo | ZoneInfo | NonecN|t|tr|St|trTt|dd}t|tr|S|d}||St d|dt dt|j)aConvert a timezone argument to an IANA timezone string. Accepts: - A string (returned as-is, assumed to be an IANA timezone name) - A ``datetime.tzinfo`` instance (e.g. ``zoneinfo.ZoneInfo("America/New_York")``, ``datetime.timezone.utc``). The ``key`` attribute is used if available, otherwise ``tzname(None)`` is used. - ``None`` (returned as ``None``) Nkeyz$Cannot determine timezone name from zL. Use a zoneinfo.ZoneInfo instance or pass a string like 'America/New_York'.z9Expected str, datetime.tzinfo, or None for timezone, got ) rrrgetattrtznamer(r6r3__name__)r[r^names r _resolve_timezonercs zZC((z "f  b%&& c3   Jyy  K Y2 Y Y Y    WDHHDUWW  r"schemeintc|dkrdndS)NhttpsiP)rds r _default_portrjsG##33+r"base_url httpx.URLlocationcRt|}|js |js|St|j}|t|j|jpt |f}|j|jpd|jpt |jf}||krtd|d|d||S)zValidate that a reconnect Location URL is same-origin as the base URL. Raises ValueError if the Location header points to a different origin (scheme + host + port), which would leak credentials to an external server. z4Refusing to follow cross-origin reconnect Location: z (origin z!) does not match base URL origin ) r rdnetlocrhostportrjhostnamer()rkrmparsed base_scheme base_origin loc_origins r _validate_reconnect_locationrxs h  F =ho&&K HM 3{33K  2 3}V]33J j   R8 R R! R RDO R R    Or"dMapping[str, Any]dict[str, Any]c>d|DS)Nci|] \}}||| SNri).0kvs r z"_provided_vals..s 8 8 8TQ!-Aq---r")items)rys r _provided_valsrs 8 8QWWYY 8 8 88r"valuec|tdt|ttfrtdt t |d}|r+t d|Drdt|z}|S)ayEncode a value for safe interpolation into a request path segment. Path segments are encoded with ``safe=""`` so that ``/`` and other reserved characters are escaped. Standalone dot-segments (``.`` and ``..``) are also encoded because some URL-handling stacks (including ``httpx``) collapse them client-side as relative-path traversal before transmission. The value is coerced to ``str`` so callers can pass ``uuid.UUID`` and similar types directly without changing call sites. A properly formed identifier (for example, a standard UUID, which contains no dots or reserved characters) round-trips through this function unchanged. Raises: TypeError: If `value` is `None` or a `bytes`/`bytearray` instance. Coercing those would produce misleading paths (e.g. `/threads/None`), so surface the caller bug instead. Nzpath parameter must not be Nonez9path parameter must not be bytes; pass a str or uuid.UUIDro)safec3"K|] }|dkV dS).Nri)rcs r z$_quote_path_param..s&//1a3h//////r"z%2E)r6rbytes bytearrayr rallrU)rquoteds r _quote_path_paramrs& }9:::%%+,,USTTT 3u::B ' ' 'F %#///////%V$ Mr"zlist[httpx.ASGITransport]_registered_transportsappNonec(tD] }||_ dSr~)rr)r transports r configure_loopback_transportsrs$+  r"rO)maxsizetype[httpx.ASGITransport]cV ddlm}|jS#t$rtjcYSwxYw)Nrasgi_transport) langgraph_apir ASGITransport ImportErrorhttpxrs r get_asgi_transportrsL#000000++ ###""""#s (()rrrr)rrr#r$rr%)r/rrr)r<r=rr>)rIrrJrrrK)r[r\rr)rdrrre)rkrlrmrrr)ryrzrr{)rrrr)rrrr)rr)+__doc__ __future__r functoolsrrecollections.abcrdatetimertypingrrr urllib.parser r rr)langgraph_sdk.schemar zoneinfor r'objectrr!r.r;compilerCrHrZrcrjrxrrr__annotations__r lru_cacherrir"r rsI:::"""""" ######++++++++++(((((((( 222222"!!!!!!!tD&&((## (42*PPPP.# <    $<,,,,<9999B576666 Q### ###r"