o ˷eH@sUdZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z ddlZddlZddlmZddlmZz ddlZddlZWn eyRdZYnwejjZejjZejdd d ejjd Zd Zd Zd ZdZ e!dej"Z#e e$dfe%d<zej&'dZ(Wn eydZ(Ynwej&)dddZ*dZ+dZ,Gddde Z-ddZ.dJddZ/ddZ0dd Z1d!d"Z2d#d$Z3d%d&Z4d'd(Z5d)d*Z6d+d,Z7dKd.d/Z8dLd1d2Z9d3d4Z:d5d6Z;d7d8Zd=d>Z?d?d@Z@dAdBZAdMdDdEZBdMdFdGZCdJdHdIZDdS)Nz^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_defaultcoreprojectcsDeZdZdZfddZddZddZdd Zed d Z Z 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. cstt|g|_dSN)superr__init___stackself __class__U/var/www/ideatree/venv/lib/python3.10/site-packages/google/cloud/_helpers/__init__.pyrSs z_LocalStack.__init__cCstt|jS)z Iterate the stack in LIFO order.)iterreversedrrrrr__iter__Wsz_LocalStack.__iter__cCs|j|dS)zPush a resource onto our stack.N)rappend)rresourcerrrpush[sz_LocalStack.pushcCs |jS)zPop a resource from our stack. :rtype: object :returns: the top-most resource, after removing it. :raises IndexError: if the stack is empty. )rpoprrrrr"_s z_LocalStack.popcCs|jr|jdSdS)z~Get the top-most resource :rtype: object :returns: the top-most item, or None if the stack is empty. N)rrrrrtophs z_LocalStack.top) __name__ __module__ __qualname____doc__rrr!r"propertyr$ __classcell__rrrrrLs  rcCs&t|ttfstd||ft|S)aEnsures an input is a tuple or list. This effectively reduces the iterable types allowed to a very short whitelist: 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 %s to be a tuple or list. Received %r) isinstancetuplelist TypeError)arg_name tuple_or_listrrr_ensure_tuple_or_listssr1cCs|dur 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. N)googleauthdefault)r_rrr_determine_default_projects r6cCst|}|dS)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)whenmicrosrrr_millis r;cCsttj|dS)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 timedeltavaluerrr_datetime_from_microsecondss rCcCs8|js |jtd}|t}tt|d|jS)zConvert non-none datetime to microseconds. :type value: :class:`datetime.datetime` :param value: The timestamp to convert. :rtype: int :returns: The timestamp, in microseconds. rg.A) r replaceUTC astimezoneintcalendartimegm timetuple microsecondrArrrr8s  r8cCs|durt|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)r;rArrr_millis_from_datetimes rLcCstj|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)r?strptimedaterArrr_date_from_iso8601_dates rOcCsDt|dkr t}nt|dkrt}ntd|tj||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 ValueErrorformatr?rMtime)rBfmtrrr_time_from_iso8601_time_naives  rYcCstj|tjtdS)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)r?rM_RFC3339_MICROSrDrE)dt_strrrr_rfc3339_to_datetimes r\cCst|}|durtd|tjftj|dt}|d}|dur(d}ndt|}t |d|}|d}|j |t d 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: %r, does not match pattern: %r no_fractionnanosr r7)rKr ) _RFC3339_NANOSmatchrUpatternr?rMgroup_RFC3339_NO_FRACTIONrRrGrDrE)r[ with_nanos bare_secondsfractionr:scaler^rrr_rfc3339_nanos_to_datetimes"    rjTcCs,|s|jdur|jdd|}|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 rD utcoffsetstrftimerZ)rB ignore_zonerrr_datetime_to_rfc3339"s  rnasciicCs4t|tr ||n|}t|tr|Std|f)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"%r could not be converted to bytes)r+strencodebytesr.)rBencodingresultrrr _to_bytes6s rucCs4t|tr |dn|}t|tr|Std|f)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$%r could not be converted to unicode)r+rrdecoderprU)rBrtrrr_bytes_to_unicodePs rwcCs*|}||std|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 {})Unpackr.rVrr%)pb_typeany_pbmsgrrr _from_any_pbcs  r|cCsttj|j|jddS)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. @@secondsr=)r>r?r@rr^) timestamp_pbrrr_pb_timestamp_to_datetime|s rcCst|}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. )rrn)r timestamprrr_pb_timestamp_to_rfc3339r<rcCs,t|}t|d\}}|d}tj||dS)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@Br7)rr^)r8divmodr Timestamp)r9ms_valuerr:r^rrr_datetime_to_pb_timestamps rcCst}|||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_pbrrr_timedelta_to_duration_pbs rcCstj|j|jddS)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. r}r~)r?r@rr^)rrrr_duration_pb_to_timedeltas rcCsht|tr t|}||}|std||jf|dur/|d}||kr/td||f|dS)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. z-path "%s" did not match expected pattern "%s"NrzEProject from client (%s) should agree with project from resource(%s).name)r+rprecompilerbrUrcrd)pathrtemplaterb found_projectrrr_name_from_project_paths      rrcCsHd|tjjf}tjjj}d|f}|f|}tjjjj ||||dS)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_PORTr2r3 transportrequestsRequestgrpcsecure_authorized_channel) credentials user_agenthost extra_optionstarget http_requestuser_agent_optionrrrrmake_secure_channels  rcCst||||d}||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_classrrchannelrrrmake_secure_stubsrcCs,|dur|}nd||f}t|}||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)rrportrrrrrmake_insecure_stub6s   rr)T)ro)r)Er( __future__rrHr? http.clientrosr threadingrLocaltypingr google.authr2google.auth.transport.requestsgoogle.protobufrrrgoogle.auth.transport.grpc ImportErrorutcnow_NOWtimezoneutcrEr>rZrerTrSrVERBOSErarp__annotations__r expanduserr join_GCLOUD_CONFIG_FILE_GCLOUD_CONFIG_SECTION_GCLOUD_CONFIG_KEYrr1r6r;rCr8rLrOrYr\rjrnrurwr|rrrrrrrrrrrrrs~         '      #   +