_iY dZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZmZmZmZdd lmZmZdd lmZerdd lm Z d Z!e"e!Z#d Z$e"e$Z%dZ&e'gdZ(dGdZ)dHdZ*dIdZ+e&fdJdZ,hdZ-dKd$Z.dLd&Z/dLd'Z0dLd(Z1dMdNd-Z2 dOdPd1Z3e&fdQd4Z4ej5d5ej6d6zd7zZ7e'gd8Z8dRd<Z9dSdAZ:e&d.d)d.dfdTdEZ;dUdFZ: @:zXUsername and password must be escaped according to RFC 3986, use urllib.parse.quote_plusz&The empty string is not valid username)countrQr partitionr )rSuser_passwds rPparse_userinfor^}s h(..--115Fx5P5P1 4   ((--OD!V CABBB   |F33 33rRentity default_port Optional[int]%tuple[str, Optional[Union[str, int]]]c|ddkrtd|d}|dkr |dd|fS|d|||dzdfS)aValidates an IPv6 literal host:port string. Returns a 2-tuple of IPv6 literal followed by port where port is default_port if it wasn't specified in entity. :param entity: A string that represents an IPv6 literal enclosed in braces (e.g. '[::1]' or '[::1]:27017'). :param default_port: The port number to use when one wasn't specified in entity. ]zNan IPv6 address literal must be enclosed in '[' and ']' according to RFC 2732.z]:rXN)find ValueError)r_r`rNs rPparse_ipv6_literal_hostris~{{32 \     DABwwad|\)) !A#;q1uww ''rRrc|}|}|ddkrt||\}}ns|dr||fS|ddkrA|ddkrt d|dd\}}t |tr|sStd|Dr+|D](}| rt d |)t d t|d kst|dkrt d t|}| |fS) aqValidates a host string Returns a 2-tuple of host followed by port where port is default_port if it wasn't specified in the string. :param entity: A host or host:port string where host could be a hostname or IP address. :param default_port: The port number to use when one wasn't specified in entity. r[.sockrWrerXzReserved characters such as ':' must be escaped according RFC 2396. An IPv6 address literal must be enclosed in '[' and ']' according to RFC 2732.c3fK|],}|p|V-dSN)isspaceisdigit).0cs rP zparse_host..s7<tlsallowinvalidhostnamestlsallowinvalidcertificatestlsdisableocspendpointcheckoptsdelim Optional[str]rct}||D]}|d\}}|dkr*||g|\||vrt jd|dd|dkr|}nt|}|||<|S)zHelper method for split_options which creates the options dict. Also handles the creation of a list for the URI tag_sets/ readpreferencetags portion, and the use of a unicode options string. =readpreferencetagszDuplicate URI option 'z'.rf stacklevelauthmechanismproperties)rrury setdefaultappendwarningswarnr )rroptionsurioptkeyvaluevals rP_parse_optionsrs )**G**U##  \\#&& U 99;;. . .   sB ' ' . .u 5 5 5 5g~~ >s>>>1MMMMyy{{777"5))GCLL NrRrc|d}|JtD]B}||vr.truth_value$s4'''f}$#t$$  JrRz=Can not specify conflicting values for URI options %s and %s.)rrrGr)get_IMPLICIT_TLSINSECURE_OPTSr cased_key)rropterr_msgtlsallowinvalidcertsrrs rP_handle_security_optionsrs++m,,K-  Cg~~U w00??ARARSVAWAWXX#;;'DEE' (G 3 3QG0'2C2CDa2b2bcd  4 ' '59G1 2\**J` 3 3C{{34''` C6!1222( EW,,     ;w{{5)) * *kk'++e:L:L.M.M M MUGW(9(9%(@(@'BSBSTYBZBZ'[[\\ \ NrRct|D]}|tvrt|\}}|dkr|}||vr_d}tj|||||fzt d||d}tj||||fzt d|dkr6d}tj||||fzt d|S)a;Issue appropriate warnings when deprecated options are present in the options dictionary. Removes deprecated option key, value pairs if the options dictionary is found to also have the renamed option. :param options: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. renamedz0Deprecated option '%s' ignored in favor of '%s'.rfrz,Option '%s' is deprecated, use '%s' instead.removedzOption '%s' is deprecated. %s.)listrrrrDeprecationWarningpop)roptnamemodemessage newoptnamewarn_msgs rP_handle_option_deprecationsr2sK== 1 1 17@MD'y  $ ((QHM G$5$5g$>$>@Q@QR\@]@]#^^*#$ KK(((I  1 1' : :JGG&  "";  1 1' : :GDD&  NrRc|d}|tD]}|||<t|D]1}tj|d}|||||<2|S)zNormalizes option names in the options dictionary by converting them to their internally-used names. :param options: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. rN)rrrrr)rrrrintnames rP_normalize_optionsrYs~++m,,K- ' 'C&GCLL==44.27DAA  &{{733GG  NrRFMapping[str, Any]rMutableMapping[str, Any]c"t||S)aValidates and normalizes options passed in a MongoDB URI. Returns a new dictionary of validated and normalized options. If warn is False then errors will be thrown for invalid options, otherwise they will be ignored and a warning will be issued. :param opts: A dict of MongoDB URI options. :param warn: If ``True`` then warnings will be logged and invalid options will be ignored. Otherwise invalid options will cause errors. )r)rrs rPvalidate_optionsros !t , ,,rRTvalidate normalizec|d}|d} |dkr|dkrtd|dkrt|d}nH|dkrt|d}n1|ddkrt|d}ntn#t$rtddwxYwt |}t |}|rt |}|rKttt||}| d d krtd |S) aTakes the options portion of a MongoDB URI, validates each option and returns the options in a dictionary. :param opt: A string representing MongoDB URI options. :param validate: If ``True`` (the default), validate and normalize all options. :param warn: If ``False`` (the default), suppress all warnings raised during validation of options. :param normalize: If ``True`` (the default), renames all options to their internally-used names. &;rz-Can not mix '&' and ';' for option separatorsrreNz'MongoDB URI options are key=value pairs authsourcez1the authSource database cannot be an empty string) rgrrrhrrrr rrr)rrrrand_idxsemi_idxrs rP split_optionsr~sYiinnGyy~~H N a<""Y u::>>$%[\\ \ ;;) * * d$%bcc c ;;| $ $ Y$%WXX X YY  Y YrRkms_tls_optionsOptional[Mapping[str, Any]]is_syncdict[str, SSLContext]cR|siSt|tstdi}|D]\}}t|tstd|d|ddt |}t |}t|}tt t|}t||\}}|td|rtdd D]}||vrtd ||||<|S) z!Parse KMS TLS connection options.zkms_tls_options must be a dictzkms_tls_options["z"] must be a dictr8TNz!TLS is required for KMS providerszInsecure TLS options prohibited)r@r9r:r>z!Insecure TLS options prohibited: ) rvdict TypeErroritemsrrrrr rrr) rrcontextsproviderrr ssl_contextallow_invalid_hostnamesns rP_parse_kms_tls_optionsrsh  ot , ,:8999H,2244--''4(( MKKKKLL L5$''')'22'--!$''.0@0F0FGG/A$/P/P, ,  $%HII I " H$%FGG G  - -A Dyy()PQ)P)PQQQ!,HX   - OrRuri srv_max_hostsdict[str, Any]c|trd}|td}nz|tr@t s t jpd}td|zd}|td}n tdtdtd|stdd} d} d} d} t} | d \}}}d |vr| d \}}} n|}| rYt| } d | vr| d d \} } t| rtd | znd} |r%| t#||||d|vr,|d\}}}t'|\} } n|}d |vrtd|zt|}d}|p| d}|r| drtdtdt+|d}t-|d krttd|d\}}|ttdnJ|s$| dtd|s|rtdt+||}t/|| || | | | | |dS)NFpythonzThe "dnspython" module must be installed to use mongodb+srv:// URIs. To fix this error install pymongo again: %s -m pip install pymongo>=4.3Tz)Invalid URI scheme: URI must begin with 'z' or ''z(Must provide at least one hostname or IP?/.rXzBad database name "%s"rVz;Any '/' in a unix domain socket must be percent-encoded: %sr5rz*Cannot specify directConnection=true with z URIs)r`z. URIs must include one, and only one, hostnamerz$ URIs must not include a port numberr6zDThe srvServiceName option is only allowed with 'mongodb+srv://' URIszAThe srvMaxHosts option is only allowed with 'mongodb+srv://' URIs)nodelistusernamepassworddatabase collectionrfqdn) startswithSCHEME SCHEME_LEN SRV_SCHEMEr sys executablerSRV_SCHEME_LENrrrZr ru _BAD_DB_CHARSsearchupdater rpartitionr^rrrMr)rr`rrrris_srv scheme_free python_pathr[r]dbaserrhost_plus_db_partr\r host_partrSrrrr{s rP _validate_urirs ~~fb*++&  # # b   .4HK$15@A  .//* `V``S]```aaa ECDDD D F EJ(**G!,!6!6s!;!;q$ /99#>> 1ee%  U## %<< % C 3 3 E:    & & ?5=>> > ? G}T8T9EEFFF i&11#66!U%h// ff e||VYbbccc   E D!?W[[%?%?M > ;;) * * e$%cR\%c%c%cdd dE555 u::?? ZZZ[[ [1X d   PPPQQ Q   > $455A R   > > O   E ===5'"""   rRci}tD]8}||vr ||||<||9|D] \}}|||< |Srn) URI_OPTIONSryrr)rcase_sensitiveoptionkvs rP_make_options_case_sensitiver^sxN   <<>>W $ $%,V_N6 " KK    1q rR)rErFrGrH)rSrFrGrT)r_rFr`rarGrb)r_rFr`rarGr)rrFrrrGr)rrrGr)F)rrrrHrGr)TFT) rrFrrHrrHrrHrGr)rrFr`rarGr)rr rrrGr)rrrrHrGr)rrFr`rarrHrrHrrHrrarGr)rrrGr)=__doc__ __future__rrerrtypingrrrrrr r r urllib.parser !pymongo.asynchronous.srv_resolverr pymongo.client_optionsrpymongo.commonrrrrpymongo.errorsrrpymongo.typingsrpymongo.pyopenssl_contextrrrMrrr DEFAULT_PORT frozensetrrQr^rir|rrrrrrrrcompileescaper_ALLOWED_TXT_OPTSrrrrrRrPrs~ #"""""                     &%%%%%======555555 :9999999$$$$$$5444444  S[[  Z i///11 h     44440((((.;G00000h,2222j$$$$N, - - - - - MQ*****Z;G4 37!3!33c9:: I\\\ Y Y Y Y!!!!L#/#' ]]]]]@rR