ѮhHUdZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z ddlZddlZddlmZddlmZ ddlZddlZejj.Zej2j4Zejdd d ej2j4 Zd Zd Zd ZdZ ejBdejDZ#e e$dfe%d< ejLjOdZ(ejLjSdddZ*dZ+dZ,Gdde Z-dZ.d0dZ/dZ0dZ1dZ2dZ3dZ4d Z5d!Z6d"Z7d1d#Z8d2d$Z9d%Z:d&Z;d'Zd*Z?d+Z@d,ZAd3d-ZBd3d.ZCd0d/ZDy#e$rdZY#wxYw#e$rdZ(YwxYw)4z^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_defaultcoreprojectcDeZdZdZfdZdZdZdZedZ 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. c8tt| g|_yN)superr__init___stack)self __class__s p/home/www/academy-backend.kofcorporation.com/venv/lib/python3.12/site-packages/google/cloud/_helpers/__init__.pyrz_LocalStack.__init__Ss k4)+ c>tt|jS)z Iterate the stack in LIFO order.)iterreversedrrs r__iter__z_LocalStack.__iter__WsHT[[)**rc:|jj|y)zPush a resource onto our stack.N)rappend)rresources rpushz_LocalStack.push[s 8$rc6|jjS)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|jdSy)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@rrrLs0 +%!##rrcft|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_listr8ss6 meT] 3%} 6    rcL|!tjj\}}|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|jt}|jt}t t j |jdz|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 rrArAsV << S )   S !E xu01C7 85;L;L LLrc| t|Sy)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~rc^tjj|djS)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 = = ??rct|dk(rt}n/t|dk(rt}ntdj |t j j ||jS)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_naiverfs^ 5zQ# Ur  299%@AA    % %eS 1 6 6 88rcrtjj|tjtS)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 RRrcvtj|}|td|dtjtjj |j dt}|j d}|d}n$dt|z }t|d|zz}|dz}|j|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. z 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-J~-- /  $$--')=L(HCM!H U+$   F3  ??rc|s/|j#|jd|jz }|jtS)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~"s; 5<<3 T *U__->> >>/ **rct|tr|j|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_bytesr6s:&(2%'=U\\( #5F&%  GHHrct|tr|jdn|}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_unicoderPs:'1&>U\\' "EF&# 5JKKrc|}|j|s9tdj|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_pbrcsP )C ==  ( / /  ))7+;+;   Jrclttj|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|s4 H&&$$L4F4F4O 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*,7I  **rcnt|}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_timestamprs:+40HXu-OGV UNE  " "7% @@rcPtj}|j||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, rc^tj|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-   ##;3D3Dv3M rc t|trtj|}|j |}|st d|d|j d|(|jd}||k7rt d|d|d|jdS) 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 ""rzProject from client (z*) should agree with project from resource(z).name)r2rrecompilerqrbrrrs)pathrtemplaterq found_projects r_name_from_project_pathrs,(C ::h' NN4 E ?CXEUEU V   I. G #07H  ;;v rc&d|tjjfz}tjj j j}d|f}|f|z}tjj jj||||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_channelrs,dkk445 5F;;((1199;L2J? "]2G ;; % % ? ?\67 @ rc0t||||}||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_stubrs$2"Z]G g rcT||}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. r)rinsecure_channel)rrportrrs rmake_insecure_stubr6s9$ |D$<'##F+G g rr)T)ascii))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 ' $%()%    4Ah.?.?.C.C D)*"" JJ  #t) ##C(Jggll8-=?OP$#%$#N0"  ;M"  @9& S @F+(I4L&2  + A&&(V@>a D>Js#E E. E+*E+.E87E8