o 'hHP@sdZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZmZmZmZdd lmZmZdd lmZer\dd lm Z d Z!e"e!Z#d Z$e"e$Z%dZ&dSddZ'dTddZ(dUddZ)e&fdVd d!Z*hd"Z+dWd'd(Z,dXd*d+Z-dXd,d-Z.dXd.d/Z/dYdZd4d5Z0 6d[d\d9d:Z1e&fd]d=d>Z2e3d?e4d@dAZ5e6gdBZ7d^dFdGZ8d_dLdMZ9e&d6d0d6dfd`dQdRZ:dS)azTools to parse and validate a MongoDB URI. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. ) annotationsN) TYPE_CHECKINGAnyMappingMutableMappingOptionalSizedUnioncast) unquote_plus)_have_dnspython)_parse_ssl_options)INTERNAL_URI_OPTION_NAME_MAPURI_OPTIONS_DEPRECATION_MAP_CaseInsensitiveDictionaryget_validated_options)ConfigurationError InvalidURI)_Address) SSLContextz mongodb://zmongodb+srv://iisstrreturnboolcCsDtt|D]}||dkr|||d}t||krdSqdS)zCheck for unescaped percent signs. :param s: A string. `s` can have things like '%25', '%2525', and '%E2%85%A8' but cannot have unquoted percent like '%foo'. %TF)rangelenr )risubr U/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/uri_parser_shared.py_unquoted_percent:s  r"userinfotuple[str, str]cCsRd|vs|ddkst|rtd|d\}}}|s!tdt|t|fS)aZValidates the format of user information in a MongoDB URI. Reserved characters that are gen-delimiters (":", "/", "?", "#", "[", "]", "@") as per RFC 3986 must be escaped. Returns a 2-tuple containing the unescaped username followed by the unescaped password. :param userinfo: A string of the form : @:zXUsername and password must be escaped according to RFC 3986, use urllib.parse.quote_plusz&The empty string is not valid username)countr"r partitionr )r#user_passwdr r r!parse_userinfoJs r-entity default_port Optional[int]%tuple[str, Optional[Union[str, int]]]cCsT|ddkr td|d}|dkr|dd|fS|d|||ddfS)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]:r'N)find ValueError)r.r/rr r r!parse_ipv6_literal_hostbs  r7rcCs|}|}|ddkrt||\}}n#|dr||fS|ddkr5|ddkr-td|dd\}}t|tro|s[t dd |DrW|D] }| rVtd |qItd t |d ksgt |dkrktd 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[.sockr&r3r'zReserved characters such as ':' must be escaped according RFC 2396. An IPv6 address literal must be enclosed in '[' and ']' according to RFC 2732.css |] }|p |VqdS)N)isspaceisdigit).0cr r r! szparse_host..z$Port contains whitespace character: zPort contains non-digit characters. Hint: username and password must be escaped according to RFC 3986, use urllib.parse.quote_plusiz+Port must be an integer between 0 and 65535) r7endswithr5r(r6split isinstancerr;allr:intlower)r.r/hostportr=r r r! parse_hostys4     rG>tlsallowinvalidhostnamestlsallowinvalidcertificatestlsdisableocspendpointcheckoptsdelim Optional[str]rcCst}||D]9}|d\}}|dkr!||g|q||vr0tjd|ddd|dkr9|}nt|}|||<q|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'.r4 stacklevelauthmechanismproperties)rr@rD setdefaultappendwarningswarnr )rKrLoptionsurioptkeyvaluevalr r r!_parse_optionss   r\rWcCs|d}|dur"tD]}||vr!d}t||d||fq |d}|durDd|vr.truth_valuez=Can not specify conflicting values for URI options %s and %s.)r[rrr)get_IMPLICIT_TLSINSECURE_OPTSr cased_key)rWr]opterr_msgtlsallowinvalidcertsr^rcr r r!_handle_security_optionssB     rjcCst|D]W}|tvr[t|\}}|dkrF|}||vr4d}tj|||||ftdd||qd}tj||||ftddq|dkr[d}tj||||ftddq|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'.r4rPz,Option '%s' is deprecated, use '%s' instead.removedzOption '%s' is deprecated. %s.)listrrUrVrfDeprecationWarningpop)rWoptnamemodemessage newoptnamewarn_msgr r r!_handle_option_deprecationss:   rucCsX|d}|durtD]}|||<q t|D]}t|d}|dur)||||<q|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. r]N)rdrermrro)rWr]rgrpintnamer r r!_normalize_options&s    rwFMapping[str, Any]rVMutableMapping[str, Any]cCs 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)rKrVr r r!validate_options<s rzTvalidate normalizecCs|d}|d}z1|dkr|dkrtd|dkr!t|d}n|dkr+t|d}n|ddkr8t|d}ntWn tyGtddwt|}t|}|rVt|}|rkttt ||}| d d krktd |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 separatorsrNr3Nz'MongoDB URI options are key=value pairs authsourcez1the authSource database cannot be an empty string) r5rr\r6rjrurwr rrzrd)rKr{rVr|and_idxsemi_idxrWr r r! split_optionsKs2       rhostslist[_Address]cCsFg}|dD]}|std|}|drd}|t||q|S)aTakes a string of the form host1[:port],host2[:port]... and splits it into (host, port) tuples. If [:port] isn't present the default_port is used. Returns a set of 2-tuples containing the host name (or IP) followed by port number. :param hosts: A string of the form host1[:port],host2[:port],... :param default_port: The port number to use when one wasn't specified for a host. ,z(Empty host (or extra comma in host list)r9N)r@rr?rTrG)rr/nodesr.rFr r r! split_hostsxs  rr8z/ "$r2)r authSource replicaset replicaSet loadbalanced loadBalancedrrNonecCsht|dkr|drtd|dr0t|dkrtd|dr'td|dr2tddSdS) Nr'directconnectionz8Cannot specify multiple hosts with directConnection=truerz4Cannot specify multiple hosts with loadBalanced=truez;Cannot specify directConnection=true with loadBalanced=truerz0Cannot specify replicaSet with loadBalanced=true)rrdr)rrWr r r!_check_optionss    rkms_tls_optionsOptional[Mapping[str, Any]]is_syncdict[str, SSLContext]c Cs|siSt|ts tdi}|D]S\}}t|ts$td|d|ddt|}t|}t|}ttt |}t ||\}}|durLt d|rRt dd D]}||vrat d ||||<qTq|S) z!Parse KMS TLS connection options.zkms_tls_options must be a dictzkms_tls_options["z"] must be a dictr`TNz!TLS is required for KMS providerszInsecure TLS options prohibited) tlsInsecuretlsAllowInvalidCertificatestlsAllowInvalidHostnames$tlsDisableCertificateRevocationCheckz!Insecure TLS options prohibited: ) rAdict TypeErroritemsrSrrjrwr rzr r) rrcontextsproviderrWrK ssl_contextallow_invalid_hostnamesnr r r!_parse_kms_tls_optionss0     ruri srv_max_hostsdict[str, Any]cCs&|trd}|td}n'|tr*ts!tjpd}td|d}|td}n t dtdtd|s;t dd} d} d} d} t } | d \}}}d |vr[| d \}}} n|}| r{t | } d | vro| d d \} } t| rzt d | nd} |r| t||||d|vr|d\}}}t|\} } n|}d |vrt d|t |}d}|p| d}|r| drtdtdt|dd}t|d krt td|d\}}|durt tdn|s| ddurtd|s|rtdt||d}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?/.r'zBad database name "%s"r%z;Any '/' in a unix domain socket must be percent-encoded: %s srvMaxHostsdirectConnectionz*Cannot specify directConnection=true with z URIs)r/z. URIs must include one, and only one, hostnamerz$ URIs must not include a port numbersrvServiceNamezDThe srvServiceName option is only allowed with 'mongodb+srv://' URIszAThe srvMaxHosts option is only allowed with 'mongodb+srv://' URIs)nodelistusernamepassworddatabase collectionrWfqdn) startswithSCHEME SCHEME_LEN SRV_SCHEMEr sys executablerSRV_SCHEME_LENrrr)r r@ _BAD_DB_CHARSsearchupdater rpartitionr-rdrrr)rr/r{rVr|ris_srv scheme_free python_pathr*r,dbaserrWhost_plus_db_partr+rK host_partr#rrrrFr r r! _validate_uris            r)rrrr)r#rrr$)r.rr/r0rr1)r.rr/r0rr)rKrrLrMrr)rWrrr)F)rKrxrVrrry)TFT) rKrr{rrVrr|rrry)rrr/r0rr)rrrWrxrr)rrrrrr)rrr/r0r{rrVrr|rrr0rr);__doc__ __future__rrerrUtypingrrrrrrr r urllib.parser !pymongo.asynchronous.srv_resolverr pymongo.client_optionsr pymongo.commonrrrrpymongo.errorsrrpymongo.typingsrpymongo.pyopenssl_contextrrrrrr DEFAULT_PORTr"r-r7rGrer\rjrurwrzrrcompileescaper frozenset_ALLOWED_TXT_OPTSrrrr r r r!sX (       4   5 '  -  &