Xj5ddZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZedZdZGdd Zed k(rgeZed ej+j-d d dedej/dddedeej3yy)a Bybit Demo REST client (custom, bypass ccxt bug con api-demo.bybit.com). Implementa solo i metodi necessari al live engine: - fetch_ohlcv(symbol, interval, limit) - fetch_balance() - fetch_positions(symbol) - create_order(symbol, side, qty) market entry - create_reduce_order(symbol, side, qty, price) - set_trading_stop(symbol, sl_price) Testato: HMAC manuale funziona, totalEquity 48462 USDT. N)Path) load_dotenv)OptionalListDictz/opt/charter/.envzhttps://api-demo.bybit.comc~eZdZdZdededefdZd*deded ed edef d Zd+d ed ede de fdZ d ede fdZ d ede de fdZdefdZd,d ede fdZd edede defdZ d-d edede de dedef dZ d.d ede de de de dededefd Zd ed!edefd"Zd,d ede fd#Zd,d ed$e de fd%Z d/d ed&e ded'edef d(Zd edefd)Zy)0BybitDemoClientctttjd|_tjd|_|jr |j st dttj|_ y)NBYBIT_DEMO_API_KEYBYBIT_DEMO_SECRET_KEYzCredenziali mancanti in ) rENV_FILEosgetenvapi_keysecret RuntimeErrorrequestsSessionsession)selfs -/opt/charter/live_deploy/bybit_demo_client.py__init__zBybitDemoClient.__init__s\Hyy!56 ii 78 ||4;;!9(DE E'') bodytsreturnc||jd|}tj|jj |j t j jS)zBybit V5 signature: timestamp + api_key + recv_window + body. body = querystring sorted (GET) oppure JSON body raw come inviato (POST).5000)rhmacnewrencodehashlibsha256 hexdigest)rrrsign_strs r_signzBybitDemoClient._sign#sPT$,,tD62xx **,hoo.?PZZ\\rNmethodpathparamssignedc |xsi}ddi}t|z}d}d}|rtttjdz} |dk(r'dj d|j D}nt j|d }|j|d <|j|| |d <| |d <d |d<|dk(r |jj|||d} n4|dk(r |jj|||d} ntd|d| j } | jdddk7r5td| jdd| jdd|dd| S)Nz Content-Typezapplication/jsoniGET&c30K|]\}}|d|yw)=N).0kvs r z+BybitDemoClient._request..6s(O1A3as(Os)z, : ) separatorszX-BAPI-API-KEYz X-BAPI-SIGNzX-BAPI-TIMESTAMPrzX-BAPI-RECV-WINDOW )r)headerstimeoutPOST)jsonr9r:zMethod z not supportedretCoderz Bybit err r6retMsgz | body_for_sign=)BASE_URLstrinttimejoinitemsr<dumpsrr&rgetpost ValueErrorr) rr'r(r)r*r9url body_for_signbody_rawrrdatas r_requestzBybitDemoClient._request)ss2!#56o  St+,-B !$(O (O O !% 6l K (, G$ %%)ZZ r%BGM "*,G& ',2G( ) U?   VWb QA v  !!#FGR!PAwvhn=> >vvx 88Iq !Q &DHHY,?+@488HCUBVVghuvzwzh{g|}~ ~ rsymbolintervallimitc Bd|t|t|d}|jdd|d}t|ddDcgc]R}t|d t |d t |d t |d t |d t |dgTc}Scc}w)zHsymbol: 'ZECUSDT' (senza /). interval: '240' (4h), '60' (1h), '15', etc.linear)categoryrPrQrRr-z/v5/market/klineFr*resultlistr)rArOreversedrBfloat)rrPrQrRr)rNcs r fetch_ohlcvzBybitDemoClient.fetch_ohlcvJs&&c(m^abg^hi}}U$6u}M!$x."89;QqTE!A$KqteAaDk51;PUVWXYVZP[\; ;;sABc |jddd|dd}|ddD]E}|jd |k(s|jd i}t|jd d cS y #t$r }Yd }~y d }~wwxYw)zQRitorna lo step minimo di qty per il simbolo (es. 1.0 per AERO, 0.001 per altri).r-z/v5/market/instruments-inforT)rUrPFrVrWrXrP lotSizeFilterqtyStepg?N)rOrGr_ Exception)rrPrNinstlotes r get_qty_stepzBybitDemoClient.get_qty_stepQs ==(E/76"JSX!ZDXv. :88H%/((?B7C C!899 :    s7A,.A,)A,, A?:A?qtyc|j|}|dk\rtt|Sdt|vr5t t|j dj ddnd}t|||zz |S)z2Arrotonda qty al multiplo del qtyStep del simbolo.rY.0r)rir_rBrAlenrstripsplitround)rrPrjstepdecimalss r round_qtyzBybitDemoClient.round_qty^st  ( 19S? "@Cs4y@P3s4y'',2237;&1VaU155;K;Pq5QTU5UVVVs 'AAsidec||jdvrdnd}d||dt|dd}|jdd |d S) zFside: 'long'/'short' oppure 'buy'/'sell'. Bybit V5 vuole 'Buy'/'Sell'.buylongBuySellrTMarketGTC)rUrPr orderTyperj timeInForcer;/v5/order/createTrVlowerrArO)rrPrrj bybit_sider)s rcreate_market_orderz#BybitDemoClient.create_market_orderrsH"jjlo=U6 &&*'CP}}V%7}MMrprice reduce_onlyc |jdvrdnd}d||dt|t|d|d}|jdd |d S) NrrrrTLimitr)rUrPrrrjrr reduceOnlyr;rTrVr)rrPrrjrrrr)s rcreate_limit_orderz"BybitDemoClient.create_limit_orderysS"jjlo=U6 &&*&s3x#e*!&kC}}V%7}MMrsl_pricetp_price trailing_stop active_price sl_trigger_by tp_trigger_bycd|dd}|t||d<||d<|t||d<||d<|t||d<|t||d <t|d kr td |jd d |dS)uSBybit V5 /v5/position/trading-stop — imposta SL, TP, trailing stop nativi sulla posizione corrente. Eseguiti DALL'EXCHANGE anche se il bot è offline. BUG_005 fix: aggiunti parametri opzionali per supportare Charter enforcement: - tp_price: take profit nativo (singolo prezzo, riduce TUTTA la posizione) - trailing_stop: distanza trailing (es. "0.5" = 0.5% sotto mark) - active_price: prezzo di attivazione trailing (es. entry*1.03 = dopo TP1) Mantiene backward-compat: set_trading_stop(symbol, sl_price) funziona come prima. NB: Bybit consente UN SOLO takeProfit nativo per posizione. Per split 50/50 si usa TP medio pesato, oppure si combinano TP nativo (riduzione totale 50%) + ordine reduceOnly residuo (NO — vedi fix live_engine per la strategia scelta). rTr)rUrP positionIdxstopLoss slTriggerBy takeProfit tpTriggerBy trailingStop activePricer[zGset_trading_stop: specificare almeno sl_price, tp_price o trailing_stopr;z/v5/position/trading-stopTrV)rArorIrO) rrPrrrrrrr)s rset_trading_stopz BybitDemoClient.set_trading_stops"'&K  !$XF: $1F= !  #&x=F< $1F= !  $%(%7F> "  #$' $5F= ! v;! fg g}}V%@&QU}VVrorder_idc8d||d}|jdd|dS)zLCancella un singolo ordine pending per symbol. Usato per cleanup reduceOnly.rT)rUrPorderIdr;z/v5/order/cancelTrVry)rrPrr)s r cancel_orderzBybitDemoClient.cancel_orders&&&XN}}V%7}MMrcddd}|r||d<|jdd|d}|jd ijd gS) zFRitorna lista ordini pending (Untriggered/New). Se symbol=None, tutti.rTr|r}rPr-z/v5/order/realtimeTrVrWrXrOrG)rrPr)rNs rget_open_orderszBybitDemoClient.get_open_orderssN&f= %F8 }}U$8&}Nxx"%))&"55rkeep_order_idsct|xsg}d} |j|}|D]v}|jd}t|jddj dk(}|jdd} ||vrW|sZ| dvs_ |j |||dz }x|S#t $r} td |d | Yd } ~ d } ~ wwxYw#t $r} td | Yd } ~ yd } ~ wwxYw) aBUG_005 FIX 3: cancella tutti i reduceOnly pendenti per symbol, tranne quelli in keep_order_ids. Usato come cleanup PRIMA di piazzare nuovi TP/SL, per evitare conflitti. Ritorna numero ordini cancellati. NB: NON cancella gli stop/positions Bybit V5 nativi (non sono ordini separate, sono campi sulla posizione). Cancella SOLO ordini 'order' veri con reduceOnly=True. rrrr,true orderStatus)New UntriggeredPartiallyFilledrYz [WARN] cancel_order z fallita: Nz [WARN] cancel_reduce_orders: )setrrGrArrreprint) rrPrkeep cancelledordersooid is_reducestatusrhs rcancel_reduce_ordersz$BybitDemoClient.cancel_reduce_orderss >'R(  ))&1F KeeI&lB 78>>@FJ }b1$;+T!TK))&#6!Q  K %K 6se:aSIJJK  3A37 8 sHA,CCB!C! C*C;CCC C)C$$C)leveragebypass_if_alreadycd|rG |j|}|jd}|"t|t|k(r dd|diddSd|t|t|d } |j d d |d S#t$rY:wxYw#t $r}d t|vr ddidcYd}~Sd}~wwxYw)aImposta la leva per il simbolo PRIMA di aprire un ordine. Charter Mattia 12/07: TARGET 3x per TUTTI gli asset. - Se l'asset e' GIA' a 3x su Bybit: BYPASSA, NON chiamare set_leverage. - Altrimenti (leva attuale diversa da 3x): chiama set_leverage(3). Comportamento: - bypass_if_already=True (default): legge get_leverage() prima; se gia' al target, ritorna {"retCode": 0, "retMsg": "bypassed (already at target)", "result": {}, "bypassed": True}. - bypass_if_already=False: chiama sempre set_leverage. Bybit ritorna 110043 "leverage not modified" se gia' al target (gia' gestito come OK). Bybit V5 richiede SIA buyLeverage CHE sellLeverage (err 10001 se manca uno). rNrzbypassed (leverage already at zx)T)r=r>rWbypassedrT)rUrP buyLeverage sellLeverager;z/v5/position/set-leveragerV110043iۭz)leverage not modified (already at target))r=r>rW) get_leveragerGrArerOr) rrPrrrcurrent current_levr)rhs r set_leveragezBybitDemoClient.set_leverages  ++F3%kk*5 *s;/?3x=/P#$$B8*B"O"$$( '&!$XH O ==)DfUY=Z Z   3q6!#)5`lnoo   s6AA9$B9 BB B/B*#B/)B**B/c|jddd|ddd}i}|jdijd gD]}}|jd |k(s|jd |d <|jd |d <|jd |d <|jd|d<|jd|d<|S|S)u~Ritorna la leva corrente per il simbolo. Richiede posizione aperta o che la leva sia stata precedentemente impostata. Ritorna dict con 'leverage', 'avgPrice', 'size', 'side', 'unrealisedPnl'. NOTA firma: ordine querystring DEVE essere (category, symbol, settleCoin) — Bybit non accetta sort alfabetico (vedi err 10004). Manteniamo ordine esplicito.r-rrTr|)rUrPr~TrVrWrXrPravgPricerr unrealisedPnlr)rrPrNrWrs rrzBybitDemoClient.get_leverages }}U$7+3vU[\%)+(B'++FB7 AuuX&(%&UU:%6z"%&UU:%6z"!"vv!"vv*+%%*@'   r)NF)r?)N)T)NNNN MarkPricer)rT)__name__ __module__ __qualname__rrAr&dictboolrOrBrXrar_rirurzrrrrrrrrrr1rrr r s*]#]3]3] s#tD]aB;#;;S;4; 3 5 33%3E3KtK WcWTWN#NSNuNN15NNCNeNEN)-N9=N?CIM04/:/: WsWeW$)WAFW(-W*-W*- W@D W@N3N#N$N 6c6T63PS8DJ04(3(#(S()-(9=(T34rr __main__zBalance: totalEquityzN/Ar|zOHLCV ZEC 4H (last 2):ZECUSDTrZzOpen positions:)__doc__rrCrr"r<rpathlibrdotenvrtypingrrrr r@r rr`rrzrGrarorr1rrrs   '' # $ 'll^ zA *aoo'++M5A6J "AMM)S!$DE S!2!2!456 r