hۃ dZddlZddlZddlmZddlmZddlmZm Z ddl m Z m Z m Z mZmZddlmZddlmZdd lmZmZdd lmZdd lmZdd lmZdd lmZddlm Z ddl!m"Z"m#Z#ddl$m%Z%ddl&m'Z'm(Z(ddl)m*Z*m+Z+ ddl,m-Z-ee-fZ.e rddl0m1Z1nddl2m1Z1dZ3de3zZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAd ZBdZCdZDdZEdZFd!ZGd"ZHd"ZId#ZJd$ZKd%ZLd&ZMd'ZNd(ZOejejejejejd)ZUd*ZVd+ZWd,ZXd-ZYd.ZZd/Z[d0Z\d1Z]d2Z^d3Z_d4Z`d5Zad6Zbd7Zcd8Zdd9Zed:Zfd;Zgd<Zhd=Zid>Zjd?Zkd@ZlemgdAZndBZodCZpdDZqdEZrdFZsdGZtdHZudIZvdJZwdKZxdLZydMZzdNZ{dOZ|emgdPZ}dQZ~dRZdSgdTgdUgdVgdWgdXgdYgdZgd[gd\ Zid]ewd^ejd_eod`e^daedbefdceWddeddeeWdfecdgeddhe\diegdje_dkeidleldme_idneWdoeWdpeWdqeedrefdse[dteWdue'dVe(dvdwdWeWdxe[dye[dze_d{d|d}eWd~eaeZedZeWexeyeWeZeWe[eWe~eke]edd Zepeqeheee_e_ezed ZdeddUdVdWdXdYdZd[dd Zddddddddddd Zej eeeD]\ZZeD]Zeevseeee<ejZej egdZemd_gZdZdZddZemgdZGddeZGdde j(Zy#e/$refZ.YtwxYw)z9Functions and classes common to multiple pymongo modules.N)SON)UuidRepresentation) CodecOptions TypeRegistry)PY3abc integer_types iteritems string_type)RawBSONDocument) MECHANISMS)validate_compressorsvalidate_zlib_compression_level) DriverInfo)%validate_auto_encryption_opts_or_noneConfigurationError)_validate_event_listeners) ReadConcern) _MONGOS_MODES _ServerMode) ServerApi)validate_allow_invalid_certsvalidate_cert_reqs)DEFAULT_WRITE_CONCERN WriteConcern) OrderedDict) unquote_plusiiz2.6 g?<g4@dT);)r i@i@i'c|}d}|jd}|dk7r|d|t||dzd}}|jdr|dd}||fS)z5Split a host:port string into (host, int(port)) pair.ii:Nr"[)rfindint startswith)nodehostportidxs L/var/www/html/eduruby.in/venv/lib/python3.12/site-packages/pymongo/common.pypartition_noder4|s_ D D **S/C by$3ZT#')_!5d sAbz :cBt|\}}|j|fS)z6Split and normalize a node name from a hello response.)r4lower)r/r0r1s r3 clean_noder8s#%JD$ ::< r5ctd|)z1Raise ConfigurationError with the given key name.zUnknown option r)keydummys r3raise_config_errorr<s C9 ::r5) unspecifiedstandard pythonLegacy javaLegacy csharpLegacycBt|tr|St|d)z(Validates that 'value' is True or False.z must be True or False) isinstancebool TypeErroroptionvalues r3validate_booleanrIs% &: ;;r5cjt|tr|dvrtd|d|dk(St||S)z8Validates that value is True, False, 'true', or 'false'.)truefalse The value of z must be 'true' or 'false'rK)rCr ValueErrorrIrFs r3validate_boolean_or_stringrOs:%% ) )vWX X FE **r5ct|tr|St|tr t|St d|d#t$rt d|dwxYw)zDValidates that 'value' is an integer (or basestring representation).rMz must be an integerWrong type for z, value must be an integerrCr r r-rNrErFs r3validate_integerrSs\%' E; ' Ru:  VM NN RPQ Q Rs >AcFt||}|dkrtd|d|S)zFValidate that 'value' is a positive integer, which does not include 0.rrMz must be a positive integerrSrNrGrHvals r3validate_positive_integerrXs( 65 )C axFTUU Jr5cFt||}|dkrtd|d|S)z1Validate that 'value' is a positive integer or 0.rrMz must be a non negative integerrUrVs r3validate_non_negative_integerrZs) 65 )C QwPVXYY Jr5cZ||St||}t|dj|S)z1Validates that 'value' is file-like and readable.r)validate_stringopencloserFs r3validate_readabler`s2 }  FE *E Lr5c"||St||S)z4Validate that 'value' is a positive integer or None.rXrFs r3!validate_positive_integer_or_nonercs } $VU 33r5c"||St||S)z9Validate that 'value' is a positive integer or 0 or None.)rZrFs r3%validate_non_negative_integer_or_noneres } ( 77r5cdt|tr|Std|dtj)zbValidates that 'value' is an instance of `basestring` for Python 2 or `str` for Python 3. rQz, value must be an instance of )rCr rE__name__rFs r3r]r]s.%% CI;K_K_` r5c"||St||S)z@Validates that 'value' is an instance of `basestring` or `None`.)r]rFs r3validate_string_or_noneris } 65 ))r5ct|tr|St|tr t|St d|d#t$r|cYSwxYw)/Validates that 'value' is an integer or string.rQz&, value must be an integer or a stringrRrFs r3validate_int_or_basestringrlsQ%' E; ' u:  TZ\ ]] L s > A  A ct|tr|St|tr t|}t ||St d|d#t$r|cYSwxYw)rkrQz3, value must be an non negative integer or a string)rCr r r-rNrZrErVs r3'validate_non_negative_int_or_basestringrnsa%' E; ' e*C-VS99 U[]  L s A AAc|d} t|}d|cxkrdksnt|d|S#t$r t|t$r t|wxYw)zXValidates that 'value' is a float, or can be converted to one, and is positive. z must be an integer or floatrgeAz1 must be greater than 0 and less than one billion)floatrNrE)rGrHerrmsgs r3validate_positive_floatrrsj28 9F e  u?s?U[]^^ L !    s /(Ac0|dk(s|dk(ryt||S)zgValidates that 'value' is 0 or a positive float, or can be converted to 0 or a positive float. r0rrrFs r3validate_positive_float_or_zerorv's! zUc\ "65 11r5c(||St||dz S)zcValidates a timeout specified in milliseconds returning a value in floating point seconds. @@rurFs r3validate_timeout_or_nonery0s  } "65 1F ::r5cV|t|d|dk(s|dk(ryt||dz S)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. z cannot be Nonerrtrx)rrrrFs r3validate_timeout_or_zeror{9s9  } !@AA zUc\ "65 1F ::r5c:| |dk(s|dk(ryt||dz S)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. NrrtrxrurFs r3 validate_timeout_or_none_or_zeror}Fs*  } esl "65 1F ::r5c0|dk(s|dk(ryt||S)zBValidates maxStalenessSeconds according to the Max Staleness Spec.r*z-1rbrFs r3validate_max_stalenessrPs {etm $VU 33r5cBt|tst|d|S)zValidate a read preference.z is not a read preference.)rCrrEr;rHs r3validate_read_preferencerXs e[ )%ABB Lr5c2|tvrt|d|S)zValidate read preference mode for a MongoReplicaSetClient. .. versionchanged:: 3.5 Returns the original ``value`` instead of the validated read preference mode. z is not a valid read preference)rrNrs r3validate_read_preference_moder_s M!GHH Lr5cZ|tvr"|dk7rt|dtt|S)z&Validate the authMechanism URI option.zCRAM-MD5z must be in )r rNtuplerFs r3validate_auth_mechanismrks-  J5J#6vuZ7HIJJ Lr5cj t|S#t$rt|dttwxYw)zS*6s*;\#&' < OOD ! Q O Q$OP P Qs AB  B%) SERVICE_NAMECANONICALIZE_HOST_NAME SERVICE_REALMAWS_SESSION_TOKENcNt||}i}|jdD]`} |jd\}}|tvrt|dt td|dk(rt ||||<St |||<b|S#t$rd|vrd}td|dwxYw) z!Validate authMechanismProperties.rr)rz_AWS_SESSION_TOKEN:, did you forget to percent-escape the token with quote_plus?zQauth mechanism properties must be key:value pairs like SERVICE_NAME:mongodb, not .z< is not a supported auth mechanism property. Must be one of r)r]rrN_MECHANISM_PROPSrrOr)rGrHpropsoptr:rWs r3"validate_auth_mechanism_propertiesrs FE *E E{{3+ yy~HC & &e$457  * *3C=E#J%c*E#J1+4 L/ "c)C'*,  s BB$cbt|tjtfst |d|S)z#Validate the document_class option.zf must be dict, bson.son.SON, bson.raw_bson.RawBSONDocument, or a sublass of collections.MutableMapping) issubclassrMutableMappingr rErFs r3validate_document_classrs6 ec00/B C8> @  Lr5cR|$t|tst|dt|S)z"Validate the type_registry option.z must be an instance of )rCrrErFs r3validate_type_registryrs& E?? Lr5cJ||St|tst|d|S)z Validate the driver keyword arg.z" must be an instance of DriverInfo)rCrrErFs r3validate_driver_or_noners) } eZ (&JKK Lr5cJ||St|tst|d|S)z$Validate the server_api keyword arg.z! must be an instance of ServerApi)rCrrErFs r3validate_server_api_or_noners) } eY 'IJJ Lr5c@||St|st|d|S)z%Validates that 'value' is a callable.z must be a callable)callablerNrFs r3validate_is_callable_or_noners& } E?F<== Lr5ctd||rBt|ts1tt |}|j dr t dyyy)z Validate a replacement document. replacement$z'replacement can not include $ operatorsN)rrCr nextiterr.rN)rfirsts r3validate_ok_for_replacer!sN {3:k?CT+&'   C FG G !D{r5ctd||s tdt|t }t t |}|r|j ds tdyy)zValidate an update document.updatezupdate cannot be emptyrz"update only works with $ operatorsN)rrNrCrrrr.)r is_documentrs r3validate_ok_for_updater+s[Xv. 122 ..K f E5++C0=>>1{r5)strictreplaceignorecP|tvrt|dtt|S)zAValidate the Unicode decode error handler option of CodecOptions.z< is an invalid Unicode decode error handler. Must be one of )_UNICODE_DECODE_ERROR_HANDLERSrNrrs r3%validate_unicode_decode_error_handlerr;s2 225!?@ B  Lr5cZ|(t|tjstd|z|S)zValidate the tzinfo optionz)%s must be an instance of datetime.tzinfo)rCdatetimetzinforErs r3validate_tzinforFs+ E8??!CCeKLL Lr5jwtimeoutssl ssl_cert_reqsssl_match_hostname ssl_crlfile ssl_ca_certs ssl_certfilessl_pem_passphrase) journal wtimeoutmstlstlsallowinvalidcertificatestlsallowinvalidhostnames tlscrlfile tlscafiletlscertificatekeyfiletlscertificatekeyfilepasswordappname authmechanismauthmechanismproperties authsource compressorsconnecttimeoutmsdirectconnectionheartbeatfrequencymsrlocalthresholdms maxidletimems maxpoolsizemaxstalenesssecondsreadconcernlevelreadpreferencereadpreferencetags replicaset retryreads retrywrites loadbalancedserverselectiontimeoutmssockettimeoutms ssl_keyfilerrrct| SNrOxs r3r|s/I1/M+Mr5rrrtlsdisableocspendpointcheckct| Srrrs r3rrs2La2P.Pr5 tlsinsecurew)rzlibcompressionlevel) connectdriver server_apifsync minpoolsizesocketkeepalivertz_awareunicode_decode_error_handleruuidrepresentationwaitqueuemultiplewaitqueuetimeoutms) document_class type_registryread_preferenceevent_listenersrusernamepasswordserver_selectorauto_encryption_optsrssl_check_ocsp_endpoint) rrrrrrrrrr)renamedr)r wTimeoutMS)rtlsAllowInvalidCertificates)rtlsAllowInvalidHostnames)r tlsCRLFile)r tlsCAFile)removedzInstead of using ssl_certfile to specify the certificate file, use tlsCertificateKeyFile to pass a single file containing both the client certificate and the private key)r"zInstead of using ssl_keyfile to specify the private keyfile, use tlsCertificateKeyFile to pass a single file containing both the client certificate and the private key)rtlsCertificateKeyFilePassword)r"zqInstead of using waitQueueMultiple to bound queuing, limit the size of the thread pool in your application server) rrrrrrrrrr)rrrrrrrcTt||\}}|tvrtd|||fS)z,Validate optional authentication parameters.zUnknown authentication option: )validate _AUTH_OPTIONSr)rGrHr7s r3validate_auth_optionr's2FE*LE5 M! 6!STT 5=r5cp|j}tj|t}|||}||fS)zGeneric validation function.)r7 VALIDATORSgetr<)rGrHr7 validators r3r%r%s4 LLNEu&89I fe $E 5=r5cxttrt}d}fd}ni}d}d}tD]<\}}||} tj |t }|||}||||<>|S#t ttf$r,} |rtjt| nYd} ~ |d} ~ wwxYw)aValidate each entry in options and raise a warning if it is not valid. Returns a copy of options with invalid entries removed. :Parameters: - `opts`: A dict containing MongoDB URI options. - `warn` (optional): If ``True`` then warnings will be logged and invalid options will be ignored. Otherwise, invalid options will cause errors. c|Srrs r3rz'get_validated_options..1r5c&j|Sr) cased_key)roptionss r3rz'get_validated_options..s7#4#4Q#7r5c"|jSr)r7rs r3rz'get_validated_options..s 1779r5c|Srr.rs r3rz'get_validated_options..r/r5N) rC_CaseInsensitiveDictionaryr URI_OPTIONS_VALIDATOR_MAPr*r<rNrErwarningswarnstr) r2r8validated_optionsget_normed_keyget_setter_keyrrH normed_keyr+excs ` r3get_validated_optionsr?s'5668$7,$( B U#C(  B155jBTUIc5)E=B nZ8 9 B I'9:  c#h'( s#A99B9 "B44B9)rrrr rrcbeZdZdZdZedZedZdZedZ dZ edZ y ) BaseObjectzA base class that provides attributes and methods common to multiple pymongo classes. SHOULD NOT BE USED BY DEVELOPERS EXTERNAL TO MONGODB. ct|ts td||_t|tst|d||_t|t s td||_t|ts td||_ y)NzDcodec_options must be an instance of bson.codec_options.CodecOptionszR is not valid for read_preference. See pymongo.read_preferences for valid options.zGwrite_concern must be an instance of pymongo.write_concern.WriteConcernzDread_concern must be an instance of pymongo.read_concern.ReadConcern) rCrrE_BaseObject__codec_optionsr_BaseObject__read_preferencer_BaseObject__write_concernr_BaseObject__read_concern)self codec_optionsr write_concern read_concerns r3__init__zBaseObject.__init__;s-6Y  -/;7.0  "1-6\  -, 4Y +r5c|jS)zdRead only access to the :class:`~bson.codec_options.CodecOptions` of this instance. )rCrGs r3rHzBaseObject.codec_optionsWs ###r5c|jS)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. )rErMs r3rIzBaseObject.write_concern^s###r5cB|r|jrtS|jS)zBRead only access to the write concern of this instance or session.)in_transactionrrIrGsessions r3_write_concern_forzBaseObject._write_concern_forhs! w--( (!!!r5c|jS)zRead only access to the read preference of this instance. .. versionchanged:: 3.0 The :attr:`read_preference` attribute is now read only. )rDrMs r3rzBaseObject.read_preferenceos%%%r5cZ|r|jxs |jS|jS)zDRead only access to the read preference of this instance or session.)_txn_read_preferencerDrQs r3_read_preference_forzBaseObject._read_preference_forxs- //1KT5K5K K%%%r5c|jS)zRead only access to the :class:`~pymongo.read_concern.ReadConcern` of this instance. .. versionadded:: 3.2 )rFrMs r3rJzBaseObject.read_concerns"""r5N) rg __module__ __qualname____doc__rKpropertyrHrIrSrrWrJr.r5r3rArA4sf +8$$ $$"&&&##r5rAcpeZdZdZdZdZdZdZdZdZ dZ d Z dd Z d Z d ZdZddZdZdZy )r5cTi|_i|_|jt|i|yr)%_CaseInsensitiveDictionary__casedkeys _CaseInsensitiveDictionary__datardict)rGargskwargss r3rKz#_CaseInsensitiveDictionary.__init__s'  D$)&)*r5c:|j|jvSr)r7r`rGr:s r3 __contains__z'_CaseInsensitiveDictionary.__contains__syy{dkk))r5c,t|jSr)rr`rMs r3__len__z"_CaseInsensitiveDictionary.__len__s4;;r5c(d|jDS)Nc3 K|]}|ywrr.).0r:s r3 z6_CaseInsensitiveDictionary.__iter__..s00s )r_rMs r3__iter__z#_CaseInsensitiveDictionary.__iter__s0t//00r5ctt|Dcic]}|j||j|!c}Scc}wr)r9r_r`)rGks r3__repr__z#_CaseInsensitiveDictionary.__repr__s3FAD$$Q'Q7FGGFs$5c`|j}||j|<||j|<yrr7r_r`)rGr:rHlc_keys r3 __setitem__z&_CaseInsensitiveDictionary.__setitem__s+#& # Fr5c<|j|jSr)r`r7res r3 __getitem__z&_CaseInsensitiveDictionary.__getitem__s{{399;''r5cX|j}|j|=|j|=yrrr)rGr:rss r3 __delitem__z&_CaseInsensitiveDictionary.__delitem__s'   V $ KK r5ct|tjstSt |t |k7ry|D]}||||k7syy)NFT)rCrrNotImplementedrrGotherr:s r3__eq__z!_CaseInsensitiveDictionary.__eq__sP%-! ! t9E " CCyE#J& r5NcV|jj|j|Sr)r`r*r7)rGr:defaults r3r*z_CaseInsensitiveDictionary.gets{{syy{G44r5c|j}|jj|d|jj|g|i|Sr)r7r_popr`)rGr:rbrcrss r3rz_CaseInsensitiveDictionary.popsB VT*t{{v7777r5cz|jj\}}|jj|}||fSr)r_popitemr`r)rGrsr1rHs r3rz"_CaseInsensitiveDictionary.popitems8 ,,446  '%r5cl|jj|jjyr)r_clearr`rMs r3rz _CaseInsensitiveDictionary.clears$   r5c|j}||vr|j|S||j|<||j|<|Sr)r7r`r_)rGr:rrss r3 setdefaultz%_CaseInsensitiveDictionary.setdefaultsF $;;;v& &'*D  V $")DKK Nr5ct|tr|D]}||||j|<y|D] }||||< yr)rCr5r1r{s r3rz!_CaseInsensitiveDictionary.updatesQ e7 8 8-23ZU__S)* 8 '!#JS  'r5c<|j|jSr)r_r7res r3r1z$_CaseInsensitiveDictionary.cased_keys ,,r5r)rgrYrZrKrfrhrmrprtrvrxr}r*rrrrrr1r.r5r3r5r5sS+ * 1H$ ( 58  '-r5r5)T)r[rr7bsonr bson.binaryrbson.codec_optionsrrbson.py3compatrrr r r bson.raw_bsonr pymongo.authr pymongo.compression_supportrrpymongo.driver_inforpymongo.encryption_optionsrpymongo.errorsrpymongo.monitoringrpymongo.read_concernrpymongo.read_preferencesrrpymongo.server_apirpymongo.ssl_supportrrpymongo.write_concernrr collectionsr ORDERED_TYPES ImportError urllib.parserurllib 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_IDLE_TIME_MSMAX_IDLE_TIME_SECWAIT_QUEUE_TIMEOUTLOCAL_THRESHOLD_MS RETRY_WRITES RETRY_READSCOMMAND_NOT_FOUND_CODESUNAUTHORIZED_CODES_MAX_END_SESSIONSr4r8r< UNSPECIFIEDSTANDARD PYTHON_LEGACY JAVA_LEGACY CSHARP_LEGACYrrIrOrSrXrZr`rcrer]rirlrnrrrvryr{r}rrrrrr frozensetrrrrrrrrrrrrrrrrrrURI_OPTIONS_ALIAS_MAPr6NONSPEC_OPTIONS_VALIDATOR_MAP KW_VALIDATORSINTERNAL_URI_OPTION_NAME_MAPURI_OPTIONS_DEPRECATION_MAProptnamealiasesaliascopyr)TIMEOUT_OPTIONSr&r'r%r?WRITE_CONCERN_OPTIONSobjectrArr5r.r5r3rs @*9JJ)#+L-8,?(PE'+&M)#! }$ %      ( ;&11"++&44$00&44 <+ O48* ^ &2; ;;4   *T B(   H ?"++J!Ku, 7$3#4!5 6 / !,-&:%;  ' '','A'/ ' ' ' 8 '2'4')'7'-'4'1'/'3' 7!'")#'$,%'&-''(.)'* 8+',7-'.$/'0 %1'2"#?3'4'5'8 M9':4;'<"='>.?'@$%2 !&.+/0''3A  "  #2 4+%9#< . )?A,,G=%P !>?!"78RGWR 1 1/H/Q %e ,RR ' + + - - 456 F""Z[R#R#jM-!3!3M-yFMs> K11K=<K=