_iSt UdZddlmZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZmZdd lmZmZmZmZdd lmZdd lmZdd l m!Z!dd l"m#Z#Gdde Z$e$e%dZ&e&jNe&jPfZ)de*d<eeegeefZ+GddZ,e!jZe&jPe!j\e&j^e!j`e&jbe!jde&jbe!jfe&jbiZ4 ddZ5 ddZ6 ddZ7 ddZ8 d dZ9d!dZ:y)"zRepresent a deployment of MongoDB servers. .. seealso:: This module is compatible with both the synchronous and asynchronous PyMongo APIs. ) annotations)sample)AnyCallableListMappingMutableMapping NamedTupleOptionalcastMinKey)ObjectId)common)ConfigurationError PyMongoError)PrimaryReadPreference _AggWritePref _ServerMode)ServerDescription) Selection) SERVER_TYPE)_AddresscJeZdZUded<ded<ded<ded<ded<ded<y) _TopologyTypeintSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____annotations___/var/www/pod-logistic/pod-api/venv/lib/python3.12/site-packages/pymongo/topology_description.pyrr-s# K L Lr)rztuple[int, int]SRV_POLLING_TOPOLOGIESceZdZ ddZddZddZddZddZd dZd!dZ e d"dZ e d#d Z e d$d Z e d%d Ze d&d Ze d%d Ze d'dZe d(dZe d'dZe d'dZe d%dZe d"dZe d"dZd)dZ d* d+dZ d, d-dZej8fd.dZd(dZd#dZy)/TopologyDescriptionc||_||_||_||_||_t |jj |_||_d|_ |jtjk7r|j|j}|sd|_ytd|Drd|_yt!d|D|_y)aRepresentation of a deployment of MongoDB servers. :param topology_type: initial type :param server_descriptions: dict of (address, ServerDescription) for all seeds :param replica_set_name: replica set name or None :param max_set_version: greatest setVersion seen from a primary, or None :param max_election_id: greatest electionId seen from a primary, or None :param topology_settings: a TopologySettings Nc38K|]}|jduywNlogical_session_timeout_minutes.0ss r* z/TopologyDescription.__init__..lsUq22d:Uc34K|]}|jywr1r2r4s r*r7z/TopologyDescription.__init__..os+6711+)_topology_type_replica_set_name_server_descriptions_max_set_version_max_election_idlistvalues_candidate_servers_topology_settings_incompatible_err TOPOLOGY_TYPEr#_init_incompatible_errreadable_servers_ls_timeout_minutesanymin)self topology_typeserver_descriptionsreplica_set_namemax_set_versionmax_election_idtopology_settingsrGs r*__init__zTopologyDescription.__init__@s&,!1$7! / /"&t'@'@'G'G'I"J#4"&   -"<"< <  ' ' ) 00'+D $ UDTU U'+D $'*+;K+(D $r)cN|jjD]}|js|jduxr|jtj kD}|j duxr|j tjk}|rEd|jd|jdxsd|jtj fz|_ |sd|jd|jdxsd|j tjtjfz|_ yy)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).) r=rAis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressrDMIN_SUPPORTED_SERVER_VERSION)rKr6server_too_newserver_too_olds r*rFz*TopologyDescription._init_incompatible_errss1**113+ A)) ""$.K&&)J)JJ ""$.K&&)J)JJ  A !  ! )**99 & L !  ! )**99;; &W+ r)cF|jrt|jy)zRaise ConfigurationError if any server is incompatible. A server is incompatible if its wire protocol version range does not overlap with PyMongo's. N)rDrrKs r*check_compatiblez$TopologyDescription.check_compatibles#  ! !$T%;%;< < "r)c||jvSr1)r=)rKrZs r* has_serverzTopologyDescription.has_servers$3333r)cT|j|j}t||S)z;A copy of this description, with one server marked Unknown.)r= to_unknownupdated_topology_description)rKrZ unknown_sds r* reset_serverz TopologyDescription.reset_servers(..w7BBD +D*==r)c6|jtjk(rtj}n |j}|jDcic]}|t |}}t |||j|j|j|jScc}w)zr?rC)rKrLrZsdss r*resetzTopologyDescription.resets   -"E"E E)==M //MCGB[B[\ww)'22\\"    " "  ! !  ! !  # #   ]s Bc6|jjS)z[dict of (address, :class:`~pymongo.server_description.ServerDescription`). )r=copyr_s r*rMz'TopologyDescription.server_descriptionss((--//r)c|jS)zThe type of this topology.)r;r_s r*rLz!TopologyDescription.topology_types"""r)c<tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )rE_fieldsr;r_s r*topology_type_namez&TopologyDescription.topology_type_names $$T%8%899r)c|jS)zThe replica set name.)r<r_s r*rNz$TopologyDescription.replica_set_names%%%r)c|jS)z1Greatest setVersion seen from a primary, or None.)r>r_s r*rOz#TopologyDescription.max_set_version$$$r)c|jS)z1Greatest electionId seen from a primary, or None.)r?r_s r*rPz#TopologyDescription.max_election_idrsr)c|jS)z)Minimum logical session timeout, or None.)rHr_s r*r3z3TopologyDescription.logical_session_timeout_minutess'''r)cv|jjDcgc]}|js|c}Scc}w)z)List of Servers of types besides Unknown.)r=rArUrKr6s r* known_serversz!TopologyDescription.known_serverss/ 44;;=XaAWAWXXX66cVtd|jjDS)z7Whether there are any Servers of types besides Unknown.c3:K|]}|js|ywr1)rUr4s r*r7z8TopologyDescription.has_known_servers..s[ADZDZ1[s)rIr=rAr_s r*has_known_serversz%TopologyDescription.has_known_serverss$[d77>>@[[[r)cv|jjDcgc]}|js|c}Scc}w)zList of readable Servers.)r=rA is_readablerws r*rGz$TopologyDescription.readable_serverss- 44;;=OaOOOryc|jS)z0List of Servers excluding deprioritized servers.)rBr_s r*candidate_serversz%TopologyDescription.candidate_serverss&&&r)cX|j}|rtd|jDSy)z3Minimum of all servers' max wire versions, or None.c34K|]}|jywr1)rXr4s r*r7z:TopologyDescription.common_wire_version..sFaq))Fr:N)rxrJrKserverss r*common_wire_versionz'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr)c.|jjSr1)rCheartbeat_frequencyr_s r*rz'TopologyDescription.heartbeat_frequency s&&:::r)c.|jjSr1)rC_srv_max_hostsr_s r* srv_max_hostsz!TopologyDescription.srv_max_hostss&&555r)c|sgSg}|jD]S}|j*d|jd|d|j}t||j |jUt |}|j jdz }|jDcgc]$}tt|j|z |kr|&c}Scc}w)Nzround_trip_time for server z is unexpectedly None: z , servers: g@@) rMround_trip_timerZrappendrJrClocal_threshold_msr float)rK selectionround_trip_timesserverconfig_err_msgfastest thresholdr6s r*_apply_local_thresholdz*TopologyDescription._apply_local_thresholdsI(*33 v~~>NNefjekkvxAxUxUwV"W(88  # #F$:$: ;  < &'++>>G 22 UA--.8YF    s)CNc|s|j|_y|Dchc]}|j}}|jDcgc]}|j|vr|}}|xs |j|_ycc}wcc}w)zBFilter out deprioritized servers from a list of server candidates.N)rxrBrZ)rKdeprioritized_serverssddeprioritized_addressesrfiltereds r*_filter_serversz#TopologyDescription._filter_servers$s%&*&8&8D #>)@@H '/&D$2D2DD # 'Ss A+A0ct|ddr8|j}|r*||jkrtd||j|fzt |t r|j ||jtjk(rgS|jtjtjfvr |jS|r2|jj|}|r|jr|gSgS|j!||jtj"k(rt%|t&urx|j(D]0}|j*t,j.k(s!|g}|r||}|cS|r5|D]0}|j*t,j.k(s!|g}|r||}|cSgSt1j2|} |jtj4k7r:|| } | s0|r.|j!dt1j2|} || } |#| r!| j7|| j} |j9| S)aList of servers matching the provided selector(s). :param 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`. :param address: A server address to select. :param custom_selector: 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 rVrzF%s requires min wire version %d, but topology's min wire version is %dN)getattrrrVr isinstancerselection_hookrLrEr"rr#rxrMgetrUrr typerrB server_typer RSPrimaryrfrom_topology_descriptionr!with_server_descriptionsr) rKselectorrZcustom_selectorr common_wv descriptionrrirs r*apply_selectorz"TopologyDescription.apply_selector3s3* 8/ 300IY)B)BB(*-5x7P7PR[,\] h .  # #D )   !6!6 6I   M$8$8-:T:T#U U%% % 22488AK$/K4T4TK= \Z\ \ 23   !D!D Dh[bIb-- >>[%:%::$C&-c2J  %/#B~~)>)>>!d*"1#"6C" #I77=   !6!6 6 +I!6$$T*%??E $Y/   &9!:: = =>I**955r)cbtjd|t|j|S)aDoes this topology have any readable servers available matching the given read preference? :param 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 read_preference)rvalidate_read_preferencerIr)rKrs r*has_readable_serverz'TopologyDescription.has_readable_servers+ ''(9?K4&&788r)c@|jtjS)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_servers''(>(>??r)ct|jjd}dj|jj |j j|j|S)Nc|jSr1)rZ)rs r*z.TopologyDescription.__repr__..s BJJr))keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedr=rAformat __class__r$rC _topology_idrprs r*__repr__zTopologyDescription.__repr__sY2299;AVW>EE NN # #  # # 0 0  # #    r))rLrrM!dict[_Address, ServerDescription]rN Optional[str]rO Optional[int]rPOptional[ObjectId]rQrreturnNone)rr)rZrrbool)rZrrr.)rr.)rr)rr)rstr)rr)rr)rr)rlist[ServerDescription])rr)rzOptional[Selection]rrr1)r!Optional[list[ServerDescription]]rr)NNN) rrrZzOptional[_Address]rzOptional[_ServerSelector]rrrr)rrrr) r$r%r&rRrFr`rbrgrjrMpropertyrLrprNrOrPr3rxr|rGrrrrrrrrrrrrr(r)r*r.r.?s11?1( 1 ' 1 , 11 1f-^=4>  &0 ##::&&%%%%((YY\\PP'';;66 &JN E%F E  E$'+59CG M6M6$M63 M6 A M6 ! M6^BPAWAW9 @ r)r.c|j}|j}|j}|j}|j}|j }|j }|||<|tjk(rs|I||jk7r:tdj||j} |j| ||<ttj|||||jS|tjk(r|tj tj"fvrEt%|jj&dk(rtj}n=|j)|n+|tjtj*fvr t,|}|tj.k(r6|tj0tjfvr|j)|nw|tj2k(r|tj tj0fvr|j)|n/|tj4k(rt7|||||\}}}}n|tj8tj:tj<fvrt?|||\}}n|tj@k(r|tj tj0fvr|j)|tC|}nr|tj4k(rt7|||||\}}}}nJ|tj8tj:tj<fvrtE|||}n tC|}t||||||jS)anReturn an updated copy of a TopologyDescription. :param topology_description: the current TopologyDescription :param 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. zeclient is configured to connect to a replica set named '{}' but this node belongs to a set named '{}')errorrT)#rZrLrNrOrPrrMrErrrrdr.rCr"r Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPEr!Mongosrr_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr _check_has_primary#_update_rs_with_primary_from_member) topology_descriptionserver_descriptionrZrLset_namerOrPrrirs r*reres!((G)66M#44H*::O*::O$00K  2 2 4C&CL ,,,  H0B0S0S$S&AAG0AABE .88u8ECL"      3 3    --- ;11;3K3KL L'::@@AQF - 4 4  !4!4k6I6I J J9+FM --- {11;3F3FG G GGG  -;; ; ;11;3E3EF F GGG  K11 1JaX1?OK G]Ho[44k6K6K[M`M`a a&GX1' #M8 -== = ;11;3E3EF F GGG .s3M K11 1JaX1?OK G]Ho[44k6K6K[M`M`a a?XOabM/s3M  //  r)c |jtvsJ|j}t|j t|k(r|St |j D]}||vs|j ||jdk7rmt|t|j z }|jt|z }|dkDr)tt|t|t|}ng}|D]}||vst|||<t|j||j|j|j |j"S)zReturn an updated copy of a TopologyDescription. :param topology_description: the current TopologyDescription :param seedlist: a list of new seeds new ServerDescription that resulted from a hello call r)rLr,rMsetkeysr@rrrrrrJrr.rNrOrPrC)rseedlistrirZ new_hostsn_to_adds r*)_updated_topology_description_srv_pollingrs= - -1G GG G  2 2 4C 388:#h-'## # ( " GGG ))Q.MC O3 '55C@ a<fY/Xs9~1NOHH6 # ,W5CL6 ** --,,,,//  r)c| |j}n9||jk7r*|j|jt||||fS|j|jdkr|j |j f}||f}d|vrQd|vrA||kr<|jtd|d|||j<t||||fS|j }|j ||j |kDr|j }n|j |j f}||f}td|D}td|D}||kr<|jtd|d|||j<t||||fS|j }|j }|jD]a} | jtjus | j|jk7s:| jtd|| j<n|jD]} | |vst| || <t!||jz D]} |j| t||||fS)agUpdate topology description from a primary's hello response. Pass in a dict of ServerDescriptions, current replica set name, the ServerDescription we are processing, and the TopologyDescription's max_set_version and max_election_id if any. Returns (new topology type, new replica_set_name, new max_set_version, new max_election_id). Nz.t![1ai&(Q">![r8c38K|]}| tn|ywr1r rs r*r7z*_update_rs_from_primary..urr8z6primary marked stale due to discovery of newer primary)rNrrZrrX set_version election_idrdrtuplerArrr all_hostsrr) rirNrrOrPnew_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrs r*rrFs ->> /@@ @ "**+!#&(8/?ZZ**26H6Y6Y\^6^%7%C%CEWEcEc$d%4o$F ) )--2DGY2Y2D2O2O VWiVjkABTAUV3&../ *#.0@/Sbbb0< c !0=C > C-777   s #%5 XXr)c |J||jk7r&|j|jt |S|jr4|j|jk7r|j|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. )rNrrZmer)rirNrs r*rrs  '' '->>> "**+ c ""   #5#=#=ASAVAV#V "**+ c ""r)cltj}| |j}n.||jk7r|j|j||fS|j D]}||vst |||<|jr4|j|jk7r|j|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). )rErrNrrZrrr)rirNrrLrZs r*rrs"55M->> /@@ @ "**+...&//6 # ,W5CL6!3!;!;?Q?T?T!T "**+ * **r)c|jD]1}|jtjk(s!tj cStj S)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )rArrrrEr r)rir6s r*rrsEZZ\1 ==K11 1 66 61000r)N)rr.rrrr.)rr.rzlist[tuple[str, Any]]rr.) ri+MutableMapping[_Address, ServerDescription]rNrrrrOrrPrrzrs#    ";XX8.+$JuQx( ,9+@+@-BWBW*XXD!234d;L6MMNe e V  --=>>]>>=<<:: !e-eCTeeP(-(9N((VUY 4UY#UY*UY# UY ( UY B UYp# 4###*# #.+ 4+#+*+ +@ 1r)