U Acj @sdZddlmZmZddlmZmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZeZeeefZeed ddZ eedddZ!ddedddddfddede e!fgZ"dde"DZ#ee$dddZ%e$edd d!Z&eed"d#d$Z'eed%d&d'Z(d1eeeed)d*d+Z)d2eee ee*e ed.d/d0Z+d,S)3zA Tools for saving and loading log events in a structured format. )dumpsloads)IOAnyAnyStrDictIterableOptionalUnioncast)UUID) NamedConstant)FailureFileLogObserver) flattenEvent)LogEvent)LogLevel)Logger)failurereturncCs t|t|jj|jjddS)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)rr8/tmp/pip-unpacked-wheel-nrvc_22y/twisted/logger/_json.py failureAsJSONs r) failureDictrcCs4tt}|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} rrr)r__new__r __setstate__)r fZtypeInforrrfailureFromJSON.s  r$cCst|tott|jd|kSN) isinstancer getattrrnamelevelrrr@s r+z$02E59486-F24D-46AD-8224-3ACDF2A5732AcCs t|jdS)N)r()rr(r)rrrr+EcCstt|ddS)Nr()r'rr)rrrr+Fr,cCs t|tSr%)r&r)orrrr+Ir,z$E76887E2-20ED-49BF-A8F8-BA25CC586F2DcCsi|]\}}}}||qSrr).0 predicateuuidsaverloaderrrr Qs r3)aDictrcCs d|krtt|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 )r4rrrobjectLoadHookTs r7) pythonObjectrcCs>tD]0\}}}}||r||}t||d<|SqddiS)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. r5Z unpersistableT) classInfostr)r8r/r0r1r2resultrrrobjectSaveHookds   r<)eventrcCs.ttttfddd}t|t||ddS)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. ) unencodablercSst|tr|dSt|S)z Serialize an object not otherwise serializable by L{dumps}. @param unencodable: An unencodable object. @return: C{unencodable}, serialized charmap)r&bytesdecoder<)r>rrrdefaults  zeventAsJSON..defaultT)rBskipkeys)objectr JSONDictr:rr)r=rBrrr eventAsJSONys rF) eventTextrcCsttt|tdS)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 rErr7)rGrrr eventFromJSONsrI)outFilerecordSeparatorrcst|fddS)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. cst|dS)N )rF)r=rLrrr+r,z%jsonFileLogObserver..r)rKrLrrNrjsonFileLogObservers rON)inFilerL bufferSizerc #sttddd}tttddd|dkrN||d}|d krH|}qZd }n ||}d }|d krld }}ntttdfd d }t|}||}|st|dkr||} | dk r| Vq|||7}||} | ddD]&} t| dkr|| } | dk r| Vq| d}qdS)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}. )srcSst|tr|S|dSdS)Nutf-8)r&r@encode)rSrrrasBytess z&eventsFromJSONLogFile..asBytes)recordrcSstzt|d}Wn(tk r:tjdt|dYdSXz t|WStk rntjdt|dYdSXdS)NrTz2Unable to decode UTF-8 for JSON record: {record!r}rWz&Unable to read JSON record: {record!r})r@rAUnicodeDecodeErrorlogerrorrI ValueError)rWtextrrreventFromBytearrays z1eventsFromJSONLogFile..eventFromBytearrayNrr, cs.|dtdkr|Stjdt|ddS)NrMz0Unable to read truncated JSON record: {record!r}rX)ordrZr[r@rXr^rreventFromRecordsz.eventsFromJSONLogFile..eventFromRecordrra)rr@ bytearrayr rreadlensplit) rQrLrRrVfirstZrecordSeparatorBytesrdbufferZnewDatar=recordsrWrrcreventsFromJSONLogFiles:      rl)rJ)NrP),__doc__jsonrrtypingrrrrrr r r r0r Z constantlyr Ztwisted.python.failurer_filer_flattenrZ _interfacesrZ_levelsrZ_loggerrrZr:rErr$r9r6rDr7r<rFrIrOintrlrrrrsX(