hMdZddlZddlZddlmZmZerddlmZnddlmZddl m Z m Z m Z m Z ddlmZmZddlmZmZdZeeZd ZeeZd Zd Zd Zefd ZhdZeDchc]}|c}eDchc]}e | c}zZdZdZ dZ!dZ"ddZ#d dZ$efdZ%ejLdejNdzdzZ(e)gdZ*eddddfdZ+e,dk(rAddl-Z-ddl.Z. e-jZe+e.j^de.jddyycc}wcc}w#e$rZ0e1e0YdZ0[00dZ0[0wwxYw)!z*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://iicd|vs|jddkDrtrd}nd}td|z|jd\}}}|s tdt |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)userinfoquote_fnuser_passwds U/var/www/html/ranktracker/api/venv/lib/python3.12/site-packages/pymongo/uri_parser.pyparse_userinfor)s| h(..-1 0H*H/19:; ;((-OD!V BCC  |F3 33c|jddk(r td|jd}|dk(r|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. :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. ]zNan IPv6 address literal must be enclosed in '[' and ']' according to RFC 2732.z]:rN)find ValueError)entity default_portis rparse_ipv6_literal_hostr%Esj{{32() )  DABwa|\)) !Q<A ''rc|}|}|ddk(rt||\}}n]|jdr||fS|jddk7r4|jddkDr t d|j dd\}}t |trE|jrt|dkDst|dkrt d |t|}|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[.sockrrrzReserved 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: ) r%endswithr rr!split isinstancerisdigitintlower)r"r#hostports r parse_hostr1[s D D ayC,V\B d  !|## S R  << q >? ?ZZQ' d$ $||~TU!2c$i1n $'( (4y ::< r>tlsallowinvalidhostnamestlsallowinvalidcertificatestlsdisableocspendpointcheckc^t}|j|D]}|jd\}}|jdk(r"|j|gj |L||vrt j d|d|jdk(r|}n t|}|||<|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'.authmechanismproperties)r r*r. setdefaultappendwarningswarnr)optsdelimoptionsurioptkeyvaluevals r_parse_optionsrDs)*G**U# \\#& U 99;. .   sB ' . .u 5g~ cCDyy{77"5)GCL  Nrcdjd}|?tD]6}|vsd}t|jdj|fzfd}|d}|.dvr!d}t|djdfz|durdd<|d}|+dD]&}j|dusd }t||fzd vrfd vrbd }|jd |jd k7r0d }t|jd jd fzS)zRaise appropriate errors when conflicting TLS options are present in the options dictionary. :Parameters: - `options`: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. tlsinsecurez9URI options %s and %s cannot be specified simultaneously.cZj|xsjt|S)N)getr)optr?s r_getoptz)_handle_security_options.._getopts, C ? 8=> @rr3r4T tlscrlfile)rFr3r4zDURI option %s=True cannot be specified when CRL checking is enabled.ssltlsc<|dvr|dk(St|tr|S|S)N)truefalserO)r+bool)rCs r truth_valuez-_handle_security_options..truth_values)''f}$#t$ Jrz=Can not specify conflicting values for URI options %s and %s.)rH_TLSINSECURE_EXCLUDE_OPTSr cased_key)r?rFrIerr_msgrJtlsallowinvalidcertsrKrRs` r_handle_security_optionsrWs++m,K, OCg~- %%m4g6G6G6L,N"NOO  O@ ##@A' (G 3)GW-w/@/@103(445 5 4 '59G1 2&J3 3C{{34'6 C6!122  3 EW,  w{{5) *k'++e:L.M M GW!!%('*;*;E*B(DDE E Nrct|D]}|tvs t|\}}|dk(r|}||vrSd}tj||j ||j |fzt d|j |vd}tj||j ||fzt d|dk(sd}tj||j ||fzt d|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. renamedz0Deprecated option '%s' ignored in favor of '%s'.r) stacklevelz,Option '%s' is deprecated, use '%s' instead.removedzOption '%s' is deprecated. %s.)listrr;r<rTDeprecationWarningpop)r?optnamemodemessage newoptnamewarn_msgs r_handle_option_deprecationsrds=6 1 17@MD'y $ (!(HMM G$5$5g$>$+$5$5j$A$CC*q:KK(I  1 1' :JGG&16";  1 1' :GDD&16)60 Nrc|jd}|tD]}t|}| ||<t|D]/}tj|d}||j |||<1|S)aNormalizes option names in the options dictionary by converting them to their internally-used names. Also handles use of the tlsInsecure option. :Parameters: - `options`: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. rFN)rH_IMPLICIT_TLSINSECURE_OPTSrr\r^)r?rFrIintnamer_s r_normalize_optionsrhs++m,K- /C237G#.GG  / =4.227DA  &{{73GG 4 NrFct||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)r=r<s rvalidate_optionsrjs !t ,,rTc|jd}|jd} |dk\r|dk\r td|dk\r t|d}n9|dk\r t|d}n'|jddk7r t|d}ntt |}t |}|r+t ||}|jd d k(r td |r t|}|S#t$r tdwxYw) 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.r6rNz(MongoDB URI options are key=value pairs. authsourcez1the authSource database cannot be an empty string) r r rDr!rWrdrjrHrh)r=validater< normalizeand_idxsemi_idxr?s r split_optionsrt)siinGyy~H E a, '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. FNzCThe "dnspython" module must be installed to use mongodb+srv:// URIsTz)Invalid URI scheme: URI must begin with 'z' or ''z)Must provide at least one hostname or IP./ro?z8A '/' is required between the host list and any options..rzBad database name "%s"rz;Any '/' in a unix domain socket must be percent-encoded: %sdirectConnectionz*Cannot specify directConnection=true with z URIs)r#z. URIs must include one, and only one, hostnamerz$ URIs must not include a port numberconnectTimeoutMS)connect_timeoutz5Only authSource and replicaSet are supported from DNSrLrOz8Cannot specify multiple hosts with directConnection=true)nodelistusernamepassworddatabase collectionr?fqdn) startswithSCHEME SCHEME_LEN SRV_SCHEMEr r SRV_SCHEME_LENr r rrr* _BAD_DB_CHARSsearchupdatert rpartitionrrHrylenr get_hosts get_optionsset_ALLOWED_TXT_OPTSitems)urir#rpr<rqris_srv scheme_freerrdbaserr? host_partr path_partr=rrwrrxr0 dns_resolver dns_optionsparsed_dns_optionsrIrCs r parse_urirxsQ^ ~~f*+&  #$&LM M./* 6gkk*<=$JL L  r__main__r)F)TFT)3__doc__rer;bson.py3compatrr urllib.parserurllibpymongo.commonrrrr pymongo.errorsr r pymongo.srv_resolverr r rrrrr DEFAULT_PORTrr%r1rfrSrDrWrdrhrjrtrycompileescaper frozensetrr__name__pprintsysargvexcprintexit)ks0rrs{ 1 +)#==:>  [  Z 48(,%1#N$//q/2LMQ %a (M N *9x!H. - *Z%18 37!33c9: <>!-t%dWt z i ,- CHHQKS 0MZ  c s$' D"6 D')%D,,E1D>>E