<#(i01 ddlZddlZddlZddlmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlmZmZmZdedee fd Zd d d d ZdeedefdZejdZejdZdedefdZdedefdZdededefdZd'dededeeeffdZ dedede eeeffdZ!d(dede ededefdZ"dede edefdZ#d(d Z$d!Z%dede e&e e&ffd"Z'd#Z(d$Z)d%e dee fd&Z*dS))N)DictIterableListMatchOptionalTextIOTuple)Metric)Sample)_is_valid_legacy_metric_name_validate_labelname_validate_metric_nametextreturnc#XKttj|Ed{VdS)z]Parse Prometheus text format from a unicode string. See text_fd_to_metric_families. N)text_fd_to_metric_familiesStringIO)rs X/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/prometheus_client/parser.pytext_string_to_metric_familiesr s9 *(*;D*A*ABBBBBBBBBBB\ ")z\\z\nz\"matchcBt|dS)Nr)ESCAPE_SEQUENCESgroup)rs rreplace_escape_sequencers EKKNN ++rz\\[\\n]z\\[\\n"]scBtt|SN)HELP_ESCAPING_REsubrr s r_replace_help_escapingr&$s    7 ; ;;rcBtt|Sr") ESCAPING_REr$rr%s r_replace_escapingr)(s ??2A 6 66rcharposcd}||kr/||dz |z dkr|dz }||kr||dz |z dk|dzdkS)Nrr r)r r* num_bslashess r_is_character_escapedr/,skL \ ! !1|+,44  \ ! !1|+,44 ! q  rF labels_string openmetricscXi}|}|r |r|ddkrtd|z |rMt||\}}}|s|rtd|z.t|\}}|st |std|r |ddkrtd}|t |krG|d|}t|d||sn|dz }|t |kG|dz} | t |krtd|zt|\} } |d krt|nt|||vrtd |z| ||<|M|S#t$rtd |zwxYw) Nr,zleading comma: zempty term in line: zunquoted UTF-8 metric namerr zunexpected text after quote: __name__z$invalid line, duplicate label name: zInvalid labels: ) strip ValueError _next_term_unquote_unescaper lenindexr/rr) r0r1labels sub_labels name_term value_term label_name quoted_namei quote_end label_value_s r parse_labelsrE4s+F$$&&J>> !A#!5!5  Ac*oo%%$$S!,,,Z^Q??Q c*oo%% AIC OO++ !@=!PQQQ.z::NKZ''%j1111#J///V## !G-!WXXX!,F: O' -P ===+m;<<<=s EF F)c|ddkr)|dd}|sdS|ddkrtdt|d}|dkr4||dkr(|d|}||dzd}t|d }nd }|d krt|}|d|}|s|rtd |||d}|||fS) aExtract the next comma-separated label term from the text. The results are stripped terms for the label name, label value, and then the remainder of the string including the final , or }. Raises ValueError if the term is empty and we're in openmetrics mode. rr3r N)rGrGzmultiple commasz=,}=z,}r4z empty term:)r6_next_unquoted_charr9r5)rr1splitpos labelnametermrests rr7r7js  Aw#~~ABBx : 7c>>.// /"4//H1}}h3..(O HqLMM"&tT22 2~~t99   ?D .K.---  ?D djjllDJJLL 00rchsstartidxcd}| tj}t||dD].\}}|dkrt|||zs| }|s ||vr||zcS/dS)zReturn position of next unquoted character in tuple, or -1 if not found. It is always assumed that the first character being checked is not already inside quotes. FNrrI)string whitespace enumerater/)rrOrP in_quotesrAcs rrJrJs I {$xyy/**$$1 881$1 EE8% I $Cxx!|### 2rct|dz }d}| tj}|dkr8||dkrt||s| }|s |||vr|S|dz}|dk8dS)zGReturn position of last unquoted character in list, or -1 if not found.r FNrrrI)r9rRrSr/)rrOrArUs r_last_unquoted_charrXs D A AI { a%% 7c>>"7a"@"@>% I Aw#~~ Q a%% 2rcxdg}d}|t|krt|||}|dkr||d|d<t|}G||kr|dz }S|dkr!t||kr||d|d<n:||||d<|dz}|d|t|k|S)zfSplits on split_ch similarly to strings.split, skipping separators if they are inside quotes. rGrrINr )r9rJappend)r separatormaxsplittokensx split_poss r _split_quotedr`s TF A c$ii--'i;; ??abbF2JD A  >> FA  a<>T"X__233 3AbDz t|| && <rc*|}d}||vrd}d||D}|st|dfSt|d}t |dkrt|ddz nd}||fS)N  c^g|]*}||+Sr-)r5).0values r z._parse_value_and_timestamp..s- M M Mu{{}} Mekkmm M M Mrrr rIi)lstripsplitfloat _parse_valuer9)r r[valuesrh timestamps r_parse_value_and_timestamprps  AI M M);); M M MF Qxx~  # #E58[[1__fRj))D00$I ) rcd|}||ksd|vrtd| t|S#t$rt |cYSwxYw)NrGrDzInvalid value: )joinr5r6intrl)rhs rrmrms GGENNE  45445555zz U||sAA0/A0cd}t|d}|dks ||d|vr~t|d}|d|}t|std|z||dzd}t |\}}t |i||S|d|}t||dd|z}t ||dz|d} |sd | vrt| d }| d =nd | vrtd ||dzd}t |\}}t || ||S) Nz # {rIz zinvalid metric name:r }Fr4z$metric name specified more than once)rJr5r r6rpr rE) rr[ label_startname_endnameremaining_textrhro label_endr;s r _parse_sampler|sI%dC00KbIl{l);;;&tU33IXI$$&&+D11 <3d:;; ;hlmm,5nEEydBy111    # # % %D#D$6<<{JI ${Qy895 A AF A V # # j! :   v  ?@@@)a-..)N1.AAE9 $y 1 11rfdc # Kd d}d}g}g}dtdtdtdttdtf d}|D]}|}|d rgt |d d }t|d krRd \}} t|d krI|ddkr |ddkrt|d \}} | st|st|ddkrS| kr dkr| |||V| d}g}|g}t|dkrt|d }d}|ddkrtt|dkrt| kr dkr| |||V| d}g}|d }dgdggdgdd |dg} fd|D}|dkrt|} | j|vr9 dkr| |||Vd d}d}g}g}|| d||| gV||  dkr| |||Vd Sd S)zParse Prometheus text format from a file descriptor. This is a laxer parser than the main Go parser, so successful parsing does not imply that the parsed text meets the specification. Yields Metric's. rGuntypedry documentationtypsamplesrc |dkrZ|dr |dd}n:g}|D]5}|t|ddzg|ddR|}6t|||}||_|S)Ncounter_totalirr )endswithrZr r r)ryrrr new_samplesr metrics r build_metricz0text_fd_to_metric_families..build_metric"s )  }}X&& *CRCy  **A&&vadXo'F!""'F'F'FGGG)GGmS11  r#Nr,)rGFr TYPEHELP)_count_sumrG)rr_bucket)rgaugesummary histogramcg|]}|zSr-r-)rgnrys rriz.text_fd_to_metric_families..^s A A Aa A A Arr)strrr r r5 startswithr`r9r8r r6r&getr|ryrZ) r}rrr allowed_namesrlinepartscandidate_namerbsamplerys @rrrs4 DM CGM 3 s  tF| X^    >'>'zz|| ??3  ; '!$a00E5zzA~~%. "NF5zzA~~8v%%%(f*<*<):58)D)D&%&B>&R&R%$$Qx6!!!T))rzz*l4WMMMMM)D#C G%3$4Mu::??$:58$D$DMM$&MMqV##u::>>$$!T))rzz*l4WMMMMM)D$&M GAh "t T555!>!>!> !! #cB4..  !B A A A= A A A RZZ "4((F{-//2::&,t]CIIIII "  " "l6!9mS6(KKKKKKv&&&& rzzl4W=======zr)F)r)+iorrerRtypingrrrrrrr metrics_corer rr validationr rrrrrrcompiler#r(r&r)rsboolr/rEr7rJrXr`r8rlrprmr|rr-rrrs( GGGGGGGGGGGGGGGGGG  CC&1ACCCC   ,5:,#,,,,2:j))bj%% 3=3=3=3=l1S1t1c3m0D1111Dc S&c #"8   " # %x0F*G    222>_>6_>hv.>_>_>_>_>_>_>r