i UdZddlZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z ddlmZddlZej$j'ej$j)edZdZd Zd ZGd d ZGd deeZGddeeZeGddZeGddZGddZ GddZ!GddZ"da#e e!e$d<da%e e"e$d<de!fdZ&de"fdZ'd ed!ed"ede efd#Z(y)$u CryptoClaw Paper Trading System ================================ Two-mode paper trading simulator: 1. FREE MODE — User places manual trades, tracks P&L 2. GUIDED MODE — Auto Hedge-Mart V4 runs live, teaches step by step Designed for Telegram integration via OpenClaw command routing. Storage: SQLite database for persistence across sessions. Price feed: Live BTC price via public API (or replay from tick data). N)datetimetimezone) dataclass)ListOptionalDictTuple)Enumzpaper_trading.dbg@g{Gz?BTCUSDcReZdZUdZdZeed<dZeed<dZeed<e defdZ y ) PriceFeedz:Fetch live BTC price from public APIs (no API key needed). _cache_price _cache_timeg@ _cache_ttlreturnctj}|jdkDr(||jz |jkr |jSddg}|D]\}} tj j |ddi}tj j|d5}tj|jj}|}|jd D]} || } t|} | dkDr| |_||_| cd d d cS d d d |jdkDr |jSy #1swY'xYw#t$rYwxYw) z3Get current BTCUSD mid price. Caches for 5 seconds.r)z:https://api.binance.com/api/v3/ticker/price?symbol=BTCUSDTprice)z/https://api.coinbase.com/v2/prices/BTC-USD/spotz data.amountz User-AgentzCryptoClaw/1.0)headers)timeout.Ngj@)timerrrurllibrequestRequesturlopenjsonloadsreaddecodesplitfloat Exception) clsnowapisurlpathreqrespdatavalkeyrs //var/www/html/crpytotradingbot/paper_trading.py get_btc_pricezPriceFeed.get_btc_price,sZiik   a S3??%:cnn$L## # T N   IC nn,,S E E >E E  EEN) __name__ __module__ __qualname____doc__rr#__annotations__rr classmethodr0r/r r %s<DL%KJer8r ceZdZdZdZy)TradeDirectionBUYSELLN)r1r2r3r;r<r7r8r/r:r:Qs C Dr8r:ceZdZdZdZy) SessionModefreeguidedN)r1r2r3FREEGUIDEDr7r8r/r>r>Vs D Fr8r>ceZdZUdZeed<eed<eed<eed<eed<e eed<e eed<eed <d Z e eed <d Z e eed <d Z e eed <dZ eed<dZeed<dZeed<edefdZdedefdZy ) PaperTradezA single paper trade.trade_iduser_id directionlots entry_pricetp_pricesl_price open_timeN close_time close_pricepnlr commissionOPENstatuscommentrc |jdk(S)NrQ)rRselfs r/is_openzPaperTrade.is_openms{{f$$r8 current_pricec|jtjk(r|j||jz z}n|j|j|z z}||j z SN)rGr:r;rHrIrP)rWrYraws r/unrealized_pnlzPaperTrade.unrealized_pnlqsU >>^// /))}t/?/??@C))t//-?@CT__$$r8)r1r2r3r4intr5strr:r#rrMrNrOrPrRrTpropertyboolrXr]r7r8r/rDrD[sM L KuouoN $J $#'K%'C%JFCGS %%%%E%e%r8rDceZdZUdZeed<eed<eed<eed<eed<eed<dZe ed <dZ e ed <dZ e ed <d Z eed <d Z eed<d Zeed<dZeed<y) UserSessionzA user's paper trading session.rFusernamemodebalanceinitial_balance start_timer trades_countwinslossesr total_pnl max_balance min_balanceT is_activeN)r1r2r3r4r_r5r>r#rir^rjrkrlrmrnrorar7r8r/rcrcysi) LM  NOL#D#MFCOIuKKItr8rccxeZdZdZefdefdZedejfdZ dZ dede e fdZefded ed ed ede f d Zd e fdZdefdZd#dedeefdZ d$dedededede ede ededefdZdedede efdZdedeefdZd%dededeefdZdede efdZdefd Z ded!edeefd"Z!y)&PaperTradingDBz5SQLite storage for paper trading sessions and trades.db_pathc||_tj|jd|_tj|j_|jj d|jy)NF)check_same_threadzPRAGMA journal_mode=WAL)rrsqlite3connect _connectionRow row_factoryexecute_init_dbrWrrs r/__init__zPaperTradingDB.__init__sP "??4<<5Q'.{{$   !:; r8rc|jSr[)rwrVs r/connzPaperTradingDB.connsr8c:|jjdy)Na CREATE TABLE IF NOT EXISTS sessions ( user_id TEXT PRIMARY KEY, username TEXT NOT NULL, mode TEXT NOT NULL DEFAULT 'free', balance REAL NOT NULL, initial_balance REAL NOT NULL, start_time TEXT NOT NULL, trades_count INTEGER DEFAULT 0, wins INTEGER DEFAULT 0, losses INTEGER DEFAULT 0, total_pnl REAL DEFAULT 0.0, max_balance REAL NOT NULL, min_balance REAL NOT NULL, is_active INTEGER DEFAULT 1 ); CREATE TABLE IF NOT EXISTS trades ( trade_id INTEGER PRIMARY KEY AUTOINCREMENT, user_id TEXT NOT NULL, direction TEXT NOT NULL, lots REAL NOT NULL, entry_price REAL NOT NULL, tp_price REAL, sl_price REAL, open_time TEXT NOT NULL, close_time TEXT, close_price REAL, pnl REAL, commission REAL DEFAULT 0.0, status TEXT DEFAULT 'OPEN', comment TEXT DEFAULT '', FOREIGN KEY (user_id) REFERENCES sessions(user_id) ); CREATE INDEX IF NOT EXISTS idx_trades_user ON trades(user_id); CREATE INDEX IF NOT EXISTS idx_trades_status ON trades(status); )r executescriptrVs r/r{zPaperTradingDB._init_dbs %! % r8rFc|jjd|fj}|rQt|d|dt |d|d|d|d|d|d |d |d |d |d t |d Sy)Nz(SELECT * FROM sessions WHERE user_id = ?rFrdrerfrgrhrirjrkrlrmrnro) rFrdrerfrgrhrirjrkrlrmrnro)rrzfetchonercr>ra)rWrFrows r/ get_sessionzPaperTradingDB.get_sessionsii 6  (*  IZ V-s9~ #$5 63|CT 0s6{8}K0@ .C C+?@ ""$ yk8X:w( ) ## ""7+  OOz )O    (w);7   r8rErNc|jjd|fj}|syt|d}|d}|d}|d}|tjk(r |||z z}n|||z z}||zt dz z} || z} || z } t jtjj} |jjd| || | |f|jj|d} |j| }|r|xj|| z z c_ |xjd z c_|xj| z c_| d kDr|xj d z c_n| d kr|xj"d z c_t%|j&|j|_t)|j*|j|_|j-|t/|| ||||d |d |d | || | d|dS)Nz;SELECT * FROM trades WHERE trade_id = ? AND status = 'OPEN'rGrHrIrPrz UPDATE trades SET close_time=?, close_price=?, pnl=?, commission=?, status='CLOSED' WHERE trade_id=? rFrrrJrKrLCLOSEDrTrErFrGrHrIrJrKrLrMrNrOrPrRrT)rrzrr:r;rrr&rrrrrrfrirlrjrkmaxrmminrnrrD)rWrErNrrGrHrIentry_commissionraw_pnlclose_commissiontotal_commissionnet_pnlr&rFrs r/ close_tradezPaperTradingDB.close_trade(s ii IH; (* "3{#34 6{-( |, ** *kK78GkK78G +-#1EF+.>>,,ll8<<(224  ;)98 D F i.""7+  OOw)99 9O  A %    ( { ! 1!#"%g&9&97??"KG "%g&9&97??"KG     (w);Z_K0@ '#i.   r8c|jjd|fj}|Dcgc]}|j|c}Scc}w)NzLSELECT * FROM trades WHERE user_id = ? AND status = 'OPEN' ORDER BY trade_idrrzr _row_to_trade)rWrFrrs r/get_open_tradeszPaperTradingDB.get_open_trades^sKyy  Z J  (* 044!""1%444sA c|jjd||fj}|Dcgc]}|j|c}Scc}w)Nz[SELECT * FROM trades WHERE user_id = ? AND status = 'CLOSED' ORDER BY trade_id DESC LIMIT ?r)rWrFrrrs r/get_trade_historyz PaperTradingDB.get_trade_historyesNyy  i e   (* 044!""1%444sA c|jjd|fj}|r|j|Sy)Nz'SELECT * FROM trades WHERE trade_id = ?)rrzrr)rWrErs r/ get_tradezPaperTradingDB.get_tradels@ii 5{ (*  %%c* *r8ct|d|dt|d|d|d|d|d|d|d |d |d |d |d |dS)NrErFrGrHrIrJrKrLrMrNrOrPrRrTr)rDr:)rWrs r/rzPaperTradingDB._row_to_tradetsu_c)n$S%56S[M*S__K0@<(c-6HE s<'8x=#i.  r8rYcg}|j|}|D]@}d}|}|jru|jtjk(r||jk\rd|j}}n:|jtj k(r||jkrd|j}}|s|j ru|jtjk(r||j krd|j }}n:|jtj k(r||j k\rd|j }}|s|j|j|}|s0|j|C|S)z2Check and auto-close any trades that hit TP or SL.FT) rrJrGr:r;r<rKrrEappend) rWrFrYclosed open_tradestradehitclose_atresults r/ check_tp_slzPaperTradingDB.check_tp_sls**73   *EC$H~~??n&8&88]enn=\$(%..C__(;(;; QVQ_Q_@_$(%..C5>>??n&8&88]enn=\$(%..C__(;(;; QVQ_Q_@_$(%..C))%..(CMM&)' *( r8 )NNrS))"r1r2r3r4DB_PATHr_r}r`ru Connectionrr{rrcrDEFAULT_BALANCEr>r#rrrr^rrrr:rDrrrrrrrr7r8r/rqrqs?&- g((  & T38K+@")8cS  %A KU 84 C4 e4 @T4 l5s5tJ/?555S5$zBR5#(:*>  J  3ujAQr8rqc .eZdZdZefdefdZddedededefdZdded ed ed edef d Zdded ed ed edef d Z ddede d ed ed edef dZ ddededefdZ dedefdZ dedefdZdedefdZddededefdZdefdZdededefdZdefdZdefdZy) PaperTradingEnginez{ Main interface for the paper trading system. All methods return formatted strings ready for Telegram display. rrc$t||_yr[)rqdbr|s r/r}zPaperTradingEngine.__init__s )r8rFrdrerc|jj|}|rB|jr6d|jjj d|j ddS t|j}|jj|||}|tjk(rd|j ddtdSd |j dd S#t$rYywxYw) z"Start a new paper trading session.u1⚠️ You already have an active session! Mode: z Balance: $,.2fz$ Use `/paper reset` to start fresh.uG❌ Invalid mode. Use `free` or `guided`. Example: `/paper start free`uH🎮 **Paper Trading Started — FREE MODE** 💰 Starting Balance: **$u(** 📊 Symbol: BTCUSD 💸 Commission: u% per trade **Commands:** `/buy ` — Open long (e.g. `/buy 0.01`) `/sell ` — Open short `/buy tp= sl=` — With TP/SL `/close ` — Close a trade `/close all` — Close all trades `/positions` — View open trades `/balance` — Check balance & P&L `/history` — Trade history `/paper stats` — Full statistics `/paper leaderboard` — Channel rankings Good luck! 🦾uJ🤖 **Paper Trading Started — GUIDED MODE** 💰 Starting Balance: **$u** 📊 Strategy: Auto Hedge-Mart V4 ⚙️ Config: 0.03 lot, $15 exit, adaptive grid I'll run the algo and explain every trade as it happens. Watch your balance grow while learning the system. **Commands:** `/positions` — View current algo trades `/balance` — Check balance & P&L `/paper explain` — Explain current state `/paper stats` — Full statistics `/paper stop` — Stop guided session 🔄 Algo is running... watching for entry signals.) rrrorerupperrfr>lower ValueErrorrrAr)rWrFrdreexisting session_moders r/startzPaperTradingEngine.starts77&&w/ **!,,22456%--d3456  _&tzz|4L''(((LI ;++ +--4__T,BC$$2#3 4"# (--4__T,B CF G 3 _^ _s!C CClots_strtp_strsl_strcH|j|tj|||Sr[) _open_trader:r;rWrFrrrs r/buyzPaperTradingEngine.buys!););XvvVVr8cH|j|tj|||Sr[)rr:r<rs r/sellzPaperTradingEngine.sells")<)rBr#r TypeErrorr r0rfr:r;r<rlenrrrErP)rWrFrGrrrrrHrposition_valuerequired_marginrJrKrremojitp_linesl_lines r/rzPaperTradingEngine._open_trades''%%g.g//N <<;-- -y @?Dqy   $;@'')(4/ W__ ,$$24#89++:4*@A"")//$!79   / = 2 22x57H@t LYY 3 33E8I@t MZZ  / = 2 22x57H@t LYY 3 33E8I@t MZZ gg--g6 { r !>""7ItUHhW''%%g.#~'9'99v4>*"iy !1!1$ 78%ood3  5 sI& @? @> /. / /. /sB H 3)H5H5?)I)I H21H25 II IItargetc|jj|}|r |jsytj }|jj ||}|j dk(r`|jj|}|s|syt|}|D]<}|jj|j|} | s,|j| >td|D} |jj|}dt|dg} |D]k} | jxsddk\rdnd } | j| d | jd | jj d | j"d | jd  m| jd| d d| jd|j$dddj'| S t)|}|jj/|}|r|j0|k7rd|dS|j2sd|dS|jj||} | sd|dS|jj|}| jxsddk\rdnd } d|d| jj d| j4dd|dd| j"d| d| jd d| j6dd |j$ddS#t*t,f$rYywxYw)!N❌ No active session.allu📭 No open trades to close.c3NK|]}|j|jywr[rO.0ts r/ z+PaperTradingEngine.close..GsHaaee6GAEEH%%u🔒 **Closed z trade(s)** r✅❌ #r → $+,.2fu 💰 Net P&L: **$**💰 Balance: **$rr.❌ Usage: `/close ` or `/close all`u ❌ Trade #z not found.z is already closed.u❌ Failed to close trade #ru🔒 **Trade #z CLOSED** Direction: z Entry: $z Exit: $z Lots: z P&L: **$u** 💸 Commission: $u 💰 Balance: **$)rrror r0rrrlistrrErsumrrOrGrrHrfjoinr^rrrrFrXrIrP)rWrFrrr auto_closedrresultsrrrllinesr pnl_emojirEs r/closezPaperTradingEngine.close2s''%%g.g//+'')gg))'59 <<>U "''11':K{6;'G$ +,,U^^UCNN6* + H7HHIgg))'2G%c'l^=ABE k&'eejqQ%6EE  {"QZZL!++:K:K9LAaffXU[\]\a\abg[hij k LL.y.?rB C LL,W__T,B"E F99U# # D6{H!!(+ 0  +6 6}}  *=> >$$Xu50 !< <''%%g.$jjoA!3E XJ' **0012))$/0D\"[[Mk6::e"45!!'!2!24 89 '5R 9 !I& DC Ds KK0/K0cF|jj|}|r |jsytj |jj |}|jj |}dddg}|r|jdt|d|D]_}|jxsddk\rdnd }|jd |d |jd |jjd |jda|jd|s|jdnd}|D]}|j} || z }|jtjk(rdnd} | dk\rdnd}|j rd|j dnd} |j"rd|j"dnd} |j| d|jd|jjd |j$d|j&dd |d| d| | |jd|dd|jj|}|jd|j(dd|j(t+fd |Dz} |jd!| ddd"j-|S)#Nru📊 **Open Positions** (BTC: $rz) u⚡ z" trade(s) auto-closed (TP/SL hit):rrrz rrrrrSu📭 No open positions.rrr📈📉z | TP: $,.0fz | SL: $z **#z**  @ $z $u 📊 Unrealized P&L: **$rrc3@K|]}|jywr[r]rrrs r/rz/PaperTradingEngine.positions..s&T1q'7'7'>&Tu💎 Equity: **$r)rrror r0rrrrrOrErGrr]r:r;rJrKrHrIrfrr)rWrFrrrrrr total_upnlupnlrtp_infosl_infoequityrs @r/ positionszPaperTradingEngine.positionsqs''%%g.g//N'')gg))'59 gg--g6 25,cBC  LL4K 011ST U  d&'eejqQ%6EE  r)Bqzzl!AKKbAB3&T &T#TT 't}B78yyr8c |jj|}|r |jsytj |jj | |jj |}t fd|D}|j|z}||jz }||jz dz}d}|jdkDr)|j|jz |jz dz}|dk\rdnd} d d d |jd d |d d |d d| d|d d|dd|ddt|d|jS)Nrc3@K|]}|jywr[rrs r/rz-PaperTradingEngine.balance..FQ))%0Frrrrrru1💰 **Paper Trading Balance** 📊 BTC Price: $ru 💵 Balance: **$u** 📊 Unrealized: $ru 💎 Equity: **$z** z Total P&L: **$ (+.1fu%)** 📉 Max Drawdown: .1fu% 🔄 Open Trades: u 📋 Total Closed: )rrror r0rrrrfrgrmrnrri) rWrFrrr r pnl_from_startpnl_pctmax_ddrrs @r/rfzPaperTradingEngine.balancesl''%%g.g//N'') GU+gg--g6 F+FF :-'"9"99!G$;$;;sB    "**W-@-@@GDWDWW[^^F,1Fv  %d|, '56!!+E 23%dm6k(>bO""(.!!$[!1 23"")"6"6!7 9 r8cV|jj|}|r |jsytj |jj |}|jj |d}tfd|D}|j|z}||jz }||jz dz}|jdkDr|j|jz dznd} td|D} ttd|D} | dkDr| | z n| dkDr td nd} td |Dd } td |Dd }d }|j dkDr)|j |j"z |j z dz}|dkDrt||z nd}d|j$j&j)d|dd|dd|dd|jd|jd|j*d| dd| dd| dd|dd|dd|dd t-|d!|dS)"Nrirc3@K|]}|jywr[rrs r/rz+PaperTradingEngine.stats..rrrrc3nK|]-}|js|jdkDs |j/ywrNrrs r/rz+PaperTradingEngine.stats..s$G1155QUUQYG 555c3nK|]-}|js|jdks |j/ywrrrs r/rz+PaperTradingEngine.stats..s$M15519quuMrinfc3NK|]}|js|jywr[rrs r/rz+PaperTradingEngine.stats..s4aaeeAEE4r)defaultc3NK|]}|js|jywr[rrs r/rz+PaperTradingEngine.stats..s5qquuQUU5rru(📊 **Paper Trading Statistics** Mode: u 💎 Equity: **$ru** 📈 Return: **rz%** ($ru) 🔢 Total Trades: u ✅ Wins: u | ❌ Losses: u 🎯 Win Rate: **ru%** ⚖️ Profit Factor: **z.2fu** 🏆 Best Trade: $u 💀 Worst Trade: $u 📉 Max Drawdown: **u%** 📐 Risk-Adj Return: **u** 🔄 Open Positions: u 📊 Unrealized: $)rrror r0rrrrfrgrirjabsr#rrrmrnrerrrkr)rWrFrrhistoryr r rrwin_rate gross_wins gross_lossespfbestworstrrarrs @r/statszPaperTradingEngine.statssc''%%g.g//+'')gg--g6 ''++G4+@F+FF :-'"9"99!G$;$;;sBBIBVBVYZBZGLL7#7#77#=`aGGG 3MgMMN ,81,F }K89 A"#%%*1!2Ikk^-?-??FVE LL'AJJu^'<&=Z3xtU   yyr8c:|jj|y)Nui🗑️ Session reset. All trades cleared. Start fresh with `/paper start free` or `/paper start guided`)rr)rWrFrds r/resetzPaperTradingEngine.resets g&|r8c8tj}d|ddS)Nu₿ **BTC/USD: $rr)r r0)rWrs r/rzPaperTradingEngine.prices!'')!%R00r8cdS)Nu🦾 **CryptoClaw Paper Trading** **Getting Started:** `/paper start free` — Manual trading mode `/paper start guided` — Algo teaches you **Trading (Free Mode):** `/buy ` — Open long `/sell ` — Open short `/buy tp= sl=` — With TP/SL `/close ` — Close trade by ID `/close all` — Close all positions **Info:** `/positions` — Open trades + live P&L `/balance` — Balance & equity `/history` — Recent closed trades `/price` — Current BTC price **Stats:** `/paper stats` — Full statistics `/paper leaderboard` — Channel rankings `/paper reset` — Wipe & start over 💰 Start with $20,000 fake money 💸 Commission: 0.04% (same as Binance) 📊 Tracks: Win rate, P&L, drawdown, profit factorr7rVs r/helpzPaperTradingEngine.helps B r8N)r?)rSrS)rSr)r1r2r3r4rr_r}rrrr:rrrrfr,r^r$r9r;rr>r7r8r/rrs '.**4S4C4s44lW3W#WsWWVYWXCX3XX#XWZXDFM 3M >M !M +.M =@M JMM ^= S= #= s= ~( ( ( T s s @, S, S, \ s 3  ( S &}S}C}C}1s1 c r8rc \eZdZdZd defdZdedededeefd Zd e ede eeffd Z y) CommandParserz>Parse Telegram-style commands and route to PaperTradingEngine.Nenginec*|xs t|_yr[)rrA)rWrAs r/r}zCommandParser.__init__:s4 2 4 r8rFrdtextrc*|j}|jdsy|j}|dj}d|vr|jdd}|dk(r t |dkr|j j S|dj}|dk(r2t |dkDr|dnd}|j j|||S|d k(r|j j|S|d k(r|j jS|d k(r|j j||S|d k(r|j j S|j j S|d k(rIt |dkry|d}|j|dd\} } |j j||| | S|dk(rIt |dkry|d}|j|dd\} } |j j||| | S|dk(r4t |dkDr|dnd} | sy|j j|| S|dk(r|j j|S|dk(r|j j!|S|dk(rMt |dkDr!|dj#rt%|dnd} |j j'|| S|dk(r|j j)S|dk(r|j jSy)N/r@z/paperrrr?r,r9r;r>z/buyu+❌ Usage: `/buy ` (e.g. `/buy 0.01`)z/sellu-❌ Usage: `/sell ` (e.g. `/sell 0.01`)z/closerSrz /positionsz/balancez/historyrz/pricez /leaderboard)strip startswithr"rrrAr>rr,r9r; _parse_tp_slrrrrrfisdigitr^r$r) rWrFrdrCpartscmdsubrerrrrrs r/parsezCommandParser.parse=szz|s# Ahnn #:))C.#C (?5zA~{{''))(.."Cg~#&u:>uQxv{{(((DAA{{((11 %{{..00{{(((;;{{'')){{'')) F]5zA~DQxH!..uQRy9NFF;;??7HffE E G^5zA~FQxH!..uQRy9NFF;;##GXvvF F H_!$UaU1XRFG;;$$Wf5 5 L ;;((1 1 J ;;&&w/ / J %(Z!^a8H8H8JCaMPRE;;&&w6 6 H_;;$$& & N ";;**, ,r8argscd}d}|D]@}|j}|jdr|dd}*|jds<|dd}B||fS)NrSztp=r0zsl=)rrI)rWrPrrarg arg_lowers r/rJzCommandParser._parse_tp_slsd !C I##E*QR%%e,QR  ! v~r8r[) r1r2r3r4rr}r_rrOrr rJr7r8r/r@r@7s\H515BSBCBsBx}BH c uS#X r8r@_engine_parserrc.t tatSr[)rTrr7r8r/ get_enginerWs$& Nr8c@tttatSr[)rUr@rWr7r8r/ get_parserrYs - Nr8rFrdrCc8tj|||S)z;Top-level entry point: parse text, return response or None.)rYrO)rFrdrCs r/handle_commandr[s <  gx 66r8))r4rruosrrr dataclassesrtypingrrrr enumr urllib.requestrr)rdirname__file__rrrSYMBOLr r_r:r>rDrcrqrr@rTr5rUrWrYr[r7r8r/rds<   '!.. '',,rwwx02D E %%XS$ #t  %% %:  *HH^R R r SSt)-$ %,#'- '&M7C737c7hsm7r8