U O{j& @sUddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZmZddlmZe rddlmZdZeedd d d d gZd ddddddddZeejdddkred=dZGdddejZeZded<ee eZ!ded<Gdd d e"Z#e$e#d!d"d#d$Z%d!d"d%d&Z&d'd!d(d)d*Z'd>d+d d,d-d.Z(e ej)ee*e fgefZ+Gd/d0d0Z,e-Z.dej/d1fd2d3d4d5d6d7d8d9Z0Gd:d;d;Z1d!d"dr?r@rQrR __classcell__r;r;rOr<rC_srCrDr!cCs dtj_dS)z!Set `--logistro-human` (default).TNcli_argsparsedhumanr;r;r;r< set_humanlsrYcCs dtj_dS)zSet `--logistro-structured`.FNrUr;r;r;r<set_structuredqsrZr)rEr!cKsd|kr>tjjr>tjjr.ttjj|d<ntjj|d<d|krNt|d<tjf|d|krt j d tjj r|t ntddjt_dS)z Call `logging.basicConfig()` with our defaults. It will overwrite any `format` or `datefmt` arguments passed. It is only ever run once. rdatefmtr=rc[sdSNr;)_kwargsr;r;r<zbetterConfig..N)rVrWrK isnumericintupper _date_stringrL basicConfig getLoggerhandlers setFormatterrXrArB__code__ betterConfig)rEr;r;r<rivs  riz str | None)rr!cCstdt|S)zr?r@__annotations__rnrtr;r;r;r<rjs rj rrkraz str | bytesztuple[FD, _LogistroLogger])rrm default_levelifsr!c szttrdnt|}|t|t\}}dddddfdd }t||d|||fd }| ||fS) u Is a special `getLogger()` which returns a pipe and logger. It spins a separate thread to feed the pipe into the logger. Common usage would be to pass the pipe to `Popen(stderr=...)`. You should close the pipe `os.close(pipe)` in case the other process freezes. Args: name: the name of the logger (á la `logging.getLogger(name)`) parser: a function whose first parameter is a `LogRecord` to modify it. If it doesn't return `True`, the whole record is ignored. The second parameter is a dictionary of already filtered info. See keys `pipe_attr_blacklist` in `logistro._api`. default_level: the default level for the logger. ifs: The character used as delimiter for pipe reads, defaults:"\n". Returns: A tuple: (pipe, logger). The pipe can be closed immediately after passing it to the writing process. zutf-8razlogging.LoggerrD)rloggerrwr!c sttjdddkptdkr.t|dd}zz0t|}|t |d7}|t|krbt dWnDt k r|r| \}}}|rt| || qtYW.read_piper)targetrr*) r.rencodere addFilterrjrpiperstart) rrmrwrxrzrywrZ pipe_readerr;rr< getPipeLoggers #rc@s\eZdZdddddddddd Zddddd d d ZddddddZddddZdS) LoggingNodeNrzparentrzlogging.Logger | NonezLoggingNode | NonerD)rrzrr!cCs||_||_i|_||_dSr\)rz_namechildrenr)r7rrzrr;r;r<rnszLoggingNode.__init__)rrzr!cCsN|r2||jkr||j|_qDt|||d|j|<nt||d|j|<|j|S)Nr)r)rrzr)r7rrzr;r;r< add_child s  zLoggingNode.add_childrra)indentr!cCsp|jd|j}|jr6t|jdr6|d|jj7}td||t|jD]\}}||dqTdS)Nr&rf-)rrzr)rfprintsortedritems)r7rlabelrchildr;r;r<rs zLoggingNode.printrTcCs|jSr\)r)r7r;r;r<__str__szLoggingNode.__str__)N)r)r>r?r@rnrrrr;r;r;r<rs   rcCs~t}td|dd}|jjD]P\}}t|tjs6q |}|d}|ddD]}| |}qP| |d|q | dS)z>Print out information about the current logging configuration.rootNrr%) rermanager loggerDictrr.rLLoggersplitrr)rzrrZ subloggerrZnodesnoder;r;r<describe_logging s   r)N)3 __future__rjsonrLrr}r-r5 threadingrtypingrrrrrZlogistror rVcollections.abcr r addLevelNamerp_outputror|rc FormatterrrArudumpsrBgetLoggerClassrCsetLoggerClassrYrZrire LogRecordrZ _LoggerFilterrjraZFDrMrrrr;r;r;r<sZ       ) N#