einddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z mZddlmZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBoolIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationErrorc eZdZdeffd ZifdedefdZdefdZ d#defdZ d ddifded ed e d e de e f d ZdefdZdifded e defdZdefdZdZdZddifded e d e de efdZdefdZdddifded e d e de efdZdddifded e d e de efdZdefdZdefdZdefdZd#dZifdZ dede!fdZ"defdZ#defdZ$defdZ%defd Z&defd!Z'defd"Z(xZ)S)$alpacareturnc&|tt|iddddddddddddd dd dd dd dd ddddddddddddddddddddddd ddddiddddidiiddiiidS)NwsT&createOrderWithTakeProfitAndStopLossWsFcreateReduceOnlyOrderWscreateStopLossOrderWscreateTakeProfitOrderWsfetchPositionForSymbolWsfetchPositionsForSymbolWsfetchPositionsWsfetchPositionWsunWatchPositions watchBalancewatchLiquidationswatchLiquidationsForSymbolswatchMarkPricewatchMarkPriceswatchMyLiquidationswatchMyLiquidationsForSymbols) watchMyTrades watchOHLCVwatchOrderBook watchOrders watchPositionwatchPositions watchTicker watchTickers watchTradesz/wss://stream.data.alpaca.markets/v1beta2/cryptozwss://api.alpaca.markets/stream)cryptotradingz%wss://paper-api.alpaca.markets/stream)apitestexact)hasurlsoptions streaming exceptions) deep_extendsuperrdescribe)self __class__s M/var/www/html/volatility/venv/lib/python3.11/site-packages/ccxt/pro/alpaca.pyr<zalpaca.describesfd 3 3 < < > >d8%*5(  *5  +E ,U#E"5#E$U.u!%"5 &u!"0#$"&""&#!&"'# %#5<"S#D"S#J  ]4A 4A 4 4 4 symbolc^K|jddd}||d{V|d{V||}d|dz}d|dgd }|||||||d{VS) a watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.alpaca.markets/docs/real-time-crypto-pricing-data#quotes :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `ticker structure ` r2rr0Nticker:rA subscribeid)actionquotes)r6 authenticate load_marketsmarketwatchextend)r=rAparamsurlrJ messageHashrequests r? watch_tickerzalpaca.watch_tickerHsit$X.$$$$$$$$$!!!!!!!!!V$$&"22 !d|n  ZZ[$++gv2N2NP[\\\\\\\\\r@clientc||}|d}d|z}||j|<||j||dS)NrArC) parse_tickertickersresolve)r=rRmessagetickerrArOs r? handle_tickerzalpaca.handle_ticker]sX""7++!&( % Vt|F+[99999r@Nc||d}||d}|id|||d||d|ddddd||d d ||d d ||d d||ddddddddddddddddddd|d|S)NStrA timestampdatetimehighlowbidbp bidVolumebsaskap askVolumeasvwapopencloselast previousClosechange percentageaverage) baseVolume quoteVolumeinfo) safe_string safe_ticker safe_symbol parse8601)r=rXrJmarketIdr^s r?rTzalpaca.parse_tickeros##FC00##FC00! d&&x88! 11!  !  D ! 4 ! 4##FD11 !  ))&$77!  4##FD11!  ))&$77!  D!  D!  T!  D!  T!  d! $!! " t#! $)! ! ! * + r@1m timeframesincelimitcK|jddd}||d{V|d{V||}|d}d|dgd}d |z} ||| |||| d{V} |jr| ||}|| ||d d S) a watches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.alpaca.markets/docs/real-time-crypto-pricing-data#bars :param str symbol: unified symbol of the market to fetch OHLCV data for :param str timeframe: the length of time each candle represents :param int [since]: timestamp in ms of the earliest candle to fetch :param int [limit]: the maximum amount of candles to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :returns int[][]: A list of candles ordered, open, high, low, close, volume r2rr0NrArDrE)rFbarsohlcv:rT r6rHrIrJrKrL newUpdatesgetLimitfilter_by_since_limit) r=rArzr{r|rMrNrJrPrOohlcvs r? watch_ohlcvzalpaca.watch_ohlcvsit$X.$$$$$$$$$!!!!!!!!!V$$!!D\N  ' jjk4;;w3O3OQ\]]]]]]]] ? 2NN6511E))%q$GGGr@c||d}||}||j|}|5||jdd}t |}||j|<||}||d|z}| ||dS)Nr[ OHLCVLimitr) rtrv safe_valueohlcvs safe_integerr7r parse_ohlcvappendrV r=rRrWrxrAstoredr|parsedrOs r? handle_ohlcvzalpaca.handle_ohlcvs##GS11!!(++f55 >%%dlL$GGE*511F"(DK !!'** f' v{+++++r@cK|jddd}||d{V|d{V||}|d}d|z}d|dgd }|||||||d{V}|S) aF watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.alpaca.markets/docs/real-time-crypto-pricing-data#orderbooks :param str symbol: unified symbol of the market to fetch the order book for :param int [limit]: the maximum amount of order book entries to return. :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: A dictionary of `order book structures ` indexed by market symbols r2rr0NrA orderbook:rDrE)rF orderbooks)r6rHrIrJrKrLr|) r=rAr|rMrNrJrOrP orderbooks r?watch_order_bookzalpaca.watch_order_booksit$X.$$$$$$$$$!!!!!!!!!V$$!'&0 !!$<.  **S+t{{7F7S7SU`aaaaaaaa    r@c ||d}||}||d}||}||dd}||jvr||j|<|j|}|r1||||dddd} || np||dg} ||dg} | |d | | |d | ||d <||d <d |z} ||j|<| || dS)Nr[r\rFbapsasksbidsr]r^r) rtrvrw safe_boolr order_bookparse_order_bookreset safe_list handle_deltasrV) r=rRrWrxrAr^r] isSnapshotrsnapshotrrrOs r?handle_order_bookzalpaca.handle_order_booksx,##GS11!!(++##GS11NN8,, ^^GS%88 $/))&*oo&7&7DOF #OF+  -,,WficSVX[\\H OOH % % % %>>'333D>>'333D   y0$ 7 7 7   y0$ 7 7 7%.Ik "$,Ij !'&0 "+y+.....r@c^||dd}||dS)Nrr) parse_bid_ask storeArray)r=booksidedeltabidAsks r? handle_deltazalpaca.handle_deltas3##E344F#####r@c~tdt|D]}||||dS)Nr)rangelenr)r=rdeltasis r?rzalpaca.handle_deltassHq#f++&& 3 3A   hq 2 2 2 2 3 3r@cK|jddd}||d{V|d{V||}|d}d|z}d|dgd }|||||||d{V} |jr| ||}|| ||d d S) a: watches information on multiple trades made in a market https://docs.alpaca.markets/docs/real-time-crypto-pricing-data#trades :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `trade structures ` r2rr0NrAtrade:rDrE)rFtradesr]Tr) r=rAr{r|rMrNrJrOrPrs r? watch_tradeszalpaca.watch_tradessit$X.$$$$$$$$$!!!!!!!!!V$$!' !d|n  zz#{DKK4P4PR]^^^^^^^^ ? 3OOFE22E))&% TRRRr@c||d}||}||j|}|5||jdd}t |}||j|<||}||d|z}| ||dS)Nr[ tradesLimitrr) rtrvrrrr7r parse_traderrVrs r? handle_tradeszalpaca.handle_trades2s##GS11!!(++f55 >%%dlM4HHE&&F"(DK !!'** f#f, v{+++++r@cK|jddd}||d{Vd}|d{V|||}|d|zz }ddd gid }|||||||d{V}|jr|||}||||d d S) a watches information on multiple trades made by the user https://docs.alpaca.markets/docs/websocket-streaming#trade-updates :param str symbol: unified market symbol of the market trades were made in :param int [since]: the earliest time in ms to fetch trades for :param int [limit]: the maximum number of trade structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :param boolean [params.unifiedMargin]: use unified margin account :returns dict[]: a list of `trade structures ` r2rr1NmyTrades:listenstreams trade_updatesrFdatar]T) r6rHrIrArKrLrrr) r=rAr{r|rMrNrOrPrs r?watch_my_tradeszalpaca.watch_my_tradesJs!it$Y/$$$$$$$$$ !!!!!!!!!  [[((F 3< 'KO,   zz#{DKK4P4PR]^^^^^^^^ ? 3OOFE22E))&% TRRRr@cK|jddd}||d{V|d{Vd}|"||}|d}d|z}dd d gid }|||||||d{V} |jr| ||}|| |||d S) a watches information on multiple orders made by the user :param str symbol: unified market symbol of the market orders were made in :param int [since]: the earliest time in ms to fetch orders for :param int [limit]: the maximum number of order structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` r2rr1NordersrAorders:rrrrT) r6rHrIrJrKrLrrfilter_by_symbol_since_limit) r=rAr{r|rMrNrOrJrPrs r? watch_orderszalpaca.watch_ordersis'it$Y/$$$$$$$$$!!!!!!!!!  [[((FH%F#f,KO,   zz#{DKK4P4PR]^^^^^^^^ ? 3OOFE22E00tTTTr@c^||||||dSN) handle_orderhandle_my_trader=rRrWs r?handle_trade_updatezalpaca.handle_trade_updates4 &'*** VW-----r@c||di}||di}|j0||jdd}t ||_|j}||}||d}|||d|dz}|||dS)Nrorder ordersLimitrrrrA)rrrr7r parse_orderrrV) r=rRrWrrawOrderr|rrrOs r?rzalpaca.handle_orders\w33??4"55 ; %%dlM4HHE077DK  ** e v{+++%/1 v{+++++r@c||di}||d}|dkr|dkrdS||di}|j}|+||jdd}t |}||}||d|d z} ||| d } ||| dS) Nreventfill partial_fillrrrz myTrades:rAr) rrtrrr7rparse_my_traderrV) r=rRrWrrrrr|traderOs r?rzalpaca.handle_my_trades\w33  w// F??u66 F??4"55=  %%dlM4HHE-e44H##H--!E(O3 x--- x-----r@c,||d}||d}||d}|ddkrd}|||d||||||dd||d|||d |d krd nd ||d ||dddd |S)NrA filled_attyper|rr/rEsiderJtakermakerfilled_avg_price filled_qty) rErsr]r^rArrr takerOrMakerpriceamountcostfee)rtfind safe_traderwrv)r=rrJrxr^rs r?rzalpaca.parse_my_trades)L##E844##E;77v.. 99W   " "D""5#..11 &&xs;;%%eT22$$UF33(,(8(8GGw%%e-?@@&&ul;;    r@cK|d}||}||}||j|}|Xd|j|jd}||jdddkrd|j|jdd }|||||||d{VS) N authenticatedauth)rFkeysecretr2rr1rH)key_id secret_keyr) check_required_credentialsrRreusableFuturer subscriptionsapiKeyrr6rK)r=rNrMrOrRfuturerrPs r?rHzalpaca.authenticate>s '')))% S!!&&{33(q#g,,'' % %A1:D  s++A""4//CN""((666I~~#"4"4%%fd333I~~#"8"8((6662&''+ G__Wa00F!vt$$$- % %r@c||d}|j|j|jd}|||}||||dSdS)Nstream) authorization listeningr)rtrrrr)r=rRrWr rr s r?handle_trading_messagezalpaca.handle_trading_messagesp!!'844!51!5   &11   F67 # # # # #  r@ct|tr|||dS|||dSr) isinstancelistr rrs r?handle_messagezalpaca.handle_messagesK gt $ $   & &vw 7 7 7 F ##FG44444r@c||d}||di}||d}|dks|dkr$|jd}||dSt |jdz)Nrrstatusr authorizedrz failed to authenticate.)rtrfuturesrVrrE)r=rRrWrrrpromises r?rzalpaca.handle_authenticates4   Wc * *w33!!$11 >>V|33n_5G OOG $ $ $ F!$',F"FGGGr@c|Srrrs r?rzalpaca.handle_subscriptions (r@r)*__name__ __module__ __qualname__rr<strr rQrrYrTrrrrrr rrrrr rrr rr rrrrrrHrrrr rrrr __classcell__)r>s@r?rrs5 #5 5 5 5 5 5 n68]]]F]]]]*:F::::$##6####J?CQUdhqsHHHH3H^aHx|~ByCHHHH8,6,,,,6@DB!!S!!S\!!!!0*/*/*/*/*/X$$$333<@d[]SSSSSSbfglbmSSSS6,F,,,,037TX\egSSCSsSRUSlpqvlwSSSS>04$UYbdUUUCUsUimnsitUUUU8.&....9,69,9,9,9,v<.f<.<.<.<.|::::x.00 M6 Mt M M M Mv%F%%%%2 $V $ $ $ $5V5555 !H&!H!H!H!HF&r@r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r !ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrrr@r?r's ffffffffffPPPPPPPPPPPPPPPPPPPP444444******000000} } } } } T  &} } } } } r@