
    Z-"i                        S SK Jr  S SKrSSKJrJrJrJrJ	r	  S SK
Jr  SSSS	S
SSSSS.	rSS	SSSSSSSSSS.rSS	SSSSSSSSS.
rSSS S!S"SSS#.rSS$S%S&SSS'.rSSS	S
SS(SSS).rSS	S*S+S,S-S.S/S0S1SSS2.rSS	SS3S4S5.r " S6 S7\5      r " S8 S9\5      r " S: S;5      r " S< S=\5      r " S> S?\5      r " S@ SA\5      r " SB SC\\	\5      r " SD SE\\	\5      r " SF SG\\	\5      r " SH SI\\	\5      r " SJ SK\\	\5      r " SL SM\\	\5      r  " SN SO\\	\5      r! " SP SQ5      r" " SR SS\#5      r$ " ST SU\#5      r% " SV SW\#5      r& " SX SY\#5      r' " SZ S[\5      r( " S\ S]\5      r) " S^ S_\#5      r* " S` Sa\5      r+ " Sb Sc\5      r,Sd r-g)e    )EnumN   )BarEntityTradeQuote_NanoTimestamped)Dictidsymbol
conditionsexchangepricesize	timestamptape	takerside)	iScxpstztksask_exchange	ask_priceask_sizebid_exchange	bid_pricebid_size)r   r   axapasbxbpbsr   r   r   openhighlowclosevolumetrade_countvwap)
r   r   ohlr   vr   nvwstatus_codestatus_messagereason_codereason_message)r   scsmrcrmr   r   limit_up_pricelimit_down_price	indicator)r   udr   r   r   cancel_error_action)r   r   r   r   r   ar   r   original_idoriginal_priceoriginal_sizeoriginal_conditionscorrected_idcorrected_pricecorrected_sizecorrected_conditions)r   r   oioposoccicpcsccr   r   bidsasks)r   r   r   brD   c                   ,    \ rS rSr\\4r\\4r\\	4rSr
g)EntityListTypec    N)__name__
__module____qualname____firstlineno__r   trade_mapping_v2r   quote_mapping_v2r   bar_mapping_v2__static_attributes__r[       T/home/james-whalen/.local/lib/python3.13/site-packages/alpaca_trade_api/entity_v2.pyrY   rY   c   s"    ##E##E
~
Crd   rY   c                   @   ^  \ rS rSrS\4U 4S jjr\S 5       rSrU =r	$ )
EntityListi   entity_typec                    > UR                   S   n[        TU ]	  U Vs/ s H
  oC" U5      PM     sn5        X l        UR                   S   U l        g s  snf )Nr   r   )valuesuper__init___rawmapping)selfri   rawentityr0   	__class__s        re   rm   EntityList.__init__j   sO    ""1%S1S&)S12	"((+ 2s   Ac                    [        U S5      (       d  [        R                  " U R                  5      nUR                   Vs/ s H  o R
                  R                  X"5      PM     snUl        UR                  (       d5  UR                  SSS9  [        R                  " UR                  5      Ul
        Xl        U R                  $ s  snf )N_dfr   T)inplace)hasattrpd	DataFramern   columnsro   getempty	set_indexDatetimeIndexindexrv   )rp   dfr   s      re   r   EntityList.dfp   s    tU##		B ;=**E*Q,,**10*EBJ88[$7++BHH5Hxx Fs    $C)rv   rn   ro   )
r\   r]   r^   r_   rY   rm   propertyr   rc   __classcell__rs   s   @re   rg   rg   i   s#    ,N ,  rd   rg   c                   F   ^  \ rS rSrS\\\4   4U 4S jjrU 4S jrSrU =r	$ )Remapped   ro   c                    > UR                  5        VVs0 s H  u  pEXT_M	     snnU l        [        TU ]  " U0 UD6  g s  snnf N)items_reversed_mappingrl   rm   )rp   ro   argskwargskeyrk   rs   s         re   rm   Remapped.__init__   s@    +2==?"<+:<CEJ?"<$)&)"<s   =c                 x   > XR                   ;   a  [        TU ]	  U R                   U   5      $ [        TU ]	  U5      $ r   )r   rl   __getattr__)rp   r   rs   s     re   r   Remapped.__getattr__   s:    (((7&t'='=c'BCCw"3''rd   )r   )
r\   r]   r^   r_   r
   strrm   r   rc   r   r   s   @re   r   r      s!    *S#X *
( (rd   r   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )BarsV2   c                 B   > [         TU ]  [        R                  U5        g r   )rl   rm   rY   r   rp   rq   rs   s     re   rm   BarsV2.__init__   s    ++S1rd   r[   r\   r]   r^   r_   rm   rc   r   r   s   @re   r   r      s    2 2rd   r   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )TradesV2   c                 B   > [         TU ]  [        R                  U5        g r   )rl   rm   rY   r   r   s     re   rm   TradesV2.__init__       --s3rd   r[   r   r   s   @re   r   r          4 4rd   r   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )QuotesV2   c                 B   > [         TU ]  [        R                  U5        g r   )rl   rm   rY   r   r   s     re   rm   QuotesV2.__init__   r   rd   r[   r   r   s   @re   r   r      r   rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )TradeV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   r`   r   s     re   rm   TradeV2.__init__       )3/rd   r[   r\   r]   r^   r_   _tskeysrm   rc   r   r   s   @re   r   r          G0 0rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )QuoteV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   ra   r   s     re   rm   QuoteV2.__init__   r   rd   r[   r   r   s   @re   r   r      r   rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )BarV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   rb   r   s     re   rm   BarV2.__init__   s    -rd   r[   r   r   s   @re   r   r      s    G. .rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )StatusV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   status_mapping_v2r   s     re   rm   StatusV2.__init__   s    *C0rd   r[   r   r   s   @re   r   r      s    G1 1rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )LULDV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   luld_mapping_v2r   s     re   rm   LULDV2.__init__   s    #.rd   r[   r   r   s   @re   r   r      s    G/ /rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )CancelErrorV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   cancel_error_mapping_v2r   s     re   rm   CancelErrorV2.__init__   s    0#6rd   r[   r   r   s   @re   r   r      s    G7 7rd   r   c                   ,   ^  \ rS rSrSrU 4S jrSrU =r$ )CorrectionV2   r   c                 .   > [         TU ]  [        U5        g r   )rl   rm   correction_mapping_v2r   s     re   rm   CorrectionV2.__init__   s    .4rd   r[   r   r   s   @re   r   r      s    G5 5rd   r   c                       \ rS rSrS rSrg)
SnapshotV2   c                 l   [        [        UR                  S5      5      U l        [        [        UR                  S5      5      U l        [        [        UR                  S5      5      U l        [        [        UR                  S5      5      U l        [        [        UR                  S5      5      U l	        g )NlatestTradelatestQuote	minuteBardailyBarprevDailyBar)
_convert_or_noner   r|   latest_trader   latest_quoter   
minute_bar	daily_barprev_daily_bar)rp   rq   s     re   rm   SnapshotV2.__init__   sx    ,Wcggm6LM,Wcggm6LM*5#''+2FG)%1DE.ucggn6MNrd   )r   r   r   r   r   Nr\   r]   r^   r_   rm   rc   r[   rd   re   r   r      s    Ord   r   c                       \ rS rSrS rSrg)SnapshotsV2   c                 Z    UR                  5        H  u  p#[        [        U5      X'   M     g r   )r   r   r   rp   rq   kr3   s       re   rm   SnapshotsV2.__init__   s"    IIKDA&z15DG  rd   r[   Nr   r[   rd   re   r   r      s    6rd   r   c                       \ rS rSrS rSrg)LatestBarsV2   c                 Z    UR                  5        H  u  p#[        [        U5      X'   M     g r   )r   r   r   r   s       re   rm   LatestBarsV2.__init__   s"    IIKDA&ua0DG  rd   r[   Nr   r[   rd   re   r   r      s    1rd   r   c                       \ rS rSrS rSrg)LatestTradesV2   c                 Z    UR                  5        H  u  p#[        [        U5      X'   M     g r   )r   r   r   r   s       re   rm   LatestTradesV2.__init__   "    IIKDA&w2DG  rd   r[   Nr   r[   rd   re   r   r          3rd   r   c                       \ rS rSrS rSrg)LatestQuotesV2   c                 Z    UR                  5        H  u  p#[        [        U5      X'   M     g r   )r   r   r   r   s       re   rm   LatestQuotesV2.__init__   r   rd   r[   Nr   r[   rd   re   r   r      r   rd   r   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )BidOrAsk   c                 $   > [         TU ]  U5        g r   rl   rm   r   s     re   rm   BidOrAsk.__init__       rd   r[   r   r   s   @re   r   r           rd   r   c                   (   ^  \ rS rSrU 4S jrSrU =r$ )OrderbookV2   c                   > [         TU ]  U5        U R                  (       aJ  [        [	        U R                  5      5       H(  n[        U R                  U   5      U R                  U'   M*     U R                  (       aK  [        [	        U R                  5      5       H(  n[        U R                  U   5      U R                  U'   M*     g g r   )rl   rm   rU   rangelenr   rV   )rp   rq   r   rs   s      re   rm   OrderbookV2.__init__   s    993tyy>*'		!5		! +993tyy>*'		!5		! + rd   r[   r   r   s   @re   r  r     s    6 6rd   r  c                       \ rS rSrS rSrg)OrderbooksV2   c                     UR                  5        HY  u  p#[        R                  5        H*  nXC;  a  M
  [        U   nX4   X5'   UR                  U5        M,     [	        [
        U5      X'   M[     g r   )r   orderbook_mapping_v2keyspopr   r  )rp   rq   r   r3   sidereadable_sides         re   rm   OrderbooksV2.__init__   s^    IIKDA,113= 4T :#$7 d 4 '{A6DG  rd   r[   Nr   r[   rd   re   r  r     s    7rd   r  c                   (   ^  \ rS rSrU 4S jrSrU =r$ )NewsV2i  c                 $   > [         TU ]  U5        g r   r  r   s     re   rm   NewsV2.__init__	  r  rd   r[   r   r   s   @re   r  r    r  rd   r  c                   (   ^  \ rS rSrU 4S jrSrU =r$ )
NewsListV2i  c                 b   > [         TU ]  U Vs/ s H  n[        U5      PM     sn5        g s  snf r   )rl   rm   r  )rp   rq   r0   rs   s      re   rm   NewsListV2.__init__  s&    S1S&)S121s   ,r[   r   r   s   @re   r  r    s    3 3rd   r  c                 "    U(       a  U " U5      $ g r   r[   )
entityTyperk   s     re   r   r     s    %  rd   ).enumr   pandasry   rr   r   r   r   r   r	   typingr
   r`   ra   rb   r   r   r   r   r  rY   listrg   r   r   r   r   r   r   r   r   r   r   r   r   dictr   r   r   r   r   r  r  r  r  r   r[   rd   re   <module>r%     sh     ? ?  
							
  	








  	







 





  
					 
								  
	







 		   
				 T  ,	( 	(2Z 2
4z 4
4z 4
0h(& 00h(& 0.H& .1x)6 1/X' /7H. 758-v 5O O6$ 614 13T 33T 3v 
6& 6	74 	7V 
3 3
rd   