'ih8ddlmZmZmZmZddlZddlmZddlZddl Z ddl Z ddl m Z ddlmZmZGdde j"ZGdd eeeZGd d ej*ZGd d eeeZy))absolute_importdivisionprint_functionunicode_literalsN) OrderedDict) TimeFrame)MAXINTwith_metaclassc(eZdZfdZfdZxZS) MetaAnalyzerctt| |i|\}}}t|_t j j|t jx|_ }t j j|t|_ t j j|t j}||j||j|_|jr|jdx|_}t!|j"D]8\}}|j%|} | rt'|d| z|t'|d|z|:t!|jD]i\} }t'|d| z|t!|j"D]<\}}|j%|} | rt'|d| | fz|t'|d| |fz|>k|j)|||fS)z2 Intercept the strategy parameter rzdata_%szdata_%dzdata%dz data%d_%sz data%d_%d)superr donewlist _childrenbtmetabase findownerStrategystrategyAnalyzer_parentObserver_register_analyzerdatasdata enumeratelines _getlinealiassetattrcreate_analysis) clsargskwargs_objr masterobsrlline linealiasd __class__s Q/var/www/app/trading-bot/venv/lib/python3.12/site-packages/backtrader/analyzer.pyrzMetaAnalyzer.donew#s #<;TLVLdF#%;;#8#8r{{#KK {{,,T8< KK))$ <   ( ( .^^  ::#zz!} ,DI$TZZ0 34 ..q1 D)i"7>i!mT2  3 %TZZ0 >4hlD1(4>GAt $ 2 21 5I kQ N&BDID+A"6= > > T6!!ctt| |g|i|\}}}|j|jj ||||fSN)rr dopostinitr _register)r"r%r#r$r+s r,r0zMetaAnalyzer.dopostinitNsT , / Ft Fv F dF << # LL " "4 (T6!!r-)__name__ __module__ __qualname__rr0 __classcell__r+s@r,r r "s)"V""r-r ceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZy)raAnalyzer base class. All analyzers are subclass of this one An Analyzer instance operates in the frame of a strategy and provides an analysis for that strategy. Automagically set member attributes: - ``self.strategy`` (giving access to the *strategy* and anything accessible from it) - ``self.datas[x]`` giving access to the array of data feeds present in the the system, which could also be accessed via the strategy reference - ``self.data``, giving access to ``self.datas[0]`` - ``self.dataX`` -> ``self.datas[X]`` - ``self.dataX_Y`` -> ``self.datas[X].lines[Y]`` - ``self.dataX_name`` -> ``self.datas[X].name`` - ``self.data_name`` -> ``self.datas[0].name`` - ``self.data_Y`` -> ``self.datas[0].lines[Y]`` This is not a *Lines* object, but the methods and operation follow the same design - ``__init__`` during instantiation and initial setup - ``start`` / ``stop`` to signal the begin and end of operations - ``prenext`` / ``nextstart`` / ``next`` family of methods that follow the calls made to the same methods in the strategy - ``notify_trade`` / ``notify_order`` / ``notify_cashvalue`` / ``notify_fund`` which receive the same notifications as the equivalent methods of the strategy The mode of operation is open and no pattern is preferred. As such the analysis can be generated with the ``next`` calls, at the end of operations during ``stop`` and even with a single method like ``notify_trade`` The important thing is to override ``get_analysis`` to return a *dict-like* object containing the results of the analysis (the actual format is implementation dependent) Tc,t|jS)zSupport for invoking ``len`` on analyzers by actually returning the current length of the strategy the analyzer operates on)lenrselfs r,__len__zAnalyzer.__len__s4==!!r-c:|jj|yr/)rappendr;childs r,r1zAnalyzer._registers e$r-cf|jD]}|j|jyr/)r_prenextprenextr?s r,rBzAnalyzer._prenexts*^^ E NN   r-cn|jD]}|j|||j||yr/)r_notify_cashvaluenotify_cashvalue)r;cashvaluer@s r,rEzAnalyzer._notify_cashvalues7^^ 1E  # #D% 0 1 dE*r-cv|jD]}|j|||||j||||yr/)r _notify_fund notify_fund)r;rGrH fundvaluesharesr@s r,rJzAnalyzer._notify_funds?^^ ?E   tUIv > ? ui8r-cj|jD]}|j||j|yr/)r _notify_trade notify_trade)r;trader@s r,rOzAnalyzer._notify_trade3^^ 'E    & ' % r-cj|jD]}|j||j|yr/)r _notify_order notify_order)r;orderr@s r,rTzAnalyzer._notify_orderrRr-cf|jD]}|j|jyr/)r _nextstart nextstartr?s r,rXzAnalyzer._nextstarts-^^ E      r-cf|jD]}|j|jyr/)r_nextnextr?s r,r[zAnalyzer._next)^^ E KKM  r-cf|jD]}|j|jyr/)r_startstartr?s r,r_zAnalyzer._starts)^^ E LLN  r-cf|jD]}|j|jyr/)r_stopstopr?s r,rbzAnalyzer._stopr]r-cy)z;Receives the cash/value notification before each next cycleN)r;rGrHs r,rFzAnalyzer.notify_cashvalue r-cy)z;Receives the current cash, value, fundvalue and fund sharesNre)r;rGrHrLrMs r,rKzAnalyzer.notify_fundrfr-cy)z3Receives order notifications before each next cycleNre)r;rVs r,rUzAnalyzer.notify_orderrfr-cy)z3Receives trade notifications before each next cycleNre)r;rQs r,rPzAnalyzer.notify_traderfr-cy)zpInvoked for each next invocation of the strategy, once the minum preiod of the strategy has been reachedNrer:s r,r\z Analyzer.next r-c$|jy)zInvoked for each prenext invocation of the strategy, until the minimum period of the strategy has been reached The default behavior for an analyzer is to invoke ``next`` Nr\r:s r,rCzAnalyzer.prenexts r-c$|jy)zInvoked exactly once for the nextstart invocation of the strategy, when the minimum period has been first reached Nrmr:s r,rYzAnalyzer.nextstarts  r-cy)zgInvoked to indicate the start of operations, giving the analyzer time to setup up needed thingsNrer:s r,r`zAnalyzer.startrkr-cy)zfInvoked to indicate the end of operations, giving the analyzer time to shut down needed thingsNrer:s r,rcz Analyzer.stoprkr-c"t|_y)zMeant to be overriden by subclasses. Gives a chance to create the structures that hold the analysis. The default behaviour is to create a ``OrderedDict`` named ``rets`` N)rretsr:s r,r!zAnalyzer.create_analysiss  M r-c|jS)aReturns a *dict-like* object with the results of the analysis The keys and format of analysis results in the dictionary is implementation dependent. It is not even enforced that the result is a *dict-like object*, just the convention The default implementation returns the default OrderedDict ``rets`` created by the default ``create_analysis`` method )rrr:s r, get_analysiszAnalyzer.get_analysissyyr-ctj|i|}|jt}|j ||j j <|j||jy)zPrints the results returned by ``get_analysis`` via a standard ``Writerfile`` object, which defaults to writing things to standard output N) r WriterFiler`dictrtr+r2 writedictrc)r;r#r$writerpdcts r,printzAnalyzer.prints[ // v(,(9(9(;T^^ $ $% r-cRtj|jg|i|y)zpPrints the results returned by ``get_analysis`` using the pretty print Python module (*pprint*) N)pppprintrt)r;r#r$s r,r~zAnalyzer.pprints# $##%777r-N)r2r3r4__doc__csvr<r1rBrErJrOrTrXr[r_rbrFrKrUrPr\rCrYr`rcr!rtr{r~rer-r,rrYs/` C" % + 9 ! !             "  8r-rceZdZfdZxZS)MetaTimeFrameAnalyzerBasec`d|vr|jd|d<tt|||||S)N _on_dt_over on_dt_over)poprr__new__)metanamebasesdctr+s r,rz!MetaTimeFrameAnalyzerBase.__new__"s> C  # 6C .=dD>CSJ Jr-)r2r3r4rr5r6s@r,rr!sJJr-rcLeZdZdZfdZdZdZdZdZdZ dZ d Z xZ S) TimeFrameAnalyzerBase)) timeframeN) compressionN) _doprenextTcb|jjxs|jj|_|jjxs|jj |_|j tjj\|_ |_ tt|7yr/)prr _timeframer _compression_get_dt_cmpkeydatetimemindtcmpdtkeyrrr_)r;r+s r,r_zTimeFrameAnalyzerBase._start3sw))ATYY-A-A66--G1G1G!%!4!4X5F5F5J5J!K DJ #T13r-c|jD]}|j|jr|j|jj r|j yyr/)rrB_dt_overrrrrCr?s r,rBzTimeFrameAnalyzerBase._prenext;sO^^ E NN   ==? OO  66   LLN r-c|jD]}|j|js|jjs|j |j yr/)rrXrrrrrYr?s r,rXz TimeFrameAnalyzerBase._nextstartEsL^^ E      ==?$&&"3"3 OO  r-c|jD]}|j|jr|j|j yr/)rr[rrr\r?s r,r[zTimeFrameAnalyzerBase._nextNs<^^ E KKM  ==? OO  r-cyr/rer:s r,rz TimeFrameAnalyzerBase.on_dt_overWs r-c|jtjk(r!ttjj }}n8|j jj }|j|\}}|j||jkDr3||jc|_ |_ ||jc|_|_ yy)NTF) rr NoTimeFramer rmaxrrrrdtkey1dtcmp1)r;rrdts r,rzTimeFrameAnalyzerBase._dt_overZs >>Y22 2!8#4#4#8#85E''002B..r2LE5 :: !3&+TZZ #DJ &+TZZ #DJ r-cT|jtjk(ry|jtjk(r1|j}t j |jdd}||fS|jtjk(rx|jdz|jz}tj|j|j\}}t j |j|j|}||fS|jtjk(rq|j\}}}|dz|z}|t jd|z z} t j | j| j| j}||fS|jtjk(re|jdz|jdzz|jz}t j |j|j|j}||fS|j!|\}}||fS)N)NN ddaysi')rrrYearsyearrdateMonthsmonthcalendar monthrangeWeeks isocalendar timedeltadayDays_get_subday_cmpkey) r;rrr_lastdayisoyearisoweek isoweekdaysundays r,rz$TimeFrameAnalyzerBase._get_dt_cmpkeyis >>Y22 2 >>Y__ ,GGEMM"''2r2E(e|%^^y// /GGcMBHH,E!,,RWWbhh?JAw%%bggrxxAEe|^^y .+->>+; (GWjcMG+E(,,!j.AAF%%fkk6<<LEe|^^y~~ -GGeObhhn4rvv=E%%bggrxx@E e| 2226LE5e|r-c|jdz|jz}|jtjkr|dz|j z}|jtj kr|dz|jz}||jz}|dz }||jz}|jtjk(rt|d\}}d}d}n|jtj k(r!t|d\}}t|d\}}d}nJ|jtjk(r-t|d\}}t|d\}}t|d\}}d}dkDr |d z}|d z}tj|jtjk(|jtj k(|jtjk( } |r|tj| z }|j| } | | z} | } | | fS) N<g.ArigtAg8A)minutesseconds microsecondsr)hourminutesecond microsecond)rrrrMinutesrSecondsrrdivmod MicroSecondsrrreplace) r;rpointphpmpspuspsec extradaystadjustrrs r,rz(TimeFrameAnalyzerBase._get_subday_cmpkeys" ryy( >>I-- -BJ*E >>I-- -CK"..0E)))   !!! >>Y.. .E2&FBBC ^^y00 0E7+FBB^FBC ^^y55 5E=1FBb(+HBT3'GB 7bI "HB$$NNi&7&77NNi&7&779+A+AAC  ($$)4 4B 2bc J e|r-) r2r3r4paramsr_rBrXr[rrrrr5r6s@r,rr+s2F 4  89r-r) __future__rrrrr collectionsrrr~r} backtraderrrbacktrader.utils.py3r r MetaParamsr objectrr+rrrer-r,rsz***# 74"2==4"nE8~lF3E8PJ 2 2JSN+D+35Sr-