hfdZddlmZGddeZdZdZdZdZd Z d Z d Z d Z d Z dZy)zFCriteria to select some ServerDescriptions from a TopologyDescription.) SERVER_TYPEcreZdZdZedZdZdZdZe dZ e dZ e dZ d Z e Zd Zy ) Selectionz.Input or output of a server selector function.c|j}d}|D]#}|jtjk(s!|}nt ||j|j |SN) known_servers server_typer RSPrimaryrcommon_wire_version)clstopology_descriptionrprimarysds [/var/www/html/ranktracker/api/venv/lib/python3.12/site-packages/pymongo/server_selectors.pyfrom_topology_descriptionz#Selection.from_topology_descriptionsb,::  B~~!6!66  --;;-AA " "c<||_||_||_||_yr)r server_descriptionsrr )selfr rr rs r__init__zSelection.__init__%s# %9!#6  #6 rcZt|j||j|jSr)rr r r)rrs rwith_server_descriptionsz"Selection.with_server_descriptions/s*22,11' 'rcbt|}|jrt|jdSy)Nc|jSr)last_write_date)rs rz>Selection.secondary_with_max_last_write_date..9s b&8&8r)key)secondary_server_selectorrmax)r secondariess r"secondary_with_max_last_write_datez,Selection.secondary_with_max_last_write_date5s2/5  * *{668: : +rcZ|jr |jgng}|j|Sr)rr)r primariess rprimary_selectionzSelection.primary_selection;s&&*llT\\N ,,Y77rc.|jjSr)r heartbeat_frequencyrs rr&zSelection.heartbeat_frequency@s((<<s rwritable_server_selectorrEZrArBc|j|jDcgc]!}|jtjk(r|#c}Scc}wr)rrr r RSSecondaryr>s rrr_sG  - -11 6q MM[44 4  6 77 6&Ac|j|jDcgc]!}|jtjk(r|#c}Scc}wr)rrr r RSArbiterr>s rarbiter_server_selectorrKesG  - -11 4q MM[22 2  4 55 4rHc2t|xs t|S)z6Like PrimaryPreferred but doesn't use tags or latency.)rErr9s r"writable_preferred_server_selectorrMks $Y / 1 %i 02rcfd}|j|jDcgc]}||js|c}Scc}w)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. cRjD]\}}||vs |||k7syy)NFT)items) server_tagsrvaluetag_sets r tags_matchz(apply_single_tag_set..tags_matchys8!--/ JC+%S)9U)B r)rrtags)rSr:rTr?s` rapply_single_tag_setrVqsA  - -11HqZ5GH JJHs AAcV|D]}t||}|s|cS|jgS)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. )rVr)tag_setsr:rS with_tag_sets rapply_tag_setsrZs; +GY?    - -b 11rc,t|t|S)z2All near-enough secondaries matching the tag sets.)rZrrXr:s r#secondary_with_tags_server_selectorr]s ($=i$H IIrc,t|t|S)z.All near-enough members matching the tag sets.)rZr@r\s r member_with_tags_server_selectorr_s ($rbsRM+:.:.zE E 7 5 2 J&2"J Ir