\d dZddlmZmZddlmZmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZeZeeefZd edefdZ dedefdZ!dedddfdede e!fgZ"de"DZ#dede$fdZ%de$defdZ&dedefdZ'dedefd Z( d*d"eed#edefd$Z) d+d'eed#e ed(e*de efd)Z+d%S),zA Tools for saving and loading log events in a structured format. )dumpsloads)IOAnyAnyStrDictIterableOptionalUnioncast)UUID) NamedConstant)FailureFileLogObserver) flattenEvent)LogEvent)LogLevel)Loggerfailurereturnct|t|jj|jjS)z Convert a failure to a JSON-serializable data structure. @param failure: A failure to serialize. @return: a mapping of strings to ... stuff, mostly reminiscent of L{Failure.__getstate__} ) __module____name__)type)dict __getstate__rrr)rs 4lib/python3.11/site-packages/twisted/logger/_json.py failureAsJSONr sL  |.\*       failureDictctjt}|d}t|dd||d<||_|S)z Load a L{Failure} from a dictionary deserialized from JSON. @param failureDict: a JSON-deserialized object like one previously returned by L{failureAsJSON}. @return: L{Failure} rr)r__new__r__dict__)r"ftypeInfos rfailureFromJSONr).sD   A6"Hx 3RBBKAJ Hr!cft|tott|jd|uSN) isinstancergetattrrnamelevels rr1@s/ um , , =%*d33u<r!z$02E59486-F24D-46AD-8224-3ACDF2A5732Ac,t|jS)N)r.)rr.r/s rr1r1Esd +++r!c:tt|ddS)Nr.)r-rr/s rr1r1Fsghf t<<r!c,t|tSr+)r,r)os rr1r1Is*Q((r!z$E76887E2-20ED-49BF-A8F8-BA25CC586F2Dci|] \}}}}|| Sr$r$).0 predicateuuidsaverloaders r r<Qs#OOO!A)T5&fOOOr!aDictc^d|vr(tt|d|S|S)a# Dictionary-to-object-translation hook for certain value types used within the logging system. @see: the C{object_hook} parameter to L{json.load} @param aDict: A dictionary loaded from a JSON object. @return: C{aDict} itself, or the object represented by C{aDict} __class_uuid__) uuidToLoaderr )r=s robjectLoadHookrATs55  D'7!899:5AAA Lr! pythonObjectctD]3\}}}}||r!||}t||d<|cS4ddiS)a Object-to-serializable hook for certain value types used within the logging system. @see: the C{default} parameter to L{json.dump} @param pythonObject: Any object. @return: If the object is one of the special types the logging system supports, a specially-formatted dictionary; otherwise, a marker dictionary indicating that it could not be serialized. r? unpersistableT) classInfostr)rBr8r9r:r;results robjectSaveHookrHdsi-6(D% 9\ " " U<((F'*4yyF# $MMM  T ""r!eventcdtdtttffd}t |t ||dS)a Encode an event as JSON, flattening it if necessary to preserve as much structure as possible. Not all structure from the log event will be preserved when it is serialized. @param event: A log event dictionary. @return: A string of the serialized JSON; note that this will contain no newline characters, and may thus safely be stored in a line-delimited file. unencodablerctt|tr|dSt|S)z Serialize an object not otherwise serializable by L{dumps}. @param unencodable: An unencodable object. @return: C{unencodable}, serialized charmap)r,bytesdecoderH)rKs rdefaultzeventAsJSON..defaults8 k5 ) ) 1%%i00 0k***r!T)rPskipkeys)objectr JSONDictrFrr)rIrPs r eventAsJSONrTysR +V +hm(< + + + + $ 7 7 77r! eventTextcTttt|tS)z Decode a log event from JSON. @param eventText: The output of a previous call to L{eventAsJSON} @return: A reconstructed version of the log event. ) object_hook)r rSrrA)rUs r eventFromJSONrXs! % ~FFF G GGr!outFilerecordSeparatorc*t|fdS)a Create a L{FileLogObserver} that emits JSON-serialized events to a specified (writable) file-like object. Events are written in the following form:: RS + JSON + NL C{JSON} is the serialized event, which is JSON text. C{NL} is a newline (C{"\n"}). C{RS} is a record separator. By default, this is a single RS character (C{"\x1e"}), which makes the default output conform to the IETF draft document "draft-ietf-json-text-sequence-13". @param outFile: A file-like object. Ideally one should be passed which accepts L{str} data. Otherwise, UTF-8 L{bytes} will be used. @param recordSeparator: The record separator to use. @return: A file log observer. c,t|dS)N )rT)rIr[s rr1z%jsonFileLogObserver..s/I;u3E3EIIIr!r)rZr[s `rjsonFileLogObserverr_s&, IIII  r!NinFile bufferSizec# Kdtdtfd}dtdttfd |*||d}|dkr|}nd }n ||}d }|d krd } }ndtdttf fd }t|} ||}|s&t |d kr||} | | VdS|||z }||} | ddD]&} t | d kr|| } | | V'| d})aM Load events from a file previously saved with L{jsonFileLogObserver}. Event records that are truncated or otherwise unreadable are ignored. @param inFile: A (readable) file-like object. Data read from C{inFile} should be L{str} or UTF-8 L{bytes}. @param recordSeparator: The expected record separator. If L{None}, attempt to automatically detect the record separator from one of C{"\x1e"} or C{""}. @param bufferSize: The size of the read buffer used while reading from C{inFile}. @return: Log events as read from C{inFile}. srcZt|tr|S|dS)Nutf-8)r,rNencode)rds rasBytesz&eventsFromJSONLogFile..asBytess+ a   %H88G$$ $r!recordcR t|d}n:#t$r-tdt|YdSwxYw t |S#t $r-tdt|YdSwxYw)Nrfz2Unable to decode UTF-8 for JSON record: {record!r}riz&Unable to read JSON record: {record!r})rNrOUnicodeDecodeErrorlogerrorrX ValueError)ritexts reventFromBytearrayz1eventsFromJSONLogFile..eventFromBytearrays ==''00DD!    IIDV}}    44    && &    II>uV}}I U U U44 s!"%3AA A//3B&%B&Nrr! c|dtdkr |Stdt|dS)Nr^z0Unable to read truncated JSON record: {record!r}rk)ordrmrnrN)rirqs reventFromRecordz.eventsFromJSONLogFile..eventFromRecordsWbzSYY&&))&111 F ==4r!Trru)rrN bytearrayr rreadlensplit) rar[rbrhfirstrecordSeparatorBytesrwbuffernewDatarIrecordsrirqs @reventsFromJSONLogFilers(%6%e%%%% 9(1C  A'' G  #( $'  'w77s""$, I (82D      u  F++j)) 6{{Q'//$KKK E'''""",,344crcl  F6{{Q'//$KKK'r!)rY)Nr`),__doc__jsonrrtypingrrrrr r r r r9r constantlyrtwisted.python.failurer_filer_flattenr _interfacesr_levelsr_loggerrrmrFrSr r)rEr@rRrArHrTrXr_intrr$r!rrs IIIIIIIIIIIIIIIIIIII$$$$$$******""""""""""""!!!!!! fhh S>7x$    g     $    344++<< )(  344   &POYOOO  ( v     ##H####*8x8C8888>HSHXHHHH.4 W'*:&*__ sG_c]__h ______r!