`gjdZddlZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z ddl mZmZmZmZ ddddddde ee fezd ed ed ed ed e ede edeeeffdZdde edede efdZGddZy)ua Session Insights Engine for Hermes Agent. Analyzes historical session data from the SQLite state database to produce comprehensive usage insights — token consumption, cost estimates, tool usage patterns, activity trends, model/platform breakdowns, and session metrics. Inspired by Claude Code's /insights command, adapted for Hermes Agent's multi-platform architecture with additional cost estimation and platform breakdown capabilities. Usage: from agent.insights import InsightsEngine engine = InsightsEngine(db) report = engine.generate(days=30) print(engine.format_terminal(report)) N)Counter defaultdict)datetime)AnyDictListOptional)CanonicalUsageestimate_usage_costformat_duration_compacthas_known_pricingcache_read_tokenscache_write_tokensproviderbase_urlsession_or_model input_tokens output_tokensrrrrreturnct|tr|}|jdxsd}t|jdxsd|jdxsd|jdxsd|jdxsd} |jd }|jd }n|xsd}t||||} t || || } t | j xsd | jfS) z?Estimate the USD cost for a session row or a model/token tuple.modelrrrrr)rrrrbilling_providerbilling_base_url)rr) isinstancedictgetr r float amount_usdstatus) rrrrrrrsessionrusageresults A/root/.hermes/venv/lib/python3.12/site-packages/agent/insights.py_estimate_costr'$s"D)" G$* ^49!++o6;!%kk*=>C!&{{+?@EA   ;;12;;12 &B%'/1   !   F "")c *FMM 99values max_widthc |r t|nd}|dk(r|Dcgc]}dc}S|Dcgc]'}|dkDrdtdt||z |zznd)c}Scc}wcc}w)z7Create simple horizontal bar chart strings from values.rru█)maxint)r)r*peak_vs r& _bar_chartr2Mse 3v;aD qy"#q##PV W1QEC3q4x)345 5B F WW$ Ws A,Ac eZdZdZdZd#dededeeeffdZ dZ d e d Z d e d Z d$d e dedeefd Zd$d e dedeefdZd$d e dedeefdZd$d e dedefdZ d$deededeeedefdZdZdZd$d e dedeefdZ d$deed e dedeefdZdeedeefdZdeedeefdZdeedeeeffdZdeedefdZdeedeefdZd edefd!Zd edefd"Zy)%InsightsEnginez Analyzes session history and produces usage insights. Works directly with a SessionDB instance (or raw sqlite3 connection) to query session and message data. c4||_|j|_y)z Initialize with a SessionDB instance. Args: db: A SessionDB instance (from hermes_state.py) N)db_conn)selfr6s r&__init__zInsightsEngine.__init__]sXX r(Ndayssourcerc *tj|dzz }|j||}|j||}|j||}|j ||}|s||digggdddddgdigd S|j |||}|j |||} |j|} |j|} |j|} |j|} |j|}||dtj| || | | | |d S) z Generate a complete insights report. Args: days: Number of days to look back (default: 30) source: Optional filter by source platform Returns: Dict with all computed insights iQTrtotal_skill_loadstotal_skill_editstotal_skill_actionsdistinct_skills_usedsummary top_skills) r: source_filteremptyoverviewmodels platformstoolsskillsactivity top_sessionsF) r:rErF generated_atrGrHrIrJrKrLrM) time _get_sessions_get_tool_usage_get_skill_usage_get_message_stats_compute_model_breakdown_compute_overview_compute_platform_breakdown_compute_tool_breakdown_compute_skill_breakdown_compute_activity_patterns_compute_top_sessions)r8r:r;cutoffsessions tool_usage skill_usage message_statsrHrGrIrJrKrLrMs r&generatezInsightsEngine.generategsVu -%%ff5))&&9 ++FF; //? !'./-./001   #% "% ,..xH))(M6J44X> ,,Z8..{;228<11(; # IIK " (  r(a id, source, model, started_at, ended_at, message_count, tool_call_count, input_tokens, output_tokens, cache_read_tokens, cache_write_tokens, billing_provider, billing_base_url, billing_mode, estimated_cost_usd, actual_cost_usd, cost_status, cost_source, api_call_countzSELECT zL FROM sessions WHERE started_at >= ? AND source = ? ORDER BY started_at DESCz= FROM sessions WHERE started_at >= ? ORDER BY started_at DESCr[c|r)|jj|j||f}n'|jj|j|f}|j Dcgc] }t |c}Scc}w)z&Fetch sessions within the time window.)r7execute_GET_SESSIONS_WITH_SOURCE_GET_SESSIONS_ALLfetchallrr8r[r;cursorrows r&rPzInsightsEngine._get_sessionssd ZZ''(F(FQWHXYFZZ''(>(> JF%+__%67cS 777s%A:ct}|r|jjd||f}n|jjd|f}|jD]}||dxx|dz cc<|r|jjd||f}n|jjd|f}t}|jD]} |d}t |t rt j|}t |trL|D]G} t | tr| jdini} | jd } | s;|| xxd z cc<I|s|r|}n]|r[|rYt|t|z} t} | D]1}t|j|d |j|d | |<3| }|j!D cgc] \} }| |d  c}} S#t jttf$rY7wxYwcc}} w) aGet tool call counts from messages. Uses two sources: 1. tool_name column on 'tool' role messages (set by gateway) 2. tool_calls JSON on 'assistant' role messages (covers CLI where tool_name is not populated on tool responses) aRSELECT m.tool_name, COUNT(*) as count FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND s.source = ? AND m.role = 'tool' AND m.tool_name IS NOT NULL GROUP BY m.tool_name ORDER BY count DESCaASELECT m.tool_name, COUNT(*) as count FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND m.role = 'tool' AND m.tool_name IS NOT NULL GROUP BY m.tool_name ORDER BY count DESC tool_namecountzSELECT m.tool_calls FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND s.source = ? AND m.role = 'assistant' AND m.tool_calls IS NOT NULLzSELECT m.tool_calls FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND m.role = 'assistant' AND m.tool_calls IS NOT NULL tool_callsfunctionnamer,r)rjrk)rr7rbrerstrjsonloadslistrrJSONDecodeError TypeErrorAttributeErrorsetr- most_common)r8r[r; tool_countsrgrhcursor2tool_calls_countscallscallfuncrn all_toolsmergedtoolrks r&rQzInsightsEngine._get_tool_usages8i  ZZ''*  FZZ''*  F??$ :C K( )S\ 9 ) : jj((N  Gjj((N  G$I##% C L)eS) JJu-EeT* %9;EdD;Qtxx B7WY#xx/-d3q83 9  0+K .K(3/@+AAIYF! ]";??4#;=N=R=RSWYZ=[\t  ] K +668 e /  %(()^D  $ s A6GG HHHc i}|r|jjd||f}n|jjd|f}|jD]N} |d}t|trt j |}t|ts@ |d}|D]}t|ts|jdi} | jd} | dvr=| jd} t| tr t j | } t| ts| jd} t| tr| js|j| | d d d d } | d k(r| d xxdz cc<n | dxxdz cc<|| d || dkDs|| d<Qt|jS#t jtf$rYwxYw#t jtf$rY_wxYw)z2Extract per-skill usage from assistant tool calls.aSELECT m.tool_calls, m.timestamp FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND s.source = ? AND m.role = 'assistant' AND m.tool_calls IS NOT NULLzSELECT m.tool_calls, m.timestamp FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND m.role = 'assistant' AND m.tool_calls IS NOT NULLrl timestamprmrn> skill_view skill_manage argumentsrN)skill view_count manage_count last_used_atrrr,rr)r7rbrerrorprqrrrsrtrrstrip setdefaultr))r8r[r; skill_countsrgrhr{rr|r}rjargs skill_nameentrys r&rRzInsightsEngine._get_skill_usage#s24 ZZ''N  FZZ''N  F??$1 6C L)eS) JJu-E!%./ K(I& 6!$-xx B/ HHV, $BBxx ,dC(!#zz$/"$-!XXf- !*c2*:J:J:L$//!+&'()(,  ,,'1,'.)Q.)(.)1Y~AV5V,5E.)M& 61 6fL'')**Y(()4   !00)<! !s$:F<8G<GGG98G9c|r|jjd||f}n|jjd|f}|j}|r t|SdddddS)z!Get aggregate message statistics.aSELECT COUNT(*) as total_messages, SUM(CASE WHEN m.role = 'user' THEN 1 ELSE 0 END) as user_messages, SUM(CASE WHEN m.role = 'assistant' THEN 1 ELSE 0 END) as assistant_messages, SUM(CASE WHEN m.role = 'tool' THEN 1 ELSE 0 END) as tool_messages FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ? AND s.source = ?aSELECT COUNT(*) as total_messages, SUM(CASE WHEN m.role = 'user' THEN 1 ELSE 0 END) as user_messages, SUM(CASE WHEN m.role = 'assistant' THEN 1 ELSE 0 END) as assistant_messages, SUM(CASE WHEN m.role = 'tool' THEN 1 ELSE 0 END) as tool_messages FROM messages m JOIN sessions s ON s.id = m.session_id WHERE s.started_at >= ?r)total_messages user_messagesassistant_messages tool_messages)r7rbfetchonerrfs r&rSz!InsightsEngine._get_message_statsosz ZZ''?  FZZ''.  FootCy !"#a&  r(r\r_rHchtd|D}td|D}td|D}td|D}||z|z|z}td|D} td|D} d} d} t} t}d}d}|D]}|jd xsd }t|\}}| |z } | |jd xsdz } d |vr|j d d n|xsd}|dk(r|dz }n |dk(r|dz }t ||jd|jdr| j ||j ||retd|D} td|D}td|D}td|D}td|D}||z|z|z}g}|D]D}|jd}|jd}|s(|s+||kDs1|j||z F|rt|dz nd}|rt|t|z nd}|Dcgc]}|jds|d}}|r t|nd}|r t|nd}idt|d| d| d|d |d!|d"|d#|d$| d%| d&|d'|d(|r| t|z ndd)|r|t|z ndd*|jd*xsdd+|jd+xsdd,|jd,xsd||t| t|||d-Scc}w).z'Compute high-level overview statistics.c3FK|]}|jdxsdywrrNr.0ss r& z3InsightsEngine._compute_overview..s!G!%%/414G!c3FK|]}|jdxsdywrrNrrs r&rz3InsightsEngine._compute_overview..s!I115516Q6Irc3FK|]}|jdxsdywrrNrrs r&rz3InsightsEngine._compute_overview..s"Q1quu%89>Q>Qrc3FK|]}|jdxsdywrrNrrs r&rz3InsightsEngine._compute_overview..s"SQ&: ; @q @Src3FK|]}|jdxsdyw)tool_call_countrNrrs r&rz3InsightsEngine._compute_overview..s"Oquu%67<1<Orc3FK|]}|jdxsdyw) message_countrNrrs r&rz3InsightsEngine._compute_overview..s!KQQUU?38q8Krrrrractual_cost_usd/unknownincludedr,rrc3XK|]"}t|jdxsd$yw)costrN)r rrms r&rz3InsightsEngine._compute_overview..s"IQU155=#7C8I(*c3XK|]"}t|jdxsd$ywrr.rrs r&rz3InsightsEngine._compute_overview..s#N!c!%%"7"<1=Nrc3XK|]"}t|jdxsd$ywrrrs r&rz3InsightsEngine._compute_overview..s#PAs155#9#>Q?Prc3XK|]"}t|jdxsd$ywrrrs r&rz3InsightsEngine._compute_overview..s$"XA3quu-@'A'FQ#G"Xrc3XK|]"}t|jdxsd$ywrrrs r&rz3InsightsEngine._compute_overview..s$#ZaC.B(C(Hq$I#Zr started_atended_atNtotal_sessionsrtotal_tool_callstotal_input_tokenstotal_output_tokenstotal_cache_read_tokenstotal_cache_write_tokens total_tokensestimated_cost actual_cost total_hoursavg_session_durationavg_messages_per_sessionavg_tokens_per_sessionrrr)date_range_startdate_range_endmodels_with_pricingmodels_without_pricingunknown_cost_sessionsincluded_cost_sessions) sumrvrr'splitr addappendlenminr-sorted)r8r\r_rH total_input total_outputtotal_cache_readtotal_cache_writerrr total_costrrrrrrr estimatedr"display durationsstartendr avg_durationstarted_timestampsrrs r&rUz InsightsEngine._compute_overviewsGhGG III QQQS(SS"\14DDGXX OhOOK(KK  !e!$ !!" 4AEE'N(bE .q 1 Iv ) #J 155!23:s :K.1Ulekk#&r*AS)G#&!+&9$%*% .@(A155I[C\]#''0&**73 4 I&IIJNvNNKPPPL""XQW"XX  ##ZSY#Z Z &58HHK\\L  .AEE,'E%% #Cu  u-  . 09c)nt+a :Cs9~I6 8@W!155CVa oWW6H312d4F/0D c(m n   0  !+  "<  &'7   '(9  L  j  ;  ;  #L  '(X(FXY  %hlS]&BTU  ]..?D1 !-"3"34H"I"NQ! " ]..?D1# $!1,#)*=#>&,-C&D%:&= ? AND s.source = ?agSELECT u.session_id, u.model, u.billing_provider, u.billing_base_url, u.api_call_count, u.input_tokens, u.output_tokens, u.cache_read_tokens, u.cache_write_tokens, u.reasoning_tokens, u.estimated_cost_usd, u.actual_cost_usd, u.cost_status, u.cost_source, u.billing_mode FROM session_model_usage u JOIN sessions s ON s.id = u.session_id WHERE s.started_at >= ?c6 |r)|jj|j||f}n'|jj|j|f}|j Dcgc] }t |c}Scc}w#t j$rgcYSwxYw)zFetch per-model usage rows within the window (issue #51607). Returns an empty list when the table is missing (e.g. a DB opened by older code that never created it) so the caller can fall back to the per-session aggregate. )r7rb_GET_MODEL_USAGE_WITH_SOURCE_GET_MODEL_USAGE_ALLrersqlite3OperationalErrorrfs r&_get_model_usagezInsightsEngine._get_model_usages ++557G++D,E,EyQ)/):;#DI; ;;'' I s$A$B&A;8B;BBBc8tdddddfd }|j||}td}|D]}||d}dD]} || xx|| xsdz cc<|d xx|d xsd z cc<|d xx|d xsd z cc<||d |d |jd|d|dxsd|dxsd|dxsd|dxsd|dxsd|jds|jdr|d nd|d |jd } | dxx|dxsdz cc<|D]} || d}td| jdxsd|dz } td| jdxsd|dz } td| jdxsd|dz }td| jdxsd|dz }td t | jd xsd |d z }td t | jd xsd |d z }td| jdxsd|dz }| s| s |s |s|s|s|s1|| jd | jd | jd| d| | ||d||| jd } | }|dxx|z cc<|D]Y} | jdxsd}|s| jd xsd}d|vr|j ddn|}|dxx|z cc<[g}j D]Q\}}d |i|}t|d|d<|jdd |jdd|j|S|jd!d"#|S)$uBreak down token usage and cost by model. Tokens and cost are attributed per model from session_model_usage, so a session that switched models mid-flight (via ``/model``) splits across every model it used instead of dumping everything on the initial model (issue #51607). Sessions without per-model rows — e.g. data written before this table existed and not yet backfilled — fall back to their single recorded (model, billing_provider) aggregate so nothing is lost. Tool calls aren't tied to a specific API invocation, so they stay attributed to the session's recorded model. c .tddddddddddd S)Nrr) r\rrrrreasoning_tokensr api_callsrlrr)rvr(r&z9InsightsEngine._compute_model_breakdown..'s%q1!"! !11S * r(N) stored_costr cost_statusc  6|xsd}d|vr|jddn|} | } | dj|| dxx|z cc<| dxx|z cc<| dxx|z cc<| dxx|z cc<| d xx|z cc<| d xx||z|z|zz cc<| t||||||xsd| \}}nt| xsd }| xsd}| d xx|z cc<| dxxt| xsd z cc<|| d<t ||xsd|rd| d<| S| j dd| S)Nrrrr\rrrrrrrrrrrT has_pricingF)rrr'r r r)rrr session_idinpout cache_read cache_write reasoningrrr display_modeldestimater" model_datas r& _accumulatez._accumulate.sh&YE475LEKK,R0eM *= 9A jM  j ) n  $  o # %  ! "j 0 " " #{ 2 #  !Y . ! n sZ!7+!E E "#13&0[%-$ & !!34$1  fI !I m k&8S 9 9 %Am  (8D(C#'- !  ]E2 r(c dddddddddS)Nrr)rrrrrapi_call_countestimated_cost_usdrrrr(r&rz9InsightsEngine._compute_model_breakdown..Os"#s" , r(r)rrrrrrrrrrrrrrrrrrr cost_sourcerridrrrrrlr\rFc|d|dfS)Nrr\rxs r&rz9InsightsEngine._compute_model_breakdown..s1^#4a m"Dr(Tkeyreverse) rrrr-r ritemsrrrsort)r8r\r[r;r usage_rows usage_totalsrtotalsrrrrrrr residual_costresidual_actualresidual_callsresidual_bucketrlrrr%datarrs @r&rTz'InsightsEngine._compute_model_breakdowns^!"  %)d !@**66: "$   CA%1!L/%BF +s qv{*  + ' (A.B,C,Js J ( $ %+<)=)D D %' A011559K3L,>!2!7a?9K9Pq%&+!Q/C-D-I$%*uu]+quu]/C*+/0EE-0 A qM+ &!,<*=*B B &- C6# ;A!!D'*Fa!%%/41~8NNOCa!%%05A9PPQCAEE-.3!v>Q7RRJAEE./41?S8TTK U155!56=#>-./M"U155!23:s;*+,O!AEE*+0qF;K4LLNsjK="ng&8 9()1T7S*k1)+EE-0 A/9mO K (N : (G# ;L BA016QJEE'N/iE475LEKK,R0eM } %l 3z A 3  B%++- !KE4e,t,E #D$4 5E*    ]E 2   ]I 6 MM%  !  Dd S r(ctd}|D]}|jdxsd}||}|dxxdz cc<|dxx|jdxsdz cc<|jd xsd}|jd xsd}|jd xsd}|jd xsd} |d xx|z cc<|d xx|z cc<|d xx|z cc<|d xx| z cc<|d xx||z|z| zz cc<|dxx|jdxsdz cc< |jD cgc] \} } d| i|  } } } | jdd| Scc} } w)z$Break down usage by platform/source.c dddddddddS)Nr)r\messagesrrrrrrlrrr(r&rz.sq!Q"#Qa- r(r;rr\r,rrrrrrrrrlrplatformc |dS)Nr\rrs r&rz.s !J-r(Tr)rrrr) r8r\ platform_datarr;rrrrrrrr%s r&rVz*InsightsEngine._compute_platform_breakdowns#%   =AUU8_1 Ff%A jMQ M jMQUU?38q 8M%%',1C%%(-AC238qJ%% 45:K n  $  o # %  ! "j 0 " " #{ 2 # n sZ!7+!E E  lOquu%67<1   s.Er]c|rtd|Dnd}g}|D],}|r |d|z dznd}|j|d|d|d.|S)z.s9!G*9rrkdrj)rrk percentage)rr)r8r] total_callsr%rpcts r&rWz&InsightsEngine._compute_tool_breakdownsj=Gc9j99Q  A6A1W: +c1qC MM+7!   r(r^c R|rtd|Dnd}|rtd|Dnd}||z}g}|D]I}|d|dz}|r||z dznd}|j|d|d|d|||jdd K|jd d |||t |d |dS)z3Process per-skill usage into summary + ranked list.c3&K|] }|d yw)rNrrs r&rz:InsightsEngine._compute_skill_breakdown..sEA,Errc3&K|] }|d yw)rNrrs r&rz:InsightsEngine._compute_skill_breakdown..sGa. 1Grrrrrr)rrr total_countrrc6|d|d|d|dxsd|dfS)Nr#rrrrrrrs r&rz9InsightsEngine._compute_skill_breakdown..s4- ,.!.!&Q' r(Trr=rB)rrrrr) r8r^r>r?r@rDrr#rs r&rXz'InsightsEngine._compute_skill_breakdownsITCEEEZ[KVCG;GG\]/2CC  E -n0EEKFY+(;;cA_`J   w#L1 %n 5*( % . 9      &7%6':(+K(8  %  r(ct}t}t}|D]y}|jd}|stj|}||j xxdz cc<||j xxdz cc<||j dxxdz cc<{gd}tdD cgc]} || |j| dd} } tdD cgc]} | |j| dd } } | rt| d nd } | rt| d nd } t|}|rt|j}d}d}tdt|D]]} tj|| dz d}tj|| d}||z jdk(r|dz }t||}\d}_nd}| | | | ||dScc} wcc} w)z2Analyze activity patterns by day of week and hour.rr,z%Y-%m-%d)MonTueWedThuFriSatSunr)dayrk)hourrkc |dSNrkrrs r&rz;InsightsEngine._compute_activity_patterns..s qzr(rNc |dSr3rrs r&rz;InsightsEngine._compute_activity_patterns..s 7r()by_dayby_hour busiest_day busiest_hour active_days max_streak)rrr fromtimestampweekdayr1strftimeranger-rrkeysstrptimer:)r8r\ day_counts hour_counts daily_countsrtsdt day_namesi day_breakdownhour_breakdownr8r9r: all_datescurrent_streakr;d1d2s r&rYz)InsightsEngine._compute_activity_patternssY i y  7A|$B''+B rzz| $ ) $  A % Z0 1Q 6 1 7F 1X aL:>>!Q+? @  2Y A!6 7  GTc--ABY] HVs>/CD\` ,'  |0023INJ1c)n- '&&yQ'7D&&y|Z@G>>Q&"a'N!$Z!@J%&N 'J$%&(&$   C  s .G Gc lg}|Dcgc]&}|jdr|jdr|(}}|rct|d}|d|dz }|jd|dddt|t j |dj d d t|d }|jd xsd d kDrZ|jd|ddd|d d|jdr't j |dj d ndd t|d}|jdxsd |jdxsd z} | d kDrX|jd|ddd| dd|jdr't j |dj d ndd t|d} | jdxsd d kDrZ|jd| ddd| dd| jdr't j | dj d ndd |Scc}w)z.Fsq}q>r(r4zLongest sessionrN%b %d)labelrvaluedatec,|jdxsdS)Nrrrr%s r&rz6InsightsEngine._compute_top_sessions..Qso0F0K!r(rrz Most messages msgs?cX|jdxsd|jdxsdzS)Nrrrrr%s r&rz6InsightsEngine._compute_top_sessions..]s(15505A!%%:P:UTUVr(rrz Most tokens, tokensc,|jdxsdS)Nrrrr%s r&rz6InsightsEngine._compute_top_sessions..is7H1I1NQr(rzMost tool callsz calls)rr-rr rr<r>) r8r\toprsessions_with_durationlongestdur most_msgs most_tokens token_total most_toolss r&rZz$InsightsEngine._compute_top_sessions:s} " uu\"quuZ'8 " "  "&?G*% (==C JJ*%dmCR005 ..w|/DENNwW  &KL MM/ * /a1 4 JJ('ocr2%o67u=]f]j]jkw]x..y/FGPPQXYB   V #~6;! P_@`@edef ? JJ&)$/4'?'2_j_n_no{_|..{|jdr7|jdd}|jdr d|ddnd}d|d |d Sg}|d }|d}|jd}|jd|jd |jd d|d }|r |d|dz }dt|z dz }|dz} || z } |jdd| zd|dd| zd|jd|jd|jdr|jdrvtj|dj d} tj|dj d} |jd| d| |jd|jd|jd|jd|ddd |d!d"|jd#|d$d%d&|d'd"|jd(|d)d%d*|d+d"|jd,|d-d"|d.d/kDr3|jd0t |d.d1zd2d3t |d4|jd5|d6d7|jd|d8r|jd9|jd|jd:d;d<dd=d>dd?d@|d8D]-} | dAdBdC}|jd:|d<d| dDd>d| d-dE/|jdt|dFdGkDs|dFr|dFd/dHdIk7r|jdJ|jd|jd:dKdLdd=d>ddMdNdd?dO|dFD]/}|jd:|dHdLd|dDd>d|dPdQd|d-dR1|jd|dSr|jdT|jd|jd:dUdVddWd>ddXd>|dSdBdYD])}|jd:|dZdVd|d[d\d|d]d^dX+t|dSdYkDr$|jd_t|dSdYz d`|jd|jdai}|jdbg}|r#|jdc|jd|jd:dddVddedfddgdfddhdi|dBdjD]i}dk}|jdlr'tj|dlj dm}|jd:|dndBdCdVd|dodpd|dqdpd|dik|jdri}|jds|jdtd/du|jdvd/d"dw|jdxd/d"|jd|jdyi}|jdzr|jd{|jd|dzDcgc]}|d[ }}t|dY|}t|dzD]+\}}||}|jd:|d}d:|d~d|d[-|jdt|ddd}|Dcgc] }|d[d/kDs |c}dBd}|r_g}|D]5}|d}|dkrdnd} |dzxsd}!|j|!| d|d[d7|jddj||jdr|jd|d|jdr |ddGkDr|jd|dd|jd|jdri|jd|jd|dD].}"|jd:|"ddd|"ddd|"dd|"dd 0|jddj|Scc}wcc}w)z6Format the insights report for terminal display (CLI).rFr:rEz (source: )rz No sessions found in the last z days.rGu ╔══════════════════════════════════════════════════════════╗uD ║ 📊 Hermes Insights ║zLast  (:u ║ u║u ╚══════════════════════════════════════════════════════════╝rrz %b %d, %Yz Period:  — u 📋 Overviewu ────────────────────────────────────────────────────────z Sessions: rz<12z Messages: rrZz Tool calls: rz<12,z User messages: rz Input tokens: rz Output tokens: rz Total tokens: rrrz Active time: ~rz<11z Avg session: ~rz Avg msgs/session: r.1frHu 🤖 Models Used Modelz<30Sessionsz>8Tokensz>12rNr\z>12,rIr,rcliu 📱 PlatformsPlatformz<14Messagesz>10z>14rz>10,z>14,rJu 🔧 Top ToolsToolz<28Calls%rrkz>8,rz>7.1fz ... and z more toolsrKrDu 🧠 Top SkillsSkillLoadsz>7Editsz Last usedz>11 u—rrRrrz>7,rrCz Distinct skills: rAz Loads: r>z Edits: r?rLr6u 📅 Activity Patterns)r*r/z<15r7c |dSr3rrs r&rz0InsightsEngine.format_terminal..s ajr(Trr1 AMPMz Peak hours: z, r:z Active days: r;z Best streak:  consecutive daysrMu 🏆 Notable SessionsrSz<20rTz<18rUr ) rrrrr<r>r r2 enumeraterjoin)#r8rer:srclineso src_filter period_labelpaddingleft_pad right_pad start_strend_strr model_nameprrKrDr last_usedrCactr day_valuesbarsrHbar busy_hoursh hour_strshrampm display_hrrEs# r&format_terminalzInsightsEngine.format_terminalxs ::g ::fb)D=CZZ=XJvo67q9^`C5dV5QG G : f~ZZ0   R N O [\tfE*  b A. .Ls<((1,a<h&  uS8^,Al^1S9_q,ABC ] a  LL12I!MJZ]aJa2bcf1gg{}TUVWmUn}o|pq r ,Q/I-J3,OPQ R (  LL- . LL* + LL2gc]!Jr?!HS>J KH% `wZ_  r*S!11Z=2DAaFWX\E]^_ ` LL  vk" #a 'F;,?F;DWXYDZ[eDfjoDo LL+ , LL* + LL2j-Qz"oQz#>NaPXY\~^ _K( x r!J-!4Aa mB5Gq:W[H\\]^_`n^opt]uvw x LL  '? LL+ , LL* + LL2fS\72,aBx@ AG_Sb) ] r!F)C!G*S1A1\?SXBYYZ[\ ]6'?#b( z#fWo*>*C)DKPQ LL Hb)ZZ b1  LL, - LL* + LL2gc]!GB!B2AFJ #KA6B#%74D!#bBJ$$ |D6AgJ sd%| d?d d@| dAd dB| i|jd|jdCi} | jdDr| jdEr| dEdF} | dGkrdHndI} | dGzxsdG}|jdJ| dDdKdL| dDd3dM|| dN| dEd3dO | jdPr|jdQ| dP| jdRdd*kDr|jdS| dRdTdUj|S)Vz;Format the insights report for gateway/messaging (shorter).rFr:rgzNo sessions found in the last z days.rGu"📊 **Hermes Insights** — Last z days z**Sessions:** rz | **Messages:** rrZz | **Tool calls:** rz **Tokens:** rz (in: rz / out: rrhrrz**Active time:** ~rz | **Avg session:** ~rrrHu**🤖 Models:**Nrrprrnr\z sessions, r[rIr,u**📱 Platforms:**rrrWrJu**🔧 Top Tools:**rrkz calls (rroz%)rKrDu**🧠 Top Skills:**rz , last used rRrrz loads, rz editsrLr8r9r1rrru**📅 Busiest:** r/zs (z sessions), rjz sessions)r:z**Active days:** r;z**Best streak:** rr)rrr rrr<r>r)r8rer:rrrrrrKrsuffixrrrrs r&format_gatewayzInsightsEngine.format_gateways ::g ::fb)D3D6@ @ : f~ 9$wGH  ~a(8&9%::KAN^L_`aKbbuvwyKwLMNvOP Q |An$5a#8qAU?VWX>YYabcdybz{|a}}~ A ] a  LL-.Ea FVY]F].^-__tvMNOPfNgvhuij k R (  LL+ ,H%bq) p r!G*Sb/!2%* kRSTbRcdeQffmno p LL  vk" #a ' LL. /K( h r!J-a m_KPQR\P]^_O``efg h LL  '? LL. /G_Ra( a r!F)E!G*Qx,X[G\\^_` a LL Hb) ::l # LL/ 0 -bq1 99^,+H,B,B5CX,Y,b,bcj,k+lmF w(eL.A!-DHUSaMbcdLeeklrkst   LL jjR( 77= !cggn&=^$V,B74DbBJ LL-c-.@.G-HCP]L^_fLgKhhtuuABFAGGIJMN\J]^eJfIggqr sww}% 0]1C0DEHww|Q'!+ 0\1B0CCTUVyyr()rgN)N) __name__ __module__ __qualname____doc__r9r.rorrr` _SESSION_COLSrcrdr rrPrQrRrSr rUrrrrTrVrWrXrYrZrrrr(r&r4r4UsL> S> s> d38n> JQM -!$ $ -!$ $ 8E838$t*8Z eZ SZ DJZ xJ+uJ+cJ+T$ZJ+X   t P(, \ t*\ \ d$ \  \ ~ 4! #ucT$Z&BFRT R,1R;>R dRhDJ4:> $t* d & DJ& 4S>& P8 4:8 $8 t8d4j8T$Z8|J dJ sJ X@ T@ c@ r(r4)rr))rrprrO collectionsrrrtypingrrrr agent.usage_pricingr r r r ror.tupler r'r2r4rr(r&rs$  ,,,$: ""$:38ns*$:$:$:  $:  $:sm$:sm$: 5#:$:RXtCyXSX$s)Xo o r(