FCfx\dZddlmZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZmZmZmZmZddlmZmZdd lmZmZdd lm Z erdd l!m"Z"d Z#e$e#Z%d Z&e$e&Z'dZ(d&dZ)d'dZ* d(dZ+e(fd)dZ,hdZ-d*dZ.d+dZ/d+dZ0d+dZ1d,d-dZ2 d. d/dZ3e(fd0dZ4ejjdejldzdzZ7e8gd Z9d1d!Z:e(ddddddf d2d"Z;d3d#ZZ> e>j|e;ej~d%ejdyy#e$rZ@eAe@YdZ@[@&dZ@[@wwxYw)4z*Tools to parse and validate a MongoDB URI.) annotationsN) TYPE_CHECKINGAnyMappingMutableMappingOptionalSizedUnioncast) unquote_plus)_parse_ssl_options)INTERNAL_URI_OPTION_NAME_MAPSRV_SERVICE_NAMEURI_OPTIONS_DEPRECATION_MAP_CaseInsensitiveDictionaryget_validated_options)ConfigurationError InvalidURI)_HAVE_DNSPYTHON _SrvResolver)_Address) SSLContextz mongodb://zmongodb+srv://iicxtt|D]#}||dk(s |||dz}t||k(s#yy)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 )sisubs R/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/pymongo/uri_parser.py_unquoted_percentr"8sL 3q6] Q43;AA,CC C'  cd|vs|jddkDs t|r td|jd\}}}|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 )userinfouser_passwds r!parse_userinfor.Hsq h(..-15Fx5P 4  ((-OD!V BCC  |F3 33r#c|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. :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)entity default_portrs r!parse_ipv6_literal_hostr7`sh{{32 \    DABwa|\)) !A;q1uw ''r#c|}|}|ddk(rt||\}}n]|jdr||fS|jddk7r4|jddkDr t d|j dd\}}t |trE|jrt|dkDst|dkrt d |t|}|j|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&r1r'zReserved 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: ) r7endswithr3r(r4split isinstancestrisdigitintlower)r5r6hostports r! parse_hostrDws D&2D ayC,V\B d  !|## S R  << q 1  ZZQ' d$||~TU!2c$i1nLTHUV V4y ::< r#>tlsallowinvalidhostnamestlsallowinvalidcertificatestlsdisableocspendpointcheckcbt}|j|D]}|jd\}}|jdk(r"|j|gj |L||vrt j d|dd|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'.r2 stacklevelauthmechanismproperties)rr<rA setdefaultappendwarningswarnr )optsdelimoptionsurioptkeyvaluevals r!_parse_optionsrYs )*G**U# \\#& U 99;. .   sB ' . .u 5g~ 6se2>1Myy{77"5)GCL  Nr#c~|jd}|?tD]6}||vsd}t||jd|j|fz|jd}|.d|vr!d}t|d|jdfz|durd|d<|jd}|+dD]&}|j|dusd}t||fzd |vrgd |vrcd d }||jd ||jd k7r0d }t||jd |jd fz|S)zRaise appropriate errors when conflicting TLS options are present in the options dictionary. :param options: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. tlsinsecurez9URI options %s and %s cannot be specified simultaneously.rFrGT tlscrlfile)r[rFrGzDURI option %s=True cannot be specified when CRL checking is enabled.ssltlsc<|dvr|dk(St|tr|S|S)N)truefalser`)r=bool)rXs r! truth_valuez-_handle_security_options..truth_values)''f}$#t$ Jr#z=Can not specify conflicting values for URI options %s and %s.)rXrreturnr)get_IMPLICIT_TLSINSECURE_OPTSr cased_key)rTr[opterr_msgtlsallowinvalidcertsr\rcs r!_handle_security_optionsrks++m,K- Cg~U w00?ARARSVAWXX #;;'DE' (G 3QG0'2C2CDa2bcd  4 '59G1 2\*J` 3C{{34'` C6!122 3  EW,  w{{5) *k'++e:L.M MUGW(9(9%(@'BSBSTYBZ'[[\ \ Nr#ct|D]}|tvs t|\}}|dk(r|}||vrSd}tj||j ||j |fzt d|j |vd}tj||j ||fzt d|dk(sd}tj||j ||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'.r2rKz,Option '%s' is deprecated, use '%s' instead.removedzOption '%s' is deprecated. %s.)listrrPrQrgDeprecationWarningpop)rToptnamemodemessage newoptnamewarn_msgs r!_handle_option_deprecationsrws= 1 17@MD'y $ (QHMM G$5$5g$>@Q@QR\@]#^^*#$ KK(I  1 1' :JGG&  ";  1 1' :GDD& -8 Nr#c|jd}|tD]}|||< t|D]/}tj|d}||j |||<1|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)rerfrorrq)rTr[rhrrintnames r!_normalize_optionsrzsw++m,K- 'C&GCL '=4.227DA  &{{73GG 4 Nr#Fct||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)rRrQs r!validate_optionsr|-s !t ,,r#Tc|jd}|jd} |dk\r|dk\r td|dk\r t|d}n9|dk\r t|d}n'|jddk7r t|d}ntt |}t |}|r t |}|r9ttt||}|jd d k(r td |S#t$r tddwxYw) 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 separators.rIr1Nz(MongoDB URI options are key=value pairs. authsourcez1the authSource database cannot be an empty string) r3rrYr4rkrwrzr rr|re)rRvalidaterQ normalizeand_idxsemi_idxrTs r! split_optionsr<siinGyy~H O a" u:>$%[\ \ ;;) *$%bc c ;;| $$%WX X % #r#c|jtr d}|td} nc|jtr4ts"t j xsd} td| zd}|td} ntdtdtd| s td d} d} d} d}t}| jd \}}}|s|}d }|r|jd \} }}n|jd \}}}| rGt| } d | vr| jd d\} }tj| rtd| zd} |r|j!t#||||||j%dt&}d|vr$|j)d\}}}t+|\} } n|}d |vrtd|zt|}d}|xs|j%d}|rM|j%drtdtdt-|d}t/|dk7rttd|d\}}|ttd|xs|j%d}t1||||}|j3}|j5}|rMt#||||}t7|t8z r td|j;D]\}}||vs |||<|j%dr |r td|j%dr |r td d!|vrHd"|vrD|rdnd#|d!<n:|s|j%d td$|s |r td%t-||}t=|||| | | |||d&S)'a(Parse 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. :param uri: The MongoDB URI to parse. :param default_port: The port number to use when one wasn't specified for a host in the URI. :param validate: If ``True`` (the default), validate and normalize all options. Default: ``True``. :param warn: 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``. :param normalize: If ``True``, convert names of URI options to their internally-used names. Default: ``True``. :param connect_timeout: The maximum time in milliseconds to wait for a response from the DNS server. :param srv_service_name: A custom SRV service name .. versionchanged:: 4.6 The delimiting slash (``/``) between hosts and connection options is now optional. For example, "mongodb://example.com?tls=true" is now a valid URI. .. versionchanged:: 4.0 To better follow RFC 3986, unquoted percent signs ("%") are no longer supported. .. 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 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?.r'zBad database name "%s"srvServiceNamer%z;Any '/' in a unix domain socket must be percent-encoded: %s srvMaxHostsdirectConnectionz*Cannot specify directConnection=true with z URIs)r6z. URIs must include one, and only one, hostnamerz$ URIs must not include a port numberconnectTimeoutMSzDOnly authSource, replicaSet, and loadBalanced are supported from DNSrz0You cannot specify loadBalanced with srvMaxHostsrz.You cannot specify replicaSet with srvMaxHostsr^r]r`zDThe srvServiceName option is only allowed with 'mongodb+srv://' URIszAThe srvMaxHosts option is only allowed with 'mongodb+srv://' URIs)nodelistusernamepassworddatabase collectionrTfqdn) startswithSCHEME SCHEME_LEN SRV_SCHEMErsys executablerSRV_SCHEME_LENrrr)r r< _BAD_DB_CHARSsearchupdaterrer rpartitionr.rrr get_hosts get_optionsset_ALLOWED_TXT_OPTSitemsr)urir6rrQrconnect_timeoutsrv_service_name srv_max_hostsis_srv scheme_free python_pathr+r-dbaserrT host_partr, path_partrRr*rrrrC dns_resolver dns_optionsparsed_dns_optionsrhrXs r! parse_urirs~ ~~f*+&  #..4HK$15@A  ./* DVHFS]R^^_`aa DEE D F EJ(*G)33C8Iq)   ",,S1q$'005 1d U# %< % C 3 E:    &5=> > }T8T9EF";;'79IJ i&11#6!U%h/ f e|VYbbcc  E D!?W[[%?M ;;) *$'QR\Q]]b%cd dE5 u:? |+YZ[ [1X d   |+OPQ Q*LW[[9K-L#D/;K][ &&("..0 !.{HdI!V %&)::(Z/446 'Sg%#&GCL ' ;;~ &=OP P ;;| $MN N  E$8%-T6GEN  $45A R    O  E =5'"  r#c|siSt|ts tdi}|jD]\}}t|tstd|d|j ddt |}t |}t|}tt t|}t|\}}| td|r tddD]}||vrtd ||||<|S) z!Parse KMS TLS connection options.zkms_tls_options must be a dictzkms_tls_options["z"] must be a dictr^Tz!TLS is required for KMS providerszInsecure TLS options prohibited) tlsInsecuretlsAllowInvalidCertificatestlsAllowInvalidHostnames$tlsDisableCertificateRevocationCheckz!Insecure TLS options prohibited: ) r=dict TypeErrorrrNrrkrzr r|r r)kms_tls_optionscontextsproviderrTrR ssl_contextallow_invalid_hostnamesns r!_parse_kms_tls_optionsrLs  ot ,899H,224-''4(/z9JKL L5$')'2'-!$'.0@0FG/A$/G, ,  $%HI I "$%FG G  -A Dy(+LQC)PQQ!,HX  --. Or#__main__r')rr>rdrb)r*r>rdztuple[str, str])r5r>r6 Optional[int]rdz%tuple[str, Optional[Union[str, int]]])r5r>r6rrdr)rRr>rS Optional[str]rdr)rTrrdr)F)rRMapping[str, Any]rQrbrdMutableMapping[str, Any])TFT) rRr>rrbrQrbrrbrdr)rr>r6rrdzlist[_Address])rr rTrrdNone)rr>r6rrrbrQrbrrbrzOptional[float]rrrrrdzdict[str, Any])rzOptional[Mapping[str, Any]]rdzdict[str, SSLContext])C__doc__ __future__rrerrPtypingrrrrrr r r urllib.parser pymongo.client_optionsr pymongo.commonrrrrrpymongo.errorsrrpymongo.srv_resolverrrpymongo.typingsrpymongo.pyopenssl_contextrrrrrr DEFAULT_PORTr"r.r7rDrfrYrkrwrzr|rrcompileescaper frozensetrrrr__name__pprintargvexcprintexitr#r!rs 1"    &5:>$4  [  Z   40( (,(*(.;G#N,2j$N, - MQ* **,0*EI**Z;G4 37!33c9: \ Y #/'+&*#'q qqq  q  q % q$q!qqhB z i ,- CHHQK  c s%EE.E))E.