o tBhM@s4dZddlmZddlZddlZddlZddlZddlmZ ddl Z ddl m Z ddl ZddlZddlmZddlmZz ddlZddlZWn eyQdZYnwejjZdZd Zd Zd Zed ejZzej d Z!Wn eyxdZ!Ynwej"dddZ#dZ$dZ%Gddde Z&Gdddej'Z(ddZ)dJddZ*ddZ+ddZ,dd Z-d!d"Z.d#d$Z/d%d&Z0d'd(Z1d)d*Z2dKd,d-Z3dLd/d0Z4d1d2Z5d3d4Z6d5d6Z7d7d8Z8d9d:Z9d;d<Z:d=d>Z;d?d@ZdJdFdGZ?zddHl@mAZAWn ey e(ZAYnwejBdjCeAdIZDdS)Nz^Shared helpers for Google Cloud packages. This module is not part of the public API surface. )absolute_importN)local) http_client) duration_pb2) timestamp_pb2z%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 ~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__l/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/google/cloud/_helpers.pyrPs z_LocalStack.__init__cCstt|jS)z)Iterate the stack in LIFO order. )iterreversedrrrrr__iter__Tsz_LocalStack.__iter__cCs|j|dS)z(Push a resource onto our stack. N)rappend)rresourcerrrpushYsz_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)rrrrrtopgs z_LocalStack.top) __name__ __module__ __qualname____doc__rrrrpropertyr __classcell__rrrrr Is  r csZeZdZdZedZdZeZddZ fddZ dd Z d d Z d d Z ddZZS)_UTCzeBasic UTC implementation. Implementing a small surface area to avoid depending on ``pytz``. rUTCcC|jS)zDaylight savings time offset.)_dstrdtrrrdst|z_UTC.dstcs&|jdur |j|dStt||S)z6Convert a timestamp from (naive) UTC to this timezone.Ntzinfo)r0replacerr'fromutcr+rrrr2s  z _UTC.fromutccCr))zGet the name of this timezone._tznamer+rrrtznamer.z _UTC.tznamecCr))zUTC offset of this timezone.) _utcoffsetr+rrr utcoffsetr.z_UTC.utcoffsetcCs d|jfS)Nz<%s>r3rrrr__repr__s z _UTC.__repr__cCr)rr3rrrr__str__sz _UTC.__str__)r!r"r#r$datetime timedeltar*r4r6r-r2r5r7r8r9r&rrrrr'rs  r'cCs&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_listsrBcCs|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 rGcCst|}|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 rLcCsttj|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)_EPOCHr:r;valuerrr_datetime_from_microsecondss rRcCs8|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. r/g.A) r0r1r( astimezoneintcalendartimegm timetuple microsecondrPrrrrIs  rIcCs|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)rLrPrrr_millis_from_datetimes rYcCstj|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:strptimedaterPrrr_date_from_iso8601_dates r\cCsDt|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:rZtime)rQfmtrrr_time_from_iso8601_time_naives  rfcCstj|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:rZ_RFC3339_MICROSr1r()dt_strrrr_rfc3339_to_datetimes ricCst|}|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 rH)rXr0) _RFC3339_NANOSmatchrbpatternr:rZgroup_RFC3339_NO_FRACTIONr_rTr1r()rh with_nanos bare_secondsfractionrKscalerkrrr_rfc3339_nanos_to_datetime!s"    rwTcCs,|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/)r0r1r7strftimerg)rQ ignore_zonerrr_datetime_to_rfc3339Ds  rzasciicCs8t|tjr ||n|}t|tjr|Std|f)aConverts a string value to bytes, if necessary. Unfortunately, ``six.b`` is insufficient for this task since in Python2 it does not modify ``unicode`` objects. :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<six text_typeencode binary_typer?)rQencodingresultrrr _to_bytesXs rcCs8t|tjr |dn|}t|tjr|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<r|rdecoder}rb)rQrrrr_bytes_to_unicodeus rcCs*|}||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?rcrr!)pb_typeany_pbmsgrrr _from_any_pbs  rcCsttj|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. @@secondsrN)rOr:r;rrk) timestamp_pbrrr_pb_timestamp_to_datetimes 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. )rrz)r timestamprrr_pb_timestamp_to_rfc3339rMrcCs,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@BrH)rrk)rIdivmodr Timestamp)rJms_valuerrKrkrrr_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. rr)r:r;rrk)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"Nr zEProject from client (%s) should agree with project from resource(%s).name)r<strrecompilerorbrprq)pathr templatero found_projectrrr_name_from_project_paths      rrcCsFd|tjf}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) r HTTPS_PORTrCrD 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_stub<srcCs,|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_stub[s   r)r(r/r)T)r{)r)Er$ __future__rrUr:osr threadingrLocalr| six.movesr google.authrCgoogle.auth.transport.requestsgoogle.protobufrrrgoogle.auth.transport.grpc ImportErrorutcnow_NOWrgrrrar`rVERBOSErnr expanduser _USER_ROOTjoin_GCLOUD_CONFIG_FILE_GCLOUD_CONFIG_SECTION_GCLOUD_CONFIG_KEYr r0r'rBrGrLrRrIrYr\rfrirwrzrrrrrrrrrrrrpytzr(utcfromtimestampr1rOrrrrs         )#      #   +