o sDi @sUdZddlmZddlZddlZddlmZmZddlm Z ddl m Z m Z ddl mZmZmZmZmZmZmZmZmZmZmZmZddlmZdd lmZdd lmZdd l m!Z!m"Z"m#Z#dd l$m%Z%dd l&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2m3Z3ddl4m5Z5ddl6m7Z7m8Z8m9Z9erddl:m;Z;eefZdZ?dZ@dZAdZBdZCdZDdZEdZFdZGdZHd ZId!ZJd"ZKd#ZLd$ZMdZNd%ZOdZPd&e=d'<dZQd&e=d(<dZRd&e=d)<d*ZSd+ZTd+ZUd,ZVd-e=d.<d/ZWd-e=d0<d1ZXd2ZYd3ZZd4gZ[d d9d:Z\d d;d<Z]d ddAdBZ^ej_ej`ejaejbejcdCZdddHdIZeddKdLZfddMdNZgddOdPZhddRdSZiddTdUZjddVdWZkddXdYZlddZd[Zmdd]d^Zndd_d`ZoddbdcZpddddeZqddgdhZrddidjZsddkdlZtddmdnZuddodpZvddsdtZwddudvZxddwdxZyddydzZzdd}d~Z{e|gdZ}dddZ~dddZdddZdddZd ddZd!ddZd"ddZd"ddZdddZd#ddZd$ddZd%ddZd&ddZd'ddZe|gdZd(ddZd)ddZd*ddZd+ddZd,ddZddgiZde=d<idedeyde~delde'detdeederdeedeqderdegdekdevdemdexde{idemdeedeedeedesdetdeedeedeedeideidemdeedeedeodehde(eleheuedۜZde=d<eeeeeeeheieeeezekeredޜ Zde=d<eeewe.eememeeed Zde=d<ddiZde=d<iZde=d<eeeD]\ZZeD]Zeevreeee<qqeZde=d<eegdZde=d<e|dgZd-ddZ d d.ddZd-ddZ +d/d0ddZd1ddZd1ddZe|gdZGdddZGdddeeefZd2ddZGdddeedfZd3d d ZdS(4z9Functions and classes common to multiple pymongo modules.) annotationsN) OrderedDictabc)get_close_matches)requiresversion) TYPE_CHECKINGAnyCallableIteratorMappingMutableMappingNoReturnOptionalSequenceTypeUnionoverload) unquote_plus)SON)UuidRepresentation) CodecOptionsDatetimeConversion TypeRegistry)RawBSONDocument)validate_compressorsvalidate_zlib_compression_level) DriverInfo)ConfigurationError)_validate_event_listeners) ReadConcern) _MONGOS_MODES _ServerMode) ServerApi)DEFAULT_WRITE_CONCERN WriteConcernvalidate_boolean)_AgnosticClientSessionzSequence[Type[Any]] ORDERED_TYPESiiliz4.2 g?<g4@d Optional[int]MAX_IDLE_TIME_MSMAX_IDLE_TIME_SECWAIT_QUEUE_TIMEOUTT);z Sequence[int]COMMAND_NOT_FOUND_CODES) i@i@UNAUTHORIZED_CODESi'mongodbautoCANONICALIZE_HOST_NAMEnodestrreturntuple[str, int]cCsZ|}d}|d}|dkr|d|t||dd}}|dr)|dd}||fS)z5Split a host:port string into (host, int(port)) pair.ii:Nr,[)rfindint startswith)r=hostportidxrJL/home/alumno/antzosa8961/venv/lib/python3.10/site-packages/pymongo/common.pypartition_nodes "  rLcCst|\}}||fS)z6Split and normalize a node name from a hello response.)rLlower)r=rGrHrJrJrK clean_nodes  rNkey suggestionsOptional[list[str]]rcCs.d|d}|r|dd|d7}t|)z1Raise ConfigurationError with the given key name.Unknown option: .z Did you mean one of (, z:) or maybe a camelCase version of one? Refer to docstring.)joinr)rOrPmsgrJrJrKraise_config_errors rW) unspecifiedstandard pythonLegacy javaLegacy csharpLegacyoptionvaluer boolcCs4t|tr|dvrtd|d|dkSt||S)z8Validates that value is True, False, 'true', or 'false'.)truefalse The value of z must be 'true' or 'false'r`) isinstancer> ValueErrorr&r]r^rJrJrKvalidate_boolean_or_strings  rfrEcCs\t|tr|St|tr"zt|WSty!td|ddwtd|dt|)zDValidates that 'value' is an integer (or basestring representation).rbz must be an integerNWrong type for z , value must be an integer, not rcrEr>rd TypeErrortypererJrJrKvalidate_integers    rkcCs&t||}|dkrtd|d|S)zFValidate that 'value' is a positive integer, which does not include 0.rrbz must be a positive integerrkrdr]r^valrJrJrKvalidate_positive_integer rocCs&t||}|dkrtd|d|S)z1Validate that 'value' is a positive integer or 0.rrbz must be a non negative integerrlrmrJrJrKvalidate_non_negative_integerrprq Optional[str]cCs&|dur|St||}t||S)z1Validates that 'value' is file-like and readable.N)validate_stringopenclosererJrJrKvalidate_readables   rvcC|dur|St||S)z4Validate that 'value' is a positive integer or None.NrorerJrJrK!validate_positive_integer_or_none rycCrw)z9Validate that 'value' is a positive integer or 0 or None.N)rqrerJrJrK%validate_non_negative_integer_or_nonerzr{cCs&t|tr|Std|dt|)z/Validates that 'value' is an instance of `str`.rgz(, value must be an instance of str, not )rcr>rirjrerJrJrKrss rscCrw)z@Validates that 'value' is an instance of `basestring` or `None`.N)rsrerJrJrKvalidate_string_or_nonerzr|Union[int, str]cCsRt|tr|St|trzt|WSty|YSwtd|dt|)/Validates that 'value' is an integer or string.rgz,, value must be an integer or a string, not rhrerJrJrKvalidate_int_or_basestrings    rcCs^t|tr|St|tr#zt|}Wn ty|YSwt||Std|dt|)r~rgz9, value must be an non negative integer or a string, not )rcrEr>rdrqrirjrmrJrJrK'validate_non_negative_int_or_basestrings     rfloatcCsn|d}zt|}Wntyt|dty"t|dwd|kr-dks5nt|d|S)zXValidates that 'value' is a float, or can be converted to one, and is positive. z must be an integer or floatNrgeAz1 must be greater than 0 and less than one billion)rrdri)r]r^errmsgrJrJrKvalidate_positive_float%s      rcC|dks|dkr dSt||S)zgValidates that 'value' is 0 or a positive float, or can be converted to 0 or a positive float. r0rrerJrJrKvalidate_positive_float_or_zero8s rOptional[float]cCs|dur|St||dSzcValidates a timeout specified in milliseconds returning a value in floating point seconds. N@@rrerJrJrKvalidate_timeout_or_noneArcCs8|dur t|d|dks|dkrdSt||dS)zValidates a timeout specified in milliseconds returning a value in floating point seconds for the case where None is an error and 0 is valid. Setting the timeout to nothing in the URI string is a config error. Nz cannot be Nonerrr)rrrerJrJrKvalidate_timeout_or_zeroJs rcCs*|dus |dks |dkrdSt||dS)zValidates a timeout specified in milliseconds returning a value in floating point seconds. value=0 and value="0" are treated the same as value=None which means unlimited timeout. NrrrrrerJrJrK validate_timeout_or_none_or_zeroWsrcCs|durdSt||dSr)rrerJrJrKvalidate_timeoutmsarrcCr)zBValidates maxStalenessSeconds according to the Max Staleness Spec.rBz-1rxrerJrJrKvalidate_max_stalenessjs rdummyr"cCst|ts t|d|S)zValidate a read preference.z is not a read preference)rcr"rirr^rJrJrKvalidate_read_preferencers rcCs|tvr t|d|S)zValidate read preference mode for a MongoClient. .. versionchanged:: 3.5 Returns the original ``value`` instead of the validated read preference mode. z is not a valid read preference)r!rdrrJrJrKvalidate_read_preference_modeysrcCs.ddlm}||vrt|dt||S)z&Validate the authMechanism URI option.r) MECHANISMSz must be in )pymongo.auth_sharedrrdtuple)r]r^rrJrJrKvalidate_auth_mechanisms rcCs2zt|WStyt|dttdw)zz< is not a supported auth mechanism property. Must be one of r<) _validate_canonicalize_host_name)rcr>dictrdrjitemsr_rMrpymongo.auth_oidc_sharedrrsrr partition_MECHANISM_PROPSrrr) r]r^propsrOropt_rnrrJrJrK"validate_auth_mechanism_propertiessR             risdigitrErirjrerJrJrKvalidate_datetime_conversions   rcCs |dvrt|d|d|S)z)Validate the serverMonitoringMode option.>r;pollstream=z7 is invalid. Must be one of "auto", "stream", or "poll")rdrerJrJrKvalidate_server_monitoring_modes rtlssslzdict[str, list[str]]URI_OPTIONS_ALIAS_MAPappname authmechanismauthmechanismproperties authsource compressorsconnecttimeoutmsdirectconnectionheartbeatfrequencymsjournallocalthresholdms maxidletimems maxconnecting maxpoolsizemaxstalenesssecondsreadconcernlevelreadpreferencereadpreferencetags replicaset retryreads retrywrites loadbalancedserverselectiontimeoutmssockettimeoutmstlsallowinvalidcertificatestlsallowinvalidhostnames tlscafiletlscertificatekeyfiletlscertificatekeyfilepasswordtlsdisableocspendpointcheck tlsinsecurew wtimeoutmszlibcompressionlevel)srvservicename srvmaxhosts timeoutmsservermonitoringmode$dict[str, Callable[[Any, Any], Any]]URI_OPTIONS_VALIDATOR_MAP) connectdriver server_apifsync minpoolsize tlscrlfiletz_awareunicode_decode_error_handleruuidrepresentationwaitqueuemultiplewaitqueuetimeoutmsdatetime_conversionNONSPEC_OPTIONS_VALIDATOR_MAP) document_class type_registryread_preferenceevent_listenersrusernamepasswordserver_selectorauto_encryption_optsauthoidcallowedhosts KW_VALIDATORSzdict[str, str]INTERNAL_URI_OPTION_NAME_MAPzdict[str, tuple[str, str]]URI_OPTIONS_DEPRECATION_MAP VALIDATORS)rrrr rrr/z list[str]TIMEOUT_OPTIONStuple[str, Any]cCs2t||\}}|tvrtd|dt||fS)z,Validate optional authentication parameters.rRz . Must be in )validate _AUTH_OPTIONSr)r]r^rMrJrJrKvalidate_auth_option7srC validators normed_keyCallable[[Any, Any], Any]cCs@|p|}z||WStyt||dd}t||YdSw)Ng?)cutoff)rrrW)rOrDrErPrJrJrK_get_validator?s  rHcCs$t|t|d}|||}||fS)zGeneric validation function.rE)rHr>rM)r]r^ validatorrJrJrKrAJs rAoptionswarnMutableMapping[str, Any]c sttrt}ddd}dfdd }n i}ddd}dd d}D]U\}}||}zt|t|d }|||} Wn8tttfysz)|d kr\tfd d t Dr\dt vr\|rht j t ddnWYdq%dww| |||<q%|S)aaValidate each entry in options and raise a warning if it is not valid. Returns a copy of options with invalid entries removed. :param opts: A dict containing MongoDB URI options. :param warn: If ``True`` then warnings will be logged and invalid options will be ignored. Otherwise, invalid options will cause errors. xr>r?cS|SNrJrNrJrJrKget_normed_key`z-get_validated_options..get_normed_keycs |SrP) cased_keyrQ)rKrJrKget_setter_keyc z-get_validated_options..get_setter_keycSs|SrP)rMrQrJrJrKrRiscSrOrPrJrQrJrJrKrUlrSrIrc3s|] }|tvVqdSrPr>).0p)excrJrK wsz(get_validated_options..z*is not a supported auth mechanism propertyr0) stacklevelN)rNr>r?r>) rc_CaseInsensitiveDictionaryrrHr$rdrirany_MECH_PROP_MUST_RAISEr>warningsrL) rKrLvalidated_optionsrRrUrr^rErJ validatedrJ)rZrKrKget_validated_optionsQs4       rcencrypted_fieldscC|dd|dS)N escCollectionenxcol_.z.escgetrdrrJrJrK_esc_coll_namerkcCre)NecocCollectionrgz.ecocrhrjrJrJrK_ecoc_coll_namerlrn)rwtimeoutrr(jrc@sfeZdZdZdd d ZedddZedddZd ddZed!ddZ d"ddZ ed#ddZ dS)$ BaseObjectzA base class that provides attributes and methods common to multiple pymongo classes. SHOULD NOT BE USED BY DEVELOPERS EXTERNAL TO MONGODB. codec_optionsCodecOptions[Any]r4r" write_concernr% read_concernr r?rcCs~t|ts td||_t|tst|d||_t|ts)tdt|||_t|t s:tdt|||_ dS)NzDcodec_options must be an instance of bson.codec_options.CodecOptionszR is not valid for read_preference. See pymongo.read_preferences for valid options.zMwrite_concern must be an instance of pymongo.write_concern.WriteConcern, not zJread_concern must be an instance of pymongo.read_concern.ReadConcern, not ) rcrri_codec_optionsr"_read_preferencer%rj_write_concernr _read_concern)selfrrr4rtrurJrJrK__init__s$       zBaseObject.__init__cC|jS)zdRead only access to the :class:`~bson.codec_options.CodecOptions` of this instance. )rvrzrJrJrKrrszBaseObject.codec_optionscCr|)zRead only access to the :class:`~pymongo.write_concern.WriteConcern` of this instance. .. versionchanged:: 3.0 The :attr:`write_concern` attribute is now read only. )rxr}rJrJrKrtszBaseObject.write_concernsession Optional[_AgnosticClientSession]cCs|r|jrtS|jS)zBRead only access to the write concern of this instance or session.)in_transactionr$rtrzr~rJrJrK_write_concern_fors zBaseObject._write_concern_forcCr|)zRead only access to the read preference of this instance. .. versionchanged:: 3.0 The :attr:`read_preference` attribute is now read only. )rwr}rJrJrKr4zBaseObject.read_preferencecCs|r |p|jS|jS)zDRead only access to the read preference of this instance or session.)_txn_read_preferencerwrrJrJrK_read_preference_forszBaseObject._read_preference_forcCr|)zRead only access to the :class:`~pymongo.read_concern.ReadConcern` of this instance. .. versionadded:: 3.2 )ryr}rJrJrKrurzBaseObject.read_concernN) rrrsr4r"rtr%rur r?r)r?rs)r?r%)r~rr?r%)r?r")r~rr?r")r?r ) __name__ __module__ __qualname____doc__r{propertyrrrtrr4rrurJrJrJrKrqs      rqc@seZdZd4ddZd5d d Zd6d dZd7ddZd8ddZd9ddZd:ddZ d;ddZ dd"d#Z d?d$d%Z d@d'd(ZdAd)d*Zed=dBd+d,ZedCd-d,Zd=dDd.d,ZdEd0d1Zd:d2d3ZdS)Fr]argsr kwargscOs$i|_i|_|t|i|dSrP)%_CaseInsensitiveDictionary__casedkeys _CaseInsensitiveDictionary__datarr)rzrrrJrJrKr{sz#_CaseInsensitiveDictionary.__init__rOr>r?r_cCs||jvSrP)rMrrzrOrJrJrK __contains__z'_CaseInsensitiveDictionary.__contains__rEcCs t|jSrP)rrr}rJrJrK__len__rVz"_CaseInsensitiveDictionary.__len__ Iterator[str]cCsdd|jDS)Ncss|]}|VqdSrPrJ)rXrOrJrJrKr[sz6_CaseInsensitiveDictionary.__iter__..)rr}rJrJrK__iter__z#_CaseInsensitiveDictionary.__iter__cstfddDS)Ncsi|] }j|j|qSrJ)rr)rXkr}rJrK sz7_CaseInsensitiveDictionary.__repr__..rWr}rJr}rK__repr__sz#_CaseInsensitiveDictionary.__repr__r^rcCs |}||j|<||j|<dSrPrMrr)rzrOr^lc_keyrJrJrK __setitem__s z&_CaseInsensitiveDictionary.__setitem__cC|j|SrP)rrMrrJrJrK __getitem__rz&_CaseInsensitiveDictionary.__getitem__cCs|}|j|=|j|=dSrPr)rzrOrrJrJrK __delitem__s z&_CaseInsensitiveDictionary.__delitem__othercCsHt|tjstSt|t|krdS|D] }||||kr!dSqdS)NFT)rcrr NotImplementedrrzrrOrJrJrK__eq__s z!_CaseInsensitiveDictionary.__eq__NdefaultrcCs|j||SrP)rrirMrzrOrrJrJrKrisz_CaseInsensitiveDictionary.getcOs0|}|j|d|jj|g|Ri|SrP)rMrpopr)rzrOrrrrJrJrKrsz_CaseInsensitiveDictionary.popr@cCs"|j\}}|j|}||fSrP)rpopitemrr)rzrrTr^rJrJrKrs z"_CaseInsensitiveDictionary.popitemcCs|j|jdSrP)rclearrr}rJrJrKrs z _CaseInsensitiveDictionary.clearcCdSrPrJrrJrJrK setdefault#z%_CaseInsensitiveDictionary.setdefaultcCrrPrJrrJrJrKr'rcCs2|}||vr |j|S||j|<||j|<|SrP)rMrr)rzrOrrrJrJrKr+s    rcCsDt|tr|D] }|||||<qdS|D]}||||<qdSrP)rcr]rTrrJrJrKr4s z!_CaseInsensitiveDictionary.updatecCrrP)rrMrrJrJrKrT<rz$_CaseInsensitiveDictionary.cased_key)rr rr )rOr>r?r_)r?rE)r?rr?r>)rOr>r^r r?r)rOr>r?r )rOr>r?r)rr r?r_rP)rOr>rrr?r )rOr>rr rr r?r )r?r@)r?r)rOr>rrr?r)rOr>rr r?r )rOr>rrr?r)rrr?r)rrrr{rrrrrrrrrirrrrrrrTrJrJrJrKr]s*               r]cCs(z ddlm}WdStyYdSw)zIs the C extension installed?r _cmessageTF)pymongor ImportErrorrrJrJrKhas_c@s   rcsbeZdZdZdfdd Zeddd dZedddZed ddZd!ddZ d"ddZ Z S)#Versionz4A class that can be used to compare version strings.rrEr?cs||d}t|t|S)N)_paddedsuper__new__r)clsrpadded_version __class__rJrKrMs zVersion.__new__rrr lengthpadding list[int]cCs8t|}t||krt|t|D]}||q|SrP)rrranger)rrrras_listrrJrJrKrQs   zVersion._paddedversion_stringr>cCsd}d}|dr|dd}d}n|dr |dd}d}n |dr-|dd}d}d |vr<|d|d }d}d |vrL|d|d }d}nd|vr]|d|d}d}d }d d |dD}||d}|rw|dd7<||t|S)NrF+rBr,z-pre--z.devz-rcTcSsg|]}t|qSrJ)rE)rXpartrJrJrK tsz'Version.from_string..rS)endswithfindrrrr)rrmodbump_patch_levelrrJrJrK from_stringYs6        zVersion.from_string version_arraycCs0t|}|ddkrd|d<||d}t|S)NrBrr)rrr)rrrrJrJrKfrom_version_arrays   zVersion.from_version_array other_versionr_cGs |t|kSrP)r)rzrrJrJrKat_leasts zVersion.at_leastcCsdtt|S)NrS)rUmapr>r}rJrJrK__str__rzVersion.__str__)rrEr?r)r)rr rrErrEr?r)rr>r?r)rr r?r)rr r?r_r) rrrrr classmethodrrrrr __classcell__rJrJrrKrJs '  r. package_nametuple[str, str, bool]cst}t|}td}|dusJfdd|Dd}d|vr)|dd}||ddd}|t|k}|||fS) z.r;z>=r0)rrrrrr)rpackage_version_strpackage_version requirements requirementrequired_versionis_validrJrrKcheck_for_min_versions   r)r=r>r?r@rP)rOr>rPrQr?r)r]r>r^r r?r_)r]r>r^r r?rE)r]r>r^r r?rr)r]r>r^r r?r1)r]r>r^r r?r>)r]r>r^r r?r})r]r r^r r?r})r]r>r^r r?r)r]r>r^r r?r)r]r r^r r?r)rr r^r r?r")rr r^r r?rE)rr>r^r r?r)r]r>r^r r?r)r]r>r^r r?r)r]r r^r r?r)r]r>r^r r?r)r]r r^r r?r)r]r r^r r?r)r]r>r^r r?r)r]r r^r r?r)r]r r^r r?r)r]r r^r r?r)rrr?r)rr r?r)rr r^r>r?r>)rr r^r r?r)r]r r^r r?r)r]r r^r r?r)r]r>r^r>r?r>)r]r>r^r r?r@)rOr>rDr#rErrr?rF)T)rKrrLr_r?rM)rdrrr>r?r )r?r_)rr>r?r)r __future__rrr` collectionsrrdifflibrimportlib.metadatarrtypingrr r r r r rrrrrr urllib.parserbsonr bson.binaryrbson.codec_optionsrrr bson.raw_bsonrpymongo.compression_supportrrpymongo.driver_inforpymongo.errorsrpymongo.monitoringrpymongo.read_concernr pymongo.read_preferencesr!r"pymongo.server_apir#pymongo.write_concernr$r%r&pymongo.typingsr'r(__annotations__ MAX_BSON_SIZEMAX_MESSAGE_SIZEMIN_WIRE_VERSIONMAX_WIRE_VERSIONMAX_WRITE_BATCH_SIZEMIN_SUPPORTED_SERVER_VERSIONMIN_SUPPORTED_WIRE_VERSIONMAX_SUPPORTED_WIRE_VERSIONHEARTBEAT_FREQUENCYKILL_CURSOR_FREQUENCYEVENTS_QUEUE_FREQUENCYSERVER_SELECTION_TIMEOUTMIN_HEARTBEAT_INTERVALMIN_SRV_RESCAN_INTERVALCONNECT_TIMEOUT MAX_POOL_SIZE MIN_POOL_SIZEMAX_CONNECTINGr2r3r4LOCAL_THRESHOLD_MS RETRY_WRITES RETRY_READSr7r9_MAX_END_SESSIONSSRV_SERVICE_NAMESERVER_MONITORING_MODEr_rLrNrW UNSPECIFIEDSTANDARD PYTHON_LEGACY JAVA_LEGACY CSHARP_LEGACYrrfrkrorqrvryr{rsr|rrrrrrrrrrrrrr frozensetrrrrrrrrrrrrrrrrrrrrrrr$r1r;r<r=rroptnamealiasesaliascopyr>r?rBrCrHrArcrkrnWRITE_CONCERN_OPTIONSrqr>r]rrrErrrJrJrJrKs  8                                7              !"#,         3  XX F