`_. **Module Overview:** :: BandwidthFile - Tor bandwidth authority measurements. .. versionadded:: 1.8.0 N) _mappings_for Descriptor) OrderedDicts=====s====c\rSrSrSrSrSrg) RecentStats)a1 Statistical information collected over the last 'data_period' (by default five days). :var int consensus_count: number of consensuses published during this period :var int prioritized_relays: number of relays prioritized to be measured :var int prioritized_relay_lists: number of times a set of relays were prioritized to be measured :var int measurement_attempts: number of relay measurements we attempted :var int measurement_failures: number of measurement attempts that failed :var RelayFailures relay_failures: number of relays we failed to measure chSUlSUlSUlSUlSUl[ 5UlgN)consensus_countprioritized_relaysprioritized_relay_listsmeasurement_attemptsmeasurement_failures RelayFailuresrelay_failuresselfs X/home/james-whalen/.local/lib/python3.13/site-packages/stem/descriptor/bandwidth_file.py__init__RecentStats.__init__:s4D"D#'D $D $D'/D)r rrr r rN__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rrrr)s  *rrc\rSrSrSrSrSrg)rCa Summary of the number of relays we were unable to measure. :var int no_measurement: number of relays that did not have any successful measurements :var int insuffient_period: number of relays whos measurements were collected over a period that was too small (1 day by default) :var int insufficient_measurements: number of relays we did not collect enough measurements for (2 by default) :var int stale: number of relays whos latest measurement is too old (5 days by default) c<SUlSUlSUlSUlgr )no_measurementinsuffient_periodinsufficient_measurementsstalers rrRelayFailures.__init__Qs!D!D%)D"DJr)r%r$r#r&NrrrrrrCs  rrcU$r rvals r_strr+[s *rcTU(a UR5(a [U5$S$r )isdigitintr)s r_intr/_sckkmmS6$6rcv[RRRU5$![a gf=fr )stemutil str_tools_parse_iso_timestamp ValueErrorr)s r_dater6cs4 99   3 3C 88  s (+ 88cVUb%[[SURS555$S$)Nc"UR5$r )strip)vs r_csv..ks AGGIr,)listmapsplitr)s r_csvrAjs';>?c%syy~6 7TPTTrversionsoftwaresoftware_versionearliest_bandwidthlatest_bandwidth created_at file_created generated_atgenerator_startedconsensus_sizenumber_consensus_relayseligible_countnumber_eligible_relayseligible_percentpercent_eligible_relays min_countminimum_number_eligible_relays min_percentminimum_percent_eligible_relaysscanner_countrydestinations_countriestime_to_report_half_networkzrecent_stats.consensus_countrecent_consensus_countz$recent_stats.prioritized_relay_listsrecent_priority_list_countrecent_priority_relay_count recent_measurement_attempt_count recent_measurement_failure_count(recent_measurements_excluded_error_count'recent_measurements_excluded_near_count&recent_measurements_excluded_few_count&recent_measurements_excluded_old_count)zrecent_stats.prioritized_relaysz!recent_stats.measurement_attemptsz!recent_stats.measurement_failuresz*recent_stats.relay_failures.no_measurementz-recent_stats.relay_failures.insuffient_periodz5recent_stats.relay_failures.insufficient_measurementsz!recent_stats.relay_failures.stale1.0.0c+F# [UR5U40UD6v g7f)a Iterates over the bandwidth authority metrics in a file. :param file descriptor_file: file with descriptor content :param bool validate: checks the validity of the descriptor's content if **True**, skips these checks otherwise :param dict kwargs: additional arguments for the descriptor constructor :returns: :class:`stem.descriptor.bandwidth_file.BandwidthFile` object :raises: * **ValueError** if the contents is malformed and validate is **True** * **IOError** if the file can't be read N) BandwidthFileread)descriptor_filevalidatekwargss r _parse_filerhs" o**,hA&AAs!c L[5n[R"UR55nUR 5 SnSnUR 5R 5nU(dOU[ [4;aOqU(dSU;aOcSU;aH[RRRU5RSS5upxXU'US:XaUnO[SU-5eUS- nMX l[5Ul["R%5Hwun upUn U RS5SSHn ['X5n M [)XRS5SU "UR+U [,R+U 5555 My UbUS:wa [S 5egg) Nsnode_id===rBz3Header expected to be key=value pairs, but had '%s'.z3The 'version' header must be in the second position)rioBytesIO get_bytesreadliner9 HEADER_DIVHEADER_DIV_ALTr1r2r3 _to_unicoder@r5headerr recent_stats HEADER_ATTRitemsgetattrsetattrgetHEADER_DEFAULT) descriptorentriesrvcontentindex version_indexlinekeyvalue full_attrkeywordclsobjattrs r _parse_headerrs =& JJz++- .'  %-     # # %D  *n- -  t+  t|99&&2248>>sAFjcSk  LtS TT QJE' *'M*#.#4#4#6i' C$Sb) C c* C%b)3vzz'>CUCUV_C`/a+bc $7=A#5 J KK$6rc$[R"UR55R5R 5nUR 5(a.[ R R[U55Ul g[SU-5e)Nz3First line should be a unix timestamp, but was '%s') rorprqrrr9r-datetimeutcfromtimestampr. timestampr5)r~r first_lines r_parse_timestamprshzz*..01::<BBD*#,,==c*oNJ JZW XXrc[R"UR55nURS:XaUR 5 O]UR 5R 5S[ [4;a0UR 5R 5S[ [4;aM00nUR5Hn[RRRUR 55n[[SU55nURSS5R!S5nU(d[#SU-5eXc;a[#SU-5eXSU'M X0lg)Nra measurementnode_id$z+Every meaurement must include 'node_id': %szBRelay %s is listed multiple times. It should only be present once.)rorprqrBrrr9rsrt readlinesr1r2r3rudictrr|lstripr5 measurements)r~rrrrr fingerprints r _parse_bodyrs JJz++- .'7"      " " $R^,L L      " " $R^,L L,!d 99   * *4::< 8D  mT2 3D((9b)005K  DtK LL  $ [^ii jj $")rc ^\rSrSrSrSrS\40\40\4S.r \ R\ "\ R5VVVs/sH oS[44PM snnn55 \S Sj5rS U4SjjrSrU=r$s snnnf) rcia$ Tor bandwidth authority measurements. :var dict measurements: **\*** mapping of relay fingerprints to their bandwidth measurement metadata :var dict header: **\*** header metadata :var datetime timestamp: **\*** time when these metrics were published :var str version: **\*** document format version :var str software: application that generated these metrics :var str software_version: version of the application that generated these metrics :var datetime earliest_bandwidth: time of the first sampling :var datetime latest_bandwidth: time of the last sampling :var datetime created_at: time when this file was created :var datetime generated_at: time when collection of these metrics started :var int consensus_size: number of relays in the consensus :var int eligible_count: relays with enough measurements to be included :var int eligible_percent: percentage of consensus with enough measurements :var int min_count: minimum eligible relays for results to be provided :var int min_percent: minimum measured percentage of the consensus :var str scanner_country: country code where this scan took place :var list destinations_countries: all country codes that were scanned :var int time_to_report_half_network: estimated number of seconds required to measure half the network, given recent measurements :var RecentStats recent_stats: statistical information collected over the last 'data_period' (by default five days) **\*** attribute is either required when we're parsed with validation or has a default value, others are left as **None** if undefined zbandwidth-fileN)rrvrrc &U(a[SUR-5eUb [U5O [5nURS[ [ [ R "5555nURS/5nURS[RS55n/nSU;a8UR[RRRU55 US:XaU(a [S5eUS:waSU;aJUR[RRRSURS5-55 UR5HDupUR[RRRU <SU <355 MF UR[ 5 UH;n UR[RRRU 55 M= S R#U5$) a Creates descriptor content with the given attributes. This descriptor type differs somewhat from others and treats our attr/exclude attributes as follows... * 'timestamp' is a reserved key for our mandatory header unix timestamp. * 'content' is a reserved key for our bandwidth measurement lines. * All other keys are treated as header fields. For example... :: BandwidthFile.content({ 'timestamp': '12345', 'version': '1.2.0', 'content': [], }) zSigning of %s not implementedrrrBraz2Headers require BandwidthFile version 1.1 or laterz version=%srl )NotImplementedErrorrrpopstrr.timer|r}appendr1r2r3 _to_bytesr5ryrsjoin) rrexcludesignrvrrrBlineskr:rs rrBandwidthFile.content4s0  ?#,, N OO"&"2[  F ;C ,<(=>IjjB'GjjN$6$6y$ABG E'! ll499&&00;<'f K LL G  ' ! TYY((22<&**YBW3WXY,,.$! TYY((22a3CDE! ll:  ll499&&00=> ::e rc>[[U] X(+S9 U(a%[US5 [ US5 [ US5 gg)N) lazy_load)superrcrrrr)r raw_contentrf __class__s rrBandwidthFile.__init__ks= -' 'NtT"D$$r)NrFF)rrrrrTYPE_ANNOTATION_NAMErrr ATTRIBUTESupdaterrxkeys classmethodrrr __classcell__).0rrrs000@rrcrcs#J*()=!%*  Dk>N>N>PQ>Pt]34>PQRS44lsRsA1rcr)rrrorstem.util.str_toolsr1stem.descriptorrr collectionsr ImportErrorstem.util.ordereddictrsrtobjectrrr+r/r6rArxr}rhrrrrcrrrrs$   0% *&*4F0 7U ' i '  z4 ' )40 '-u5')51'''&.'.5' -t4!'"0$7#'$0$7%'&3T:''.'./'05t<1'8 "?!F9'<!#;T"B='>)+G*N?'@'DT%J(JD'Q(JD'Q1[]a0b4]_c3d