":hkddlZddlmZmZmZddlmZmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZGdd ej*j,Zy) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationErrorc eZdZdeffd ZifdedefdZdefdZ d"defdZ d ddifded e d e de e fd Zdefd Zdifded e defdZdefdZdZdZddifded e d e de efdZdefdZdddifded e d e de efdZdddifded e d e de efdZdefdZdefdZdefdZd"dZifdZ defdZ!defdZ"defdZ#defdZ$defdZ%defd Z&defd!Z'xZ(S)#alpacareturnc|jtt|ddddddddddd ddddiddddid iidd iiid S) NTF) ws watchBalance watchMyTrades watchOHLCVwatchOrderBook watchOrders watchTicker watchTickers watchTrades watchPositionrz/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 I/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/pro/alpaca.pyr+zalpaca.describesfd < > %!%""&## %#!& "S#D"S#J =$A $ $ symbolc>K|jddd}|j|d{|jd{|j|}d|dz}d|dgd }|j |||j |||d{S7j7T7w) 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 ` r!rrNticker:r0 subscribeid)actionquotes)r% authenticate load_marketsmarketwatchextend)r,r0paramsurlr9 messageHashrequests r. watch_tickerzalpaca.watch_ticker8siit$X.$$$!!!V$&"22 !d|n ZZ[$++gv2NP[\\\ %!]s4*BBBBA BBBBBclientc|j|}|d}d|z}||j|<|j|j||y)Nr0r2) parse_tickertickersresolve)r,rAmessagetickerr0r>s r. handle_tickerzalpaca.handle_tickerMsM""7+!&( % Vt||F+[9r/Nc|j|d}|j|d}|jid|j||d|j|d|ddddd|j|d d |j|d d |j|d d|j|ddddddddddddddddddd|d|S)NStr0 timestampdatetimehighlowbidbp bidVolumebsaskap askVolumeasvwapopencloselast previousClosechange percentageaverage) baseVolume quoteVolumeinfo) safe_string safe_ticker safe_symbol parse8601)r,rGr9marketIdrMs r.rCzalpaca.parse_ticker_sg##FC0##FC0! d&&x8! 1!  !  D ! 4 ! 4##FD1 !  ))&$7!  4##FD1!  ))&$7!  D!  D!  T!  D!  T!  d! $!! " t#! $)! * + r/1msincelimitcK|jddd}|j|d{|jd{|j|}|d}d|dgd}d |z} |j || |j ||| d{} |j r| j||}|j| ||d d S777;w) 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 r!rrNr0r3r4)r5barsohlcv:rT r%r7r8r9r:r; newUpdatesgetLimitfilter_by_since_limit) r,r0 timeframerirjr<r=r9r?r>ohlcvs r. watch_ohlcvzalpaca.watch_ohlcvsiit$X.$$$!!!V$!!D\N ' jjk4;;w3OQ\]] ??NN651E))%q$GG %!^4*CC CCACC8CCCcf|j|d}|j|}|j|j|}|7|j |j dd}t |}||j|<|j|}|j|d|z}|j||y)NrJ OHLCVLimitrm) rcre safe_valueohlcvs safe_integerr&r parse_ohlcvappendrE r,rArFrgr0storedrjparsedr>s r. handle_ohlcvzalpaca.handle_ohlcvs##GS1!!(+f5 >%%dllL$GE*51F"(DKK !!'* f' v{+r/cbK|jddd}|j|d{|jd{|j|}|d}d|z}d|dgd }|j |||j |||d{}|j S7|7f7w) aH 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 r!rrNr0 orderbook:r3r4)r5 orderbooks)r%r7r8r9r:r;rj) r,r0rjr<r=r9r>r? orderbooks r.watch_order_bookzalpaca.watch_order_booksiit$X.$$$!!!V$!'&0 !!$<. **S+t{{7F7SU`aa    %!bs4*B/B)B/B+AB/B-B/+B/-B/c |j|d}|j|}|j|d}|j|}|j|dd}||jvr|j |j|<|j|}|r)|j |||dddd} |j| nZ|j|dg} |j|dg} |j|d | |j|d | ||d <||d <d |z} ||j|<|j|| y)NrJrKrFbapsasksbidsrLrMr) rcrerf safe_boolr order_bookparse_order_bookreset safe_list handle_deltasrE) r,rArFrgr0rMrL isSnapshotrsnapshotrrr>s r.handle_order_bookzalpaca.handle_order_books<,##GS1!!(+##GS1NN8, ^^GS%8 $//)&*oo&7DOOF #OOF+ ,,WficSVX[\H OOH %>>'33D>>'33D   y0$ 7   y0$ 7%.Ik "$,Ij !'&0 "+y+.r/cL|j|dd}|j|y)Nrr) parse_bid_ask storeArray)r,booksidedeltabidAsks r. handle_deltazalpaca.handle_deltas$##E34F#r/cbtdt|D]}|j|||y)Nr)rangelenr)r,rdeltasis r.rzalpaca.handle_deltass0q#f+& 3A   hq 2 3r/cK|jddd}|j|d{|jd{|j|}|d}d|z}d|dgd }|j |||j |||d{} |j r| j||}|j| ||d d S777;w) 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 ` r!rrNr0trade:r3r4)r5tradesrLTrn) r,r0rirjr<r=r9r>r?rs r. watch_tradeszalpaca.watch_tradessiit$X.$$$!!!V$!' !d|n zz#{DKK4PR]^^ ??OOFE2E))&% TRR %!_rucf|j|d}|j|}|j|j|}|7|j |j dd}t |}||j|<|j|}|j|d|z}|j||y)NrJ tradesLimitrxr) rcreryrr{r&r parse_trader}rEr~s r. handle_tradeszalpaca.handle_trades"s##GS1!!(+f5 >%%dllM4HE&F"(DKK !!'* f#f, v{+r/cK|jddd}|j|d{d}|jd{||j|}|d|zz }ddd gid }|j |||j |||d{}|j r|j||}|j|||d d S777;w) 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 ` r!rr NmyTrades:listenstreams trade_updatesr5datarLT) r%r7r8r0r:r;rorprq) r,r0rirjr<r=r>r?rs r.watch_my_tradeszalpaca.watch_my_trades:siit$Y/$$$ !!!  [[(F 3< 'KO,  zz#{DKK4PR]^^ ??OOFE2E))&% TRR %!_s4*CC CCACC8CCCcK|jddd}|j|d{|jd{d}||j|}|d}d|z}dd d gid }|j |||j |||d{} |j r| j||}|j| |||d S777;w) 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 ` r!rr Nordersr0orders:rrrrT) r%r7r8r9r:r;rorpfilter_by_symbol_since_limit) r,r0rirjr<r=r>r9r?rs r. watch_orderszalpaca.watch_ordersYsiit$Y/$$$!!!  [[(FH%F#f,KO,  zz#{DKK4PR]^^ ??OOFE2E00tTT! %!_s4*CCCCACC8CCCcL|j|||j||yN) handle_orderhandle_my_trader,rArFs r.handle_trade_updatezalpaca.handle_trade_updateus" &'* VW-r/cz|j|di}|j|di}|j-|j|jdd}t ||_|j}|j |}|j |d}|j||d|dz}|j||y)Nrorder ordersLimitrxrrr0)ryrr{r&r parse_orderr}rE) r,rArFrrawOrderrjrrr>s r.rzalpaca.handle_orderys\w3??4"5 ;; %%dllM4HE07DK  * e v{+%/1 v{+r/c|j|di}|j|d}|dk7r|dk7ry|j|di}|j}|(|j|jdd}t |}|j |}|j|d|d z} |j|| d } |j|| y) Nreventfill partial_fillrrrxz myTrades:r0r) ryrcrr{r&rparse_my_trader}rE) r,rArFrrrrrjtrader>s r.rzalpaca.handle_my_trades\w3  w/ F?u6 ??4"5==  %%dllM4HE-e4H##H-!E(O3 x- x-r/c|j|d}|j|d}|j|d}|jddk\rd}|j|j|d||j|||j |dd|j|d||j|d |d k(rd nd |j|d |j|dddd |S)Nr0 filled_attyperjrr/r4sider9takermakerfilled_avg_price filled_qty) r4rbrLrMr0rrr takerOrMakerpriceamountcostfee)rcfind safe_traderfre)r,rr9rgrMrs r.rzalpaca.parse_my_tradesL##E84##E;7v. 99W  "D""5#.1 &&xs;%%eT2$$UF3(,(8Gw%%e-?@&&ul;   r/cK|jd}|j|}|j|}|j|j|}|cd|j |j d}||jdddk(rd|j |j dd }|j||||||d{S7w) N authenticatedauth)r5keysecretr!rr r7)key_id secret_keyr) check_required_credentialsrAfuturery subscriptionsapiKeyrr%r:)r,r=r<r>rArrr?s r.r7zalpaca.authenticate.s '')% S!{+(<(Cc|j|d}|j|di}t|jdz|zdz|z)Ncodemsgz code: z message: )rcryrr4)r,rArFrrs r.handle_error_messagezalpaca.handle_error_messageFsK0oogub1DGGi/$6EKLLr/c|Srrs r.handle_connectedzalpaca.handle_connectedRs r/ctdt|D]}||}|j|d}|j|d}|dk(r|j||y|dk(r|dk(r|j ||y|dk(r|dk(r|j ||y|j |j|j|j|jd}|j||}||||y) NrTr subscriptionsuccess connectedr)errorrqrKo) rrrchandle_subscriptionrhandle_authenticaterrrHrrry) r,rArFrrrrmethodsmethods r.handle_crypto_messagezalpaca.handle_crypto_message[sq#g,' %A1:D  s+A""4/CN"((6I~#"4%%fd3I~#"8((622&&''''++ G__Wa0F!vt$- %r/c|j|d}|j|j|jd}|j ||}| |||yy)Nstream) authorization listeningr)rcrrrry)r,rArFrrrs r.handle_trading_messagezalpaca.handle_trading_messagets]!!'84!5511!55  &1   67 # r/cnt|tr|j||y|j||yr) isinstancelistrrrs r.handle_messagezalpaca.handle_messages/ gt $  & &vw 7  ##FG4r/c|j|d}|j|di}|j|d}|dk(s|dk(r!|jd}|j|yt |j dz)Nrrstatusr authorizedrz failed to authenticate.)rcryfuturesrErr4)r,rArFrrrpromises r.rzalpaca.handle_authenticatesz4   Wc *w3!!$1 >V|3nn_5G OOG $ !$'',F"FGGr/c|Srrrs r.rzalpaca.handle_subscriptions (r/r))__name__ __module__ __qualname__rr+strr r@r rHrCrrrrtrr rrrrr rrr rrrrrrrr7rrrrrrr __classcell__)r-s@r.rrs% #% N68]]F]*:F:$#6#J8<$]ajlHHCHWZHquvzq{H8,6,6@DB!S!!S\!0*/*/X$3<@d[]SSSSSbfglbmS6,F,037TX\egSCSsSRUSlpqvlwS>04$UYbdUUCUsUimnsitU8.&.9,69,v<.f<.|:x.00 M6 Mv%F%2 $V $5V5 !H&!HF&r/r)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r !ccxt.async_support.base.ws.clientr typingrccxt.base.errorsrr async_supportrrr/r.rs? ffJJJ4*0m T   & &m r/