hQZ dZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZed gd ed Zej"ej$fZGd d eZej,ej$ej.ej0ej2ej4ej6ej4ej8ej4iZdZdZdZ dZ!dZ"dZ#y)z*Represent a deployment of MongoDB servers.) namedtuple)common)ConfigurationError)ReadPreferenceServerDescription) Selection) SERVER_TYPE TopologyType)SingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknownceZdZdZdZdZdZdZdZe dZ e dZ e d Z e d Z e d Ze d Ze d Ze dZe dZe dZe dZddZej.fdZdZdZy)TopologyDescriptionc,||_||_||_||_||_||_d|_|jjD]}|js|jduxr|jtjkD}|jduxr|jtjk} |rAd|jd|jd|jtjfz|_| sd|jd|jd|jtjtjfz|_n|j } | sd|_yt%d| Drd|_yt'd| D|_y)aRepresentation of a deployment of MongoDB servers. :Parameters: - `topology_type`: initial type - `server_descriptions`: dict of (address, ServerDescription) for all seeds - `replica_set_name`: replica set name or None - `max_set_version`: greatest setVersion seen from a primary, or None - `max_election_id`: greatest electionId seen from a primary, or None - `topology_settings`: a TopologySettings 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).c38K|]}|jduywNlogical_session_timeout_minutes.0ss _/var/www/html/ranktracker/api/venv/lib/python3.12/site-packages/pymongo/topology_description.py z/TopologyDescription.__init__..os#,22d:,c34K|]}|jywrrrs rrz/TopologyDescription.__init__..ss +F/0,-+L+L+F)_topology_type_replica_set_name_server_descriptions_max_set_version_max_election_id_topology_settings_incompatible_errvaluesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressMIN_SUPPORTED_SERVER_VERSIONreadable_servers_ls_timeout_minutesanymin) self topology_typeserver_descriptionsreplica_set_namemax_set_versionmax_election_idtopology_settingsrserver_too_newserver_too_oldr1s r__init__zTopologyDescription.__init__%s$,!1$7! / /#4"&**113 A)) ""$.K&&)J)JJ ""$.K&&)J)JJ  Ayy|QYYq\))6+L+LNN&  Lyy|QYYq\))88::<<&A R 00'+D $ ,*,,'+D $'*+F4D+F(FD $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)r(rr5s rcheck_compatiblez$TopologyDescription.check_compatiblevs#  ! !$T%;%;< < "r?c||jvSr)r$)r5r/s 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)r5r/ unknown_sds r reset_serverz TopologyDescription.reset_servers(..w7BBD +D*==r?c|jtjk(rtj}n |j}t d|j D}t |||j|j|j|jS)z.s#=.w78=s) r" TOPOLOGY_TYPErr dictr$rr#r%r&r')r5r6sdss rresetzTopologyDescription.resets   -"E"E E)==M //M="&";";==#    " "  ! !  ! !  # # % %r?c6|jjS)zRDict of (address, :class:`~pymongo.server_description.ServerDescription`).)r$copyrAs rr7z'TopologyDescription.server_descriptionss((--//r?c|jS)zThe type of this topology.)r"rAs rr6z!TopologyDescription.topology_types"""r?c<tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )rL_fieldsr"rAs rtopology_type_namez&TopologyDescription.topology_type_names $$T%8%899r?c|jS)zThe replica set name.)r#rAs rr8z$TopologyDescription.replica_set_names%%%r?c|jS)z1Greatest setVersion seen from a primary, or None.)r%rAs rr9z#TopologyDescription.max_set_version$$$r?c|jS)z1Greatest electionId seen from a primary, or None.)r&rAs rr:z#TopologyDescription.max_election_idrXr?c|jS)z)Minimum logical session timeout, or None.)r2rAs rrz3TopologyDescription.logical_session_timeout_minutess'''r?ct|jjDcgc]}|jr|c}Scc}w)z)List of Servers of types besides Unknown.)r$r)r*r5rs r known_serversz!TopologyDescription.known_serverss; 44;;=+a))+ ++s5cVtd|jjDS)z7Whether there are any Servers of types besides Unknown.c38K|]}|jr|ywr)r*rs rrz8TopologyDescription.has_known_servers..s .,,.r)r3r$r)rAs rhas_known_serversz%TopologyDescription.has_known_serverss,.d77>>@.. .r?cv|jjDcgc]}|js|c}Scc}w)zList of readable Servers.)r$r) is_readabler\s rr1z$TopologyDescription.readable_serverss- 44;;=OaOOOs66cX|j}|rtd|jDSy)z3Minimum of all servers' max wire versions, or None.c34K|]}|jywr)r-rs rrz:TopologyDescription.common_wire_version..sFaq))Fr!N)r]r4r5serverss rcommon_wire_versionz'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr?c.|jjSr)r'heartbeat_frequencyrAs rriz'TopologyDescription.heartbeat_frequencys&&:::r?Nc0fd}t|ddr8j}|r*||jkrtd||j|fzjt j k(r jS|r&jj|}|r|gSgSjt jk(rtj}n|tj}|#|r!|j||j}||S)Nc|sgSj}td|jD}|jdz }|jDcgc]}|j|z |kr|c}Scc}w)Nc34K|]}|jywr)round_trip_timers rrzTTopologyDescription.apply_selector..apply_local_threshold..sJ&'!!Jr!g@@)r'r4r7local_threshold_msrm) selectionsettingsfastest thresholdrr5s rapply_local_thresholdzATopologyDescription.apply_selector..apply_local_thresholds ..HJ+4+H+HJJG 33f@I$Y//r?cdtjd|t|j|dS)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 read_preferenceN)rvalidate_read_preferencer3r|)r5r~s rhas_readable_serverz'TopologyDescription.has_readable_server s- ''(9?K4&&=>>r?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 )rrPRIMARYrAs rhas_writable_serverz'TopologyDescription.has_writable_servers''(>(>??r?c t|jjd}d|jjd|j j d|jd|d S)Nc|jSr)r/)sds rz.TopologyDescription.__repr__..'s  r?)key)sortedr$r) __class____name__r' _topology_idrUres r__repr__zTopologyDescription.__repr__$sR2299;24 NN # #T%<%<%I%I  # #W. .r?r)r __module__ __qualname__r>rBrDrIrOr7propertyr6rUr8r9r:rr]r`r1rgrir|rrrrrr?rrr$s#OFb=4> %&0 ##::&&%%%%((++ .. PP;;)0V3A2H2H?"@.r?rc|j}|j}|j}|j}|j}|j }|j }|||<|tjk(rj|@||jk7r1td|d|jd} |j| ||<ttj|||||jS|tjk(r|tjk(rEt!|jj"dk(rtj}n=|j%|n+|tjtj&fvr t(|}|tj*k(r6|tj,tjfvr|j%|nw|tj.k(r|tjtj,fvr|j%|n/|tj0k(rt3|||||\}}}}n|tj4tj6tj8fvrt;|||\}}n|tj<k(r|tjtj,fvr|j%|t?|}nr|tj0k(rt3|||||\}}}}nJ|tj4tj6tj8fvrtA|||}n t?|}t||||||jS)aReturn an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `server_description`: a new ServerDescription that resulted from an ismaster call Called after attempting (successfully or not) to call ismaster on the server at server_description.address. Does not modify topology_description. z8client is configured to connect to a replica set named 'z(' but this node belongs to a set named '')errorr)!r/r6r8r9r: server_typer7rLr rrFrr'rr StandalonelenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPErMongosr RSPrimary_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr_check_has_primary#_update_rs_with_primary_from_member) topology_descriptionserver_descriptionr/r6set_namer9r:rrNrs rrGrG8s'!((G)66M#44H*::O*::O$00K  2 2 4C&CL ,,,  .???&0AACDE.88u8ECL"      3 3 5 5 --- +00 0'::@@AQF - 4 4  !4!4k6I6I J J9+FM --- {11;3F3FG G GGG  -;; ; ;11;3E3EF F GGG  K11 1!88@8J8G8G !I ]    ''%%##%%'HX1'3 #M8 -== = ;11;3E3EF F GGG .s3M K11 1!88@8J8G8G !I ]    ''%%##%%@X13M /s3M }"'..3FF  HHr?c|j}t|jt|k(r|S|D]}||vst|||<t |jD]}||vs|j |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 an ismaster call ) r7setkeysrlistrrr6r8r9r:r')rseedlistrNr/s r)_updated_topology_description_srv_pollingrs  2 2 4C 388:#h-'##6 # ,W5CL6  # ( " GGG  ** --,,,,//  11r?c4| |j}n9||jk7r*|j|jt||||fS||f}d|jvrKd|vr;||jkDr,|j ||j<t||||fS|j }|j||j|kDr |j}|jD]W}|jtjus |j|jk7s:|j ||j<n|jD]}||vst|||<t||jz D]}|j|t||||fS)ajUpdate topology description from a primary's ismaster 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). N)r8rr/relection_tuplerF election_id set_versionr)rr r all_hostsrr) rNr8rr9r:max_election_tupleserver new_addressaddrs rrrs->> /@@ @ "**+"3' ! ! )/9 %444 * *"%7%F%FF/A.K.K.MC"** +&s+$##% % -88&&2   * *_ <,88**,   +"7"7 7NN&8&@&@@#)"3"3"5C  *33> c !0=C > C-777   s #    r?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. )r8rr/mer)rNr8rs rrrs  '' '->>> "**+ c ""     $ $(:(=(= = "**+ 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). )rLr r8rr/rrr)rNr8rr6r/s rrr/s"55M->> /@@ @ "**+...&//6 # ,W5CL6   & &*<*?*? ? "**+ * **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. )r)rr rrLrr )rNrs rrrOsEZZ\1 ==K11 1 66 61000r?N)$__doc__ collectionsrpymongorpymongo.errorsrpymongo.read_preferencesrpymongo.server_descriptionrpymongo.server_selectorsr pymongo.server_typer rangerLrrSRV_POLLING_TOPOLOGIESobjectrrrrrr rrrrGrrrrrrr?rrs1"-38.+8 >,789>qC (//1F1FGF.&F.X --=>>]>>=<<:: !pHf1DHV#.+@ 1r?