/i2ddlmZmZddlmZddlmZmZmZm Z ddl Z ddl m Z ddl m Z ddlmZddlmZd d lmZGd d eZGd deeZGddeZGddeZGddeZy))ABCabstractmethod)Enum)OptionalDictAnyListN)datetime)unquote)Console)Text)create_box_messagec>eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zy )LogLevelrr c6|jjSN)namelowerselfs Q/mnt/e/genesis-system/.venv/lib/python3.12/site-packages/crawl4ai/async_logger.py__str__zLogLevel.__str__syy  N)__name__ __module__ __qualname__DEFAULTDEBUGINFOSUCCESSWARNINGERRORCRITICALALERTNOTICE EXCEPTIONFATALr"r#r!rr s>G E DGG EH E FI E!r#rcBeZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZd Zy ) LogColorzEnum for log colors. bright_blackcyangreenyellowredmagentaz dim magentac|jS)z+Automatically convert rich color to string.)valuers r!r"zLogColor.__str__,s zzr#N)r$r%r&__doc__r(r)r*r+r,CYANGREENYELLOWMAGENTA DIM_MAGENTAREDr"r2r#r!r4r4sA E DGG E D E FGK Cr#r4c eZdZeddedefdZeddedefdZeddedefdZeddedefdZeddedefdZ edded e d e ded e f d Z edded eded e fdZy)AsyncLoggerBasemessagetagc yrr2r rFrGkwargss r!debugzAsyncLoggerBase.debug2 r#c yrr2rIs r!infozAsyncLoggerBase.info6rLr#c yrr2rIs r!successzAsyncLoggerBase.success:rLr#c yrr2rIs r!warningzAsyncLoggerBase.warning>rLr#c yrr2rIs r!errorzAsyncLoggerBase.errorBrLr#urlrPtiming url_lengthcyrr2)r rUrPrVrGrWs r! url_statuszAsyncLoggerBase.url_statusFrLr#rTcyrr2)r rUrTrGrWs r! error_statuszAsyncLoggerBase.error_statusJrLr#Nr(r)r*r+r,FETCHdr,rc)r$r%r&rstrrKrNrPrRrTboolfloatintrYr[r2r#r!rErE1s S s   C c   s    s    S s   c D % c ad    C c QT  r#rEcHeZdZdZidddddddd d d d d dddddddddddddddddddd d!d"Zej ej ejejejejejejejejiZ d#ej d$d#d#d%fd&e ed'ed(ed)e eeefd*e eeefd+ef d,Zd-ed.efd/Zd-ed.efd0ZdJd1Zd2efd3Z dKd4ed2ed-ed5e eeefd*e eeefd6e eed7e efd8ZdLd2ed-efd9ZdMd2ed-efd:ZdNd2ed-efd;ZdOd2ed-efd<ZdPd2ed-efd=ZdQd2ed-efd>ZdRd2ed-efd?Z dSd2ed-efd@Z!dTd2ed-efdAZ"dUd2ed-efdBZ# dVdCedDedEe$d-edFef dGZ% dWdCedHed-edFefdIZ&y#)X AsyncLoggerz Asynchronous logger with support for colored console output and file logging. Supports templated messages with colored components. INITu→READY✓rbu↓SCRAPEu◆EXTRACTu■COMPLETEu●r,×r(u⋯r)uℹr+u⚠r*u✔r-u‼r.u⚡r/r0u❗r1u☠r'u•NrTlog_file log_level tag_widthiconscolorsverbosecV||_||_||_|xs |j|_|xs |j |_||_t|_ |rRtjtjjtjj|dyy)ap Initialize the logger. Args: log_file: Optional file path for logging log_level: Minimum log level to display tag_width: Width for tag formatting icons: Custom icons for different tags colors: Custom colors for different log levels verbose: Whether to output to console Texist_okN)rrrsrt DEFAULT_ICONSruDEFAULT_COLORSrvrwr consoleosmakedirspathdirnameabspath)r rrrsrtrurvrws r!__init__zAsyncLogger.__init__qs(! ""0d00 3 3 3  y   KK(ABT R r#rGreturncBd|dj|jdS)z#Format a tag with consistent width.[].)ljustrtr rGs r! _format_tagzAsyncLogger._format_tags!3%qz44r#cT|jj||jdS)z=Get the icon for a tag, defaulting to info icon if not found.r))rugetrs r! _get_iconzAsyncLogger._get_icons zz~~c4::f#566r#ct||kr|j|S|t|z dz}|d||z|| dz}|j|S)zETruncate text in the middle if longer than length, or pad if shorter.rN)lenr)r textlength placeholderhalf shorteneds r!_shortenzAsyncLogger._shortens] t9 ::f% %[))a/$K+-dUV < v&&r#rFc6|jrtj|}|j}t j j ddd}t|jdd5}|jd|d|d dddyy#1swYyxYw) z.Write a message to the log file if configured.%Y-%m-%d %H:%M:%S.%fNautf-8encodingr]  ) rrr from_markupplainr nowstrftimeopenwrite)r rFr plain_text timestampfs r!_write_to_filezAsyncLogger._write_to_files ==##G,DJ //0FGLIdmmS7; 9q!I;b B78 9 9  9 9s ,BBlevelparamsboxes base_colorc |j|jjkry|jddjdd} |r| jd i|} |j D]\} } t | jddjdd} |r*| |vr&d|| d| d|| d}| j| |} |} |s`| |vse| j| t | t |} n| } |xs|j|}d|d|j|d|j|d| d |d }|js|jd d r|jj||j|y) a Core logging method that handles message formatting and output. Args: level: Log level for this message message: Message template string tag: Tag for the message params: Parameters to format into the message colors: Color overrides for specific parameters boxes: Box overrides for specific parameters base_color: Base color for the entire message Nrz[[rz]]z[/)type z [/ force_verboseFr2)r<rsreplaceformatitemsrerrvrrrwrr}printr)r rrFrGrrvrrrJparsed_messageformatted_messagekeyr< value_str color_strcolorlog_lines r!_logzAsyncLogger._logs. ;;-- - !d3;;CF  !6 5 5 ? ? $lln H UJ..sD9AA#tL cVm"#F3K=)Bvc{m1 MI(9(A(A)Y(W% )ISE\(9(A(A)*93u:F)H% H!/ %: E(:ugQt//45Qt~~c7J6K1M^L__bchbiijk <<6::ou= LL  x ( H%r#c J|jtj||fi|y)zLog a debug message.N)rrr(rIs r!rKzAsyncLogger.debug (..'39&9r#c J|jtj||fi|y)zLog an info message.Nrrr)rIs r!rNzAsyncLogger.info (--#88r#c J|jtj||fi|y)zLog a success message.N)rrr*rIs r!rPzAsyncLogger.success (""GS;F;r#c J|jtj||fi|y)zLog a warning message.N)rrr+rIs r!rRzAsyncLogger.warningrr#c J|jtj||fi|y)zLog a critical message.Nrrr,rIs r!criticalzAsyncLogger.criticalrr#c J|jtj||fi|y)zLog an exception message.NrrIs r! exceptionzAsyncLogger.exceptionrr#c J|jtj||fi|y)zLog a fatal message.NrrIs r!fatalzAsyncLogger.fatalrr#c J|jtj||fi|y)zLog an alert message.NrrIs r!alertzAsyncLogger.alertrr#c J|jtj||fi|y)zLog a notice message.NrrIs r!noticezAsyncLogger.noticerr#c J|jtj||fi|y)zLog an error message.NrrIs r!rTzAsyncLogger.errorrr#rUrPrVrWc t|}|j||}|j|rtjntj d|||rdnd|d|rt jnt j t jdy)a@ Convenience method for logging URL fetch status. Args: url: The URL being processed success: Whether the operation was successful timing: Time taken for the operation tag: Tag for the message url_length: Maximum length for URL in log u%{url} | {status} | ⏱: {timing:.2f}srmu✗)rUstatusrV)rrV)rrFrGrrvN)r rrrr*r,r4r+)r rUrPrVrGrW decoded_url readable_urls r!rYzAsyncLogger.url_status sx$cl }}[*=  &-(""8>>;##*%  /6(**8>>"**  r#rTct|}|j||}|jtjd|||dy)z Convenience method for logging error status. Args: url: The URL being processed error: Error message tag: Tag for the message url_length: Maximum length for URL in log z{url} | Error: {error})rUrT)rrFrGrN)r rrrr,)r rUrTrGrWrrs r!r[zAsyncLogger.error_status/sCcl }}[*=  ..,'%8  r#)z...)NNNNr\r]r^r_)r-)r0)r1)r.)r/r`ra)r,2)'r$r%r&r=r{rr(r4r)r*r+r,r|rrerhrrfrrrrrrr rrKrNrPrRrrrrrrTrgrYr[r2r#r!rjrjOs   %  5  E     5 5 E  % U !" 5#M*  x}}(**(** N#'&nn*.59S3-SS S S#X' S h012 SS@5s5s57S7S7'9c9,004%))-<&<&<& <& c3h( <& c8m,- <&S "<&X&<&|:S:s:9C9c9Nr#rrFrGc tjjddd}t|jdd5}|j d|d|d|d |d dddy#1swYyxYw) z Write a message to the log file.rNrrrrrz] [rr)r rrrrrr)r rrFrGrrs r!rzAsyncFileLogger._write_to_fileSsrLLN++,BCCRH $--w 7 D1 GGa {#eWCuBwirB C D D Ds A''A0c *|jd||y)zLog a debug message to file.r(NrrIs r!rKzAsyncFileLogger.debugY GWc2r#c *|jd||y)zLog an info message to file.r)NrrIs r!rNzAsyncFileLogger.info]s FGS1r#c *|jd||y)zLog a success message to file.r*NrrIs r!rPzAsyncFileLogger.successa Iw4r#c *|jd||y)zLog a warning message to file.r+NrrIs r!rRzAsyncFileLogger.warningerr#c *|jd||y)zLog an error message to file.r,NrrIs r!rTzAsyncFileLogger.errorirr#rUrPrVrWcT|rdnd}|d|d|d|dd}|jd||y) zLog URL fetch status to file.r*FAILEDNz... | Status: z | Time: z.2fs URL_STATUSr)r rUrPrVrGrWrrFs r!rYzAsyncFileLogger.url_statusms@%8*%&nVHIfS\QRS L'37r#rTc>|d|d|}|jd||y)zLog error status to file.Nz ... | Error: r,r)r rUrTrGrWrFs r!r[zAsyncFileLogger.error_statusss,*%&mE7; GWc2r#Nr\r]r^r_r`rard)r$r%r&r=rerrrKrNrPrRrTrfrgrhrYr[r2r#r!rrDsOODCD#DCD 3S3s32C2c25s555s553S3s38c8D8%8c8ad8 33C3c3QT3r#r)abcrrenumrtypingrrrr r~r urllib.parser rich.consoler rich.textr utilsrrrer4rErjrr2r#r!rsd#,,  %!t!"sD( c