[j]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(dIdZ)dJdZ*dKdZ+e(fdLdZ,hdZ-dMd#Z.dNd%Z/dNd&Z0dNd'Z1dOdPd,Z2 dQdRd0Z3e(fdSd3Z4ej5d4ej6d5zd6zZ7e8gd7Z9dTd;Z:e(d-d(d-dddfdUdBZ;dVdFZZ> e>j>e;ej?dHn#e$rZ@eAe@YdZ@[@ndZ@[@wwxYwejBddSdS)Wz*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://iisstrreturnboolctt|D]1}||dkr#|||dz}t||krdS2dS)zCheck for unescaped percent signs. :Parameters: - `s`: A string. `s` can have things like '%25', '%2525', and '%E2%85%A8' but cannot have unquoted percent like '%foo'. %TF)rangelenr )risubs V/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/pymongo/uri_parser.py_unquoted_percentr%8s_3q66]] Q43;;AAI,CC  C''tt 5userinfotuple[str, str]cd|vs(|ddkst|rtd|d\}}}|stdt |t |fS)alValidates 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. :Parameters: - `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_passwds r$parse_userinfor2Is h(..--115Fx5P5P1 4   ((--OD!V DBCCC   |F33 33r&entity 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. :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]:r,N)find ValueError)r3r4r"s r$parse_ipv6_literal_hostr=bs~{{32 \     DABwwad|\)) !A#;q1uww ''r&rc<|}|}|ddkrt||\}}ns|dr||fS|ddkrA|ddkrt d|dd\}}t |tr[|r&t|dkst|dkrt d |t|}| |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[.sockr+r9r,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: ) r=endswithr;r-r<split isinstancerisdigitintlower)r3r4hostports r$ parse_hostrIzs' D&2D ayC,V\BB dd  ! ! (|## S  R   <<  q 1  ZZQ'' d$||~~ WTU!2!2c$ii1nnUTUUVV V4yy ::<< r&>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'.r: stacklevelauthmechanismproperties)rrBrF setdefaultappendwarningswarnr )rMrNoptionsurioptkeyvaluevals r$_parse_optionsr_s )**G**U##  \\#&& U 99;;. . .   sB ' ' . .u 5 5 5 5g~~ >s>>>1MMMMyy{{777"5))GCLL Nr&rZc|d}|JtD]B}||vr.truth_values4'''f}$#t$$  Jr&z=Can not specify conflicting values for URI options %s and %s.)r^rrr)get_IMPLICIT_TLSINSECURE_OPTSr cased_key)rZraopterr_msgtlsallowinvalidcertsrbrhs r$_handle_security_optionsros++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'[[\\ \ Nr&ct|D]}|tvrt|\}}|dkr|}||vr_d}tj|||||fzt d||d}tj||||fzt d|dkr6d}tj||||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:rSz,Option '%s' is deprecated, use '%s' instead.removedzOption '%s' is deprecated. %s.)listrrXrYrkDeprecationWarningpop)rZoptnamemodemessage newoptnamewarn_msgs r$_handle_option_deprecationsr{sK== 1 1 17@MD'y  $ ((QHM G$5$5g$>$>@Q@QR\@]@]#^^*#$ KK(((I  1 1' : :JGG&  "";  1 1' : :GDD&  Nr&c|d}|tD]}|||<t|D]1}tj|d}|||||<2|S)zNormalizes option names in the options dictionary by converting them to their internally-used names. :Parameters: - `options`: Instance of _CaseInsensitiveDictionary containing MongoDB URI options. raN)rirjrsrru)rZrarlrvintnames r$_normalize_optionsr~s~++m,,K- ' 'C&GCLL==44.27DAA  &{{733GG  Nr&FMapping[str, Any]rYMutableMapping[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. :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)rMrYs r$validate_optionsr4s !t , ,,r&Tvalidate 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. :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.rQr9Nz(MongoDB URI options are key=value pairs. authsourcez1the authSource database cannot be an empty string) r;rr_r<ror{r~r rrri)rMrrYrand_idxsemi_idxrZs r$ split_optionsrDsYiinnGyy~~H O a<""Y u::>>$%[\\ \ ;;) * * d$%bcc c ;;| $ $ Y$%WXX X YY  Y Yr&uriconnect_timeoutOptional[float]srv_service_name srv_max_hostsdict[str, Any]cV|trd}|td} ns|tr9ts t jpd} td| zd}|td} n tdtdtd| std d} d} d} d}t}| d \}}}|s|}d }|r| d \} }}n| d \}}}| rYt| } d | vr| d d\} }t| rtd| znd} |r%|t#||||||dt&}d|vr,|d\}}}t+|\} } n|}d |vrtd|zt|}d}|p|d}|r|drtdtdt-|d}t/|dkrttd|d\}}|ttd|p|d}t1||||}|}|}|r[t#||||}t7|t8z rtd|D]\}}||vr|||<|dr|rtd|dr|rtd d!|vr d"|vr |rdnd#|d!<nJ|s$|dtd$|s|rtd%t-||}t=|||| | | |||d&S)'awParse 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. - `srv_service_name` (optional): 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)r4z. 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 srvMaxHostsrdrcrfzDThe srvServiceName option is only allowed with 'mongodb+srv://' URIszAThe srvMaxHosts option is only allowed with 'mongodb+srv://' URIs)nodelistusernamepassworddatabase collectionrZfqdn) startswithSCHEME SCHEME_LEN SRV_SCHEMErsys executablerSRV_SCHEME_LENrrr.r rB _BAD_DB_CHARSsearchupdaterrir rpartitionr2rr!r get_hosts get_optionsset_ALLOWED_TXT_OPTSitemsr)rr4rrYrrrris_srv scheme_free python_pathr/r1dbaserrZ host_partr0 path_partrMr'rrrrH dns_resolver dns_optionsparsed_dns_optionsrlr^s r$ parse_urirs@ ~~fb*++&  # # b .4HK$15@A  .//* `V``S]```aaa FDEEE D F EJ(**G)33C88Iq)   6",,S11q$$'0055 1d U## %<< % C 3 3 E:    & & ?5=>> > ? G}T8T9EEFFF";;'79IJJ i&11#66!U%h// ff e||VYbbccc   E D!?W[[%?%?M (> ;;) * * e$%cR\%c%c%cdd dE555 u::?? ZZZ[[ [1X d   PPPQQ Q*LW[[9K-L-L#D/;K][[ &&(("..00  '!.{HdI!V!V %&&):: (Z/4466 ' 'Sg%%#&GCL ;;~ & & Q= QOPP P ;;| $ $ O OMNN N   E$8$8%-9TT6GEN  > $455A R   > > O   E ===5'"""   r&kms_tls_optionsOptional[Mapping[str, Any]]dict[str, SSLContext]cP|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 dictrdTNz!TLS is required for KMS providerszInsecure TLS options prohibited) tlsInsecuretlsAllowInvalidCertificatestlsAllowInvalidHostnames$tlsDisableCertificateRevocationCheckz!Insecure TLS options prohibited: ) rCdict TypeErrorrrVrror~r rr r)rcontextsproviderrZrM ssl_contextallow_invalid_hostnamesns r$_parse_kms_tls_optionsrWsd  ot , ,:8999H,2244--''4(( MKKKKLL L5$''')'22'--!$''.0@0F0FGG/A$/G/G, ,  $%HII I " H$%FGG G  - -A Dyy()PQ)P)PQQQ!,HX   - Or&__main__r,)rrrr)r'rrr()r3rr4r5rr6)r3rr4r5rr)rMrrNrOrr)rZrrr)F)rMrrYrrr)TFT) rMrrrrYrrrrr)rrr4r5rr)rr rZrrr)rrr4r5rrrYrrrrrrrOrr5rr)rrrr)C__doc__ __future__rrerrXtypingrrrrrr r r urllib.parser pymongo.client_optionsr pymongo.commonrrrrrpymongo.errorsrrpymongo.srv_resolverrrpymongo.typingsrpymongo.pyopenssl_contextrrr!rrr DEFAULT_PORTr%r2r=rIrjr_ror{r~rrrcompileescaper frozensetrrrr__name__pprintargvexcprintexitr&r$rs 10""""""                     &%%%%%555555:9999999>>>>>>>>$$$$$$5444444  S[[  Z "44442((((0;G$$$$$P,3333l%%%%P. - - - - -"MQ+++++\;G6 37!3!33c9:: I\\\ Y Y Y Y #/'+&*#'rrrrrjB zMMM ii ,,----  c  CHQKKKKKs$D))E. D>>E