8jddlmZddlZddlmZddlmZddlmZm Z ddl m Z m Z ddl mZmZe rddlmZddd  d d Zedd Zdd Zy)) annotationsN) b64encode)cache) isawaitable iscoroutine) TYPE_CHECKINGAny) WebhookCreateWebhookRepresentation) WebhooksList) content_typecontent_encodingc\t|dd}t|ru|}t|r&t|r|j t dt |tttfs"t dt|jd|xsdjj}|dvr;t |ttfs%t dt|jd |d |s.t |ttfrd }nt |trd }nd }d|vrGt |tttfs,tj|ddtj!d}t |tttfs%t dt|jd|d||fS)aEncode a value for storage in a key-value store record. Args: value: The value to encode. Anything exposing a callable `read` is treated as a file-like object: `read` is called with no arguments, so the value is consumed from its current position and buffered in memory whole - the object is neither rewound nor closed, and async file-like objects are rejected. Any other value is JSON-serialized unless it is already bytes or a string. content_type: The content type; if None, it's inferred from the value type. content_encoding: The encoding the caller declares the value already carries, if any. Anything other than `identity` means the value is compressed, which only a bytes-like payload can be, so any other value is rejected. The check belongs here because a file-like value has to be read before its payload type is known, and reading it a second time in the caller is not possible. Returns: A tuple of (encoded_value, content_type). Raises: TypeError: If the value cannot be encoded into a body the transport accepts, or if it cannot be carrying the declared `content_encoding`. readNzjAsync file-like objects are not supported. Await the read yourself and pass the resulting bytes or string.z%Reading the file-like value returned z, expected bytes or str.)ridentityzCannot upload a z value with `Content-Encoding: z`. An encoding other than `identity` declares the value is already compressed, so pass the compressed bytes, or a file-like object that reads them.zapplication/octet-streamztext/plain; charset=utf-8zapplication/json; charset=utf-8zapplication/jsonF) ensure_ascii allow_nandefaultutf-8zCannot encode a z value as zJ. Pass bytes, a string, or a file-like object, or use a JSON content type.)getattrcallablerrclose TypeError isinstancebytes bytearraystrtype__name__striplowerjsondumpsencode)valuer rrdeclared_encodings S/var/www/html/GAP/venv/lib/python3.12/site-packages/apify_client/_utils/encoding.py#encode_key_value_store_record_valuer)s4 5&$ 'D~ u 5! #  %%C!89CDKDXDXCYYqrs s */R668>>@ 00EES\K]9^tE{3344STdSef0 0   eeY/ 05L s #6LNO< <  <  ctt}tjj D]>\}}|j ||j $|j |j @t|S)zGReturn all field names and aliases declared on `WebhookRepresentation`.)setrr model_fieldsitemsaddalias frozenset)keysnameinfos r(_webhook_representation_keysr5_sb s8:D+88>>@! d  :: ! HHTZZ ! T?r*cX|sytt}t}|D]}t|tr|j |%t|t r|j dn t|}|jDcic] \}}||vs ||}}}|j tj||Dcgc]}|j dd}}tj|jd} t| jdScc}}wcc}w)awEncode a list of ad-hoc webhooks to a base64 string for the `webhooks` query parameter. Returns `None` for `None` or an empty list, so the query parameter is omitted. See `WebhooksList` for the accepted shapes. `WebhookRepresentation` instances are used as-is. `WebhookCreate` instances and dict shapes are projected onto the fields `WebhookRepresentation` declares, dropping anything else (e.g. persistent-only fields like `condition`). Filtering by the declared field names and aliases means new ad-hoc fields added to `WebhookRepresentation` flow through automatically, without touching this function. NT)by_alias)r7 exclude_noner)encodingascii)listr r5rappendr model_dumpdictr.model_validater#r$r%rdecode) webhooksrepresentationsallowedwebhookdatakeyr&filteredr json_strings r(encode_webhooks_to_base64rJjs 013O*,GO g4 5  " "7 + 4>w 4Vw!!4!0\`ah\i15P:3CJPP4CCHMNOET TqALL$TL : TD T**T"))7);K [ ! ( (' ( :: Q Us D!D!D')r&r r str | NonerrKreturnz#tuple[bytes | bytearray | str, str])rLzfrozenset[str])rAzWebhooksList | NonerLrK) __future__rr#base64r functoolsrinspectrrtypingrr apify_client._modelsr r apify_client.typesr r)r5rJr*r(rUsl" ,%E//3SWM! M!!+M!FPM!(M!`;r*