B fHUdZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z ddlZddlZddlmZddlmZ ddlZddlZn #e$rdZYnwxYwejjZejjZejdd d ejj Zd Zd Zd ZdZ ej!dej"Z#e e$dfe%d< ej&'dZ(n #e$rdZ(YnwxYwej&)dddZ*dZ+dZ,Gdde Z-dZ.d3dZ/dZ0dZ1dZ2dZ3dZ4d Z5d!Z6d"Z7d4d$Z8d5d&Z9d'Z:d(Z;d)Zd,Z?d-Z@d.ZAd6d0ZBd6d1ZCd3d2ZDdS)7z^Shared helpers for Google Cloud packages. This module is not part of the public API surface. )absolute_importN)local)Union) duration_pb2) timestamp_pb2itzinfoz%Y-%m-%dT%H:%M:%S.%fZz%Y-%m-%dT%H:%M:%Sz %H:%M:%S.%fz%H:%M:%Sah (?P \d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2} # YYYY-MM-DDTHH:MM:SS ) ( # Optional decimal part \. # decimal point (?P\d{1,9}) # nanoseconds, maybe truncated )? Z # Zulu _USER_ROOT~gcloudconfigurationsconfig_defaultcoreprojectcJeZdZdZfdZdZdZdZedZ xZ S) _LocalStackzManage a thread-local LIFO stack of resources. Intended for use in :class:`google.cloud.datastore.batch.Batch.__enter__`, :class:`google.cloud.storage.batch.Batch.__enter__`, etc. cdtt|g|_dSN)superr__init___stack)self __class__s m/home/panchajanya/Development/work/volatility3/lib/python3.11/site-packages/google/cloud/_helpers/__init__.pyrz_LocalStack.__init__Ss* k4  ))+++ cDtt|jS)z Iterate the stack in LIFO order.)iterreversedrrs r__iter__z_LocalStack.__iter__WsHT[))***rc:|j|dS)zPush a resource onto our stack.N)rappend)rresources rpushz_LocalStack.push[s 8$$$$$rc4|jS)zPop a resource from our stack. :rtype: object :returns: the top-most resource, after removing it. :raises IndexError: if the stack is empty. )rpopr s rr'z_LocalStack.pop_s{   rc.|jr |jdSdS)z~Get the top-most resource :rtype: object :returns: the top-most item, or None if the stack is empty. N)rr s rtopz_LocalStack.tophs$ ; #;r? " # #r) __name__ __module__ __qualname____doc__rr!r%r'propertyr* __classcell__)rs@rrrLs +++%%%!!!##X#####rrct|ttfstd|d|t|S)aEnsures an input is a tuple or list. This effectively reduces the iterable types allowed to a very short allowlist: list and tuple. :type arg_name: str :param arg_name: Name of argument to use in error message. :type tuple_or_list: sequence of str :param tuple_or_list: Sequence to be verified. :rtype: list of str :returns: The ``tuple_or_list`` passed in cast to a ``list``. :raises TypeError: if the ``tuple_or_list`` is not a tuple or list. z Expected z! to be a tuple or list. Received ) isinstancetuplelist TypeError)arg_name tuple_or_lists r_ensure_tuple_or_listr8ssN meT] 3 3 i%XX}} 6      rcL|!tj\}}|S)aYDetermine default project ID explicitly or implicitly as fall-back. See :func:`google.auth.default` for details on how the default project is determined. :type project: str :param project: Optional. The project name to use as default. :rtype: str or ``NoneType`` :returns: Default project if it can be determined. )googleauthdefault)r_s r_determine_default_projectr>s%[((** 7 Nrc*t|}|dzS)zConvert a zone-aware datetime to integer milliseconds. :type when: :class:`datetime.datetime` :param when: the datetime to convert :rtype: int :returns: milliseconds since epoch for ``when`` )_microseconds_from_datetime)whenmicross r_millisrDs) . .F T>rc<ttj|zS)zConvert timestamp to datetime, assuming UTC. :type value: float :param value: The timestamp to convert :rtype: :class:`datetime.datetime` :returns: The datetime object created from the value. ) microseconds)_EPOCHdatetime timedeltavalues r_datetime_from_microsecondsrLs H&E::: ::rc|js|t}|t}t t j|dz|jzS)zConvert non-none datetime to microseconds. :type value: :class:`datetime.datetime` :param value: The timestamp to convert. :rtype: int :returns: The timestamp, in microseconds. r g.A) r replaceUTC astimezoneintcalendartimegm timetuple microsecondrJs rrArAsc <* S ))   S ! !E xu0011C7 8 85;L LLrc(|t|SdS)zConvert non-none datetime to timestamp, assuming UTC. :type value: :class:`datetime.datetime` :param value: (Optional) the timestamp :rtype: int, or ``NoneType`` :returns: the timestamp, in milliseconds, or None N)rDrJs r_millis_from_datetimerWs u~~rcftj|dS)zConvert a ISO8601 date string to native datetime date :type value: str :param value: The date string to convert :rtype: :class:`datetime.date` :returns: A datetime date object created from the string z%Y-%m-%d)rHstrptimedaterJs r_date_from_iso8601_dater[s)   % %eZ 8 8 = = ? ??rct|dkrt}n=t|dkrt}n"td|t j||S)a*Convert a zoneless ISO8601 time string to naive datetime time :type value: str :param value: The time string to convert :rtype: :class:`datetime.time` :returns: A datetime time object created from the string :raises ValueError: if the value does not match a known format. zUnknown time format: {})len_TIMEONLY_NO_FRACTION_TIMEONLY_W_MICROS ValueErrorformatrHrYtime)rKfmts r_time_from_iso8601_time_naiverfst 5zzQ# Ur   299%@@AAA   % %eS 1 1 6 6 8 88rc~tj|ttS)zConvert a microsecond-precision timestamp to a native datetime. :type dt_str: str :param dt_str: The string to convert. :rtype: :class:`datetime.datetime` :returns: The datetime object created from the string. r )rHrY_RFC3339_MICROSrNrO)dt_strs r_rfc3339_to_datetimerjs.   % %fo > > F Fc F R RRrct|}|td|dtjtj|dt}|d}|d}n,dt|z }t|d|zz}|d z}| |t S) aConvert a nanosecond-precision timestamp to a native datetime. .. note:: Python datetimes do not support nanosecond precision; this function therefore truncates such values to microseconds. :type dt_str: str :param dt_str: The string to convert. :rtype: :class:`datetime.datetime` :returns: The datetime object created from the string. :raises ValueError: If the timestamp does not match the RFC 3339 regular expression. Nz Timestamp: z, does not match pattern: no_fractionnanosr r@)rUr ) _RFC3339_NANOSmatchrbpatternrHrYgroup_RFC3339_NO_FRACTIONr_rQrNrO)ri with_nanos bare_secondsfractionrCscalerms r_rfc3339_nanos_to_datetimerys  %%f--Jjvv~-- /   $--'')=L((HCMM!H U+$   F3  ? ??rTc|s2|j+|d|z }|tS)atConvert a timestamp to a string. :type value: :class:`datetime.datetime` :param value: The datetime object to be converted to a string. :type ignore_zone: bool :param ignore_zone: If True, then the timezone (if any) of the datetime object is ignored. :rtype: str :returns: The string representing the datetime stamp. Nr )r rN utcoffsetstrftimerh)rK ignore_zones r_datetime_to_rfc3339r~"sG ?5<3 T **U__->->> >>/ * **rasciict|tr||n|}t|tr|St |d)a'Converts a string value to bytes, if necessary. :type value: str / bytes or unicode :param value: The string/bytes value to be converted. :type encoding: str :param encoding: The encoding to use to convert unicode to bytes. Defaults to "ascii", which will not allow any characters from ordinals larger than 127. Other useful values are "latin-1", which which will only allows byte ordinals (up to 255) and "utf-8", which will encode any unicode that needs to be. :rtype: str / bytes :returns: The original value converted to bytes (if unicode) or as passed in if it started out as bytes. :raises TypeError: if the value could not be converted to bytes. z could not be converted to bytes)r2strencodebytesr5)rKencodingresults r _to_bytesr6sV&(2%'='= HU\\( # # #5F&%  I GHHHrct|tr|dn|}t|tr|St |d)acConverts bytes to a unicode value, if necessary. :type value: bytes :param value: bytes value to attempt string conversion on. :rtype: str :returns: The original value converted to unicode (if bytes) or as passed in if it started out as unicode. :raises ValueError: if the value could not be converted to unicode. zutf-8z" could not be converted to unicode)r2rdecoderrb)rKrs r_bytes_to_unicoderPsV'1&>&> IU\\' " " "EF&#L 555JKKKrc|}||s2td|jj|j|S)ayConverts an Any protobuf to the specified message type Args: pb_type (type): the type of the message that any_pb stores an instance of. any_pb (google.protobuf.any_pb2.Any): the object to be converted. Returns: pb_type: An instance of the pb_type message. Raises: TypeError: if the message could not be converted. zCould not convert {} to {})Unpackr5rcrr+)pb_typeany_pbmsgs r _from_any_pbrcs] '))C ==    ( / / )7+;     JrcXttj|j|jdz zS)a1Convert a Timestamp protobuf to a datetime object. :type timestamp_pb: :class:`google.protobuf.timestamp_pb2.Timestamp` :param timestamp_pb: A Google returned timestamp protobuf. :rtype: :class:`datetime.datetime` :returns: A UTC datetime object converted from a protobuf timestamp. @@secondsrF)rGrHrIrrm) timestamp_pbs r_pb_timestamp_to_datetimer|s5 H&$L4F4O rc>t|}t|S)aConvert a Timestamp protobuf to an RFC 3339 string. :type timestamp_pb: :class:`google.protobuf.timestamp_pb2.Timestamp` :param timestamp_pb: A Google returned timestamp protobuf. :rtype: str :returns: An RFC 3339 formatted timestamp string. )rr~)r timestamps r_pb_timestamp_to_rfc3339rs*,77I  * **rc|t|}t|d\}}|dz}tj||S)a Convert a datetime object to a Timestamp protobuf. :type when: :class:`datetime.datetime` :param when: the datetime to convert :rtype: :class:`google.protobuf.timestamp_pb2.Timestamp` :returns: A timestamp protobuf corresponding to the object. i@Br@)rrm)rAdivmodr Timestamp)rBms_valuerrCrms r_datetime_to_pb_timestamprsC+400HXu--OGV UNE  "7% @ @ @@rcVtj}|||S)aConvert a Python timedelta object to a duration protobuf. .. note:: The Python timedelta has a granularity of microseconds while the protobuf duration type has a duration of nanoseconds. :type timedelta_val: :class:`datetime.timedelta` :param timedelta_val: A timedelta object. :rtype: :class:`google.protobuf.duration_pb2.Duration` :returns: A duration object equivalent to the time delta. )rDuration FromTimedelta) timedelta_val duration_pbs r_timedelta_to_duration_pbrs,'))Km,,, rcHtj|j|jdz S)aConvert a duration protobuf to a Python timedelta object. .. note:: The Python timedelta has a granularity of microseconds while the protobuf duration type has a duration of nanoseconds. :type duration_pb: :class:`google.protobuf.duration_pb2.Duration` :param duration_pb: A protobuf duration object. :rtype: :class:`datetime.timedelta` :returns: The converted timedelta object. rr)rHrIrrm)rs r_duration_pb_to_timedeltars.  #;3Dv3M   rcHt|trtj|}||}|st d|d|jd|1|d}||krt d|d|d|d S) aValidate a URI path and get the leaf object's name. :type path: str :param path: URI path containing the name. :type project: str :param project: (Optional) The project associated with the request. It is included for validation purposes. If passed as None, disables validation. :type template: str :param template: Template regex describing the expected form of the path. The regex must have two named groups, 'project' and 'name'. :rtype: str :returns: Name parsed from ``path``. :raises ValueError: if the ``path`` is ill-formed or if the project from the ``path`` does not agree with the ``project`` passed in. zpath "z"" did not match expected pattern ""NrzProject from client (z*) should agree with project from resource(z).name)r2rrecompilerqrbrrrs)pathrtemplaterq found_projects r_name_from_project_pathrs,(C  (:h'' NN4 E  j?CttXEUEUEU V    I.. G # #*07H  ;;v  rcd|tjjfz}tjjj}d|f}|f|z}tjjj ||||S)aMakes a secure channel for an RPC service. Uses / depends on gRPC. :type credentials: :class:`google.auth.credentials.Credentials` :param credentials: The OAuth2 Credentials to use for creating access tokens. :type user_agent: str :param user_agent: The user agent to be used with API requests. :type host: str :param host: The host for the service. :type extra_options: tuple :param extra_options: (Optional) Extra gRPC options used when creating the channel. :rtype: :class:`grpc._channel.Channel` :returns: gRPC secure channel with credentials attached. %s:%dzgrpc.primary_user_agent)options) httpclient HTTPS_PORTr:r; transportrequestsRequestgrpcsecure_authorized_channel) credentials user_agenthost extra_optionstarget http_requestuser_agent_optionrs rmake_secure_channelrsx,dk45 5F;(199;;L2J? "]2G ; % ? ?\67 @  rc>t||||}||S)aMakes a secure stub for an RPC service. Uses / depends on gRPC. :type credentials: :class:`google.auth.credentials.Credentials` :param credentials: The OAuth2 Credentials to use for creating access tokens. :type user_agent: str :param user_agent: The user agent to be used with API requests. :type stub_class: type :param stub_class: A gRPC stub type for a given service. :type host: str :param host: The host for the service. :type extra_options: tuple :param extra_options: (Optional) Extra gRPC options passed when creating the channel. :rtype: object, instance of ``stub_class`` :returns: The stub object used to make gRPC requests to a given API. )r)r)rr stub_classrrchannels rmake_secure_stubrs32"Z]G :g  rcX||}nd||fz}tj|}||S)aMakes an insecure stub for an RPC service. Uses / depends on gRPC. :type stub_class: type :param stub_class: A gRPC stub type for a given service. :type host: str :param host: The host for the service. May also include the port if ``port`` is unspecified. :type port: int :param port: (Optional) The port for the service. :rtype: object, instance of ``stub_class`` :returns: The stub object used to make gRPC requests to a given API. Nr)rinsecure_channel)rrportrrs rmake_insecure_stubr6s@$ |D$<'#F++G :g  rr)T)r)r)Er. __future__rrRrH http.clientrosr threadingrLocaltypingr google.authr:google.auth.transport.requestsgoogle.protobufrrrgoogle.auth.transport.grpc ImportErrorutcnow_NOWtimezoneutcrOrGrhrtrar`rVERBOSErpr__annotations__r expanduserr join_GCLOUD_CONFIG_FILE_GCLOUD_CONFIG_SECTION_GCLOUD_CONFIG_KEYrr8r>rDrLrArWr[rfrjryr~rrrrrrrrrrrrrrrrs '&&&&& $$$$$$%%%%(((((())))))KKK%%%%% DDD  4Ah.?.C D D D)*"" J   #t) ##C((JJJJJgll8-=?OPP$#$#$#$#$#%$#$#$#N0"    ; ; ;MMM"    @ @ @999& S S S @ @ @F++++(IIII4LLL&2    + + + A A A&&(((V@>s#AAA7CCC