+ *Caj-aRtg0tRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt ^RI t ^RI H t ^RI H t ] !]4P4P ^,t]R, R, R, t]R, tRtR t]!]R , R , 4t]]P09d]P0P3^]4^RItR tR tRt^^AbR?^2bR@^2bRA^RqRRjRRrRRsR/t?Rtt@RRultARvtBRwtCRxRRyRRzRR{R R|R /tDR}tER~tFRtG!RR] PP4tJRtKRtLRtM]R , R , R, tN]R, tO]R, R, R, tP]R , R , R, tQ] PN!4tRRm.tSRtTRtURtV]R , R , R, tW] PN!4tXRm.tYRtZ]R , R , R, t[]R, t\]R, t]]R, t^]R, R, R, t_] PN!4t`Rm.taRtbRtcRtdRte]fR8Xd ]e!4R#R# ]dt]!R ] R24RtAEL,RtAii;iuupi)ub dashboard_server.py ==================== Reads the live_monitor.log file every 30 seconds and writes dashboard_data.json which the dashboard.html reads automatically. Run this alongside the live signal monitor: python src/execution/dashboard_server.py Then open dashboard.html in any browser. No internet required — runs entirely on your machine. N)Pathdatetimedatalogszlive_monitor_v2.logzdashboard_data.jsoni="Fsrc executionTz[regime] module not available: u# — regime cards will show Unknownresearchextract_live_trades.pybuild_equity_curve.pyc BR^RRRRR^R^RR/p^RIp.pRFp\R , R , V, pVP4'gK6VP!VP R R 74p\ V\ 4'dVPV4KK V'gV#VUu.uFqfPR ^4NK pp\V4VR&\\V4^4VR&\\^\V44^4VR&\RV44VR&\RV44VR&V'd+\VR,\V4, ^d,^4MRVR&WpR&V# \dEKni;iuupi \dT#i;i)z Read trade history from the pair-specific trade logs written by live_signal_monitor. Reads BOTH trade_history_eurusd.json and trade_history_usdjpy.json from data/logs/ and combines them. trade_count pnl_totalp1_pnlwinslosseswin_rateNrrutf-8encodingnet_pnlc36"TFq^8gK ^xK R#5iN.0ns& SC:\Users\Administrator\OneDrive\fx_macro_intraday\src\execution\dashboard_server.py (get_mt5_trade_history..is%>AAaa c36"TFq^8:gK ^xK R#5irrrs& r r!r"js%?AQaar# trade_resultsztrade_history_eurusd.jsonztrade_history_usdjpy.json)json BASE_PATHexistsloads read_text isinstancelistextend Exceptiongetlenroundsummax)resultr' all_trades pair_filepath pair_tradestnets r get_mt5_trade_historyr<Fs qssqqs F  SIv%.:D;;== "jj)IJ k400%%k21 TM,67JquuY"J7"%c(}"'C!"4{"'As3x(8!"<x"%%>%>">v"%%?%?"?x36#( 6NSX % +Q#0FA E7 F&F(F,F B/F7 FFFF FFcF^RIp.pRFp\R, R, V, pVP4'gK6VP!VP RR74p\ V\ 4'dVPV4KK V# \dKi;i)z;Helper: load combined trades from both pair-specific files.Nrrrrr&) r'r(r)r*r+r,r-r.r/)r'r6r7r8r9s r _load_all_tradesr>ssJO 6!F*Y6{{}}  **T^^W^%EFK+t,,!!+.- P    sA B B B gj@cr^RIp\R, R, R, pVP4'gR#VPVP RR74pRV9d\ P !VR,PRR 44p\ P!VP4V, P4R , pVR 8d\R VR R24R#RRRVPRR4RVPRR4RVPRR4RVPRR4RVPRR4RVPR^4RVPRRRRR/4RVPRR^R^/4/ # \dLi;i \dp\RT 24Rp?R#Rp?ii;i)a Authoritative source of truth for P&L and DD. Reads the account snapshot file written by live_signal_monitor_v2 every hour (monitor has MT5 connected; server can't share that connection since MT5 terminal only allows one). If snapshot exists and is fresh, returns its contents. If missing or stale, returns None and callers fall back to JSON trade history. Snapshot fields: pnl_total, balance, equity, floating_pnl, daily_loss, trade_count, pair_pnl, pair_trades Nrrzaccount_snapshot.jsonrr snapshot_atZz+00:00r @z[Account snapshot] stale (.1fzh old), falling backsourcemonitor_snapshotrrcurrent_balancebalancecurrent_equityequity floating_pnl daily_lossrpair_pnlEURUSDUSDJPYr9z [Account snapshot] read failed: )r'r(r)r*r+r fromisoformatreplacenowtzinfo total_secondsprintr/r0)_json snap_pathsnap snap_time age_hourses r get_mt5_account_snapshotr[s &/2II !!{{9...@A D  $224 3F3N3NsT\3]^ %\\)*:*:;iGVVX[__ s?6yoEYZ[# 1 txx S9 txx 37 txx#6 txx< txx c: txx q9 txx XsHc4RS txx !Xq7QR      045sB4F(F"BF$BF F FFF F6F11F6@2d9e4c37c81f1b4c970d7b1f8d7d382ff450312cd0adf57117f28d5708e6e38e b4e39ea4507e1ceca1a389cfacee8a00zcore inflation rate monthzcore inflation rate yearzinflation rate monthzinflation rate yearzconsumer price indexzcore pcezpce price indexzpersonal spendingzpersonal incomeznonfarm payrollsznon-farm payrollszadp employment changezunemployment ratezfomc meeting minutesz fed minutesz fomc ratezfederal funds ratezgdp growth rategdpzretail sales monthzism manufacturing pmizism services pmizism non-manufacturingzdurable goods orderszconsumer confidencezmichigan consumerzjolts job openingszproducer price indexz10-year note auctionz30-year bond auctiontreasuryzecb interest ratezecb rate decisionzecb monetary policyz ecb presidentlagardez ecb minuteszconsumer pricez zew economicz ifo businessz gdp growthzindustrial productionzfactory orderszmanufacturing pmiz services pmiz retail salesmortgageredbookzweekly earningszweekly joblesszadp employment change weeklyz adp weeklyz3-month treasuryz6-month treasuryz4-weekz8-weekz bill auctionzt-billbubill non-monetaryspeaksspeech interview testimonyzindex of coincidentzindex of leadingzwholesale inventorieszbuilding permitszhousing startsz existing homez pending homezconstruction spendingz natural gasz crude oileiaz api weeklymilkgrain%Y-%m-%dr)weeksfetchedc^a VPRR4P4pVPRR4P4o \VPR^44pRV9pRV9pRV9pRV9pV'gV'gV'g V'g^#\;QJd#V 3Rl\4F 'gK R M R M!V 3Rl\44'd^#V'dhR ^ZR ^ZR ^ZR^UR^KR^KR^FR^AR^.!s 6 8  TFbojz bank of japanz interest ratezmonetary policy inflationcpir^z trade balancezcurrent account employment industrialretailtankanpmic3><"TFwrVS9gKVxK R#5iryrrkvr{s& r r!r|/sD!2#!a8mAA!2  )defaultc3><"TFwrVS9gKVxK R#5iryrrs& r r!r|7s?~h!!~rrd) r0lowerintany TE_EXCLUSIONSr4items TE_US_SCORESTE_DE_EU_SCORES) eventcountry importanceis_usis_deis_euis_jp JP_SCORESbasescoresr{s & @r _score_te_eventrs9R(..0G:b)//1HUYY|Q/0J w &E  E g E w E Ueu s 6 6sss 6 666  b/R b"3R b%R b/R b,R b(R b%R D!2DaP 19qD QY:?D "\F ?v||~? KD qyZ1_ n8 Kc^RIp^RIpVPVPP4.pR1EFUwrVRpTPTR\RTRTRT/^ RR 7pTP^8XEdTP4p T PR 4'Ed\T PR 4\4'EdyT R ,p \ R T R \T 4 RT RT R2 4T EFDp T PRR4p Rp \T 4^8dm\P!T R,R4p^TP u;8d^ 8dMM^M^pTP"T,^,pTR RTP$R 2p TP)RT PRT4RT PRR4RT PRR4RT R,RT RR ^R!^R"^/PT PR#R"4^4R$T PR%R4R&T PR'R4R(T PR)R4/ 4EKG EK\ R*T R \+T 4R+, 24EK&\ R*T R,TP R TP,R-, 24EKX \ R/\T4 R024T# \ d\ R4.u#i;i \&dT R,p EL_i;i \&dp \ R*T R.T 24Rp ? EKRp ? ii;i)2z$Fetch calendar from FinanceFlow API.NuH[WARNING] requests not installed — run: python -m pip install requestsz4https://financeflowapi.com/api/v1/financial-calendarapi_keyr date_fromdate_toF)paramstimeoutverifysuccessrz[INFO] FinanceFlow : z events ( → )rrq:NNz%Y-%m-%d %H:%M02d:: rNrpEvent report_namerrDateN NTimersHighModerateLoweconomicImpactForecast consensusPreviouspreviousActualactualz[WARNING] FinanceFlow NdN HTTP :NPNz failed: z[INFO] FinanceFlow total: z events fetched)) United StatesUS)GermanyDE) Euro AreaEU)JapanJP)requestsurllib3disable_warnings exceptionsInsecureRequestWarning ImportErrorrTr0 TE_API_KEY status_coder'r,r-r1rstrptimemonthhourminuter/appendstrtext)startend_reqrevents country_namelabelurlresprrawrZdt_struk_timedt_utcoffsetuk_hs&& r _fetch_te_calendarrBs  !3!3!J!JKF k * @IC88CZ\US ) % )D 3&yy{88I&&:dhhv6F+M+Mv,C/wbS )E7RWX[W\\]^_ "#%% 2"6"$v;",8)1):):6#;HX)Y./&,,.C.C*0++*>")D-1#Ja c7J*K %!%% <*H#!%% b*A&!%% b*A"&+"'(6!Jqq*I*M*M !&6u =q+B&!%% B*?&!%% 2*>$!%%*< ' !225'CIdO;LMN.ugVD$-8*0-8$ @ *5'1#> ? ? @sb-J'AK A:K A+K=B5K 5!K /K 'KKKK KK  L+LLrc6 \P!4p\pVP4pV^8d+V\ R4P ^V, R7,pM"V\ R4P VR7, pVR,'dWR,, P 4MRpVPR4'd#VR,VPR48wdRVR&VR,'dVR8d\VR ,V4#VPR4pV\ R4P ^R7,PR4p\^4Uu/uF5pV\ R4P VR7,PR4.bK7 p p\Wg4p \V 4^8p V EFp V PR R 4R ,p V PR R 4P4P4pRV9dKT\V 4pW9gKgV^8gKpW,P!RV PRV PRR 44RV PR R 4RVRV PRR 4RV PRR 4RV PRR 4RV PRR 4RR/4EK V EFSp W,Uu.uF pVR,NK ppV \"9dZ\$;QJdRV4F 'gK RM R M !RV44'g W,P!RR!RR"R^ZRR#/4V \&9dZ\$;QJdR$V4F 'gK RM R M !R$V44'g W,P!RR%RR&R^_RR#/4V \(9gK\$;QJdR'V4F 'gK RM R M !R'V44'dEK4W,P!RR(RR&R^KRR#/4EKV V 'g\+R)4^RIHpR*V R+V R,\0 R-2p\2P4!VP7V^R.7P944p^R;^2R<^3R=^ R>^.R?^R@^eRA^fRB^4RC^7RD/ pVPR/.4FipVPR04VPR1R 4R ,p pW9gK5VV9gK>VV,wppW,P!RVRR&RVRR2/4Kk .p\^4FpV\ R4P VR7,PR4p \=V PV .4R4RR57pTP!R1T R6.REOV,R7VR8,R9V'dV^,R,MR:RV 'dRMR2/4K VVR &WR&VPR4VR&\VV4#uupiuupi \:dp\+R3T 24Rp?ELRp?ii;i)Fz,Build weekly signal outlook. Caches 6 hours.rdaysrn韆 week_startrlNr rrrqrrprwrrrrrscoretimerforecastrrrrrrDFFc3F"TFpRV9;'dRV9xK R#5i)ECBRateNrrevs& r r!%get_weekly_outlook..s&0aX`RT"1M1M21MX`!!TFzECB Rate Decisionr hardcodedc3F"TFpRV9;'dRV9xK R#5iFOMCrNrrs& r r!r&1cZbTV&B,2O2O6R<2OZbrFOMC Rate Decisionrc3,"TF pRV9xK R#5iMinutesNrrs& r r!r0T8Rb8FOMC Meeting Minutesu'TE unavailable — falling back to FREDz>https://api.stlouisfed.org/fred/releases/dates?realtime_start=z&realtime_end=z2&include_release_dates_with_no_data=false&api_key=z&file_type=json)r release_dates release_iddateFREDz [WARNING] FRED fallback failed: cVR,#rrxs&r $get_weekly_outlook..s' rkeyreversedayrNN top_event No key events)zConsumer Price Index (CPI)U)zPersonal Income & PCEr)zPersonal Income & Outlaysr)zEmployment Situation (NFP)K)zGross Domestic Product<)z Retail Sales-)zISM Manufacturing PMIr)zISM Services PMIr)zDurable Goods Orders#)PPI(MonTueWedThuFri)rrQ_outlook_cacheweekday __import__ timedeltarSr0strftime _recalc_probsrange_fetch_te_calendar_cachedr1striprrrECB_MEETINGS_2026rFOMC_MEETINGS_2026FOMC_MINUTES_2026rTurllib.requestrequest FRED_API_KEYr'r*urlopenreadr/sorted) current_zrQcachermonday cache_agerri week_events te_eventste_usedrZrrrrexisting_urrFRED_IDSrdridrsfer5rs& r get_weekly_outlookrEs LLNC E ++-C axz*-77a#g7GGz*-77S7AAC::bjjaj8==?@D4b9U3b9Z0b9L0c:Q.b Hhhr2FF<0"&&2CC2HT&3(?#C=DAq%,,ga /RYZ[\dek-lm 3F 1X:j1;;;CCMMjY R06JTXY  8;  v7+? f   E&M) //*5E,  ++[:=< ; 4RD9 : : ;s1;W*W/0B#W4W4!/W44 X?XXc:Rp.pVEFpVPR.4pV'g^pMV^,R,p\V4^8dV^,R,R,M^p\Wx,^d, ^2,^24p V\V4, p V ^8:d^M%V R8d^MV R8d^MV R8d^ M V R8d^M^p \ R VR ,44p \\ W,V ,4^U4pVP /VCR VR V/C4EK V#) z6Recalculate signal probabilities with current z-score.@rr皙?g?g?g?rBc3a"TFIo\;QJdV3RlR4F 'gK RM RM!V3RlR44'gKE^xKK R#5i)c3X<"TFpVSR,P49xK! R#5irNupperrrrZs& r r!*_recalc_probs...s/@)?1 !AgJ$4$4$66)?'*TFN)CPIPCErNFPzECB RATEMINUTESrrrZs&@r r! _recalc_probs..sLA:a3@)?@333@)?@@:AAA ANNprobsignal_probabilityr0r1minabsr3rr days_datar6 THRESHOLDoutdrr[topsecepdistzpbonuss && r r)r)sI C x$D!9W%C/26{Q6!9W%+AC S(2-r2Bs9~-D!)Btcz*Bs "*A! A6":AAEs27U?+R0D BaB';TBC#$ Jrrrrrc4\P!4p\pVR,eWVR,V8XdIVR,V8Xd;VR,'d,W#R,, P4R8d VR,#\ W4pWCR&W#R&WR&WR&V#)zKWrapper that caches calendar results for 6 hours to avoid double API calls.rrrrnr )rrQ_calendar_cacherSr)rrrQr7rs&& r r+r+s ,,.C E h#g%'e #i  Y''6684?X  +F(O)'N%L Mrc a^RIpVPP4p\pVP4pV^8d!W!P ^V, R7,pMW!P VR7, pVR,'dW#R,, P 4MRpVP R4'd#VR,VPR48wdRVR&VR,'dVR8d\VR,V4#VPR4pWQP ^R7,PR4p\^4U u/uF+p WQP V R7,PR4.bK- p p \Wx4p V EF@p V P R R 4R ,p V P R R 4P4P4o\V 4pW9gK^V^8gKg\;QJdV3R lR-4F 'gK RM RM!V3R lR-44'gKW,PRV P RV P RR 44RV P R R 4RVRV P RR 4RV P RR 4RV P RR 4RV P RR 4RR/4EKC V Fp W,Uu.uF qR,NK ppV \ 9dZ\;QJdRV4F 'gK RM RM !RV44'g W,PRR RR!R^_RR"/4V \"9gK\;QJdR#V4F 'gK RM RM !R#V44'dKW,PRR$RR!R^KRR"/4K .p\^4Fp WQP V R7,PR4p \%V P V .4R%RR&7pTPR'T R(.R.OV ,R)VR*,R+V'dV^,R,MR,/4K VVR&W#R&VPR4VR&\VV4#uup iuupi)/u@Weekly outlook for USDJPY — US + Japan events. Caches 6 hours.Nrrnrrrlr rrrqrrpc3,<"TF qS9xK R#5iryr)rcrs& r r!,get_usdjpy_weekly_outlook..5sD)CA<)Cr}TFrrrrrrrrrrrrrrrDrc3F"TFpRV9;'dRV9xK R#5irrrs& r r!rpDrrrrrc3,"TF pRV9xK R#5irrrs& r r!rpGrrrcVR,#r rr s&r r +get_usdjpy_weekly_outlook..Ns7rrrrrrrr)rtrwr)rrQ_uj_outlook_cacher%r'rSr0r(_recalc_probs_ujr*r+r,rrrrr.r/r5)r6_dtrQr7rr8r9rrr:r;r<rZrrrr>r5rrs& @r get_usdjpy_weekly_outlookrxs LL   C E ++-C ax}}1s7}44}}#}....ls1F)E1 !AgJ$4$4$66)ErPTFN)BOJrrQrS INFLATIONMONETARYz RATE DECISIONrUrVs&@r r!#_recalc_probs_uj..ksNG:a3F)EF333F)EFF:rXrYr[r\r]r`s && r rvrv\sI C x$D!9W%C/26{Q6!9W%+AC S(2-r2Bs9~-D!)Btcz*Bs ! G6":GGEs27U?+R0D BaB';TBC!" Jrc4aA\P4'gR#\PRRR7P4pR\ P !4P4RRR R R R R ^RRRRR^R^RR/ p^RIp\R, R, R, pTP4'dSTPTPRR74pTPR4pTe\T4TR&\T4TR&^RIp\R, R, R, pTP4'dETPTPRR74pTPR4pTe\T4TR&.p .p \ P !4\R4P^&M^RIp\R, R, R, p T P4'dTP!T PRR74p!T!PR?4'd8T!PR@R14p"T!PRA4^8XdRBMRCp#T# RDT" 2TR &MrT!PRE/4p$T$PRFRG4'dDT$PRHR14p%T$PRI4^8XdRBMRCp#T%'d RJT# RKT%RL 2MRMTR &MR TR &^RIp&\R, R, R, pTP4'dT&PTPRR74pTPR?4'd8TPR@R14p'TPRA4^8XdRBMRCp(T( RDT' 2TRN&MrTPRE/4p)T)PRFRG4'dDT)PRHR14p*T)PRI4^8XdRBMRCp(T*'d RJT( RKT*RO 2MRMTRN&MR TRN&\;4p+TP=T+4\?4p,T,eT,R,TR&T,RP,TRP&\AT,R ,T+PR ^44TR &T,RQ,TRQ&T,RR,TRR&T,RS,TRS&\ART,R,4TR&RTTRU&MRVTRU&\14p-T-Uu.uF,pTPRWR14PC4RX8XgK*TNK. p.pT-Uu.uF,pTPRWR14PC4RY8XgK*TNK. p/pRZp0T0!T/4p1T0!T.4p2T,eoT,R[,RX,T2R&T,R[,RY,T1R&\AT2R ,T,R\,RX,4T2R &\AT1R ,T,R\,RY,4T1R &T1TR]&T2TR^&R_T2R,R`T1R,Ra\)T2R,T1R,,^4RbT2R ,T1R ,,/TRc&\TPR4;'gTPR4;'gR4p\TPR4;'gR4p\ET4TRd&\GT4TRe&^RI%oA\R, Rh, Ri, p4Rp5.p6Rp7.p8T4Rj, p9T4Rk, p:TA3Rllp;T9P4'dmT;!T94pT>'d\)\T>Rx,^,4^4p?\)T?T5, ^4p7T>U=u/uFp=T=^,\T=^,4bK p@p=T6Uu.uFFpTRm,X@9gKRmTRm,Ro\)X@TRm,,TRn,, ^4/NKH p8pRpTPR4RqTPR/.4RnT5RrT6RsT7RtT8/TR:&T# \d>\PRRR7P4pE LT \dR#i;ii;i \dE Li;i \dE LRi;i \dE Li;iuupiuupi \d.TR.&.TR/&ELi;i \dpRTR9&RTR;&Rp?ELCRp?ii;i \d RTR6&EL^i;i \dELXi;i \dELSi;iuupiuupi \d p3Rp3?3ELmRp3?3ii;i \d%p3\IRfRgT3 24.TRd&.TRe&Rp3?3EL!Rp3?3ii;iuup=iuup=iuupi \d@p3\IRuT34RpTPR4RqTPR/.4/TR:&Rp3?3T#Rp3?3ii;i)zz1Parse live_monitor.log and extract current state.Nrignore)rerrorscp1252 timestampzscorerpositionNone rate_statusUpdatedrrrrrrrrstate_eurusd.jsonz utf-8-sigr last_zscore eu_zscorestate_usdjpy.json uj_zscorerrrzlive_monitor.logzRate data updated successfullyzRate update failedFailedz(\d{4}-\d{2}-\d{2} \d{2}:\d{2})z] [EURUSD] Z-score:zZ-score:\s*([-\d.]+)r:zz] [USDJPY] Z-score:zCurrent z-score:zCurrent z-score:\s*([-\d.]+)cVR,#r:rr s&r r parse_log..afr)rcVR,#rrr s&r r rrrzscore_historyuj_zscore_history closed_atrq:NNz2026-:rNr heatmap_2026zheatmap_data.jsoneurusdheatmap_eu_allusdjpyheatmap_uj_all cutover_monthz2026-04heatmap_cutover position_open entry_priceposition_signalLONGSHORTz @ _armedactiveF target_price directionzArmed rz.5fArmed uj_position.3frKrFrHrJmt5_live pnl_source json_fallbackpairrMrNc`V'g R^RRR^R^RR/#VUu.uFqPR^4NK pp\RV44pR\V4R\\V4^4RTR\V4V, RV'd%\V\V4, ^d,^4/#R/#uupi)rrrrrrrc36"TFq^8gK ^xK R#5irrrs& r r!2parse_log.._trade_stats..Is/#QQqq#r#)r0r3r1r2)tradesr:r;rs& r _trade_statsparse_log.._trade_statsFs=;s6!HUVWabe"ff/56v!551%vC6/#//D!3s8[%C:KD(CHTMcd3s8mC&7 :L LGJL L7sB+rLr9 usdjpy_trades eurusd_tradeseu_pnluj_pnl combined_pnl total_trades portfoliosignal_outlookusdjpy_outlookz [WARNING]zSignal outlook failed: rratesjp2y.csvus2y.csvc<.pSP\V44F9p\V4^8dK\V^,4VP V4K; V# \ \ 3dKSi;i)z>Read CSV rows, skipping header and any non-numeric value rows.)readeropenr1floatr ValueError TypeError)r8r5r_csvs& r _safe_rowsparse_log.._safe_rowsshF[[d,q6A:x!A$KMM!$ -M#I.s#AA21A2rjp2yspreadr6 z_history jp2y_seriescurrent_spreadspread_historyz[WARNING] uj block:)ri )&LOG_FILEr)r+ splitlinesr/rrQ isoformatr'r(r*r0rr&r'r-researchgrouprr2valuessortcalendarr> startswithrrr*r<updater[r4rMrErxrTcsv)BlinesrrU eu_state_patheu_stateeu_z uj_state_pathuj_stateuj_z eu_history uj_historycutoff all_linesold_loglinem_ttsm_zrZrr monthly_2026r:closed month_idx now_monthr:_json_hm_hm_path_hm_hm_er' state_pathstateentryrarmedtarget_json_ujuj_entry uj_directionuj_armed uj_target mt5_statsrWr6 eu_trades_raw uj_trades_rawruj_statseu_stats_e rates_diruj_jp2y uj_jp2y_ser uj_spread uj_spr_hist jp2y_path us2y_pathrrowsrus_rowsus_lastus_dictrsB @r parse_logrtsn ??   ""GH"EPPR  002  D  !F*V36II    ! !{{=#:#:K#:#PQH<< .D$)$KX$)$K[!  !F*V36II    ! !{{=#:#:K#:#PQH<< .D$)$K[! .'  ,,.:j#9#C#C#C#LLWWYZ]^K f$v-0BB >>   #--wx-P[[]`ii D/47&/]#%-88M*,>*2D'))>EC1B#w$,ii 7> ))3CuSYYq\?RTU9V*WX3&$.ii 7> ))3CuSYYq\?RTU9V*WX3#t+ii ?F3 ))3CuSYYq\?RTU9V*WX+0j9j1S619j9@@BC j9j1S619j9@@BC ,-,-$.tu$5 $.tu$5 ! $!# 638L{B/3$$W-- #F3K 01 4II***$Y/5y!9L3MM/ ! ,,I9b)"& Q*#/D  /'$v-69LLnnX%7%7%7%IJ*-''(B*?%&*-''(B*?%&*-''/9*M&'- < '&03FF     JJz33[3IJEyy)) -4&+ii0A&Ba&GFW &/[E7#;Z  (B/99Xu--"YY~r:F*/))K*@A*E7IPV {%s|'L\cD$'-D$ !F*V36II    ! !~~m&=&={&=&STH||O,,#<< r:)16G)HA)MvSZ )5c(&D]##<<"5<<%00 ( ^R @I-5\\+-F!-K6QXL.7.4L>yQTo+V=D'+1D' &'IKK  $ %D  $[ 1[ $\ 2\ #D$7}VW9X Y]"&'8"9 "&'7"8 "&~"6^ #Ck): ;X'\,\( %' $.WJq!%%r2B2H2H2Jh2VJ W$.WJq!%%r2B2H2H2Jh2VJ W L . .  &*:&6x&@H[ !&*:&6x&@H[ !&)(=*A4 CVW_C`&aH] #&)(=*A4 CVW_C`&aH] # (_ (_ H[1 H[1 E(;"7(;:O"OQRS H]3h}6MM  [%TXXk*GGdhhx.@GGCHTXXk*11c2"4T": ";D"A 7 &(507:     *  *       i(D#E$r(1+$6:(,ST 4(21!'!feE!A$K6JK(24     '"5 +G!% A"7;!'G"3Q7 8?@1QqT51;.@))AfI,@IVQvYuWQvY%7!F)%CQGI( dhh{3 dhh':B? g k i k  X Ke  &&&JUUWE  :          6:9 '$& $& !'> /*.%&*.%& / $#^$,    2    :XWH     % k4RD9:"$ "$ %B4A   #R( +. "5r: X K sG%q$<4r/1Ar/4s9As>B s/ (s1As/As/A s//As/6s/As/s%0s/s*!A s/-At.%t./A2t."A?t $4u8u6u )u33u'u6u<4u17u)6u )u 3u>u u?u3 'u)9u)?u3'u.1u.7C u3v 5v #v 2#v Aw +w ;*w %0v>w -w :w ;#ww $w97w02w $ r,0%r r(#r,'r((r,/ r>=r> ss s"s/!s"" s//tt t+ t& t.&t++t..uu uu u&%u&) u33 v v  v;v66v;>w x4xxrSOFREFFR SOFR_tried EFFR_triedc^RIpVPP4P4p\R,V8wd.V\R&R \R&R \R&R\R&R\R&VR,p\P V4'd\P VR 4#R \V&V!W4wrgWg3\V&Wg3#) zFetch a FRED series at most ONCE per calendar day, success or fail. Returns (value, date) - may be (None, None) if today's single attempt failed, in which case the caller falls back to the cached CSV.NrrrFrr_triedTNN)rrQr_fred_daily_cacher0) series_idcsv_pathfetch_fnrwtoday tried_keyvalvdates&&& r _fred_cachedr&s LL    # # %E E)$)&!$0&!$0&!*/,'*/,'H$IY'' $$Y ==#'i ).JC$'<i <rc /p\R, R, R, pVR, pVR, p^RIp^.__annotate__s, , 3, rc 4^RIpRpRVR\RRR^RR /pVPW4^R 7pVP^8wd2\ R V R VP R VP R, 24R#VP 4PR.4pV'g\ R V R24R#VUu.uF,qwPR4R9gKVR,VR,3NK. ppVP4V'gR#VPRRRR7;_uu_4p VFwrV PV RV R24K RRR4VR,wr\V 4V 3#uupi +'giL-;i \dp\ R T RT 24RuRp?#Rp?ii;i)u Fetch a FRED series via the official API and persist as 2-column CSV (date, value) in chronological order. Returns (latest_value, latest_date) or (None, None) on failure (no logging spam — caller decides how loud). Nz3https://api.stlouisfed.org/fred/series/observationsrr file_typer'limit sort_orderdesc)rrz [fred] rrNxN observationsz returned no observationsvaluerqrwr)rnewline, z fetch failed: r).rqNr) rr2r0rrTrr'rrwriterr/)rr _rqrrrobsocleanfrdr latest_date latest_valr s&& r _fred_api_fetch)fetch_yield_data.._fred_api_fetchs & "GCilfcfFB7A}}# )F1==/AFF4L>RS##&&(,,~r2C ),EFG##7:ccUU7^Sb=b,ai7,cEc MMO##sWbAAQ!DAGGqc1#RL)"B',Bi #K*%{3 3d BA   Ii[t< =   sfA*E/-'E/E/&E/*EEE/8E/#E7E/E/ E, 'E// F:F FFr sofr_daily sofr_dater ffr_daily spread_dailysofr_ffr_spread_bp sofr_vs_2y)r' sofr_series sofr_timesrrrlusjp_spread_dailyrusjp_spread_series)rDrqVALUErr)r(rr)rrr1rr2r/rr&rr'rrrr*rQr(zip)yieldsr  sofr_pathffr_pathr HISTORY_DAYSrrrhist de2y_pathrrZrMsofr_valrPffr_valffr_date_sc_td sofr_path2 sofr_rowsr$_dt2r:datesjp_dictrdrs r fetch_yield_datarksFF"U*W4IJ&II%H)+  *     "zz$y/:G:!1v{'(t3E'EA:DG(-d2hqk(:|$(,R {#MN+HL(M1uQqT{A)>(M}%7;((M}%7;(K#>aq6Q;+,Q47I+I#>K+0b!+=F<(+/8A;F;' &fhHGX%{    #&::d8n#=K#=aq6Q;+,Q47I+I#=K*/R *(C#$v,&"8$ < 6,#7 7 <| -'%/'9JF     IZZZ 01q6A:x1Q4[)"2"21"529~! GK(Lt!uQqT{1)=t(L}%7;(T R?T 24R# \dELi;i +'giEL;i \dp \R*T 24Rp ? ELRp ? ii;i \d+p \R.T 24R/\-T 4./TR-&Rp ? EL[!$&FF=#$>X ??  8--w-?@Bxx $,$&FF=#$>[!)*DNhlln.F.F.HID$Ff$x/2II >>  w//1))A,0  gkk)R&@ gkk.&A gkk2F&K   $gkk2KR&P  &GKK8SUW,X +GKK8XZ\,] &GKK8SUW,X +GKK8XZ\,] -7;;?[]_3` 27;;?`bd3e 4'++Fikm:n  9'++Fnpr:s! "4'++Fikm:n# $9'++Fnpr:s% ("W[[1BB%G) *$W[[1Db%I+ ."W[[1BB%G/ 0$W[[1Db%I1 D : +&CC$((8*<CC DD +&--# .D 88$ % %"4T":  88$ % %";D"A  4(88CDN D3gFTd*X FTd*X F - #B ((:v &C C '' 345s1VH%s1VH%4wse %&O    0//@ F ?tDEEF$ 4 -cU3 4&S 3DN 4sj2T' A3T'A T' A U T90E#U U4' T65T69 U  U U1U,,U14 V)?V$$V)cdaa]tRtRtoRtR tV3RltRtRtRt Rt Rt V3R lt R t VtV;t#) DashboardHandleriaGServes dashboard.html and dashboard_data.json from BASE_PATH. Protected resources (the dashboard HTML and its data JSON) require a valid ?key= query parameter. Tokens are managed by the live signal monitor via Telegram (/grantdashboard, /revokedashboard). Static assets (favicon etc.) are served without a token check. cF<\SV`!VR\\4/VBR#) directoryN)super__init__rr()selfargskwargs __class__s&*,r rDashboardHandler.__init__ s $C#i.CFCrcR#ryr)rr4rs&&*r log_messageDashboardHandler.log_messages rc  \R, R, R, pVP4'g \4#\P!VP RR74pVP R.4Uu0uF7pVP R4'gK\VP RR44kK9 up#uupi \d\4u#i;i) uRead dashboard_tokens.json and return set of valid token strings. File is read fresh on each request — overhead is minimal (file is small) and means token grants/revokes take effect immediately without restarting the server. rrzdashboard_tokens.jsonrrtokenstokenrq) r(r)setr'r*r+r0rr/)rprr:s& r _load_valid_tokens#DashboardHandler._load_valid_tokenss F"V+.EEA88::u ::akk7k;.'s!N5M:((++5Ms!TF)rsplitr_PROTECTED_PREFIXES)rr8rs&&@r _path_requires_token%DashboardHandler._path_requires_token$sUZZ\''Q/2 sNT5M5MNssNsNsNT5M5MNNNrc RV9dR#^RIHpVPR^4^,pV!V4pVPRR.4^,P 4#)z9Pull ?key=X from the URL. Returns empty string if absent.rrq)parse_qsr) urllib.parserrr0r,)rr8rqsrs&& r _extract_tokenDashboardHandler._extract_token)sN d?) ZZQ  ""zz%"&q)//11rc 2RPR4pVPR4VPRR4VPR\\ V444VP 4VP PV4R# \dR#i;i)z3Send a friendly access-denied HTML page (HTTP 403).u0Access required

🔒 Private dashboard

This dashboard requires a personal access link.

Message the bot on Telegram and use /requestdashboard to request access.

riz Content-Typeztext/html; charset=utf-8zContent-LengthN) encode send_response send_headerrr1 end_headerswfilerEr/)rbodys& r _serve_access_denied%DashboardHandler._serve_access_denied2s  &/  3 )CD )3s4y>:   JJ  T "   s*B BBc\<VPVP4'g\SV` 4#VP VP4pV'dKWP 49d7VPP R^4^,Vn\SV` 4#VP4#)r)rr8rdo_GETrrrr)rrrs& r rDashboardHandler.do_GETKs((337># ###DII. U5577 Q/2DI7># #((**r)r8)/dashboard.htmlz/dashboard_data.jsonz/dashboard_equity.jsonz/forecast.htmlz/forecast_data.jsonz/forecast_live.jsonz /walls.htmlz/walls_data.json)__name__ __module__ __qualname____firstlineno____doc__rrrrrrrr__static_attributes____classdictcell__ __classcell__)r __classdict__s@@r rrs<> D "O 22 + +rrc^K\n\PP R\ 3\4;_uu_4p\ R\ R24VP4RRR4R# +'giR#;i)rz 127.0.0.1z/ Dashboard server running at http://localhost:rN)rrhttpserverThreadingHTTPServerPORTrT serve_forever)httpds r run_serverrZsY!  ( (+t)<>N O OSX ?v_UV  P O O Os $A,, A= c ^ \P!4p\'d\PR4MRp\ RV R24\ P P4pRVR&\RRRR\\4VR 7p\P!4s \P4'g/\ R \ 24\;_uu_4R sR R R 4R #\ P"!\$P&\\4.3R \(/VBpVP*^8wdWVP,;'gVP.;'gRRR P14p\ RVP* RV 24\4P4'g/\ R\4 24\;_uu_4R sR R R 4R #\ P"!\$P&\\44.3R \6/TBpTP*^8wdsTP,;'gTP.;'gRRR P14p\ RTP* RT 24\;_uu_4R sR R R 4R #\P!4s\T, P94pRpTP.;'gRP;4F.p T P14p RT 9gKRT 9gK%T R,pM T'gRp\ RTR RT 24\;_uu_4R sR R R 4R # +'giR #;i \ P2dE\ R\( R24\;_uu_4R sR R R 4R # +'giR #;ii;i +'giR #;i +'giR #;i \ P2dE\ R\6 R24\;_uu_4R sR R R 4R # +'giR #;ii;i \<dp \ RT 24R p ? EL.R p ? ii;i +'giR #;i \;_uu_4R sR R R 4i +'gii;i;i) aBackground worker: runs extract + build subprocesses sequentially. Runs in a daemon thread, never raises (failures are logged + swallowed). On success, the build script overwrites dashboard_equity.json and the HTTP handler picks it up on the next browser request automatically. rneverz) [live-refresh] Starting (last success: rrPYTHONIOENCODINGTrP)capture_outputrrrcwdenvz1 [live-refresh] WARN: extract script missing at FNrrqz" [live-refresh] extract returned rz" [live-refresh] extract timeout (us) — skipping rebuildz/ [live-refresh] WARN: build script missing at z [live-refresh] build returned z [live-refresh] build timeout (us) — abortedz live trades:rMr<OKz [live-refresh] Complete in rCus — z% [live-refresh] Failed (non-fatal): i8)rrQ_last_live_refreshr(rTosenvironcopydictrr(_last_live_refresh_attemptEXTRACT_SCRIPTr)_live_refresh_lock_live_refresh_running subprocessrunsys executableLIVE_REFRESH_EXTRACT_TIMEOUT returncodestderrstdoutr,TimeoutExpired BUILD_SCRIPTLIVE_REFRESH_BUILD_TIMEOUTrSrr/) startedlast_str child_env run_kwargsr1tailr2elapsedsummaryrrZs r _do_refresh_live_tradesrasllnG:L:L!**:6RYH 5hZq AB !I$+I !   N  J"*9*$$&& EnEUV W h $) ! g ^!454B }}! 44RYY44"de<BBD:2==/D6RS ""$$ CL>R S B $) ! A \!232B }}! 44RYY44"de<BBD8r$PQ. $) ! 5"&\\^%/>>@YY__"002D::"Q''Q>* Q; >R, R  R, R) $R,c\'gR#\;_uu_4\'d RRR4R#\;'g\pVeA\ P !4V, P4pV\8d RRR4R#RsRRR4\P!\RR7P4R# +'giL<;i)aDecide whether a live-data refresh is due. Non-blocking. Called from the main update loop. Spawns a daemon thread to run the actual extract + build if (a) feature is enabled, (b) no refresh is already running, and (c) enough time has elapsed since last refresh ATTEMPT (success or failure). Throttling on failure prevents log spam when MT5 is momentarily disconnected or scripts have issues. NTrdaemon) LIVE_REFRESH_ENABLEDrrrrrrQrSLIVE_REFRESH_INTERVAL_SEC threadingThreadrr)lastrs r maybe_refresh_live_tradesr s       *??-?  ||~,;;=G22  !% 3DAGGI  sC CAC C C zbuild_forecast.pyzforecast_data.jsonzforecast_build.logznotify_forecast.pyc^RIHpHp^RIHp\P !V!R44pW1!^R7,# \ d2\P !TP4T!^R7, pLJi;i)uFX session clock. Sessions roll at 17:00 New York (= broker midnight): the returned datetime's .date() is the session date — after Tue 5pm NY it reads Wednesday, and Sunday's rollover opens Monday's session. UTC-4 fallback if tzdata isn't installed.)timezoner')ZoneInfozAmerica/New_York)hours)rrr'zoneinforrQr/utc)rr'rnys r _session_nowrsb -=% \\(#56 7  " "" = \\(,, ')!*< <=s";9A76A7c`\P4'gR#\4pVP4^8dR#VP^8XdVP ^ 8dR#\ P4'gR#\\ RR7;_uu_4p\P!V4pRRR4XPRR4TPR48wdR#TPR 4'dTP^8dR#R# +'giLd;i \dR#i;i) z3True when a new session's forecast should be built.FTrrN session_daterqrlanchor_pending) FORECAST_SCRIPTr)rr%rr FORECAST_JSONrr'rr/r0r()rCrJrs r _forecast_stalers  ! ! # #Ayy{avv{qxx"}    ! ! -' 2 2a99Q._runs= % 6|~h6OtT UlC'::b< '7v>? NN^^S%9:Ir%,,c <<1$)?)F)F)H)HNN-C)DE N2)00"; 6q||nAF G  " " $%;: 5 /s3 4 4 5  " " $sH2FB6E5+AE5>!F5 F F F+F&!F.&F++F..GTr)r_forecast_last_attemptrr(acquirer r rr,s r maybe_refresh_forecastr1st yy{+A..4     ! !5 ! 1 1 $ 1%.D.446rzupdate_live_quotes.pyc\P4'gR#\P!4\^,, ^<8dR#\ 4P 4^8dR#\ PRR7'gR#\P!4\^&Rp\P!VRR7P4R#)zARuns update_live_quotes.py roughly once a minute during sessions.NFrc\P!\P\ \ 4.\ \ 4\P\P^7R7pVP^8wd\RVP R24\P4R# \dp\RT 24Rp?L4Rp?ii;i \P4i;i)7r#z [quotes] update failed (exit rz [quotes] update failed: N) rrrrrLIVE_QUOTES_SCRIPTr(DEVNULLrrTr/_live_quotes_lockr))rrZs r r,'maybe_refresh_live_quotes.._run;s (%7!89 N:+=+=!))2A ||q 7 ~QGH  % % ' 4 .qc2 3 3 4  % % 's*B B## C.C<C CC CTr) r5r)r_live_quotes_lastrr%r7r/r r rr0s r maybe_refresh_live_quotesr:/s  $ $ & & yy{&q))B.~1$  $ $e $ 4 499;a (D.446rzbuild_walls.pyz oi_data.xlsxoi_pdfszwalls_data.jsonzwalls_build.logc <.p\P4'dh\\PR44FEpVP VP R\ VP4P4 24KG \P4'd;TP R\ \P4P4 24RPT4# \dKi;i \dLi;i \dLAi;i)zFingerprint of the OI sources: top-level PDFs in oi_pdfs (history\ ignored) plus oi_data.xlsx if present. Must match what build_walls.py writes as source_sig.z*.pdfrzxlsx:|) WALLS_PDF_DIRis_dirr5globrnamerstatst_mtimeOSErrorr/ WALLS_XLSXr)join)partsrs r _walls_signaturerHVs E    ! !M..w78LLAFF81S1B1B-C,D!EF9  LL5Z__%6%?%?!@ AB C 88E?       sMC<!C<AC*C< 9D * C95C<8C99C<< D  D  DDc\P4'gR#\4pV'gR#\P4'gR#\ \RR7;_uu_4p\ P !V4PRR4pRRR4W8g# +'giTX8g#;i \dR#i;i)z6True when the OI sources changed since the last build.FTrr source_sigrqN) WALLS_SCRIPTr)rH WALLS_JSONrr'rr0r/)sigrJdones r _walls_stalerOls      C       *w / /199Q<##L"5D0 ; 0 / $; s0B1''BB1 B. %B1.B11 C?CcL\P!4\^,, R8dR#\4'gR#\P RR7'gR#\P!4\^&Rp\ P !VRR7P4R#)zARebuilds walls whenever a new oi_data.xlsx lands (OneDrive sync).iXNFrc x\R4\\RRR7;_uu_4pVPR\P !4 R24VP 4\P!\P\\4.\\4V\P^R7pRRR4\RXP R 24\"P%4R# +'giL?;i \ dp\R T 24Rp?LGRp?ii;i \"P%4i;i) u6 [walls] new oi_data.xlsx detected — rebuilding ...r rrr!r"r#Nz [walls] build finished (exit rz [walls] build failed: )rTr WALLS_LOGrErrQr%rrrrrrKr(r&rr/ _walls_lockr)r*s r r,!maybe_refresh_walls.._runs " J Kiw772< '7v>? NN^^S%67Ir%,,c8 3ALL>C D    !87 2 ,QC0 1 1 2    !sA%C=B C*3!C=* C: 5C== D DD#D  D##D9Tr)r_walls_last_attemptrOrSr/r r rr0s r maybe_refresh_wallsrV}sp yy{(++c1 >>     . .!YY[""D.446rcb\R4\R4\R\ 24\R\ 24\R\ 24\R, R, R, p\P 4'gVP 4'd \R4M \R 4\ 'd,\\ 4^8d\R \ RR  R 24M \R 4\'d\^<,p\P 4;'d\P 4pV'd\RV R24M.p\P 4'gVPR4\P 4'gVPR4\RRPV4 R 24M \R4\R4\P !\"RR7pVP%4\R\ R24\R4\'4\)4\+4\-4\/4\0P2!^4KL \d\R4ELi;i \4d\R4R #i;i)=zDASHBOARD SERVERz Log file : z Data file: z Port : rrrz$ Mode : VPS (writing live data)uG Mode : Home machine (read-only — serving VPS data via OneDrive)z- Calendar : FinanceFlow API enabled (key ...Nrz. Calendar : FinanceFlow DISABLED (no API key)z2 Calendar : FinanceFlow DISABLED (no API key set)z Live-refresh: ENABLED (every u/ min) → fires on first request after intervalr r z# Live-refresh: DISABLED (missing: z, zQ Live-refresh: DISABLED (set LIVE_REFRESH_ENABLED=True in server file to enable)Trz% Open in browser: http://localhost:z/dashboard.html z. Updating every 30 seconds (Ctrl+C to stop): z Dashboard server stopped.z<============================================================i)rTrrrr(r)rr1 NameErrorrr rrrrFr r rrrr r1r:rVrsleepKeyboardInterrupt)eu_stminsokmissing server_threads r mainras  (O  M( $% M) %& M$ !   '*= =EELLNN 46 WYE :#j/A- A*RS/ARRST U B D(B.  " " $ > >)<)<)> 3D69hi jG!((**GNN;S,T&&((GNN;R,S 7 '8J7K1M N ac (O$$JtDM 24&8I JK ;<   L % ' " $ % '  ! JJrNA E BDEB!  1 2  s10 I7<*I7' I7-AJ7JJJ.-J.__main__cV^8dQh/^\9d\R,;R&^\9d\R,;R&^\9d \;R&#)rZNrrr)__conditional_annotations__rbool)r4s"r r5r5sP  ~+*HtO* @32HtO2A B$#t#C r)z 2026-03-19z 2026-04-30z 2026-06-11z 2026-07-23z 2026-09-10z 2026-10-29z 2026-12-17)z 2026-01-28z 2026-03-18z 2026-04-29z 2026-06-17z 2026-07-29z 2026-09-16z 2026-10-28z 2026-12-09)rr)hrdrr'rrrrr http.serverrr pathlibrr__file__resolveparentsr(rrrrr _src_pathr8insertrr/r rTrr rrrrrrrLockrr<r>STARTING_BALANCEr[rr2rrrr-r.rr&r'r(r/r$rrrEr)rurlr+rxrvrrr&rkrrSimpleHTTPRequestHandlerrrrr rrr$r'r(r.rrr1r5r7r9r:rKrEr>rLrRrSrUrHrOrVrarr5)rdrds0@r rps   (^ # # % - -a 0  & (+@ @ . . UI% 34I  9%!% $ " #U"Z/2JJU"Z/2II &**.22##^^%*Z$-dR 1  " " " "  "  " " " " " " " " " "  "! ""# $" """""""""""""?  B""""  "  " """""" """ "!""#$""'.   , .> " $0  + -5 7?   '      '  )4  6A    .  0G  ) +:  , .;   % '- /6      q$Z %;%E%EA%E%NNXXYcd  $ 40+\:zd,N4i|TJtYgtUDQ"E/P0|D T\6<!5,?.BJe&PZ+t{{;;Z+zV*rJ6e#k14GG22 f$v-0DD "U*[8;OO! #2"7L&47NNNN$E7<5 ;.1AA >) I% ,, 6!F*->> nn e,"7<4n zFO5U +B4/R STTUBs%&O("OAO>O;$ O66O;