FCfh UdZddlmZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZdd lmZmZmZdd lmZdd lmZdd lmZdd l m!Z!Gdde Z"e"e#dZ$e$jJe$jLfZ'de(d<eeegeefZ)GddZ*ejVe$jLejXe$jZej\e$j^ej`e$j^ejbe$j^iZ2 ddZ3 ddZ4 ddZ5 ddZ6 d dZ7d!dZ8y)"z*Represent a deployment of MongoDB servers.) annotations)sample)AnyCallableListMappingMutableMapping NamedTupleOptionalcastMinKey)ObjectId)common)ConfigurationError)ReadPreference _AggWritePref _ServerMode)ServerDescription) Selection) SERVER_TYPE)_AddresscJeZdZUded<ded<ded<ded<ded<ded<y) _TopologyTypeintSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____annotations__\/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/pymongo/topology_description.pyrr*s# K L Lr'rztuple[int, int]SRV_POLLING_TOPOLOGIESceZdZ ddZddZddZddZddZddZddZ 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 dZd'dZ d( d)dZej4fd*dZd&dZd!dZy)+TopologyDescriptioncN||_||_||_||_||_||_d|_|jtjk7r|j|j}|sd|_ ytd|Drd|_ ytd|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__..hsUq22d:Uc34K|]}|jywr/r0r2s r(r5z/TopologyDescription.__init__..ks+6711+)_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)self topology_typeserver_descriptionsreplica_set_namemax_set_versionmax_election_idtopology_settingsrBs r(__init__zTopologyDescription.__init__=s&,!1$7! / /#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;valuesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressr?MIN_SUPPORTED_SERVER_VERSION)rFr4server_too_newserver_too_olds r(rAz*TopologyDescription._init_incompatible_erros1**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)r?rrFs r(check_compatiblez$TopologyDescription.check_compatibles#  ! !$T%;%;< < "r'c||jvSr/)r;)rFrVs 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)rFrV unknown_sds r( reset_serverz TopologyDescription.reset_servers(..w7BBD +D*==r'c6|jtjk(rtj}n |j}|jDcic]}|t |}}t |||j|j|j|jScc}w)z)rFrGrVsdss 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(rHz'TopologyDescription.server_descriptionss((--//r'c|jS)zThe type of this topology.)r9r[s r(rGz!TopologyDescription.topology_types"""r'c<tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )r@_fieldsr9r[s r(topology_type_namez&TopologyDescription.topology_type_names $$T%8%899r'c|jS)zThe replica set name.)r:r[s r(rIz$TopologyDescription.replica_set_names%%%r'c|jS)z1Greatest setVersion seen from a primary, or None.)r<r[s r(rJz#TopologyDescription.max_set_version$$$r'c|jS)z1Greatest electionId seen from a primary, or None.)r=r[s r(rKz#TopologyDescription.max_election_idror'c|jS)z)Minimum logical session timeout, or None.)rCr[s r(r1z3TopologyDescription.logical_session_timeout_minutess'''r'cv|jjDcgc]}|js|c}Scc}w)z)List of Servers of types besides Unknown.)r;rPrQrFr4s r( known_serversz!TopologyDescription.known_serverss/ 44;;=XaAWAWXXX66cVtd|jjDS)z7Whether there are any Servers of types besides Unknown.c3:K|]}|js|ywr/)rQr2s r(r5z8TopologyDescription.has_known_servers..s[ADZDZ1[s)rDr;rPr[s r(has_known_serversz%TopologyDescription.has_known_serverss$[d77>>@[[[r'cv|jjDcgc]}|js|c}Scc}w)zList of readable Servers.)r;rP is_readablerss r(rBz$TopologyDescription.readable_serverss- 44;;=OaOOOrucX|j}|rtd|jDSy)z3Minimum of all servers' max wire versions, or None.c34K|]}|jywr/)rTr2s r(r5z:TopologyDescription.common_wire_version..sFaq))Fr8N)rtrErFserverss r(common_wire_versionz'TopologyDescription.common_wire_versions,$$ F43E3EFF Fr'c.|jjSr/)r>heartbeat_frequencyr[s r(rz'TopologyDescription.heartbeat_frequencys&&:::r'c.|jjSr/)r>_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@@) rHround_trip_timerVrappendrEr>local_threshold_msr float)rF selectionround_trip_timesserverconfig_err_msgfastest thresholdr4s r(_apply_local_thresholdz*TopologyDescription._apply_local_threshold sI(*33 v~~>NNefjekkvxAxUxUwV"W(88  # #F$:$: ;  < &'++>>G 22 UA--.8YF    s)CNct|ddr8|j}|r*||jkrtd||j|fzt |t r|j ||jtjk(rgS|jtjtjfvr |jS|r&|jj|}|r|gSgStj |}|jtj"k7r||}|#|r!|j%||j}|j'|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 rRrzF%s requires min wire version %d, but topology's min wire version is %d)getattrrrRr isinstancerselection_hookrGr@r rr!rtrHgetrfrom_topology_descriptionrwith_server_descriptionsr)rFselectorrVcustom_selector common_wv descriptionrs r(apply_selectorz"TopologyDescription.apply_selectorsG( 8/ 300IY)B)BB(*-5x7P7PR[,\] h .  # #D )   !6!6 6I   M$8$8-:T:T#U U%% % 22488AK$/K= 7R 777=   !6!6 6 +I  &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_preferencerDr)rFrs r(has_readable_serverz'TopologyDescription.has_readable_serverPs+ ''(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_server`s''(>(>??r'ct|jjd}dj|jj |j j|j|S)Nc|jSr/)rV)sds r(z.TopologyDescription.__repr__..ls BJJr')keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedr;rPformat __class__r"r> _topology_idrlr}s r(__repr__zTopologyDescription.__repr__jsY2299;AVW>EE NN # #  # # 0 0  # #    r')rGrrH!dict[_Address, ServerDescription]rI Optional[str]rJ Optional[int]rKOptional[ObjectId]rLrreturnNone)rr)rVrrbool)rVrrr,)rr,)rr)rr)rstr)rr)rr)rr)rlist[ServerDescription])rr)rzOptional[Selection]rr)NN)rrrVzOptional[_Address]rzOptional[_ServerSelector]rr)rrrr)r"r#r$rMrAr\r^rcrfrHpropertyrGrlrIrJrKr1rtrxrBrrrrrrrrrrr&r'r(r,r,<s00?0( 0 ' 0 , 00 0d-^=4>  &0 ##::&&%%%%((YY\\PP;;66 *'+59 3636$363 36 ! 36jBPAWAW9 @ 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 '{}')errorrO)#rVrGrIrJrK server_typerHr@rrrr`r,r>r r Standalone LoadBalancerlenseedspopRSGhost_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_descriptionrVrGset_namerJrKrrers r(raras!((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)rGr*rHsetkeyslistrrrrrrErr,rIrJrKr>)rseedlistrerV 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|vrAd|vr1||kr,|j||j<t||||fS|j }|j ||j |kDr|j }n|j |j f}||f}td|D}td|D}||kr,|j||j<t||||fS|j }|j }|jD]W} | jtjus | j|jk7s:| j|| 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). Nc38K|]}| tn|ywr/r r3is r(r5z*_update_rs_from_primary..>![1ai&(Q">![r6c38K|]}| tn|ywr/r rs r(r5z*_update_rs_from_primary..?rr6)rIrrVrrT set_version election_idr`tuplerPrrr all_hostsrr) rerIrrJrKnew_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrs r(rrsp ->> /@@ @ "**+!#&(8/?ZZ**26H6Y6Y\^6^%7%C%CEWEcEc$d%4o$F ) )--2DGY2Y2D2O2O2Q&../)#.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. )rIrrVmer)rerIrs r(rrbs  '' '->>> "**+ 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). )r@rrIrrVrrr)rerIrrGrVs r(rrys"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. )rPrrrr@rr)rer4s r(rrsEZZ\1 ==K11 1 66 61000r'N)rr,rrrr,)rr,rzlist[tuple[str, Any]]rr,) re+MutableMapping[_Address, ServerDescription]rIrrrrJrrKrrzrs1"    "-OO8.+$JuQx( ,9+@+@-BWBW*XXD!234d;L6MMNv v x  --=>>]>>=<<:: !e-eCTeeP(-(9N((VKY 4KY#KY*KY# KY ( KY B KY\# 4###*# #.+ 4+#+*+ +@ 1r'