[jg UdZddlmZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZdd lmZmZmZdd lmZdd lmZdd lmZdd l m!Z!Gdde Z"e"e#dZ$e$j%e$j&fZ'de(d<eeegeefZ)GddZ*ej+e$j&ej,e$j-ej.e$j/ej0e$j/ej1e$j/iZ2d.dZ3d/dZ4d0d&Z5d1d(Z6d2d*Z7d3d,Z8d-S)4z*Represent a deployment of MongoDB servers.) annotations)sample)AnyCallableListMappingMutableMapping NamedTupleOptionalcastMinKey)ObjectId)common)ConfigurationError)ReadPreference _AggWritePref _ServerModeServerDescription) Selection) SERVER_TYPE)_AddresscLeZdZUded<ded<ded<ded<ded<ded<dS) _TopologyTypeintSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____annotations__`/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/pymongo/topology_description.pyrr*sQKKKLLLLLLr(rztuple[int, int]SRV_POLLING_TOPOLOGIESceZdZd5dZd6dZd6dZd7dZd8dZd9dZd:dZ e d;dZ e ddZe d?dZe d>dZe d@d!Ze dAd"Ze d@d#Ze d>d$Ze d;d%Ze d;d&ZdBd)Z dCdDd/ZejfdEd2ZdAd3Zdz/TopologyDescription.__init__..is*UUq2d:UUUUUUr(c3$K|] }|jV dSr<r=r?s r)rBz/TopologyDescription.__init__..ls6++671++++++r()_topology_type_replica_set_name_server_descriptions_max_set_version_max_election_id_topology_settings_incompatible_err TOPOLOGY_TYPEr"_init_incompatible_errreadable_servers_ls_timeout_minutesanymin)selfr.r/r1r3r5r7rMs r)__init__zTopologyDescription.__init__=s(,!1$7! / /#4"&  -"< < <  ' ' ) ) ) 0 '+D $ $ $ UUDTUUU U U '+D $ $ $'*++;K+++((D $ $ $r(c|jD]}|js |jduo|jtjk}|jduo|jtjk}|r6d|jd|jdpd|jtjfz|_ ~|rCd|jd|jdpd|jtjtj fz|_ dSdS)z>Internal compatibility check for non-load balanced topologies.Nz]Server at %s:%d requires wire version %d, but this version of PyMongo only supports up to %d.rzgServer at %s:%d reports wire version %d, but this version of PyMongo requires at least %d (MongoDB %s).) rFvaluesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressrJMIN_SUPPORTED_SERVER_VERSION)rQrAserver_too_newserver_too_olds r)rLz*TopologyDescription._init_incompatible_errps)*1133+ + A)  "$.K&)JJ "$.K&)JJ   A !  ! )*9 && L !  ! )*9; & =+ + r(c<|jrt|jdS)zRaise ConfigurationError if any server is incompatible. A server is incompatible if its wire protocol version range does not overlap with PyMongo's. N)rJrrQs r)check_compatiblez$TopologyDescription.check_compatibles*  ! =$T%;<< < = =r(r[rboolc||jvSr<)rF)rQr[s r) has_serverzTopologyDescription.has_servers$333r(c`|j|}t||S)z;A copy of this description, with one server marked Unknown.)rF to_unknownupdated_topology_description)rQr[ unknown_sds r) reset_serverz TopologyDescription.reset_servers+.w7BBDD +D*===r(c|jtjkr tj}n|j}d|jD}t |||j|j|j|j S)zz-TopologyDescription.reset..s#\\\ww)'22\\\r() rDrKrrrFr-rErGrHrI)rQr.sdss r)resetzTopologyDescription.resetsn  -"E E E)=MM /M]\$B[\\\"    "  !  !  #    r(c4|jS)z[dict of (address, :class:`~pymongo.server_description.ServerDescription`). )rFcopyr`s r)r/z'TopologyDescription.server_descriptionss(--///r(c|jS)zThe type of this topology.)rDr`s r)r.z!TopologyDescription.topology_types ""r(strc0tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )rK_fieldsrDr`s r)topology_type_namez&TopologyDescription.topology_type_names $T%899r(c|jS)zThe replica set name.)rEr`s r)r1z$TopologyDescription.replica_set_names %%r(c|jS)z1Greatest setVersion seen from a primary, or None.)rGr`s r)r3z#TopologyDescription.max_set_version $$r(c|jS)z1Greatest electionId seen from a primary, or None.)rHr`s r)r5z#TopologyDescription.max_election_idrxr(c|jS)z)Minimum logical session timeout, or None.)rNr`s r)r>z3TopologyDescription.logical_session_timeout_minutess ''r(list[ServerDescription]cHd|jDS)z)List of Servers of types besides Unknown.c g|] }|j | Sr'rVr?s r) z5TopologyDescription.known_servers..s XXXaAWXXXXr(rFrUr`s r) known_serversz!TopologyDescription.known_serverss(YX44;;==XXXXr(cbtd|jDS)z7Whether there are any Servers of types besides Unknown.c3(K|] }|j |VdSr<r~r?s r)rBz8TopologyDescription.has_known_servers..s*[[ADZ[1[[[[[[r()rOrFrUr`s r)has_known_serversz%TopologyDescription.has_known_serverss0[[d7>>@@[[[[[[r(cHd|jDS)zList of readable Servers.c g|] }|j | Sr') is_readabler?s r)rz8TopologyDescription.readable_servers..sOOOaOOOOr(rr`s r)rMz$TopologyDescription.readable_serverss(PO44;;==OOOOr(cT|j}|rtd|jDSdS)z3Minimum of all servers' max wire versions, or None.c3$K|] }|jV dSr<)rYr?s r)rBz:TopologyDescription.common_wire_version..s%FFaq)FFFFFFr(N)rrPrQserverss r)common_wire_versionz'TopologyDescription.common_wire_versions:$  GFF43EFFFFF Ftr(c|jjSr<)rIheartbeat_frequencyr`s r)rz'TopologyDescription.heartbeat_frequencys&::r(c|jjSr<)rI_srv_max_hostsr`s r) srv_max_hostsz!TopologyDescription.srv_max_hostss&55r( selectionOptional[Selection]c|sgStd|jD|jjdz fd|jDS)Nc3JK|]}tt|jVdSr<r floatround_trip_timer?s r)rBz=TopologyDescription._apply_local_threshold..s/\\d5!"344\\\\\\r(g@@cVg|]%}tt|jz k#|&Sr'r)r@rAfastest thresholds r)rz>TopologyDescription._apply_local_threshold..s@   UA-..8YFF FFFr()rPr/rIlocal_threshold_ms)rQrrrs @@r)_apply_local_thresholdz*TopologyDescription._apply_local_threshold ss I\\i>[\\\\\+>G      2    r(NselectorOptional[_Address]custom_selectorOptional[_ServerSelector]ct|ddr.|j}|r%||jkrtd||j|fzt |t r|||jtj krgS|jtj tj fvr|j S|r.| |}|r|gngStj|}|jtjkr ||}|%|r#|||j }||S)aList of servers matching the provided selector(s). :Parameters: - `selector`: a callable that takes a Selection as input and returns a Selection as output. For example, an instance of a read preference from :mod:`~pymongo.read_preferences`. - `address` (optional): A server address to select. - `custom_selector` (optional): A callable that augments server selection rules. Accepts a list of :class:`~pymongo.server_description.ServerDescription` objects and return a list of server descriptions that should be considered suitable for the desired operation. .. versionadded:: 3.4 rWrzF%s requires min wire version %d, but topology's min wire version is %d)getattrrrWr isinstancerselection_hookr.rKr!rr"rr/getrfrom_topology_descriptionr with_server_descriptionsr)rQrr[r common_wv descriptionrs r)apply_selectorz"TopologyDescription.apply_selectorsq* 8/ 3 3 0I Y)BBB(*-5x7PR[,\] h . . *  # #D ) ) )  !6 6 6I  M$8-:T#U U U% %  8224488AAK$/7K==R 77==  !6 6 6 ++I  &9 &!:: =>>I**9555r(read_preferencercptjd|t||S)aDoes this topology have any readable servers available matching the given read preference? :Parameters: - `read_preference`: an instance of a read preference from :mod:`~pymongo.read_preferences`. Defaults to :attr:`~pymongo.read_preferences.ReadPreference.PRIMARY`. .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 r)rvalidate_read_preferencerOr)rQrs r)has_readable_serverz'TopologyDescription.has_readable_serverLs4 '(9?KKK4&&77888r(c@|tjS)zDoes this topology have a writable server available? .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 )rrPRIMARYr`s r)has_writable_serverz'TopologyDescription.has_writable_server]s''(>???r(ct|jd}d|jj|jj|j|S)Nc|jSr<)r[)sds r)z.TopologyDescription.__repr__..isBJr()keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedrFrUformat __class__r#rI _topology_idrurs r)__repr__zTopologyDescription.__repr__gsY299;;AVAVWWW>EE N #  # 0  #     r()r.rr/r0r1r2r3r4r5r6r7rr8r9)r8r9)r[rr8rb)r[rr8r-)r8r-)r8r0)r8r)r8rr)r8r2)r8r4)r8r6)r8r{)r8rb)rrr8r{)NN)rrr[rrrr8r{)rrr8rb)r#r$r%rRrLrardrirnr/propertyr.rur1r3r5r>rrrMrrrrrrrrrrr'r(r)r-r-<s1111f----^====4444>>>>     &0000 ###X#:::X:&&&X&%%%X%%%%X%(((X(YYYXY\\\X\PPPXPX;;;X;666X6     '+59 4646464646lBPAW99999"@@@@      r(r-topology_descriptionserver_descriptionrr8c$|j}|j}|j}|j}|j}|j}|}|||<|tjkrq|L||jkrAtd ||j} | | ||<ttj|||||j S|tjkr|tjtjfvr@t%|j jdkr tj}n=||n'|tjtjfvr t,|}|tjkr1|tjtjfvr||nb|tjkr|tjtjfvr||n!|tjkrt7|||||\}}}}n|tjtjtjfvrt?|||\}}n|tj kr|tjtjfvr%||tC|}no|tjkrt7|||||\}}}}nF|tjtjtjfvrtE|||}ntC|}t||||||j S)a}Return an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `server_description`: a new ServerDescription that resulted from a hello call Called after attempting (successfully or not) to call hello on the server at server_description.address. Does not modify topology_description. Nzeclient is configured to connect to a replica set named '{}' but this node belongs to a set named '{}')errorrT)#r[r.r1r3r5 server_typer/rKrrrrfr-rIr!r Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPEr Mongosr RSPrimary_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr_check_has_primary#_update_rs_with_primary_from_member) rrr[r.set_namer3r5rrmrs r)rgrg~s2!(G)6M#4H*:O*:O$0K  2 2 4 4C&CL ,,,  H0B0S$S$S&AAG0ABBE .88u8EECL"      3     --- ;1;3KL L L':@AAQFF - 4     !4k6I J J J9+FM --- {1;3FG G G GGG    -; ; ; ;1;3EF F F GGG     K1 1 1JaX1?OKK G]Ho[4k6K[M`a a a&GX1'' #M8 -= = = ;1;3EF F F GGG   .s33MM K1 1 1JaX1?OKK G]Ho[4k6K[M`a a a?XOabbMM/s33M  /   r(seedlistlist[tuple[str, Any]]c |jtvsJ|}t|t|kr|St |D]}||vr|||jdkrt|t|z }|jt|z }|dkr9tt|t|t|}ng}|D]}||vrt|||<t|j||j|j|j|jS)zReturn an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `seedlist`: a list of new seeds new ServerDescription that resulted from a hello call r)r.r+r/setkeyslistrrrrrrPrr-r1r3r5rI)rrrmr[ new_hostsn_to_adds r))_updated_topology_description_srv_pollingrse -1G G G G G  2 2 4 4C 388::#h--''## ## ( " " GGG   )Q..MMC OO3 '5C@ a<<fY//Xs9~~1N1NOOHHH66 #  ,W55CL * -,,/   r(rm+MutableMapping[_Address, ServerDescription]r1r2r3r4r5r6.=.![![1ai&(((Q![![![![![![r(c3:K|]}|tn|VdSr<r rs r)rBz*_update_rs_from_primary..>rr()r1rr[rrY set_version election_idrftuplerUrrr all_hostsrr) rmr1rr3r5new_election_tuplemax_election_tuplenew_election_safemax_election_safeserver new_addressaddrs r)rrs -> /@ @ @ "*+++!#&&(8/?ZZ*26H6Y\^6^6^%7%CEWEc$d%4o$F ) ) )---2DGY2Y2Y2D2O2O2Q2Q&./)#..0@/Sbbb0> c ! !0==C C-77   s # #%5 XXr(rc|J||jkr||jn1|jr*|j|jkr||jt |S)zRS with known primary. Process a response from a non-primary. Pass in a dict of ServerDescriptions, current replica set name, and the ServerDescription we are processing. Returns new topology type. )r1rr[mer)rmr1rs r)rrbs{  ' ' '->>> "*++++  ,#5#=ASAV#V#V "*+++ c " ""r(tuple[int, Optional[str]]c*tj}||j}n)||jkr||j||fS|jD]}||vrt |||<|jr*|j|jkr||j||fS)zRS without known primary. Update from a non-primary's response. Pass in a dict of ServerDescriptions, current replica set name, and the ServerDescription we are processing. Returns (new topology type, new replica_set_name). )rKrr1rr[rrr)rmr1rr.r[s r)rrys"5M-> /@ @ @ "*+++...&/66 #  ,W55CL,!3!;?Q?T!T!T "*+++ * **r($Mapping[_Address, ServerDescription]c|D]%}|jtjkrtjcS&tjS)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )rUrrrrKrr)rmrAs r)rrsJZZ\\11 =K1 1 1 6 6 6 6 200r(N)rr-rrr8r-)rr-rrr8r-) rmrr1r2rrr3r4r5r6r8r)rmrr1r2rrr8r)rmrr1r2rrr8r)rmrr8r)9__doc__ __future__rrandomrtypingrrrrr r r r bson.min_keyr bson.objectidrpymongorpymongo.errorsrpymongo.read_preferencesrrrpymongo.server_descriptionrpymongo.server_selectorsrpymongo.server_typerpymongo.typingsrrrangerKr!r r+r&_ServerSelectorr-rrrrrrrrrgrrrrrr'r(r)rs100""""""                     """"""------OOOOOOOOOO888888......++++++$$$$$$J uuQxx( ,9+@-BW*XXXXXD!234d;L6MMNs s s s s s s s r  -=>]>=<: !ffffR))))XLYLYLYLY^####.++++@ 1 1 1 1 1 1r(