!:h/;ddlmZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lm Z dd lm!Z!ddl"m#Z#ddl$m%Z%GddeeZ&y))Exchange) ImplicitAPI)AnyBalancesCurrencyDepositAddressIntMarketNumOrder OrderBook OrderSide OrderTypeStrStringsTickerTickersTrade Transaction)List) ExchangeError)PermissionDenied)ArgumentsRequired) BadRequest) BadSymbol)InsufficientFunds) InvalidOrder) NotSupported)RateLimitExceeded) TICK_SIZE)Precisec eZdZdeffd ZifdefdZifdeefdZ defdZ ddifde ded edee fd Z difde d edefd Zd ddifde ded edeefd ZdGdedefdZifde defdZdifdedefdZdZifde dedefdZifde defdZifde defdZdifde dedededef dZ difde de!fdZ"difde!fdZ#difde de!fd Z$dddifde!ded edee%fd!Z&dddifde!ded edee%fd"Z'dddifde!ded edee%fd#Z(ddifde de dedededef d$Z)dGd%e*dede%fd&Z+d'e!fd(Z,d)e!fd*Z-dddifde!ded efd+Z.dGd,e*dede fd-Z/ifd.e de0fd/Z1dGd0e2de0fd1Z3difd.e ded2e de4fd3Z5d4Z6dddifd.e!ded edee4fd5Z7dddifd.e!ded edee4fd6Z8dddifd.e!ded edee4fd7Z9dGd8e*d0e2de4fd9Z:d'e!fd:Z;d;Zde=fd=Z?d>d?iddfd@Z@d.eAdAe dBe dCe dDe*dEe f dFZBxZCS)HalpacareturncT |jtt|iddddddgddd d d d d ddddddddddddddidddd ddddddd dd!dd"dd#dd$dd%d d&d d'dd(dd)d d*d d+d id,d d-dd.dd/dd0d d1d d2d d3d d4dd5dd6dd7dd8dd9dd:dd;d ddd?d d@ddAd dBd dCddDddEddFddGddHddIddJddKddLddMdidNd dOddPddQddRddSddTddUddVddWddXddYddZd d[dd\dd]dd^did_d d`d daddbddcddddded dfddgddhd did djd dkddlddmddnddodidpddqddrddsddtddud dvd dwd dxd dyddzdd{dd|dd}dd~ddd ddddd dddddd d didgdgdgdddggddidgdidgdiddddddddddddddddddddtdd d dddd d |j d|j d|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dgg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dg|j d|j dggddidddiddgddddÜdd dd ddddd d d dŜd dƜd d d ddǜdd ddddddȜddddddd˜ddddd̜ddddddΜddddddddϜdddddddddМddidӜ dddԜdddԜd՜dt ttt ttdלttd؜dٜS)Nidr#nameAlpaca countriesUS rateLimitiMhostnamezalpaca.marketsproTurlszOhttps://github.com/user-attachments/assets/e9476df8-a450-4c3e-ab9a-1a7794219e1bzhttps://alpaca.marketszhttps://broker-api.{hostname}zhttps://api.{hostname}zhttps://data.{hostname})brokertradermarketz%https://broker-api.sandbox.{hostname}zhttps://paper-api.{hostname}zhttps://alpaca.markets/docs/z,https://docs.alpaca.markets/docs/crypto-fees)logowwwapitestdocfeeshasCORSFspotmarginswapfutureoption addMarginborrowCrossMarginborrowIsolatedMargin borrowMargincancelAllOrders cancelOrdercloseAllPositions closePositioncreateMarketBuyOrdercreateMarketBuyOrderWithCostcreateMarketOrderWithCost createOrder$createOrderWithTakeProfitAndStopLoss&createOrderWithTakeProfitAndStopLossWscreateReduceOnlyOrdercreateStopOrdercreateTriggerOrder editOrder fetchBalance fetchBidsAsksfetchBorrowInterestfetchBorrowRatefetchBorrowRateHistoriesfetchBorrowRateHistoryfetchBorrowRatesfetchBorrowRatesPerSymbolfetchClosedOrdersfetchCrossBorrowRatefetchCrossBorrowRatesfetchCurrenciesfetchDepositAddressfetchDepositAddressesByNetwork fetchDepositsfetchDepositsWithdrawalsfetchFundingHistoryfetchFundingIntervalfetchFundingIntervalsfetchFundingRatefetchFundingRateHistoryfetchFundingRates fetchGreeksfetchIndexOHLCVfetchIsolatedBorrowRatefetchIsolatedBorrowRatesfetchIsolatedPositionsfetchL1OrderBookfetchL2OrderBook fetchLeveragefetchLeveragesfetchLeverageTiersfetchLiquidationsfetchLongShortRatiofetchLongShortRatioHistoryfetchMarginAdjustmentHistoryfetchMarginModefetchMarginModesfetchMarketLeverageTiers fetchMarketsfetchMarkOHLCVfetchMarkPricesfetchMyLiquidationsfetchMySettlementHistory fetchMyTrades fetchOHLCVfetchOpenInterestfetchOpenInterestHistoryfetchOpenInterestsfetchOpenOrderfetchOpenOrders fetchOptionfetchOptionChain fetchOrderfetchOrderBook fetchOrders fetchPositionfetchPositionHistoryfetchPositionModefetchPositionsfetchPositionsForSymbolfetchPositionsHistoryfetchPositionsRiskfetchPremiumIndexOHLCVfetchSettlementHistory fetchStatus fetchTicker fetchTickers fetchTime fetchTradesfetchTradingFeefetchTradingFeesfetchTransactionFeesfetchTransactionsfetchTransfersfetchVolatilityHistoryfetchWithdrawals reduceMargin) repayCrossMarginrepayIsolatedMarginsandbox setLeverage setMargin setMarginModesetPositionModetransferwithdrawr4private)z v2/account v2/ordersv2/orders/{order_id} v2/positions!v2/positions/{symbol_or_asset_id}zv2/account/portfolio/history v2/watchlistsv2/watchlists/{watchlist_id}v2/watchlists:by_namev2/account/configurationszv2/account/activitiesz%v2/account/activities/{activity_type}z v2/calendarzv2/clockz v2/assetszv2/assets/{symbol_or_asset_id}z'v2/corporate_actions/announcements/{id}z"v2/corporate_actions/announcementsz v2/walletsv2/wallets/transfers)rrrrr)rrrrr)rrrrrrz%v2/watchlists/{watchlist_id}/{symbol})getpostputpatchdeleter)zv1beta3/crypto/{loc}/barsz v1beta3/crypto/{loc}/latest/barsz&v1beta3/crypto/{loc}/latest/orderbooksz"v1beta3/crypto/{loc}/latest/quotesz"v1beta3/crypto/{loc}/latest/tradeszv1beta3/crypto/{loc}/quoteszv1beta3/crypto/{loc}/snapshotszv1beta3/crypto/{loc}/trades)zv1beta1/corporate-actionszv1beta1/forex/latest/rateszv1beta1/forex/rateszv1beta1/logos/{symbol}z v1beta1/newsz$v1beta1/screener/stocks/most-activesz%v1beta1/screener/{market_type}/moverszv2/stocks/auctionszv2/stocks/barszv2/stocks/bars/latestz$v2/stocks/meta/conditions/{ticktype}zv2/stocks/meta/exchangeszv2/stocks/quoteszv2/stocks/quotes/latestzv2/stocks/snapshotszv2/stocks/tradeszv2/stocks/trades/latestzv2/stocks/{symbol}/auctionszv2/stocks/{symbol}/barszv2/stocks/{symbol}/bars/latestzv2/stocks/{symbol}/quotesz v2/stocks/{symbol}/quotes/latestzv2/stocks/{symbol}/snapshotzv2/stocks/{symbol}/tradesz v2/stocks/{symbol}/trades/latest)publicr timeframes1min3min5min15min30min1H2H4H6H8H12H1D3D1W1M)1m3m5m15m30m1h2h4h6h8h12h1d3d1wr precisionModerequiredCredentials)apiKeysecretr7tradingz0.0015z0.00250100000z0.0022500000z0.00201000000z0.00181000000025000000z0.001350000000z0.0012 100000000z0.001z0.0008z0.0005z0.0002z0.00)takermaker) tierBased percentagerrtiersheaderszAPCA-PARTNER-IDccxtoptionsCBSE)rFTXGNSSERSXgtcz ccxt_{id})defaultExchange exchangesdefaultTimeInForce clientOrderIdfeatures)lastmarkindex)triggerPriceTypeprice)IOCFOKPOGTD) marginMode triggerPricertriggerDirection stopLossPricetakeProfitPriceattachedStopLossTakeProfit timeInForcehedgedtrailingleveragemarketBuyRequiresPricemarketBuyByCostselfTradePreventionicebergdi)rlimitdaysBack untilDayssymbolRequired)rtriggerrri)rr rrr)rr rrrrr)rr rdaysBackCanceledrrrrr ) rrJ createOrdersr}rrrrYr~)linearinverse)r:r<r= exceptions)z forbidden.4041000040010001401100004031000042910000)zInvalid format for parameterzInvalid symbol)exactbroad) deep_extendsuperr#describer parse_numberrrrrrr)self __class__s E/var/www/html/turnos/venv/lib/python3.12/site-packages/ccxt/alpaca.pyr!zalpaca.describesC fd < >RA (RA HRA  $RA  RA  (RA  4RA  i/=67 F<7 6FRA 4 ppp%p p % p % pUp$Up'pp"4ptp$Up p'p /!p",T#p$t%p&7'p(9%)p*(+p,"4-p.%d/p0T1p23p4 5p6&u7p8"59p:+E;p<)%=p>#E?p@,UApB$TCpD'EpF(GpH"5IpJ&tKpL1%MpN OpP+DQpR&uSpT'UpV(WpX#EYpZ*5[p\$U]p^u_p`"5apb*5cpd+Eepf)%gph#Dipj#Ekpl mpn!%opp%eqpr$Uspt&uupv-ewpx/ypz"5{p|#E}p~+Ep@ApB!%CpD"5EpF&uGpH+EIpJ KpLdMpN$UOpP+EQpR%eSpT!%UpV"4WpXuYpZ#E[p\d]p^!$_p`tapb cpd'epf$Ugph!%ipj*5kpl(mpn%eopp)%qpr)%sptuupvtwpxypzT{p|t}p~"5p@#EApB'CpD$UEpF!%GpH)%IpJ#DKpLMpN%*',$"!&#(! _p5RA V  ,!  37"#O0 2j    *maWRA Z [RA | Y}RA ~ "$RA F !%"&!..x8!..x8"..s3T5F5Fx5PQ!..x8$:K:KH:UV!..x8$:K:KH:UV!..y94;L;LX;VW!..z:D,7nnY'$*?*?*G$*NQU*UU r&cpddd}|j|j||}|j|S)a retrieves data on all markets for alpaca https://docs.alpaca.markets/reference/get-v2-assets :param dict [params]: extra parameters specific to the exchange api endpoint :returns dict[]: an array of objects representing market data cryptoactive) asset_classstatus)traderPrivateGetV2Assetsextend parse_markets)r#r1requestassetss r% fetch_marketszalpaca.fetch_marketssA$ ..t{{7F/KL.!!&))r&c`|j|d}|jd}|j|d}|j|d}|j|d}|j|}|j|}||dk(rd}|dz|z} |j|d} | d k(} |j|d } |j|d } |j|d }id |d| d|d|ddd|d|ddddddddddddddd | dddddddddd| |dddd| ddddddddd d|d! S)"Nsymbol/classr us_equityUSDr=r;min_order_sizemin_trade_incrementprice_incrementr&basequotesettlebaseIdquoteIdsettleIdtyper:Tr;r<Fr=r>contractr)amountr)minmax)rrVrcost) r contractSizeexpiryexpiryDatetimestrike optionType precisionlimitscreatedinfo)r-splitsafe_currency_code safe_number)r#assetmarketIdparts assetClassrQrRrNrOrEr=r; minAmountrVrs r% parse_marketzalpaca.parse_markets(*##E84s#%%eW5 !!%+""5!,&&v.''0 =Z;6Ee#!!%2H$$$U,<= !!%)>?  (9:0 (0 f0  D0  U 0 d 0 f 0  w0  0  F0  D0  d0  E0  e0  e0  f0 !0 " d#0 $ "    %    $_0 0 r&NrEsincer c|j|j|}|d}|j|dd}|j|dd}||d} |j|ddg}d} |dk(re||j || d<||| d <|j |j | |} |j| d i} |j| |g} nn|d k(rK|j|j | |} |j| d i} |j| |i} | g} nt|jd z|zd z|j| |||S)a get the list of most recent trades for a particular symbol https://docs.alpaca.markets/reference/cryptotrades https://docs.alpaca.markets/reference/cryptolatesttrades :param str symbol: unified symbol of the market to fetch trades for :param int [since]: timestamp in ms of the earliest trade to fetch :param int [limit]: the maximum amount of trades to fetch :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.loc]: crypto location, default: us :param str [params.method]: method, default: marketPublicGetV1beta3CryptoLocTrades :returns Trade[]: a list of `trade structures ` r&locusmethod%marketPublicGetV1beta3CryptoLocTradessymbolsrnNstartr trades+marketPublicGetV1beta3CryptoLocLatestTradesz fetchTrades() does not support ze, marketPublicGetV1beta3CryptoLocTrades and marketPublicGetV1beta3CryptoLocLatestTrades are supported) load_marketsr1r-omitiso8601rqr? safe_dict safe_listrvrr& parse_trades) r#rErlr r1r1rgrnrprA symbolTradesr2rus r% fetch_tradeszalpaca.fetch_tradesCs V$$<vud3!!&(4[\ 6E8#45 < < #'<<#6  #( AA$++gW]B^_H"^^Hh;F>>&(B?L D DGG T[]cHdeH^^Hh;F>>&(B?L(>Ltww)KKfTX @ @  vueDDr&c |j|j|}|d}|j|dd}||d}|j|j ||}|j |di} |j | |i} |j |j| d} |j| |d| dd d d S) a fetches information on open orders with bid(buy) and ask(sell) prices, volumes and other data https://docs.alpaca.markets/reference/cryptolatestorderbooks :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 :param str [params.loc]: crypto location, default: us :returns dict: A dictionary of `order book structures ` indexed by market symbols r&rnrorr orderbookstrEbaps)rwr1r-/marketPublicGetV1beta3CryptoLocLatestOrderbooksr?rzr/parse_order_book) r#rEr r1r1r&rnrAr2r rawOrderbookr(s r%fetch_order_bookzalpaca.fetch_order_books V$ D\vud3 GG T[]cHdeL^^HlB? ~~j"b9 NN4#3#3L##FG $$\6(3CYPSUXZ]_bccr&rc|j|j|}|d}|j|dd}|j|dd} ||d} |j|ddg}d} | dk(r||| d<||j || d <|j|j ||| d <|j |j| |} |j| d i} |j| |g} nn| d k(rK|j|j| |} |j| d i} |j| |i} | g} nt|jd z| zdz|j| ||||S)a_ fetches historical candlestick data containing the open, high, low, and close price, and the volume of a market https://docs.alpaca.markets/reference/cryptobars https://docs.alpaca.markets/reference/cryptolatestbars :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 alpha api endpoint :param str [params.loc]: crypto location, default: us :param str [params.method]: method, default: marketPublicGetV1beta3CryptoLocBars :returns int[][]: A list of candles ordered, open, high, low, close, volume r&rnrorp#marketPublicGetV1beta3CryptoLocBarsrrNr rt timeframebars)marketPublicGetV1beta3CryptoLocLatestBarsz fetchOHLCV() does not support za, marketPublicGetV1beta3CryptoLocBars and marketPublicGetV1beta3CryptoLocLatestBars are supported)rwr1r-rxyyyymmddrrr?rzr{rrr& parse_ohlcvs)r#rErrlr r1r1rgrnrprAohlcvsr2rs r% fetch_ohlcvzalpaca.fetch_ohlcvs V$$<vud3!!&(4YZ 6E8#45 : : #(  #'==#7 #'#3#3DOOYPY#ZGK ?? GU[@\]H<>>(FB7D^^D(B7F B BEEdkkRY[aFbcH">>(FB7D^^D(B7FXFtww)JJVSWz z{ {  E5IIr&r1c |j|d}|j|}||j|d|j|d|j|d|j|d|j|dgS)Nrohlcv)r-r/re)r#ohlcvr1datetimer(s r% parse_ohlcvzalpaca.parse_ohlcv$s##E3/NN8,    UC (   UC (   UC (   UC (   UC (   r&c|j|j|}|j|g|}|j||S)a fetches a price ticker, a statistical calculation with the information calculated over the past 24 hours for a specific market https://docs.alpaca.markets/reference/cryptosnapshots-1 :param str symbol: unified symbol of the market to fetch the ticker for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.loc]: crypto location, default: us :returns dict: a `ticker structure ` )rwrE fetch_tickersrz)r#rEr1tickerss r% fetch_tickerzalpaca.fetch_ticker<sC V$$$fXv6~~gv..r&rsc |t|jdz|j|j|}|j |dd}|j |}dj ||d}|j|d}|j|j||}g}|j|di}t|j} tdt| D]} | | } |j| } |j|| } |j| d i}|j| d i}|j| d i}|j| d i}|j |d }|j!id| d| dd|j#|d|d|j |dd|j |dd|j |dd|j |dd|j |dd|j |dd|j |dd |j |d!d"|j |d#d$|j |d%d&|j |d#d'dd(dd|j |d)|j |d*d+| }|j%||j'|d|S),a fetches price tickers for multiple markets, statistical information calculated over the past 24 hours for each market https://docs.alpaca.markets/reference/cryptosnapshots-1 :param str[] symbols: unified symbols of the markets to fetch tickers for :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.loc]: crypto location, default: us :returns dict: a dictionary of `ticker structures ` Nz+ fetchTickers() requires a symbols argumentrnro,rr snapshotsrdailyBar prevDailyBar latestQuote latestTraderrbrEr(rhighrlowrbidbp bidVolumebsaskap askVolumeasvwapvwopenrcloserrr previousClosechangerrn)average baseVolume quoteVolume)rr&rwmarket_symbolsr- market_idsjoinrx(marketPublicGetV1beta3CryptoLocSnapshotsr?rzlistkeysranger. safe_market safe_tickerr/appendfilter_by_array)r#rsr1rnidsrAr2resultsr marketIdsirgr1entryrrrrrtickers r%rzalpaca.fetch_tickersLs6 ?#DGG.[$[\ \ %%g.vud3oog&xx} 65)@@WV\A]^jNN8["= )* q#i.) #A |H%%h/FNN9h7E~~eZ>%DL.. rBK.. rBK'' S9H%%''&*'T^^H5'H ' ((37 ' t''#6 't'' T:'T--k4@'t'' T:'T--k4@'((48'((37'))(C8'((c:' !1!1,!D' $!'"d#'$ "..x=#//#>)'*+F, NN6 "? #@##GXw??r&c|j|jd}|j}|jd}dj |}|j |d|i}|j|d|}|S)Nr-r&)r-ruuidrcrimplode_params)r#r1clientOrderIdprefixrrh random_iddefaultClientIdrs r%generate_client_order_idzalpaca.generate_client_order_idsp"..t||_Myy{ 3GGEN --.AD)CTU((/R r&siderYc v|jd|i}|j|d|dd|j||S)a create a market order by providing the symbol, side and cost https://docs.alpaca.markets/reference/postorder :param str symbol: unified symbol of the market to create an order in :param str side: 'buy' or 'sell' :param float cost: how much you want to trade in units of the quote currency :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` rYr1rNrw create_orderr?)r#rErrYr1reqs r%create_market_order_with_costz$alpaca.create_market_order_with_costsE  D   4D$++cSYBZ[[r&c v|jd|i}|j|dddd|j||S)a create a market buy order by providing the symbol and cost https://docs.alpaca.markets/reference/postorder :param str symbol: unified symbol of the market to create an order in :param float cost: how much you want to trade in units of the quote currency :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` rYr1buyrNrr#rErYr1rs r%!create_market_buy_order_with_costz(alpaca.create_market_buy_order_with_costsE  D   5!T4;;sTZC[\\r&c v|jd|i}|j|dd|d|j||S)a create a market sell order by providing the symbol and cost https://docs.alpaca.markets/reference/postorder :param str symbol: unified symbol of the market to create an order in :param float cost: how much you want to trade in units of the quote currency :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `order structure ` rYr1sellNrrs r%"create_market_sell_order_with_costz)alpaca.create_market_sell_order_with_costsF  D   64t{{SVX^G_``r&rTrVrcX|j|j|}|d}|||d} |j|ddg} | O|jddk\rd} nt |j dz|zd z|j || | d<| | d <|jddk\r|j ||| d <|j|d } | (|j|d }|j|| | d <n|j||| d<|j|jd} |j|d| | d<|j|ddg}|j|| d<|j|dg}|j|j| |}|j||S)at create a trade order https://docs.alpaca.markets/reference/postorder :param str symbol: unified symbol of the market to create an order in :param str type: 'market', 'limit' or 'stop_limit' :param str side: 'buy' or 'sell' :param float amount: how much of currency you want to trade in units of base currency :param float [price]: the price at which the order is to be fulfilled, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param float [params.triggerPrice]: The price at which a trigger order is triggered at :param float [params.cost]: *market orders only* the cost of the order in units of the quote currency :returns dict: an `order structure ` r&)rErrTr stop_pricer r stop_limitz0 createOrder() does not support stop orders for z- orders, only stop_limit orders are supportedrT limit_pricerYnotionalqtyrr time_in_forceclient_order_idr)rwr1 safe_string_nfindrr&price_to_precisionr-rxcost_to_precisionamount_to_precisionrrtraderPrivatePostV2Ordersr? parse_order)r#rErTrrVrr1r1r&rArnewTyperY defaultTIForders r%rzalpaca.create_orders V$ D\  ))&><2PQ  #yy!Q&&"477-_#_bf#fjY$YZZ$($;$;FL$QGL !%GFO 99W  "%)%<%#BC%)%B%B6%J!"6O#45..t{{7F/KLJv..r&r&cnd|i}|j|j||}|j|S)a cancels an open order https://docs.alpaca.markets/reference/deleteorderbyorderid :param str id: order id :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` order_id)"traderPrivateDeleteV2OrdersOrderIdr?r)r#r&rEr1rAr2s r% cancel_orderzalpaca.cancel_orderNsA  ::4;;wPV;WX))r&c|j|j|}t|tr|j |dS|j d|igS)a cancel all open orders in a market https://docs.alpaca.markets/reference/deleteallorders :param str symbol: alpaca cancelAllOrders cannot setting symbol, it will cancel all open orders :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `order structures ` Nrb)rwtraderPrivateDeleteV2Orders isinstancer parse_orders safe_order)r#rEr1r2s r%cancel_all_orderszalpaca.cancel_all_orderses_ 33F; h %$$Xt4 4H! r&c|jd|i}|j|j||}|j|d}|j |}|j ||S)a fetches information on an order made by the user https://docs.alpaca.markets/reference/getorderbyorderid :param str id: the order id :param str symbol: unified symbol of the market the order was made in :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: An `order structure ` rrE)rwtraderPrivateGetV2OrdersOrderIdr?r-rr)r#r&rEr1rArrgr1s r% fetch_orderzalpaca.fetch_orderzsn   44T[[&5QR##E84!!(+v..r&c||jddi}d}||j|}|d|d<|j|d}|&|j|d}|j ||d<||j ||d<|||d <|j |j ||}|j||||S) aw fetches information on multiple orders made by the user https://docs.alpaca.markets/reference/getallorders :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 :param int [params.until]: the latest time in ms to fetch orders for :returns Order[]: a list of `order structures ` r=allNr&rsuntilendTimeafterr )rwr1 safe_integerrxrytraderPrivateGetV2Ordersr?r) r#rErlr r1rAr1rr2s r% fetch_orderszalpaca.fetch_orderss  e   [[(F!'GI !!&'2  YYvw/F!%e!4GI   #||E2GG   $GG 00Wf1MNR  65%@@r&c Rddi}|j||||j||S)ah fetch all unfilled currently open orders https://docs.alpaca.markets/reference/getallorders :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 :param int [params.until]: the latest time in ms to fetch orders for :returns Order[]: a list of `order structures ` r=rrr?r#rErlr r1rAs r%fetch_open_orderszalpaca.fetch_open_orderss4 f   t{{7F7STTr&c Rddi}|j||||j||S)a~ fetches information on multiple closed orders made by the user https://docs.alpaca.markets/reference/getallorders :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 :param int [params.until]: the latest time in ms to fetch orders for :returns Order[]: a list of `order structures ` r=closedr r s r%fetch_closed_orderszalpaca.fetch_closed_orderss4 h   t{{7F7STTr&c|jd|i}d} ||j|} ||j|||d<|j|ddg} | '|j || |d<|j |d}||j |||d<d} |j |ddd \} }| | |d <|j||d <|j |d g}|j|j||} |j| | S) a edit a trade order https://docs.alpaca.markets/reference/patchorderbyorderid-1 :param str id: order id :param str [symbol]: unified symbol of the market to create an order in :param str [type]: 'market', 'limit' or 'stop_limit' :param str [side]: 'buy' or 'sell' :param float [amount]: how much of the currency you want to trade in units of the base currency :param float [price]: the price for the order, in units of the quote currency, ignored in market orders :param dict [params]: extra parameters specific to the exchange API endpoint :param str [params.triggerPrice]: the price to trigger a stop order :param str [params.timeInForce]: for crypto trading either 'gtc' or 'ioc' can be used :param str [params.clientOrderId]: a unique identifier for the order, automatically generated if not sent :returns dict: an `order structure ` rNrrrrrPrrrrr) rwr1rrrrxhandle_option_and_params_2r!traderPrivatePatchV2OrdersOrderIdr?r) r#r&rErTrrVrr1rAr1rrr2s r% edit_orderzalpaca.edit_orders=$     [[(F  !55ffEGEN))&><2PQ  #$($;$;FL$QGL !YYv~6F  %)%<%:NN8,  $""5$/ T--e5FG      !$  f   f  I  433D4D4DUO4\]    D$$UF3  T%%e];  D,,ULA  D  t''/AB d&&ue4! " d&&ul;# $+ , - r&r=c:ddddddd}|j|||S)Nrr) pending_newacceptednewpartially_filled activatedrr-r#r=statusess r%r!zalpaca.parse_order_statusvs2! &  &&99r&rc0ddi}|j|||S)NdayDayr,)r#r timeInForcess r%r"zalpaca.parse_time_in_forces% 5  k;GGr&c|jd}ddi}||j|}|j|d}|&|j|d}|j ||d<||j ||d<|||d<|j d||\}}|j |j||}|j||||S)a fetch all trades made by the user https://docs.alpaca.markets/reference/getaccountactivitiesbyactivitytype-1 :param str [symbol]: unified market symbol :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 int [params.until]: the latest time in ms to fetch trades for :param str [params.page_token]: page_token - used for paging :returns Trade[]: a list of `trade structures ` N activity_typeFILLrr page_size) rwr1rrxryhandle_until_option/traderPrivateGetV2AccountActivitiesActivityTyper?r|) r#rErlr r1r1rArr2s r%fetch_my_tradeszalpaca.fetch_my_tradess  V   [[(F!!&'2  YYvw/F#||E2GG   #||E2GG   #(GK 227GVLGG T[]cHde(  65%@@r&tradec|j|dd}|j||}|j|dd}|j|}|j|d}|j|d}|dk(rd}n|dk(rd }|j|d d } |j|d d } |j ||j|dd||j |||j|dd|d| | ddd |S)NSrErtransaction_timetksrBrrrrrrrr&rr) rbr&r(rrErrTr takerOrMakerrrVrYr ) safe_string_2 safe_symbolr/r- safe_tradery) r#r:r1rgrErr( alpacaSider priceString amountStrings r% parse_tradezalpaca.parse_trades>%%eS(;!!(F3%%eS2DENN8, %%eU3 v.  D 3 D((W= ))%e< $$UC6" Y/%%eZ8# "   r&codec|j|j|}d|di}|j|j||}|j ||S)a fetch the deposit address for a currency associated with self account https://docs.alpaca.markets/reference/listcryptofundingwallets :param str code: unified currency code :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: an `address structure ` rfr&)rwrtraderPrivateGetV2Walletsr?parse_deposit_address)r#rHr1rrAr2s r%fetch_deposit_addresszalpaca.fetch_deposit_addresss` ==& Xd^ 11$++gv2NO))(H==r&rcDd}||d}||d|j|dddS)Nr&address)rbrnetworkrNtagr,)r#depositAddressrparsedCurrencys r%rKzalpaca.parse_deposit_addresss>  %d^N"&'' B   r&rNc:|j||\}}|j||j|j|}|r|dz|z}|d||j |d}|j |j ||}|j||S)a make a withdrawal https://docs.alpaca.markets/reference/createcryptotransferforaccount :param str code: unified currency code :param float amount: the amount to withdraw :param str address: the address to withdraw to :param str tag: a memo for the transaction :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `transaction structure ` :r&)rfrNrV)handle_withdraw_tag_and_params check_addressrwrnumber_to_string#traderPrivatePostV2WalletsTransfersr?parse_transaction) r#rHrVrNrPr1rrAr2s r%rzalpaca.withdraw"s99#vF V 7# ==& mc)Gd^++F3  ;;DKKQW` r\r_r#rHrlr r1s r%fetch_deposits_withdrawalsz!alpaca.fetch_deposits_withdrawalsos--fdE5&QQr&c,|jd||||S)a fetch all deposits made to an account https://docs.alpaca.markets/reference/listcryptofundingtransfers :param str [code]: unified currency code :param int [since]: the earliest time in ms to fetch deposits for :param int [limit]: the maximum number of deposit structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `transaction structures ` INCOMINGrarbs r%fetch_depositszalpaca.fetch_deposits}--j$ufUUr&c,|jd||||S)a fetch all withdrawals made from an account https://docs.alpaca.markets/reference/listcryptofundingtransfers :param str [code]: unified currency code :param int [since]: the earliest time in ms to fetch withdrawals for :param int [limit]: the maximum number of withdrawal structures to retrieve :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict[]: a list of `transaction structures ` OUTGOINGrarbs r%fetch_withdrawalszalpaca.fetch_withdrawalsrgr& transactionc|j|d}|j|d}|j||}|j|d}|j|d}tj||}|j ||d} id|d|j|dd|j|d d |j |d |d |j|d d|j|dd|j|dd|j|dddddddd|j |j|dd|j|dd|d|j|j|ddd| dddS)N created_atrfr7 network_feerrbr&txidtx_hashr(rrOchainrN to_address addressTo addressFrom from_addressrPtagTotagFromrTr[rVrr=updated)r commentinternal) r-rdr! string_addr"r/parse_transaction_typereparse_transaction_status) r#rkrr currencyIdrHr7 networkFeetotalFeer s r%rYzalpaca.parse_transactions$##K>%%k7; &&z8< V4%%k=A %%dJ7%%h/  K $"";5  D$$[)<  1    t'' W=   t'' \B  ))+|D  4++KH  4  T  t  D//0@0@k0Z[  d&&{H=   d33D4D4D[RZ4[\! " t# $)  r&c4dddd}|j|||S)Npendingfailedok) PROCESSINGFAILEDCOMPLETEr,r-s r%r}zalpaca.parse_transaction_statuss)#  &&99r&c2ddd}|j|||S)Ndeposit withdrawal)rerir,)r#rTtypess r%r|zalpaca.parse_transaction_types&!$ tT22r&cf|j|j|}|j|S)a^ query for balance and get the amount of funds available for trading or funds locked in orders https://docs.alpaca.markets/reference/getaccount-1 :param dict [params]: extra parameters specific to the exchange API endpoint :returns dict: a `balance structure ` )rwtraderPrivateGetV2Account parse_balance)r#r1r2s r% fetch_balancezalpaca.fetch_balances4 11&9b!!(++r&cd|i}|j}|j|d}|j|}|j|d|d<|j|d|d<|||<|j|S)Nrbrcashfreeequitytotal)accountr-rd safe_balance)r#r2resultrr~rHs r%rzalpaca.parse_balances),,.%%h ; &&z2**8V<++Hh?t   ((r&rGETcd|j||z}|j|jd|d}||ni}|ddk(r.|j|j|d<|j |d<|j ||j|} | r8|dk(s|d k(r|d |j| zz }n|j| }d |d <||z}||||d S)NrFr4rrHrzAPCA-API-KEY-IDzAPCA-API-SECRET-KEYrDELETE?zapplication/jsonz Content-Type)urlrpbodyr) rimplode_hostnamer.check_required_credentialsrrrxextract_params urlencodejson) r#pathr4rpr1rrendpointrquerys r%signz alpaca.sign"s,,T6::##DIIe$4SV$<=%1' q6Y   + + -)-G% &-1[[G) * &$"5"5d";< %Vx%7C$.."777yy'*<'HnfdwOOr&reasonrrprrc V|y|jdz|z} |j|d} | |j|jd| | |j |dd} | K|j|jd| | |j |jd| | t | y)N rHrmessager)r&r-throw_exactly_matched_exceptionr safe_valuethrow_broadly_matched_exceptionr) r#rHrrrprrr2requestHeaders requestBodyfeedback errorCoders r% handle_errorszalpaca.handle_errors4s   77S=4'$$Xv6    0 01I9V^ _//(It<    0 01I7T\ ]  0 01I7T\ ]) )r&)N)D__name__ __module__ __qualname__rr!r r8rr rCrkstrrr~r rrrrrrrrrrrfloatrrrrr rrrrrr rr rrdictrr!r"r9rGrrLrrKrrr_rcrfrjrYr}r|rrrrintr __classcell__)r$s@r%r#r#s8S #S j !#s.$&$*$v,$*LV VV p6:UWFE3FEsFE#FE\`af\gFEP:>b=ds=d3=dY=d~26DW[dfXJ#XJcXJQTXJkoptkuXJt  4 002/3/f/ 04Bn@Wn@7n@`_a\C\y\PU\$RT]]5]"SUaaEa"gksuS/3S/iS/yS/RWS/`cS/j37r*s*C*./32*26b/c/3/(*.Dt\^FA3FAcFAFAcghmcnFAP/3TXacUU3UcUhlmrhsU$154VZceU#USUPSUjnotjuU$`drv@B(2S(2#(2Y(2i(2Y\(2lo(2TPPvPPd : :HsH -1tRV_a2Ac2A2AC2Ah99v99v79>#>^>2 h R` &DHPR*:S*:%*:#*:Wb*:XPB6:[_hj Rs R# RUX RostpA R*.Dt\^ V3 Vc V Vcghsct V-1tRV_a Vc V VC Vfjkvfw V1 T1 X1 Q\1 f:s:3$&;,(;,z))&eBSWP$#scTX`cr&r#N)'ccxt.base.exchangerccxt.abstract.alpacarccxt.base.typesrrrrr r r r r rrrrrrrrtypingrccxt.base.errorsrrrrrrrrrccxt.base.decimal_to_precisionr ccxt.base.preciser!r#r&r%rs_ (,qqqqq*-.'&.)).4%mX{mr&