ijddlZddlmZmZmZddlmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZGdd ejjZdS) N) ArrayCacheArrayCacheBySymbolByIdArrayCacheByTimestamp)IntOrder OrderBookStrTickerTrade)Client)List) ExchangeError)AuthenticationErrorc eZdZfdZifdedefdZdefdZd"defdZ d ddifded e d e de e fd Z defd Zdifded e defdZdefdZdZdZddifded e d e de efdZdefdZdddifded e d e de efdZdddifded e d e de efdZdefdZdefdZdefdZd"dZifdZdefdZ defdZ!defdZ"defdZ#defdZ$defd Z%defd!Z&xZ'S)#alpacac|tt|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 U/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/ccxt/pro/alpaca.pyr)zalpaca.describesfd 3 3 < < > > %!%""&## %#!&  "S#D"S#J  =$A $A $ $ $ symbolreturnc^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 :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 ` rrrNticker:r. subscribeid)actionquotes)r# authenticate load_marketsmarketwatchextend)r*r.paramsurlr8 messageHashrequests r, watch_tickerzalpaca.watch_ticker8sit$X.$$$$$$$$$!!!!!!!!!V$$&"22 !d|n  ZZ[$++gv2N2NP[\\\\\\\\\r-clientc||}|d}d|z}||j|<||j||dS)Nr.r1) parse_tickertickersresolve)r*r@messagetickerr.r=s r, handle_tickerzalpaca.handle_tickerJsX""7++!&( % Vt|F+[99999r-Nc||d}||d}|id|||d||d|ddddd||d d ||d d ||d d||ddddddddddddddddddd|d|S)NStr. timestampdatetimehighlowbidbp bidVolumebsaskap askVolumeasvwapopencloselast previousClosechange percentageaverage) baseVolume quoteVolumeinfo) safe_string safe_ticker safe_symbol parse8601)r*rFr8marketIdrLs r,rBzalpaca.parse_ticker\s##FC00##FC00! d&&x88! 11!  !  D ! 4 ! 4##FD11 !  ))&$77!  4##FD11!  ))&$77!  D!  D!  T!  D!  T!  d! $!! " t#! $)! ! ! * + r-1msincelimitcK|jddd}||d{V|d{V||}|d}d|dgd}d |z} ||| |||| d{V} |jr| ||}|| ||d d S) aQ watches historical candlestick data containing the open, high, low, and close price, and the volume of a market :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 rrrNr.r2r3)r4barsohlcv:rT r#r6r7r8r9r: newUpdatesgetLimitfilter_by_since_limit) r*r. timeframerhrir;r<r8r>r=ohlcvs r, watch_ohlcvzalpaca.watch_ohlcvsit$X.$$$$$$$$$!!!!!!!!!V$$!!D\N  ' jjk4;;w3O3OQ\]]]]]]]] ? 2NN6511E))%q$GGGr-c||d}||}||j|}|5||jdd}t |}||j|<||}||d|z}| ||dS)NrI OHLCVLimitrl) rbrd safe_valueohlcvs safe_integerr$r parse_ohlcvappendrD r*r@rErfr.storedriparsedr=s 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) a watches information on open orders with bid(buy) and ask(sell) prices, volumes and other data :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 rrrNr. orderbook:r2r3)r4 orderbooks)r#r6r7r8r9r:ri) r*r.rir;r<r8r=r> orderbooks r,watch_order_bookzalpaca.watch_order_booksit$X.$$$$$$$$$!!!!!!!!!V$$!'&0 !!$<.  **S+t{{7F7S7SU`aaaaaaaa    r-c ||d}||}||d}||}||dd}||j|}||}|r1||||dddd} || np||dg} ||dg} | |d | | |d | ||d <||d <d |z} ||j|<| || dS)NrIrJrFbapsasksbidsrKrLr) rbrdre safe_boolrwr order_bookparse_order_bookreset handle_deltasrD) r*r@rErfr.rLrK isSnapshotrsnapshotrrr=s r,handle_order_bookzalpaca.handle_order_bookss,##GS11!!(++##GS11NN8,, ^^GS%88 OODOV<<  ))I  -,,WficSVX[\\H OOH % % % %??7C44D??7C44D   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 :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]{@link https://docs.ccxt.com/#/?id=trade-structure rrrNr.trade:r2r3)r4tradesrKTrm) r*r.rhrir;r<r8r=r>rs r, watch_tradeszalpaca.watch_tradessit$X.$$$$$$$$$!!!!!!!!!V$$!' !d|n  zz#{DKK4P4PR]^^^^^^^^ ? 3OOFE22E))&% TRRRr-c||d}||}||j|}|5||jdd}t |}||j|<||}||d|z}| ||dS)NrI tradesLimitrvr) rbrdrwrryr$r parse_trader{rDr|s r, handle_tradeszalpaca.handle_tradess##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 :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]{@link https://docs.ccxt.com/#/?id=trade-structure rrrNmyTrades:listenstreams trade_updatesr4datarKT) r#r6r7r.r9r:rnrorp) r*r.rhrir;r<r=r>rs r,watch_my_tradeszalpaca.watch_my_trades.s!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]{@link https://docs.ccxt.com/#/?id=order-structure rrrNordersr.orders:rrrrT) r#r6r7r8r9r:rnrofilter_by_symbol_since_limit) r*r.rhrir;r<r=r8r>rs r, watch_orderszalpaca.watch_ordersJs'it$Y/$$$$$$$$$!!!!!!!!!  [[((FH%F#f,KO,   zz#{DKK4P4PR]^^^^^^^^ ? 3OOFE22E00tTTTr-c^||||||dSN) handle_orderhandle_my_trader*r@rEs r,handle_trade_updatezalpaca.handle_trade_updatefs4 &'*** VW-----r-c||di}||di}|j0||jdd}t ||_|j}||}||d}|||d|dz}|||dS)Nrorder ordersLimitrvrrr.)rwrryr$r parse_orderr{rD) r*r@rErrawOrderrirrr=s r,rzalpaca.handle_orderjs\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_fillrrrvz myTrades:r.r) rwrbrryr$rparse_my_trader{rD) r*r@rErrrrritrader=s 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)Nr. filled_attyperirr/r3sider8takermakerfilled_avg_price filled_qty) r3rarKrLr.rrr takerOrMakerpriceamountcostfee)rbfind safe_tradererd)r*rr8rfrLrs 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)r4keysecretrrrr6)key_id secret_keyr) check_required_credentialsr@futurerw subscriptionsapiKeyrr#r9)r*r<r;r=r@rrr>s r,r6zalpaca.authenticates '')))% S!!{++(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)rbrrrrw)r*r@rErrrs r,handle_trading_messagezalpaca.handle_trading_messageesp!!'844!51!5   &11   F67 # # # # #  r-ct|tr|||dS|||dSr) isinstancelistrrrs r,handle_messagezalpaca.handle_messagepsK gt $ $   & &vw 7 7 7 F ##FG44444r-c||d}||di}||d}|dks|dkr$|jd}||dSt |jdz)Nrrstatusr authorizedrz failed to authenticate.)rbrwfuturesrDrr3)r*r@rErrrpromises r,rzalpaca.handle_authenticatevs4   Wc * *w33!!$11 >>V|33n_5G OOG $ $ $ F!$',F"FGGGr-c|Srrrs r,rzalpaca.handle_subscriptions (r-r)(__name__ __module__ __qualname__r)strr r?r rGrBrr rrsrrrrrrr rrr rrrrrrrr6rrrrrrr __classcell__)r+s@r,rrs% % % % % N68]]]F]]]]$:F::::$##6####J8<$]ajlHHHCHWZHquvzq{HHHH2,6,,,,6@DB!!S!!S\!!!!**/*/*/*/*/X$$$333<@d[]SSSSSSbfglbmSSSS0,F,,,,037TX\egSSCSsSRUSlpqvlwSSSS804$UYbdUUUCUsUimnsitUUUU8.&....9,69,9,9,9,v<.f<.<.<.<.|::::x.00 M6 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 !ccxt.async_support.base.ws.clientr typingr ccxt.base.errorsrr async_supportrrr-r,rs ffffffffffEEEEEEEEEEEEEEEE444444******000000^ ^ ^ ^ ^ T  &^ ^ ^ ^ ^ r-