o K j1@sdZddlZddlZddlZddlZddlmZmZddlmZdZ dZ dZ e Z dad$d d Zd$d d Zd%ddZd&ddZddZddZdZddZddZddZdd Zd!d"Zed#krgedSdS)'z Dashboard estatico del wrapper de arbitraje. Cada 60s consulta SQLite y regenera dashboard.html con: - Resumen general - Distribucion por categoria - Top 10 oportunidades activas - Posiciones paper abiertas/cerradas - PnL post-mortem N)datetime timedelta)Pathz*/root/arbitrage_data/data/opportunities.dbz-/root/arbitrage_data/dashboard/dashboard.html<TcCs|}||||S)z=Helper para queries que devuelven filas como lista de tuples.)cursorexecutefetchall)connsqlparamsrrr5/root/arbitrage_data/dashboard/dashboard_generator.pyqs rcCst|||}|r |dSdS)zHelper para una unica fila.rN)r)r r r rowsrrr q_one s rc Cp|durdSzt|}Wnttfyt|YSw|dkr"dn|dkr(dnd}d|d |d |d d S) z"Format pct con signo y color HTML.N—g{Gz?#16a34ag{Gz#dc2626#6b7280+.fz%float ValueError TypeErrorstrvdecimalscolorrrr fmt_pct&  r$c Cr) zFormat USD con color.NrgMbP?rgMbPrrrrrrrr rrr fmt_usd2r%r(cCsT|durdSt|}|dkr|ddS|d}|dkr"|ddS|ddd S) z"Format duracion en formato humano.Nrr.0fmz.1fhd)r)minuteshoursrrr fmt_dur>s  r0cCs~tt}|}|dkrt|ddS|dkr-t|ddt|dddSt|ddt|dddS)z.Format uptime desde el arranque del generador.irr*iQr,r-)rutcnow START_TIME total_secondsint)delta total_secrrr fmt_uptimeKs $$r7ue Polymarket Arb Dashboard

Polymarket Arbitrage Dashboard

Generated {generated_at} UTC · Dashboard uptime {uptime} · Auto-refresh 60s

Summary

{summary_metrics}

Distribution by Category (Active Opportunities)

{categories_table}

Top 10 Active Opportunities (by edge after fees)

{top_opps_table}

Paper Trader — Open Positions

{open_positions_table}

Paper Trader — Last 20 Closed Positions

{closed_positions_table}

PnL Post-mortem (Vanished opportunities)

{pnl_outcome_table} cCsd|d|dS)Nz'
z
z
r)labelvaluerrr render_metricsr:cCs(|sdSd|}d|d|dS)Nu—ztag-zSELECT SUM(pnl_usd) FROM paper_positions WHERE status='closed'z4SELECT scan_time FROM scans ORDER BY id DESC LIMIT 1Nrz Total scansz Active oppsz Vanished oppsz Paper openz Paper closedzPaper PnL (USD)rz Last scanu_ SELECT COALESCE(category, '—') as cat, COUNT(*) as n, ROUND(AVG(last_edge_after_fees_pct), 2) as avg_edge, ROUND(MAX(last_edge_after_fees_pct), 2) as max_edge, ROUND(AVG(last_min_liquidity), 0) as avg_liq FROM opportunities WHERE status='active' GROUP BY cat ORDER BY n DESC zzz
CategoryCountAvg edgeMax edgeAvg liq USD
zz%z%$r)z
z SELECT description, category, last_edge_after_fees_pct, last_min_liquidity, scans_count, high_fee_zone FROM opportunities WHERE status='active' ORDER BY last_edge_after_fees_pct DESC LIMIT 10 zu⚠️Az
DescriptionCatEdgeLiqScansHFZ
z.2fz-

No active opportunities.

z SELECT position_id, description, category, entry_time, entry_edge_pct, entry_total_cost, entry_size_usd FROM paper_positions WHERE status='open' ORDER BY entry_time DESC LIMIT 20 z7z'

No open positions.

z SELECT position_id, description, category, entry_time, exit_time, exit_reason, pnl_usd, pnl_pct, entry_size_usd FROM paper_positions WHERE status='closed' ORDER BY exit_time DESC LIMIT 20 z
IDDescriptionCatEntry timeEntry edgeSize USD
z-

No closed positions yet.

a SELECT outcome, COUNT(*) as n, ROUND(AVG(pnl_pct_on_cost), 3) as avg_pnl, ROUND(AVG(duration_minutes), 1) as avg_dur, ROUND(AVG(initial_edge_pct), 2) as avg_init_edge FROM pnl_simulations GROUP BY outcome ORDER BY n DESC z
IDDescriptionCatReasonPnL USDPnL %
z %z4

No vanished opps processed yet.

z%Y-%m-%d %H:%M:%S) generated_atuptimesummary_metricscategories_tabletop_opps_tableopen_positions_tableclosed_positions_tablepnl_outcome_table) rr:r(rr>r$r0 HTML_TEMPLATEformatrr1strftimer7).r n_scansn_active n_vanished n_paper_openn_paper_closed paper_pnl_row paper_pnl last_scan last_scan_strmetricscat_rowscat_htmlr<navg_emax_eavg_ltop_rowstop_htmldescedgeliqscanshfzhfz_txt desc_short open_rows open_htmlpidentry_tcostsize closed_rows closed_htmlentextreasonpnl_upnl_ppnl_rowspnl_htmloutcomeavg_pnlavg_duravg_initrrr build_htmlsx   0  8 L L 6 r{cCstd|dddadS)Nz[shutdown] Senal TflushF)print_running)signumframerrr shutdownsrc Csvttjtttjtttjjdddtdtddd}t r|d7}zEt t }t |}|td}t|d }||Wd n1sPwYt|ttd |d td ddWn&ty}ztd |d |dddd l}|WYd }~nd }~wwd}|tkrt rttdt||d7}|tkrt st s%tdddd S)z2Loop infinito: regenera HTML cada REFRESH_SECONDS.T)parentsexist_okz&Dashboard generator iniciado. Salida: r|rz.tmpwNz[cycle z] z dashboard regeneratedz ] ERROR: zDashboard generator detenido)signalSIGTERMrSIGINTr HTML_PATHparentmkdirr~rsqlite3connectDB_PATHr{closeopenwritereplacerr1 isoformat Exception traceback print_excREFRESH_SECONDStimesleepmin)cycler htmltmp_pathrersleptrrr mains@      r__main__)r)r)r&)__doc__rrrsysrrpathlibrrrrr1r2rrrr$r(r0r7rLr:r>r{rr__name__rrrr s6         Lb# 
OutcomeCountAvg PnL%Avg durationAvg initial edge