i)idZddlmZddlmZmZmZmZmZm Z m Z ddl m Z er ddl mZddlmZe dZeeefZeeZGdd Zdd Zdd ZddZddZddZddZddZddZddZddZdS)zFCriteria to select some ServerDescriptions from a TopologyDescription.) annotations) TYPE_CHECKINGAnyMappingOptionalSequenceTypeVarcast) SERVER_TYPE)ServerDescription)TopologyDescriptionTceZdZdZeddZdd Zdd ZddZe ddZ e ddZ e ddZ ddZ d dZdS)! Selectionz.Input or output of a server selector function.topology_descriptionr returnc|j}d}|D]}|jtjkr|}nt ||j|j|SN) known_servers server_typer RSPrimaryrcommon_wire_version)clsrrprimarysds j/Users/user/workspace/sujinbaek/cqa-test-app/venv/lib/python3.11/site-packages/pymongo/server_selectors.pyfrom_topology_descriptionz#Selection.from_topology_description#sc,:   B~!6667 . 4     server_descriptionslist[ServerDescription]r Optional[int]rOptional[ServerDescription]c>||_||_||_||_dSr)rrrr)selfrrrrs r__init__zSelection.__init__3s)%9!#6  #6   rcDt|j||j|jSr)rrrr)r$rs rwith_server_descriptionsz"Selection.with_server_descriptions?s(  %':Dz>Selection.secondary_with_max_last_write_date..HsUBL^@_@_r)key)secondary_server_selectorrmax)r$ secondariess r"secondary_with_max_last_write_datez,Selection.secondary_with_max_last_write_dateDsD/55  * /5_5_ trcN|jr|jgng}||Sr)rr')r$ primariess rprimary_selectionzSelection.primary_selectionLs*&*l:T\NN ,,Y777rintc|jjSr)rheartbeat_frequencyr$s rr7zSelection.heartbeat_frequencyQs(<s r __getitem__zSelection.__getitem__\s'--rN)rr rr)rr rr rr!rr")rr rr)rr")rr)rr5)rr;)r>r5rr )__name__ __module__ __qualname____doc__ classmethodrr%r'r1propertyr4r7r:r=r@rrrr s88    [   7 7 7 7    888X8===X=777X7..........rr selectionrc|SrrGrHs rany_server_selectorrK`s rcJ|d|jDS)Nc g|] }|j | SrG) is_readable.0ss r z,readable_server_selector..fCCCqQ]CCCCrr'rrJs rreadable_server_selectorrUd.  - -CCI1CCC  rcJ|d|jDS)Nc g|] }|j | SrG) is_writablerOs rrRz,writable_server_selector..lrSrrTrJs rwritable_server_selectorrZjrVrcJ|d|jDS)Nc<g|]}|jtjk|SrG)rr RSSecondaryrOs rrRz-secondary_server_selector..rs'^^^qQ]kF]5]5]5]5]5]rrTrJs rr.r.ps.  - -^^I1^^^  rcJ|d|jDS)Nc<g|]}|jtjk|SrG)rr RSArbiterrOs rrRz+arbiter_server_selector..xs'\\\qQ]kF[5[5[5[5[5[rrTrJs rarbiter_server_selectorravs.  - -\\I1\\\  rc>t|pt|S)z6Like PrimaryPreferred but doesn't use tags or latency.)rZr.rJs r"writable_preferred_server_selectorrc|s #I . . V2KI2V2VVrtag_setTagSetc^dfd |fd|jDS)zAll servers matching one tag set. A tag set is a dict. A server matches if its tags are a superset: A server tagged {'a': '1', 'b': '2'} matches the tag set {'a': '1'}. The empty tag set {} matches any server. server_tagsMapping[str, Any]rr;cbD]\}}||vs |||krdSdS)NFT)items)rgr-valuerds r tags_matchz(apply_single_tag_set..tags_matchsL!--//  JC+%%S)9U)B)Buu*Ctrc4g|]}|j|SrG)tags)rPrQrls rrRz(apply_single_tag_set..s*HHHqZZ5G5GHHHHr)rgrhrr;rT)rdrHrls` @rapply_single_tag_setrosV  - -HHHHI1HHH  rtag_setsTagSetscb|D]}t||}|r|cS|gS)aNAll servers match a list of tag sets. tag_sets is a list of dicts. The empty tag set {} matches any server, and may be provided at the end of the list as a fallback. So [{'a': 'value'}, {}] expresses a preference for servers tagged {'a': 'value'}, but accepts any server if none matches the first preference. )ror')rprHrd with_tag_sets rapply_tag_setsrtsQ  +GY??        - -b 1 11rc<t|t|S)z2All near-enough secondaries matching the tag sets.)rtr.rprHs r#secondary_with_tags_server_selectorrws ($=i$H$H I IIrc<t|t|S)z.All near-enough members matching the tag sets.)rtrUrvs r member_with_tags_server_selectorrys ($rsML""""""QQQQQQQQQQQQQQQQQQ++++++A<<<<<<@@@@@@ GCLL c  6 =.=.=.=.=.=.=.=.@    WWWW *2222"JJJJ IIIIIIr