i)im 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&j'e&j(fZ)de*d<eeegeefZ+GddZ,e!j-e&j(e!j.e&j/e!j0e&j1e!j2e&j1e!j3e&j1iZ4d.dZ5d/dZ6d0d&Z7d1d(Z8d2d*Z9d3d,Z:d-S)4zRepresent 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 _ServerModeServerDescription) Selection) SERVER_TYPE)_AddresscLeZdZUded<ded<ded<ded<ded<ded<dS) _TopologyTypeintSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____annotations__n/Users/user/workspace/sujinbaek/cqa-test-app/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__..ks*UUq2d:UUUUUUr*c3$K|] }|jV dSr>r?rAs r+rDz/TopologyDescription.__init__..ns6++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)selfr0r1r3r5r7r9rOs 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).) rHvaluesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressrLMIN_SUPPORTED_SERVER_VERSION)rSrCserver_too_newserver_too_olds r+rNz*TopologyDescription._init_incompatible_errrs)*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)rLrrSs r+check_compatiblez$TopologyDescription.check_compatibles*  ! =$T%;<< < = =r*r]rboolc||jvSr>)rH)rSr]s r+ has_serverzTopologyDescription.has_servers$333r*c`|j|}t||S)z;A copy of this description, with one server marked Unknown.)rH to_unknownupdated_topology_description)rSr] 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*) rFrMr!r rHr/rGrIrJrK)rSr0sdss r+resetzTopologyDescription.resetsn  -"E E E)=MM /M]\$B[\\\"    "  !  !  #    r*c4|jS)z[dict of (address, :class:`~pymongo.server_description.ServerDescription`). )rHcopyrbs r+r1z'TopologyDescription.server_descriptionss(--///r*c|jS)zThe type of this topology.)rFrbs r+r0z!TopologyDescription.topology_types ""r*strc0tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )rM_fieldsrFrbs r+topology_type_namez&TopologyDescription.topology_type_names $T%899r*c|jS)zThe replica set name.)rGrbs r+r3z$TopologyDescription.replica_set_names %%r*c|jS)z1Greatest setVersion seen from a primary, or None.)rIrbs r+r5z#TopologyDescription.max_set_version $$r*c|jS)z1Greatest electionId seen from a primary, or None.)rJrbs r+r7z#TopologyDescription.max_election_idrzr*c|jS)z)Minimum logical session timeout, or None.)rPrbs r+r@z3TopologyDescription.logical_session_timeout_minutess ''r*list[ServerDescription]cHd|jDS)z)List of Servers of types besides Unknown.c g|] }|j | Sr)rXrAs r+ z5TopologyDescription.known_servers..s XXXaAWXXXXr*rHrWrbs r+ known_serversz!TopologyDescription.known_serverss(YX44;;==XXXXr*cbtd|jDS)z7Whether there are any Servers of types besides Unknown.c3(K|] }|j |VdSr>rrAs r+rDz8TopologyDescription.has_known_servers..s*[[ADZ[1[[[[[[r*)rQrHrWrbs r+has_known_serversz%TopologyDescription.has_known_serverss0[[d7>>@@[[[[[[r*cHd|jDS)zList of readable Servers.c g|] }|j | Sr)) is_readablerAs r+rz8TopologyDescription.readable_servers..sOOOaOOOOr*rrbs r+rOz$TopologyDescription.readable_serverss(PO44;;==OOOOr*cT|j}|rtd|jDSdS)z3Minimum of all servers' max wire versions, or None.c3$K|] }|jV dSr>)r[rAs r+rDz:TopologyDescription.common_wire_version..s%FFaq)FFFFFFr*N)rrRrSserverss r+common_wire_versionz'TopologyDescription.common_wire_versions:$  GFF43EFFFFF Ftr*c|jjSr>)rKheartbeat_frequencyrbs r+rz'TopologyDescription.heartbeat_frequencys&::r*c|jjSr>)rK_srv_max_hostsrbs r+ srv_max_hostsz!TopologyDescription.srv_max_hostss&55r* selectionOptional[Selection]c|sgSg}|jD]G}|j$d|jd|d|j}t|||jHt ||jjdz fd|jDS)Nzround_trip_time for server z is unexpectedly None: z , servers: g@@cVg|]%}tt|jz k#|&Sr))r floatround_trip_time)rBrCfastest thresholds r+rz>TopologyDescription._apply_local_threshold..s@   UA-..8YFF FFFr*)r1rr]rappendrRrKlocal_threshold_ms)rSrround_trip_timesserverconfig_err_msgrrs @@r+_apply_local_thresholdz*TopologyDescription._apply_local_threshold s I(*3 < G      2    r*NselectorOptional[_Address]custom_selectorOptional[_ServerSelector]crt|ddr.|j}|r%||jkrtd||j|fzt |t r|||jtj krgS|jtj tj fvr|j S|r.| |}|r|gngS|jtjkr]t!|t"urG|jD]+}|jt*jkr|g}|r ||}|cS,gSt/j|}|jtjkr ||}|%|r#|||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 rYrzF%s requires min wire version %d, but topology's min wire version is %d)getattrrrYr isinstancerselection_hookr0rMr#rr$rr1getr!typerrHrW server_typer RSPrimaryrfrom_topology_descriptionr"with_server_descriptionsr) rSrr]r common_wv descriptionsdrors r+apply_selectorz"TopologyDescription.apply_selectors( 8/ 3 3 0I Y)BBB(*-5x7PR[,\] h . . *  # #D ) ) )  !6 6 6I  M$8-:T#U U U% %  8224488AAK$/7K==R 7  !D D Dh[bIbIb/6688  >[%:::$C&3-oc22JJJ ; I7==  !6 6 6 ++I  &9 &!:: =>>I**9555r*read_preferencercptjd|t||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 r)rvalidate_read_preferencerQr)rSrs r+has_readable_serverz'TopologyDescription.has_readable_server^s4 '(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 )rrPRIMARYrbs r+has_writable_serverz'TopologyDescription.has_writable_serverns''(>???r*ct|jd}d|jj|jj|j|S)Nc|jSr>)r])rs r+z.TopologyDescription.__repr__..zsBJr*)keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedrHrWformat __class__r%rK _topology_idrwrs r+__repr__zTopologyDescription.__repr__xsY299;;AVAVWWW>EE N #  # 0  #     r*)r0rr1r2r3r4r5r6r7r8r9rr:r;)r:r;)r]rr:rd)r]rr:r/)r:r/)r:r2)r:r)r:rt)r:r4)r:r6)r:r8)r:r})r:rd)rrr:r})NN)rrr]rrrr:r})rrr:rd)r%r&r'rTrNrcrfrkrpr1propertyr0rwr3r5r7r@rrrOrrrrrrrrrrr)r*r+r/r/?s0000d----^====4444>>>>     &0000 ###X#:::X:&&&X&%%%X%%%%X%(((X(YYYXY\\\X\PPPXPX;;;X;666X6    *'+59 >6>6>6>6>6@BPAW99999 @@@@      r*r/topology_descriptionserver_descriptionrr:c$|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)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. Nzeclient is configured to connect to a replica set named '{}' but this node belongs to a set named '{}')errorrV)#r]r0r3r5r7rr1rMrrrrhr/rKr#r Standalone LoadBalancerlenseedspopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPEr"Mongosr r_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr!_check_has_primary#_update_rs_with_primary_from_member) rrr]r0set_namer5r7rrors r+riris2!(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. :param topology_description: the current TopologyDescription :param seedlist: a list of new seeds new ServerDescription that resulted from a hello call r)r0r-r1setkeyslistrrrrrrRrr/r3r5r7rK)rrror] 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*ro+MutableMapping[_Address, ServerDescription]r3r4r5r6r7r8r rBis r+rDz*_update_rs_from_primary..P.![![1ai&(((Q![![![![![![r*c3:K|]}|tn|VdSr>r rs r+rDz*_update_rs_from_primary..Qrr*z6primary marked stale due to discovery of newer primary)r3rr]rr[ set_version election_idrhrtuplerWrrr all_hostsrr) ror3rr5r7new_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrs r+rr"s -> /@ @ @ "*+++!#&&(8/?ZZ*26H6Y\^6^6^%7%CEWEc$d%4o$F ) ) )---2DGY2Y2Y2D2O2O VWiVVBTVV33&./ *#..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. )r3rr]mer)ror3rs r+rrzs{  ' ' '->>> "*++++  ,#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). )rMr r3rr]rrr)ror3rr0r]s r+rrs"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. )rWrrrrMr!r )rorCs r+rrsJZZ\\11 =K1 1 1 6 6 6 6 200r*N)rr/rrr:r/)rr/rrr:r/) rorr3r4rrr5r6r7r8r:r)rorr3r4rrr:r)rorr3r4rrr:r)rorr:r);__doc__ __future__rrandomrtypingrrrrr r r r bson.min_keyr bson.objectidrpymongorpymongo.errorsrrpymongo.read_preferencesrrrrpymongo.server_descriptionrpymongo.server_selectorsrpymongo.server_typerpymongo.typingsrrrangerMr#r"r-r(_ServerSelectorr/rrr!rr rrrrirrrrrr)r*r+r s#"""""                     """""";;;;;;;;XXXXXXXXXXXX888888......++++++$$$$$$J uuQxx( ,9+@-BW*XXXXXD!234d;L6MMNA A A A A A A A N  -=>]>=<: !eeeeP((((VUYUYUYUYp####.++++@ 1 1 1 1 1 1r*