E#ioSSKrSSKJrJrJr SSKJrJrJ r J r J r J r J r Jr SSKJr SSKJr SSKJr SSKJr "SS \R,R.5rg) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)AnyBoolIntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationErrorc ^\rSrSrS\4U4Sjjr04S\S\4SjjrS\ 4Sjr S%S\4S jjr S SS04S\S \S \ S \ S\ \4 SjjrS\ 4SjrS04S\S \ S\4SjjrS\ 4SjrSrSrSS04S\S \ S \ S\ \4SjjrS\ 4SjrSSS04S\S \ S \ S\ \4SjjrSSS04S\S \ S \ S\ \4SjjrS\ 4SjrS\ 4SjrS\ 4SjrS%Sjr 04Sjr!S\ S\"4Sjr#S\ 4Sjr$S\ 4Sjr%S\ 4S jr&S\ 4S!jr'S\ 4S"jr(S\ 4S#jr)S$r*U=r+$)&alpacareturnc>UR[[U]50SS_SS_SS_SS_SS_SS_S S_S S_S S_S S_S S_SS_SS_SS_SS_SS_SS_SSSSSSSSSS. ESSSS.0SSSS.0S.00SS000S.5$)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 I/home/james-whalen/.local/lib/python3.13/site-packages/ccxt/pro/alpaca.pyr=alpaca.describesdfd < >d8%*5(  *5  +E ,U#E"5#E$U.u!%"5 &u!"0#$"&""&#!&"'# %#5<"S#D"S#J ]4A 4 4 symbolc:# URSSSnURU5IShvN UR5IShvN URU5nSUS-nSUS/S .nUR X5UR Xb5U5IShvN $NhNRN7f) 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 ` r3rr1Nticker:rC subscribeid)actionquotes)r7 authenticate load_marketsmarketwatchextend)r>rCparamsurlrL messageHashrequests r@ watch_tickeralpaca.watch_tickerHsiit$X.$$$!!!V$&"22 !d|n ZZ$++g2NP[\\\ %!]s4*BBBBA BBBBBclientcURU5nUSnSU-nX0RU'URURUU5 g)NrCrE) parse_tickertickersresolve)r>rUmessagetickerrCrQs r@ handle_tickeralpaca.handle_ticker]sK""7+!&( % Vt||F+[9rBNcURUS5nURUS5nUR0SURX25_SURU5_SU_SS_SS_SURUS 5_S URUS 5_S URUS 5_SURUS5_SS_SS_SS_SS_SS_SS_SS_SS_SSUS.EU5$)NStrC timestampdatetimehighlowbidbp bidVolumebsaskap askVolumeasvwapopencloselast previousClosechange percentageaverage) baseVolume quoteVolumeinfo) safe_string safe_ticker safe_symbol parse8601)r>r[rLmarketIdrbs r@rWalpaca.parse_tickerose##FC0##FC0! d&&x8! 1!  !  D ! 4 ! 4##FD1 !  ))&$7!  4##FD1!  ))&$7!  D!  D!  T!  D!  T!  d! $!! " t#! $)! * + rB1m timeframesincelimitc# URSSSnURU5IShvN UR5IShvN URU5nUSnSUS/S.nS U-n UR XiUR X5U 5IShvN n UR (aU RX5nURXUS S 5$NNN>7f) aW 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 r3rr1NrCrFrG)rHbarsohlcv:rT r7rJrKrLrMrN newUpdatesgetLimitfilter_by_since_limit) r>rCrrrrOrPrLrRrQohlcvs r@ watch_ohlcvalpaca.watch_ohlcvsiit$X.$$$!!!V$!!D\N ' jj4;;w3OQ\]] ??NN61E))%q$GG %!^4*CC CCA CC;CCCcdURUS5nURU5nURURU5nUc6UR UR SS5n[ U5nXPRU'URU5nURU5 SU-nURXX5 g)Nr_ OHLCVLimitr) rxrz safe_valueohlcvs safe_integerr8r parse_ohlcvappendrY r>rUrZr|rCstoredrparsedrQs r@ handle_ohlcvalpaca.handle_ohlcvs##GS1!!(+f5 >%%dllL$GE*51F"(KK !!'* f' v+rBc^# URSSSnURU5IShvN UR5IShvN URU5nUSnSU-nSUS/S .nUR XFUR Xs5U5IShvN nUR 5$NzNdN7f) a 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 r3rr1NrC orderbook:rFrG)rH orderbooks)r7rJrKrLrMrNr) r>rCrrOrPrLrQrR orderbooks r@watch_order_bookalpaca.watch_order_booksiit$X.$$$!!!V$!'&0 !!$<. **St{{77SU`aa    %!bs4*B-B'B-B)A B-B+B-)B-+B-c URUS5nURU5nURUS5nURU5nURUSS5nX@R;aUR 5URU'URUnU(a(UR X$USSSS5n URU 5 OXURUS/5n URUS/5n URUS U 5 URUS U 5 XhS 'XXS 'S U-n XRU'URX5 g)Nr_r`rFbapsasksbidsrarbr) rxrzr{ safe_boolr order_bookparse_order_bookreset safe_list handle_deltasrY) r>rUrZr|rCrbra isSnapshotrsnapshotrrrQs r@handle_order_bookalpaca.handle_order_books0,##GS1!!(+##GS1NN8, ^^GS%8 //)&*oo&7DOOF #OOF+ ,,WicSVX[\H OOH %>>'33D>>'33D   y0$ 7   y0$ 7%.k "$,j !'&0 "+y.rBcLURUSS5nURU5 g)Nrr) parse_bid_ask storeArray)r>booksidedeltabidAsks r@ handle_deltaalpaca.handle_deltas$##E34F#rBcd[S[U55HnURXU5 M g)Nr)rangelenr)r>rdeltasis r@ralpaca.handle_deltass)q#f+&A   hq 2'rBc# URSSSnURU5IShvN UR5IShvN URU5nUSnSU-nSUS/S .nUR XWUR X5U5IShvN n UR (aU RX5nURXUS S 5$NNN>7f) 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 ` r3rr1NrCtrade:rFrG)rHtradesraTr) r>rCrrrOrPrLrQrRrs r@ watch_tradesalpaca.watch_tradessiit$X.$$$!!!V$!' !d|n zz#DKK4PR]^^ ??OOF2E))& TRR %!_rcdURUS5nURU5nURURU5nUc6UR UR SS5n[ U5nXPRU'URU5nURU5 SU-nURXX5 g)Nr_ tradesLimitrr) rxrzrrrr8r parse_traderrYrs r@ handle_tradesalpaca.handle_trades2s##GS1!!(+f5 >%%dllM4HE&F"(KK !!'* f#f, v+rBc# URSSSnURU5IShvN SnUR5IShvN UbURU5nUSU-- nSSS /0S .nUR XVUR Xt5U5IShvN nUR (aURX5nURXUS S 5$NNN>7f) 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 ` r3rr2NmyTrades:listenstreams trade_updatesrHdataraT) r7rJrKrCrMrNrrr) r>rCrrrOrPrQrRrs r@watch_my_tradesalpaca.watch_my_tradesJsiit$Y/$$$ !!!  [[(F 3< 'KO,  zz#DKK4PR]^^ ??OOF2E))& TRR %!_s4*CCCCA CC;CCCc# URSSSnURU5IShvN UR5IShvN SnUbURU5nUSnSU-nSS S /0S .nUR XVUR X5U5IShvN n UR (aU RX5nURXX#S 5$NNN=7f) 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 ` r3rr2NordersrCorders:rrrrT) r7rJrKrLrMrNrrfilter_by_symbol_since_limit) r>rCrrrOrPrQrLrRrs r@ watch_ordersalpaca.watch_ordersisiit$Y/$$$!!!  [[(FH%F#f,KO,  zz#DKK4PR]^^ ??OOF2E00tTT! %!_s4*CCCCACC:CCCcHURX5 URX5 gN) handle_orderhandle_my_trader>rUrZs r@handle_trade_updatealpaca.handle_trade_updates &* V-rBcxURUS05nURUS05nURc-URURSS5n[ U5UlURnUR U5nUR U5 SnURXh5 SUS-nURXh5 g)Nrorder ordersLimitrrrrC)rrrr8r parse_orderrrY) r>rUrZrrawOrderrrrrQs r@ralpaca.handle_orders\w3??4"5 ;; %%dllM4HE07DK  * e v+%/1 v+rBcURUS05nURUS5nUS:waUS:wagURUS05nURnUc(URURSS5n[ U5nUR U5nURU5 SUS -n URXi5 S n URXi5 g) Nreventfill partial_fillrrrz myTrades:rCr) rrxrrr8rparse_my_traderrY) r>rUrZrrrrrtraderQs r@ralpaca.handle_my_trades\w3  w/ F?u6 ??4"5==  %%dllM4HE-e4H##H-!E(O3 x- x-rBcURUS5nURUS5nURUS5nURS5S:aSnURURUS5UURU5UUR USS5URUS5UURUS 5US :XaS OS URUS 5URUS5SSS. U5$)NrC filled_attyperrr/rGsiderLtakermakerfilled_avg_price filled_qty) rGrwrarbrCrrr takerOrMakerpriceamountcostfee)rxfind safe_trader{rz)r>rrLr|rbrs r@ralpaca.parse_my_tradesL##E84##E;7v. 99W  "D""5#.1 &&xs;%%eT2$$UF3(,(8Gw%%e-?@&&ul;   rBc# UR5 SnURU5nURU5nURURU5nUcaSUR UR S.nXRSSS:XaSUR UR S.S .nURXXsU5 UIShvN $N7f) N authenticatedauth)rHkeysecretr3rr2rJ)key_id secret_keyr) check_required_credentialsrUreusableFuturer subscriptionsapiKeyrr7rM)r>rPrOrQrUfuturerrRs r@rJalpaca.authenticate>s '')% S!&&{3(<(rUrZr rs r@handle_error_messagealpaca.handle_error_messageVsK0oogub1DGGi/$6EKLLrBcU$rrs r@handle_connectedalpaca.handle_connectedbs rBc[S[U55HnX#nURUS5nURUS5nUS:XaURX5 gUS:XaUS:XaUR X5 gUS:XaUS:XaUR X5 gUR URURURURS.nURXu5nUcMU"X5 M g) NrTr subscriptionsuccess connectedr)errorrqr`o) rrrxhandle_subscriptionrhandle_authenticaterrr\rrr) r>rUrZrrrrmethodsmethods r@handle_crypto_messagealpaca.handle_crypto_messageksq#g,'A:D  s+A""4/CN"((6I~#"4%%f3I~#"8((622&&''''++ G__W0F!v$-(rBcURUS5nURURURS.nUR XC5nUb U"X5 gg)Nstream) authorization listeningr)rxrrrr)r>rUrZr$rr s r@handle_trading_messagealpaca.handle_trading_messagesY!!'84!5511!55  1   6 # rBct[U[5(aURX5 gURX5 gr) isinstancelistr!r'rs r@handle_messagealpaca.handle_messages. gt $ $  & &v 7  ##F4rBcURUS5nURUS05nURUS5nUS:XdUS:Xa!URSnURU5 g[ UR S-5e)Nrrstatusr authorizedrz failed to authenticate.)rxrfuturesrYrrG)r>rUrZrrr/promises r@ralpaca.handle_authenticatesz4   Wc *w3!!$1 >V|3nn_5G OOG $ !$'',F"FGGrBcU$rrrs r@ralpaca.handle_subscriptions (rB)rr),__name__ __module__ __qualname____firstlineno__rr=strr rSrr\rWrrr+rrr rrrrr rrr rr rrrrrrJrrrr!r'r,rr__static_attributes__ __classcell__)r?s@r@rrs-5 #5 n68]]F]*:F:$#6#J?CQUdhqsHHH3H^aHx|~ByCH8,6,6@DB!S!!S\!0*/*/X$3<@d[]SSSSSbfglbmS6,F,037TX\egSCSsSRUSlpqvlwS>04$UYbdUUCUsUimnsitU8.&.9,69,v<.f<.|:x.00 M6 Mt Mv%F%2 $V $5V5 !H&!HF&rBr)ccxt.async_supportccxt ccxt.async_support.base.ws.cacherrrccxt.base.typesrrrr r r r r !ccxt.async_support.base.ws.clientrtypingrccxt.base.errorsrr async_supportrrrBr@rEs? ffPPP4*0} T   & &} rB