3 O6bqQ@sdZddlZddlZddlZddlmZmZer>ddlmZn ddl mZddl m Z m Z m Z mZddlmZmZddlmZmZdZeeZd ZeeZd Zd d Zd dZefddZdddhZddeDddeDBZddZ ddZ!ddZ"ddZ#d6d d!Z$d7d#d$Z%efd%d&Z&ej'd'ej(d(d)Z)e*d*d+d,d-d.d/gZ+d0d1Z,ed"dd"dfd2d3Z-e.d4krddl/Z/ddlZye/j/e-ej0d5Wn,ek rZ1ze2e1WYddZ1[1XnXej3ddS)8z*Tools to parse and validate a MongoDB URI.N) string_typePY3) unquote_plus)get_validated_optionsINTERNAL_URI_OPTION_NAME_MAPURI_OPTIONS_DEPRECATION_MAP_CaseInsensitiveDictionary)ConfigurationError InvalidURI)_HAVE_DNSPYTHON _SrvResolverz mongodb://zmongodb+srv://iicCs\d|ks|jddkr0tr d}nd}td||jd\}}}|sLtdt|t|fS)aValidates the format of user information in a MongoDB URI. Reserved characters like ':', '/', '+' and '@' must be escaped following RFC 3986. Returns a 2-tuple containing the unescaped username followed by the unescaped password. :Paramaters: - `userinfo`: A string of the form : .. versionchanged:: 2.2 Now uses `urllib.unquote_plus` so `+` characters must be escaped. @:zurllib.parse.quote_pluszurllib.quote_pluszFUsername and password must be escaped according to RFC 3986, use %s().z'The empty string is not valid username.)countrr partitionr)userinfoZquote_fnuser_passwdrQ/var/www/html/sandeepIITI/myenv/lib/python3.6/site-packages/pymongo/uri_parser.pyparse_userinfo*srcCsT|jddkrtd|jd}|dkr8|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. :Parameters: - `entity`: A string that represents an IPv6 literal enclosed in braces (e.g. '[::1]' or '[::1]:27017'). - `default_port`: The port number to use when one wasn't specified in entity. ]rzNan IPv6 address literal must be enclosed in '[' and ']' according to RFC 2732.z]:Nrr)find ValueError)entity default_portirrrparse_ipv6_literal_hostFs  r!cCs|}|}|ddkr$t||\}}nF|jdr6||fS|jdd krj|jddkrZtd|jdd\}}t|tr|j st |dkst |dkrtd|ft |}|j |fS) aValidates 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. :Parameters: - `entity`: A host or host:port string where host could be a hostname or IP address. - `default_port`: The port number to use when one wasn't specified in entity. r[z.sockrrzReserved characters such as ':' must be escaped according RFC 2396. An IPv6 address literal must be enclosed in '[' and ']' according to RFC 2732.iz/Port must be an integer between 0 and 65535: %sr) r!endswithrrrsplit isinstancerisdigitintlower)rrhostportrrr parse_host\s    " r+tlsallowinvalidcertificatesZtlsallowinvalidhostnamestlsdisableocspendpointcheckcCsh|]}|qSrr).0krrr sr0cCsh|] }t|qSr)r)r.r/rrrr0scCst}xz|j|D]l}|jd\}}|jdkrD|j|gj|q||kr\tjd|f|jdkrn|}nt|}|||<qW|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.=ZreadpreferencetagszDuplicate URI option '%s'.Zauthmechanismproperties)rr$r( setdefaultappendwarningswarnr)optsdelimoptionsZurioptkeyvaluevalrrr_parse_optionss   r<cs0jd}|dk rHx4tD],}|krd}t|jdj|fqWfdd}|d}|dk rdkrd}t|djdf|dkrdd<|d }|dk rx,dD]$}j|dkrd }t||fqWd kod kr,d d}|jd |jd kr,d}t|jd jd fS)zRaise appropriate errors when conflicting TLS options are present in the options dictionary. :Parameters: - `options`: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. tlsinsecureNz9URI options %s and %s cannot be specified simultaneously.csj|pjt|S)N)getr)opt)r8rr_getopts z)_handle_security_options.._getoptr,r-T tlscrlfilezDURI option %s=True cannot be specified when CRL checking is enabled.sslZtlscSs"|dkr|dkSt|tr|S|S)Ntruefalse)rCrD)r%bool)r;rrr truth_values  z-_handle_security_options..truth_valuez=Can not specify conflicting values for URI options %s and %s.)r=r,r-)r>_TLSINSECURE_EXCLUDE_OPTSr cased_key)r8r=r?err_msgr@ZtlsallowinvalidcertsrArFr)r8r_handle_security_optionss>    rJcCsxt|D]}|tkr t|\}}|dkr|}||krjd}tj||j||j|ftdd|j|q d}tj||j||ftddq |dkr d}tj||j||ftddq W|S)aMIssue 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. :Parameters: - `options`: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. Zrenamedz0Deprecated option '%s' ignored in favor of '%s'.r) stacklevelz,Option '%s' is deprecated, use '%s' instead.removedzOption '%s' is deprecated. %s.)listrr4r5rHDeprecationWarningpop)r8optnamemodemessageZ newoptnameZwarn_msgrrr_handle_option_deprecationss.       rScCsj|jd}|dk r2xtD]}t|}| ||<qWx2t|D]&}tj|d}|dk r<|j|||<q_IMPLICIT_TLSINSECURE_OPTSrrMrO)r8r=r?ZintnamerPrrr_normalize_optionss   rUFcCs 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. :Parameters: - `opts`: A dict of MongoDB URI options. - `warn` (optional): If ``True`` then warnings will be logged and invalid options will be ignored. Otherwise invalid options will cause errors. )r)r6r5rrrvalidate_optionss rVTc Cs|jd}|jd}yd|dkr0|dkr0tdnF|dkrDt|d}n2|dkrXt|d}n|jdd krrt|d}ntWntk rtdYnXt|}t|}|rt||}|jd d krtd |rt|}|S) aTakes the options portion of a MongoDB URI, validates each option and returns the options in a dictionary. :Parameters: - `opt`: A string representing MongoDB URI options. - `validate`: If ``True`` (the default), validate and normalize all options. - `warn`: If ``False`` (the default), suppress all warnings raised during validation of options. - `normalize`: If ``True`` (the default), renames all options to their internally-used names. &;rz.Can not mix '&' and ';' for option separators.r1rNz(MongoDB URI options are key=value pairs. authsourcez1the authSource database cannot be an empty stringr) rr r<rrJrSrVr>rU)r6validater5 normalizeZand_idxZsemi_idxr8rrr split_options*s0       r]cCsJg}x@|jdD]2}|s td|}|jdr2d}|jt||qW|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. :Parameters: - `hosts`: A string of the form host1[:port],host2[:port],... - `default_port`: The port number to use when one wasn't specified for a host. ,z)Empty host (or extra comma in host list).z.sockN)r$r r#r3r+)hostsrnodesrr*rrr split_hostsWs  rar"z/ "$rrYZ authSource replicasetZ replicaSet loadbalancedZ loadBalancedcCsdt|dkr|jdrtd|jdr`t|dkrr )r`r8rrr_check_optionszs    recCs|jtrd}|td}nF|jtrRts@tjp2d}td|d}|td}nt dttf|snt dd} d} d} d} t } |j d\}}}|s|}d }| rd |krt d |r*|j d \} }}| r t | } d | kr| j d d \} } tj| rt d| nd} |r*| jt||||d|krR|jd\}}}t|\} } n|}d|krlt d|t |}d}|r| jdrtdtft|dd}t|d krt dtf|d\}}|dk rt dtf|p| jd}t||d}|j}|j}|rdt||||}t|tr:tdx(|jD]\}}|| krD|| |<qDWd| kr|rxdnd| d<n t||d}t|| || | | | | |dS)aParse and validate a MongoDB URI. Returns a dict of the form:: { 'nodelist': , 'username': or None, 'password': or None, 'database': or None, 'collection': or None, 'options': , 'fqdn': or None } If the URI scheme is "mongodb+srv://" DNS SRV and TXT lookups will be done to build nodelist and options. :Parameters: - `uri`: The MongoDB URI to parse. - `default_port`: The port number to use when one wasn't specified for a host in the URI. - `validate` (optional): If ``True`` (the default), validate and normalize all options. Default: ``True``. - `warn` (optional): When validating, if ``True`` then will warn the user then ignore any invalid options or values. If ``False``, validation will error when options are unsupported or values are invalid. Default: ``False``. - `normalize` (optional): If ``True``, convert names of URI options to their internally-used names. Default: ``True``. - `connect_timeout` (optional): The maximum time in milliseconds to wait for a response from the DNS server. .. versionchanged:: 3.9 Added the ``normalize`` parameter. .. versionchanged:: 3.6 Added support for mongodb+srv:// URIs. .. versionchanged:: 3.5 Return the original value of the ``readPreference`` MongoDB URI option instead of the validated read preference mode. .. versionchanged:: 3.1 ``warn`` added so invalid options can be ignored. FNpythonzThe "dnspython" module must be installed to use mongodb+srv:// URIs. To fix this error install pymongo with the srv extra: %s -m pip install "pymongo[srv]"Tz4Invalid URI scheme: URI must begin with '%s' or '%s'z)Must provide at least one hostname or IP./rZ?z8A '/' is required between the host list and any options..rzBad database name "%s"r z;Any '/' in a unix domain socket must be percent-encoded: %sZdirectConnectionz1Cannot specify directConnection=true with %s URIs)rz0%s URIs must include one, and only one, hostnamerz&%s URIs must not include a port numberZconnectTimeoutMS)connect_timeoutzDOnly authSource, replicaSet, and loadBalanced are supported from DNSrBrC)ZnodelistusernamepasswordZdatabase collectionr8fqdn) startswithSCHEME SCHEME_LEN SRV_SCHEMEr sys executabler SRV_SCHEME_LENr rrrr$ _BAD_DB_CHARSsearchupdater] rpartitionrr>rardr Z get_hostsZ get_optionsset_ALLOWED_TXT_OPTSitemsre)urirr[r5r\rjZis_srvZ scheme_freeZ python_pathrrZdbasermr8Z host_partrZ path_partr6rr_rnr`r*Z dns_resolverZ dns_optionsZparsed_dns_optionsr?r;rrr parse_uris/                    r~__main__r)F)TFT)4__doc__rer4rsZbson.py3compatrr urllib.parserurllibZpymongo.commonrrrrZpymongo.errorsr r Zpymongo.srv_resolverr r rprdrqrrruZ DEFAULT_PORTrr!r+rTrGr<rJrSrUrVr]racompileescaperv frozensetr{rer~__name__pprintargvexcprintexitrrrrs\  ( <$  -