o 'huk @s~UdZddlmZddlmZddlmZmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZmZdd lmZmZmZdd lmZdd lmZdd lm Z dd l!m"Z"Gddde Z#e#e$dZ%e%j&e%j'fZ(de)d<eeegeefZ*GdddZ+e j,e%j'e j-e%j.e j/e%j0e j1e%j0e j2e%j0iZ3d4ddZ4d5ddZ5d6d(d)Z6d7d+d,Z7d8d.d/Z8d9d1d2Z9d3S):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)ReadPreference _AggWritePref _ServerModeServerDescription) Selection) SERVER_TYPE)_Addressc@s>eZdZUded<ded<ded<ded<ded<ded<dS) _TopologyTypeintSingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknown LoadBalancedN)__name__ __module__ __qualname____annotations__r&r&X/var/www/html/olx_land/venv/lib/python3.10/site-packages/pymongo/topology_description.pyr-s  rztuple[int, int]SRV_POLLING_TOPOLOGIESc@s8eZdZdMddZdNddZdNddZdOddZdPddZdQddZdRddZ e dSd d!Z e dTd#d$Z e dUd%d&Z e dVd'd(Ze dWd)d*Ze dVd+d,Ze dXd.d/Ze dYd0d1Ze dXd2d3Ze dVd4d5Ze dSd6d7Ze dSd8d9ZdZd >d[d\dCdDZejfd]dGdHZdYdIdJZdTdKdLZd>S)^TopologyDescription topology_typerserver_descriptions!dict[_Address, ServerDescription]replica_set_name Optional[str]max_set_version Optional[int]max_election_idOptional[ObjectId]topology_settingsrreturnNonecCs||_||_||_||_||_||_d|_|jtjkr| |j }|s)d|_ dSt dd|Dr7d|_ dSt dd|D|_ dS)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 Ncss|]}|jduVqdSNlogical_session_timeout_minutes.0sr&r&r' kz/TopologyDescription.__init__..cs|]}|jVqdSr7r8r:r&r&r'r=ns )_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,r.r0r2r4rIr&r&r'__init__@s"    zTopologyDescription.__init__cCs|jD]L}|js q|jduo|jtjk}|jduo |jtjk}|r7d|jd|jdp.d|jtjf|_ q|rQd|jd|jdpDd|jtjtj f|_ dSqdS)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).) rBvaluesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressrFMIN_SUPPORTED_SERVER_VERSION)rMr<server_too_newserver_too_oldr&r&r'rHrs>        z*TopologyDescription._init_incompatible_errcCs|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)rFrrMr&r&r'check_compatibles z$TopologyDescription.check_compatiblerVrboolcCs ||jvSr7)rB)rMrVr&r&r' has_servers zTopologyDescription.has_servercCs|j|}t||S)z;A copy of this description, with one server marked Unknown.)rB to_unknownupdated_topology_description)rMrV unknown_sdr&r&r' reset_servers z TopologyDescription.reset_servercCsD|jtjkr tj}n|j}dd|jD}t|||j|j|j|j S)zz-TopologyDescription.reset..) r@rGrrrBr*rArCrDrE)rMr+sdsr&r&r'resets zTopologyDescription.resetcCs |jS)z[dict of (address, :class:`~pymongo.server_description.ServerDescription`). )rBcopyrZr&r&r'r,s z'TopologyDescription.server_descriptionscC|jS)zThe type of this topology.)r@rZr&r&r'r+z!TopologyDescription.topology_typestrcCs tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )rG_fieldsr@rZr&r&r'topology_type_names z&TopologyDescription.topology_type_namecCrg)zThe replica set name.)rArZr&r&r'r.rhz$TopologyDescription.replica_set_namecCrg)z1Greatest setVersion seen from a primary, or None.)rCrZr&r&r'r0rhz#TopologyDescription.max_set_versioncCrg)z1Greatest electionId seen from a primary, or None.)rDrZr&r&r'r2rhz#TopologyDescription.max_election_idcCrg)z)Minimum logical session timeout, or None.)rJrZr&r&r'r9rhz3TopologyDescription.logical_session_timeout_minuteslist[ServerDescription]cCdd|jDS)z)List of Servers of types besides Unknown.cSg|]}|jr|qSr&rQr:r&r&r' rcz5TopologyDescription.known_servers..rBrPrZr&r&r' known_serversz!TopologyDescription.known_serverscCstdd|jDS)z7Whether there are any Servers of types besides Unknown.css|]}|jr|VqdSr7ror:r&r&r'r=r>z8TopologyDescription.has_known_servers..)rKrBrPrZr&r&r'has_known_serverssz%TopologyDescription.has_known_serverscCrm)zList of readable Servers.cSrnr&) is_readabler:r&r&r'rprcz8TopologyDescription.readable_servers..rqrZr&r&r'rIrsz$TopologyDescription.readable_serverscCs"|j}|rtdd|jDSdS)z3Minimum of all servers' max wire versions, or None.csr?r7)rTr:r&r&r'r=sz:TopologyDescription.common_wire_version..N)rrrLrMserversr&r&r'common_wire_versionsz'TopologyDescription.common_wire_versioncC|jjSr7)rEheartbeat_frequencyrZr&r&r'rzz'TopologyDescription.heartbeat_frequencycCryr7)rE_srv_max_hostsrZr&r&r' srv_max_hostsr{z!TopologyDescription.srv_max_hosts selectionOptional[Selection]csz|sgSg}|jD]}|jdur!d|jd|d|j}t|||jq t||jjdfdd|jDS)Nzround_trip_time for server z is unexpectedly None: z , servers: g@@cs$g|]}tt|jkr|qSr&)r floatround_trip_timer:fastest thresholdr&r'rps z>TopologyDescription._apply_local_threshold..)r,rrVrappendrLrElocal_threshold_ms)rMr~round_trip_timesserverconfig_err_msgr&rr'_apply_local_threshold s    z*TopologyDescription._apply_local_thresholdNselectorOptional[_Address]custom_selectorOptional[_ServerSelector]cCst|ddr|j}|r||jkrtd||j|ft|tr$|||jtj kr,gS|jtj tj fvr8|j S|rH| |}|rF|gSgSt|}|jtjkrW||}|dure|re|||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 %dN)getattrrxrRr isinstancerselection_hookr+rGr rr!rrr,getrfrom_topology_descriptionrwith_server_descriptionsr)rMrrVr common_wv descriptionr~r&r&r'apply_selectors2         z"TopologyDescription.apply_selectorread_preferencercCstd|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_preferencerKr)rMrr&r&r'has_readable_serverSs z'TopologyDescription.has_readable_servercCs |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 )rrPRIMARYrZr&r&r'has_writable_servercs z'TopologyDescription.has_writable_servercCs0t|jddd}d|jj|jj|j|S)NcSrgr7)rV)sdr&r&r'osz.TopologyDescription.__repr__..)keyz-<{} id: {}, topology_type: {}, servers: {!r}>) sortedrBrPformat __class__r"rE _topology_idrkrvr&r&r'__repr__mszTopologyDescription.__repr__)r+rr,r-r.r/r0r1r2r3r4rr5r6)r5r6)rVrr5r\)rVrr5r*)r5r*)r5r-)r5r)r5ri)r5r/)r5r1)r5r3)r5rl)r5r\)r~rr5rl)NN)rrrVrrrr5rl)rrr5r\)r"r#r$rNrHr[r]rarer,propertyr+rkr.r0r2r9rrrtrIrxrzr}rrrrrrrr&r&r&r'r*?sN  2 /                 5  r*topology_descriptionserver_descriptionrr5c Cs|j}|j}|j}|j}|j}|j}|}|||<|tjkrD|dur9||jkr9t d ||j} |j | d||<t tj|||||j S|tjkro|tjtjfvrct|j jdkr]tj}n||n |tjtjfvrot|}|tjkr|tjtjfvr||nv|tjkr|tjtjfvr||nc|tjkrt|||||\}}}}nQ|tjtjtjfvrt|||\}}n>|tj kr|tjtjfvr||t!|}n'|tjkrt|||||\}}}}n|tjtjtjfvrt"|||}nt!|}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 '{}')errorrO)#rVr+r.r0r2 server_typer,rGrrrr^r*rEr 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) rrrVr+set_namer0r2rrdrr&r&r'r_s               r_seedlistlist[tuple[str, Any]]cCs|jtvsJ|}t|t|kr|St|D] }||vr(||q|jdkrRt|t|}|jt|}|dkrPt t |t |t|}ng}|D] }||vr`t |||<qTt |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)r+r)r,setkeyslistrr}rrrrLrr*r.r0r2rE)rrrdrV new_hostsn_to_addr&r&r')_updated_topology_description_srv_pollings4    rrd+MutableMapping[_Address, ServerDescription]r.r/r0r1r2r3|j|jf}||f}t dd|D}t dd|D}||kr|td|d|||j<t||||fS|j}|j}| D]} | j t j ur| j|jkr| td|| j<nq|jD] } | |vrt| || <qt||jD]} || qt||||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.csrr7r rr&r&r'r=Frz6primary marked stale due to discovery of newer primary)r.rrVrrT set_version election_idr^rtuplerPrrr all_hostsrr) rdr.rr0r2new_election_tuplemax_election_tuplenew_election_safemax_election_safer new_addressaddrr&r&r'rsb              rrcCsP|dusJ||jkr||jt|S|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. N)r.rrVmer)rdr.rr&r&r'ros   rtuple[int, Optional[str]]cCsztj}|dur |j}n||jkr||j||fS|jD] }||vr)t|||<q|jr9|j|jkr9||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). N)rGrr.rrVrrr)rdr.rr+rVr&r&r'rs      r$Mapping[_Address, ServerDescription]cCs*|D] }|jtjkrtjSqtjS)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )rPrrrrGrr)rdr<r&r&r'rs   rN)rr*rrr5r*)rr*rrr5r*) rdrr.r/rrr0r1r2r3r5r)rdrr.r/rrr5r)rdrr.r/rrr5r)rdrr5r):__doc__ __future__rrandomrtypingrrrrrr r r bson.min_keyr bson.objectidrpymongorpymongo.errorsrrpymongo.read_preferencesrrrpymongo.server_descriptionrpymongo.server_selectorsrpymongo.server_typerpymongo.typingsrrrangerGr rr)r%_ServerSelectorr*rrrrrrrrr_rrrrrr&r&r&r's@  (       > h + X