a 9gZ@sddlmZddlZddlZddlZddlZddlmZmZmZm Z ddl m Z ddl m Z mZmZmZmZmZmZddlmZddlmZdd lmZdd lmZdd lmZmZdd lm Z m!Z!dd l"m#Z#ddl$m%Z%m&Z&ddl'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.ddl/m0Z0ddl1m2Z2m3Z3ddl4m5Z5m6Z6ddl7m8Z8ddl9m:Z:ddl;mZ>e3dddddZ?Gdd d e>Z@dS)!) annotationsN)CancelledErrorEventFutureLock)suppress)AnyAsyncGeneratorDictListOptionalSetUnion)loggers)Bot)TelegramAPIError)FSMContextMiddleware)BaseEventIsolation BaseStorage)DisabledEventIsolation MemoryStorage) FSMStrategy) GetUpdatesTelegramMethod) TelegramType)UpdateUser)UNSET UNSET_TYPE)UpdateTypeLookupError)Backoff BackoffConfig) UNHANDLED SkipHandler)TelegramEventObserver)ErrorsMiddleware)UserContextMiddleware)Routerg?g@g?g?)Z min_delayZ max_delayZfactorjitterc seZdZdZdejddddddddd d d d fd dZdd dddZdd d dddZdd dddZ d\ddddddZ e dddd Z e d!dd"d#Z e jd$d d%d&d#Z d'd(d d d)d*d+Zd'd,d d d)d-d.Zed/edfd'd0d1d2d3d4d5d6Zd(d d d7d8d9Zed'd:d d;dedfd'd0dd1d2d d dBdCdDZd'd(d d d)dEdFZd^d'dHdId dJdKdLdMZd ddNdOZdPd dQdRdSZdTd>eed>d>dUd'd0dd1dVddd d dW dXdYZdTd>eed>d>dUd'd0dd1dVddd d dW dZd[ZZS)_ Dispatcherz Root router NF)storage fsm_strategyevents_isolation disable_fsmnamezOptional[BaseStorage]rzOptional[BaseEventIsolation]boolz Optional[str]rNone)r,r-r.r/r0kwargsreturnc stt|j|d|r4t|ts4tdt|jt|dd|_ |j d<|j |j |j t||j tt|pt||ptd|_|s|j |j|j |jj||_t|_d|_d|_t|_dS)a Root router :param storage: Storage for FSM :param fsm_strategy: FSM strategy :param events_isolation: Events isolation :param disable_fsm: Disable FSM, note that if you disable FSM then you should not use storage and events isolation :param kwargs: Other arguments, will be passed as keyword arguments to handlers )r0z4FSM storage should be instance of 'BaseStorage' not update)routerZ event_name)r,Zstrategyr.N)superr+__init__ isinstancer TypeErrortype__name__r&r5Z observersregister_listen_updateZouter_middlewarer'r(rrrfsmshutdownclose workflow_datar _running_lock _stop_signal_stopped_signalset_handle_update_tasks)selfr,r-r.r/r0r3 __class__z/var/www/vosh/data/www/fastworkle.ru/webshop-tgbot-v.1.0/venv/lib/python3.9/site-packages/aiogram/dispatcher/dispatcher.pyr8&s0zDispatcher.__init__str)itemr4cCs |j|SNrB)rHrNrKrKrL __getitem__dszDispatcher.__getitem__)keyvaluer4cCs||j|<dSrOrP)rHrRrSrKrKrL __setitem__gszDispatcher.__setitem__)rRr4cCs |j|=dSrOrP)rHrRrKrKrL __delitem__jszDispatcher.__delitem__z Optional[Any])defaultrRr4cCs|j||SrO)rBget)rHrRrVrKrKrLrWmszDispatcher.getr)r4cCs|jjSrO)r?r,rHrKrKrLr,pszDispatcher.storagezOptional[Router]cCsdS)z} Dispatcher has no parent router and can't be included to any other routers or dispatchers :return: NrKrXrKrKrL parent_routertszDispatcher.parent_routerr))rSr4cCs tddS)z Dispatcher is root Router then configuring parent router is not allowed :param value: :return: z1Dispatcher can not be attached to another Router.N) RuntimeError)rHrSrKrKrLrY}srr)botr5r3r4c st}d}|}|j|kr4tj|d|id}z||j|jj |i|j |d|iIdH}|t u}|W|}||d} t j d|j|rdnd| |jSd| |jn8|}||d} t j d|j|rdnd| |j0dS) z Main entry point for incoming updates Response of this method can be used as Webhook response :param bot: :param update: Fr[contextNiz/Update id=%s is %s. Duration %d ms by bot id=%dhandledz not handled)asyncioget_running_looptimer[rmodel_validateZ model_dumpr5Zwrap_outer_middlewaretriggerrBr$reventinfo update_idid) rHr[r5r3loopr^ start_timeresponseZ finish_timedurationrKrKrL feed_updates^      zDispatcher.feed_updatezDict[str, Any]cs.tj|d|id}|jf||d|IdHS)z Main entry point for incoming updates with automatic Dict->Update serializer :param bot: :param update: :param kwargs: r[r\r[r5N)rrb_feed_webhook_update)rHr[r5r3Z parsed_updaterKrKrLfeed_raw_updateszDispatcher.feed_raw_updateintr"zOptional[List[str]]zAsyncGenerator[Update, None])r[polling_timeoutbackoff_configallowed_updatesr4c Cs t|d}t||d}i}|jjr6t|jj||d<d}z||fi|IdH} Wnpty} zXd}tjdt | j | tj d|j |j |j|IdHWYd} ~ q:WYd} ~ n d} ~ 00|rtjd |j |j|d}| D]} | V| jd |_qq:dS) z Endless updates reader with correctly handling any server-side or connection errors. So you may not worry that the polling will stop working. )config)timeoutrtrequest_timeoutFNTz Failed to fetch updates - %s: %szASleep for %f seconds and try again... (tryings = %d, bot id = %d)z2Connection established (tryings = %d, bot id = %d)r#)r!rsessionrvrq Exceptionr dispatchererrorr;r<warningZ next_delaycounterrgZasleepreresetrfoffset) clsr[rrrsrtbackoffZ get_updatesr3failedZupdateser5rKrKrL_listen_updatess<  "zDispatcher._listen_updates)r5r3r4c sz|j}|j}WnFtyV}z.td|jddtt|WYd}~n d}~00|j|d|j f||d|IdHS)a Main updates listener Workflow: - Detect content type and propagate to observers in current router - If no one filter is pass - propagate update to child routers as Update :param update: :param kwargs: :return: zDetected unknown update type. Seems like Telegram Bot API was updated and you have installed not latest version of aiogram framework Update: T)Z exclude_unsetN)Z event_update) update_typerd) Z event_typerdr warningswarnZmodel_dump_jsonRuntimeWarningr%r5Zpropagate_event)rHr5r3rrdrrKrKrLr>s    zDispatcher._listen_updatezTelegramMethod[Any])r[resultr4c sPz||IdHWn8tyJ}z tjd|jj|WYd}~n d}~00dS)zk Simulate answer into WebHook :param bot: :param result: :return: NzFailed to make answer: %s: %s)rrrdr{rJr<)rr[rrrKrKrLsilent_call_requests zDispatcher.silent_call_requestT)r[r5 call_answerr3r4c szF|j||fi|IdH}|r>t|tr>|j||dIdH|tuWSty}z*tjd|j |j |j j |WYd}~dSd}~00dS)aL Propagate update to event listeners :param bot: instance of Bot :param update: instance of Update :param call_answer: need to execute response as Telegram method (like answer into webhook) :param kwargs: contextual data for middlewares, filters and handlers :return: status Nr[r>Cause exception while process update id=%d by bot id=%d %s: %sT) rlr9rrr$ryrrd exceptionrfrgrJr<)rHr[r5rr3rjrrKrKrL_process_update(s  zDispatcher._process_update)r[rrhandle_as_tasksrsrtr3r4c s|IdH}tjd|j|j|jz|j||||d2zV3dHW}|jf||d|} |rt | } |j | | |j jq:| IdHq:6Wtjd|j|j|jntjd|j|j|j0dS)zg Internal polling process :param bot: :param kwargs: :return: Nz"Run polling for bot @%s id=%d - %r)rrrsrtrmz&Polling stopped for bot @%s id=%d - %r)merrzreusernamergZ full_namerrr_ create_taskrGaddadd_done_callbackdiscard) rHr[rrrrsrtr3userr5Z handle_updateZhandle_update_taskrKrKrL_pollingDs,   zDispatcher._pollingc sdz|j||fi|IdHWSty^}z*tjd|j|j|jj|WYd}~n d}~00dS)zg The same with `Dispatcher.process_update()` but returns real response instead of bool Nr) rlryrrdrrfrgrJr<)rHr[r5r3rrKrKrLrnkszDispatcher._feed_webhook_update7zUnion[Update, Dict[str, Any]]floatz&Optional[TelegramMethod[TelegramType]])r[r5_timeoutr3r4c s(t|tstj|did}t}t}|dddfdd }|||}t j f|d|} | j ||dd dd fd d } zzIdHWn&t y| || Yn0| r| } t| tr| W|Sn| || j | |dW|n |0dS) Nr[r\rr2)_r4cssddSrO)doneZ set_result)r)waiterrKrLrelease_waitersz6Dispatcher.feed_webhook_update..release_waiterrmz Future[Any])taskr4c sdtdtz |}Wn(ty@}z|WYd}~n d}~00t|tr`tj |ddS)NzDetected slow response into webhook. Telegram is waiting for response only first 60 seconds and then re-send update. For preventing this situation response into webhook returned immediately and handler is moved to background and still processing update.r) rrrrryr9rr_ ensure_futurer)rrr)r[rHrKrLprocess_responses  z8Dispatcher.feed_webhook_update..process_response)r9rrb contextvarsZ copy_contextr_r`Z create_futureZ call_laterrrnrrZremove_done_callbackcancelrrr) rHr[r5rr3ctxrhrZtimeout_handleZprocess_updatesrrjrK)r[rHrrLfeed_webhook_update{s:      zDispatcher.feed_webhook_updatecs@|jstd|jr|js"dS|j|jIdHdS)zd Execute this method if you want to stop polling programmatically :return: zPolling is not startedN)rClockedrZrDrErFwaitrXrKrKrL stop_pollings    zDispatcher.stop_pollingzsignal.Signals)sigr4cCs6|jsdStjd|j|js(dS|jdS)NzReceived %s signal)rCrrrzr|r0rDrF)rHrrKrKrL_signal_stop_pollings  zDispatcher._signal_stop_polling rrrrsrthandle_signalsclose_bot_sessionz&Optional[Union[List[str], UNSET_TYPE]]) botsrrrrsrtrrr3r4cs|s tdd|vrtdj4IdHjdur@t_jdurRt_turbjj|rt } t t 8| t jjt j| t jjt jWdn1s0Y|dj|dvrdjfd|diIdHtjdz$fdd |D} | tjtj| tjd IdH\} } | D]B} | t t| IdHWdn1s0Yqvtj| IdHWtjd zBjfd|diIdHW|r>tjd d |DIdHn"|rs z,Dispatcher.start_polling..)Z return_whenzPolling stoppedcss|]}|jVqdSrO)rxrArrKrKrL /z+Dispatcher.start_polling..) ValueErrorrCrDrrErZresolve_used_update_typesclearr_r`rNotImplementedErrorZadd_signal_handlersignalSIGTERMrSIGINTrBpopZ emit_startuprrzreappendrrZFIRST_COMPLETEDrrZgatherZ emit_shutdownrF)rHrrrrsrtrrrr3rhZtasksrpendingrrKrrL start_pollings|       "     .    zDispatcher.start_pollingc OsTtt8t|j|i|||||||dWdS1sF0YdS)a" Run many bots with polling :param bots: Bot instances (one or more) :param polling_timeout: Long-polling wait time :param handle_as_tasks: Run task for each event and no wait result :param backoff_config: backoff-retry config :param allowed_updates: List of the update types you want your bot to receive :param handle_signals: handle signals (SIGINT/SIGTERM) :param close_bot_session: close bot sessions on shutdown :param kwargs: contextual data :return: rN)rKeyboardInterruptr_runr) rHrrrrsrtrrrr3rKrKrL run_polling2s zDispatcher.run_polling)N)T)r) r< __module__ __qualname____doc__rZ USER_IN_CHATr8rQrTrUrWpropertyr,rYsetterrlro classmethodDEFAULT_BACKOFF_CONFIGrr>rrrrnrrrrrr __classcell__rKrKrIrLr+!sj"> - 9';  "ir+)A __future__rr_rrrrrrr contextlibrtypingrr r r r r rrZ client.botr exceptionsrZfsm.middlewarerZfsm.storage.baserrZfsm.storage.memoryrrZ fsm.strategyrmethodsrrZ methods.basertypesrrZ types.baserrZ types.updater Z utils.backoffr!r"Z event.basesr$r%Zevent.telegramr&Zmiddlewares.errorr'Zmiddlewares.user_contextr(r6r)rr+rKrKrKrLs6  $