
    i                     ~   d Z ddlZddlZddlZddlmZmZmZmZm	Z	m
Z
mZmZ 	 ddlZddlmZ ddlmZ dZn# e$ r dZY nw xY wddlmZ dd	lmZ dd
lmZ ddlmZ ddlmZmZ ererddlm Z! ddl"m#Z#  e$ e%d                    Z& ee'd          Z( G d dee                   Z) G d dee                   Z dS )z2This module contains the classes JobQueue and Job.    N)TYPE_CHECKINGAnyGenericOptionalTupleUnioncastoverload)AsyncIOExecutor)AsyncIOSchedulerTF)
get_logger)build_repr_with_selected_attrs)JSONDict)ExtBot)CCTJobCallback)Job)Application   JobQueue)
class_namec                   6   e Zd ZdZdZdZd2dZdefdZe	d3d	            Z
e	defd
            Zdej        fdZed4dddeddfd            Ze	 d4deeej        ej        ej        f         dedej        fd            Z	 d4deeej        ej        ej        df         dedeej                 fdZ	 	 	 	 d5dZed6d            Z	 	 	 	 	 d7dee         deeej        ej        ej        f         dee         dee         dee         dee         dee         ddfd Z	 	 	 	 	 	 	 d8dee         d!eeej        f         d"eeeej        ej        ej        f                  d#eeeej        ej        ej        f                  dee         dee         dee         dee         dee         ddfd$Z	 	 	 	 	 d7dee         dej        d%edee         dee         dee         dee         dee         ddfd&Z e!dddddfdee         dej        d'e"ed(f         dee         dee         dee         dee         dee         ddfd)Z#	 	 	 	 d9dee         dedee         dee         dee         dee         ddfd*Z$d2d+Z%d:d-eddfd.Z&de"d/         fd0Z'dede"d/         fd1Z(dS );r   a  This class allows you to periodically perform tasks with the bot. It is a convenience
    wrapper for the APScheduler library.

    This class is a :class:`~typing.Generic` class and accepts one type variable that specifies
    the type of the argument ``context`` of the job callbacks (:paramref:`~run_once.callback`) of
    :meth:`run_once` and the other scheduling methods.

    Important:
        If you want to use this class, you must install PTB with the optional requirement
        ``job-queue``, i.e.

        .. code-block:: bash

           pip install "python-telegram-bot[job-queue]"

    Examples:
        :any:`Timer Bot <examples.timerbot>`

    .. seealso:: :wiki:`Architecture Overview <Architecture>`,
        :wiki:`Job Queue <Extensions---JobQueue>`

    .. versionchanged:: 20.0
        To use this class, PTB must be installed via
        ``pip install "python-telegram-bot[job-queue]"``.

    Attributes:
        scheduler (:class:`apscheduler.schedulers.asyncio.AsyncIOScheduler`): The scheduler.

            Warning:
                This scheduler is configured by :meth:`set_application`. Additional configuration
                settings can be made by users. However, calling
                :meth:`~apscheduler.schedulers.base.BaseScheduler.configure` will delete any
                previous configuration settings. Therefore, please make sure to pass the values
                returned by :attr:`scheduler_configuration` to the method call in addition to your
                custom values.
                Alternatively, you can also use methods like
                :meth:`~apscheduler.schedulers.base.BaseScheduler.add_jobstore` to avoid using
                :meth:`~apscheduler.schedulers.base.BaseScheduler.configure` altogether.

            .. versionchanged:: 20.0
                Uses :class:`~apscheduler.schedulers.asyncio.AsyncIOScheduler` instead of
                :class:`~apscheduler.schedulers.background.BackgroundScheduler`

    )_application	_executor	scheduler)sunmontuewedthufrisatreturnNc                     t           st          d          d | _        t                      | _        t          di | j        | _        d S )Nz\To use `JobQueue`, PTB must be installed via `pip install "python-telegram-bot[job-queue]"`. )APS_AVAILABLERuntimeErrorr   r   r   r   scheduler_configurationr   selfs    \/var/www/html/crypto-bot/backend/venv/lib/python3.11/site-packages/telegram/ext/_jobqueue.py__init__zJobQueue.__init__d   sV     	5  
 KO(**-=-]-]@\-]-]    c                 .    t          | | j                  S )a$  Give a string representation of the JobQueue in the form ``JobQueue[application=...]``.

        As this class doesn't implement :meth:`object.__str__`, the default implementation
        will be used, which is equivalent to :meth:`__repr__`.

        Returns:
            :obj:`str`
        )application)r   r/   r)   s    r+   __repr__zJobQueue.__repr__o   s     .d@PQQQQr-   3Application[Any, CCT, Any, Any, Any, JobQueue[CCT]]c                 |    | j         t          d          |                                  }||S t          d          )z1The application this JobQueue is associated with.Nz)No application was set for this JobQueue.z,The application instance is no longer alive.)r   r'   r*   r/   s     r+   r/   zJobQueue.applicationz   sH     $JKKK''))"IJJJr-   c                     t           j        }| j        rRt          | j        j        t                    r3| j        j        j        r"| j        j        j        j        pt           j        }|d| j	        idS )a_  Provides configuration values that are used by :class:`JobQueue` for :attr:`scheduler`.

        Tip:
            Since calling
            :meth:`scheduler.configure() <apscheduler.schedulers.base.BaseScheduler.configure>`
            deletes any previous setting, please make sure to pass these values to the method call
            in addition to your custom values:

            .. code-block:: python

                scheduler.configure(..., **job_queue.scheduler_configuration)

            Alternatively, you can also use methods like
            :meth:`~apscheduler.schedulers.base.BaseScheduler.add_jobstore` to avoid using
            :meth:`~apscheduler.schedulers.base.BaseScheduler.configure` altogether.

        .. versionadded:: 20.7

        Returns:
            Dict[:obj:`str`, :obj:`object`]: The configuration values as dictionary.

        default)timezone	executors)
pytzutcr   
isinstancer/   botr   defaultstzinfor   )r*   r6   s     r+   r(   z JobQueue.scheduler_configuration   s|    0  8	H4+/88	H  $-	H
 '+4;GtxH !#T^4
 
 	
r-   c                 T    t           j                             | j        j                  S N)datetimenowr   r6   r)   s    r+   _tz_nowzJobQueue._tz_now   s     $$T^%<===r-   Ftime	shift_dayc                     d S r?   r%   r*   rC   rD   s      r+   _parse_time_inputzJobQueue._parse_time_input   s    NQcr-   c                     d S r?   r%   rF   s      r+   rG   zJobQueue._parse_time_input   s	    
  Cr-   c                    |d S t          |t          t          f          r*|                                 t	          j        |          z   S t          |t          j                  r|                                 |z   S t          |t          j                  rt          j                            t          j                            |j	        p| j
        j                                                  |          }|j	        | j
        j                            |          }|rE|t          j                            t          j                  k    r|t	          j        d          z  }|S |S )N)seconds)tz   )days)r:   intfloatrB   r@   	timedeltarC   combinerA   r=   r   r6   datelocalizer8   r9   )r*   rC   rD   	date_times       r+   rG   zJobQueue._parse_time_input   s7   
 <4dS%L)) 	E<<>>H$6t$D$D$DDDdH.// 	)<<>>D((dHM** 	 )11!%%)O8O%PPUUWWY] I ' N3<<YGG	 8Y(*;*?*?*I*IIIX/Q7777	r-   r/   c                 f    t          j        |          | _         | j        j        di | j         dS )zSet the application to be used by this JobQueue.

        Args:
            application (:class:`telegram.ext.Application`): The application.

        Nr%   )weakrefrefr   r   	configurer(   r3   s     r+   set_applicationzJobQueue.set_application   s:     $K44  @@4#?@@@@@r-   	job_queueJobQueue[CCT]jobJob[CCT]c                 J   K   |                     | j                   d{V  dS )a  This method is used as a callback for the APScheduler jobs.

        More precisely, the ``func`` argument of :class:`apscheduler.job.Job` is set to this method
        and the ``arg`` argument (representing positional arguments to ``func``) is set to a tuple
        containing the :class:`JobQueue` itself and the :class:`~telegram.ext.Job` instance.

        Tip:
            This method is a static method rather than a bound method. This makes the arguments
            more transparent and allows for easier handling of PTBs integration of APScheduler
            when utilizing advanced features of APScheduler.

        Hint:
            This method is effectively a wrapper for :meth:`telegram.ext.Job.run`.

        .. versionadded:: 20.4

        Args:
            job_queue (:class:`JobQueue`): The job queue that created the job.
            job (:class:`~telegram.ext.Job`): The job to run.
        N)runr/   )rZ   r\   s     r+   job_callbackzJobQueue.job_callback   s5      , ggi+,,,,,,,,,,,r-   callbackwhendatanamechat_iduser_id
job_kwargsc           	          |si }|p|j         }t          |||||          }|                     |d          }	 | j        j        | j        f|d|	| |f|	j        p| j        j        d|}
|
|_        |S )a  Creates a new :class:`Job` instance that runs once and adds it to the queue.

        Args:
            callback (:term:`coroutine function`): The callback function that should be executed by
                the new job. Callback signature::

                    async def callback(context: CallbackContext)

            when (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta` |                                           :obj:`datetime.datetime` | :obj:`datetime.time`):
                Time in or at which the job should run. This parameter will be interpreted
                depending on its type.

                * :obj:`int` or :obj:`float` will be interpreted as "seconds from now" in which the
                  job should run.
                * :obj:`datetime.timedelta` will be interpreted as "time from now" in which the
                  job should run.
                * :obj:`datetime.datetime` will be interpreted as a specific date and time at
                  which the job should run. If the timezone (:attr:`datetime.datetime.tzinfo`) is
                  :obj:`None`, the default timezone of the bot will be used, which is UTC unless
                  :attr:`telegram.ext.Defaults.tzinfo` is used.
                * :obj:`datetime.time` will be interpreted as a specific time of day at which the
                  job should run. This could be either today or, if the time has already passed,
                  tomorrow. If the timezone (:attr:`datetime.time.tzinfo`) is :obj:`None`, the
                  default timezone of the bot will be used, which is UTC unless
                  :attr:`telegram.ext.Defaults.tzinfo` is used.

            chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will
                be available in the callback.

                .. versionadded:: 20.0

            user_id (:obj:`int`, optional): User id of the user associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will
                be available in the callback.

                .. versionadded:: 20.0
            data (:obj:`object`, optional): Additional data needed for the callback function.
                Can be accessed through :attr:`Job.data` in the callback. Defaults to
                :obj:`None`.

                .. versionchanged:: 20.0
                    Renamed the parameter ``context`` to :paramref:`data`.
            name (:obj:`str`, optional): The name of the new job. Defaults to
                :external:attr:`callback.__name__ <definition.__name__>`.
            job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the
                :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`.

        Returns:
            :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job
            queue.

        ra   rc   rd   re   rf   T)rD   rR   )rd   triggerrun_dateargsr6   )	__name__r   rG   r   add_jobr`   r=   r6   _job)r*   ra   rb   rc   rd   re   rf   rg   r\   rT   js              r+   run_oncezJobQueue.run_once   s    @  	J(x(8$T7T[\\\**44*@@	"DN"
%@)@
 
 
 
 
r-   intervalfirstlastc
           
      z   |	si }	|p|j         }t          |||||          }
|                     |          }|                     |          }|r|r||k     rt          d          t	          |t
          j                  r|                                } | j        j	        | j
        fd| |
f||||d|	}||
_        |
S )a~  Creates a new :class:`Job` instance that runs at specified intervals and adds it to the
        queue.

        Note:
            For a note about DST, please see the documentation of `APScheduler`_.

        .. _`APScheduler`: https://apscheduler.readthedocs.io/en/stable/modules/triggers/cron.html
                           #daylight-saving-time-behavior

        Args:
            callback (:term:`coroutine function`): The callback function that should be executed by
                the new job. Callback signature::

                    async def callback(context: CallbackContext)

            interval (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta`): The interval in which
                the job will run. If it is an :obj:`int` or a :obj:`float`, it will be interpreted
                as seconds.
            first (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta` |                                           :obj:`datetime.datetime` | :obj:`datetime.time`, optional):
                Time in or at which the job should run. This parameter will be interpreted
                depending on its type.

                * :obj:`int` or :obj:`float` will be interpreted as "seconds from now" in which the
                  job should run.
                * :obj:`datetime.timedelta` will be interpreted as "time from now" in which the
                  job should run.
                * :obj:`datetime.datetime` will be interpreted as a specific date and time at
                  which the job should run. If the timezone (:attr:`datetime.datetime.tzinfo`) is
                  :obj:`None`, the default timezone of the bot will be used.
                * :obj:`datetime.time` will be interpreted as a specific time of day at which the
                  job should run. This could be either today or, if the time has already passed,
                  tomorrow. If the timezone (:attr:`datetime.time.tzinfo`) is :obj:`None`, the
                  default timezone of the bot will be used, which is UTC unless
                  :attr:`telegram.ext.Defaults.tzinfo` is used.

                Defaults to :paramref:`interval`

                Note:
                    Setting :paramref:`first` to ``0``, ``datetime.datetime.now()`` or another
                    value that indicates that the job should run immediately will not work due
                    to how the APScheduler library works. If you want to run a job immediately,
                    we recommend to use an approach along the lines of::

                        job = context.job_queue.run_repeating(callback, interval=5)
                        await job.run(context.application)

                    .. seealso:: :meth:`telegram.ext.Job.run`

            last (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta` |                                           :obj:`datetime.datetime` | :obj:`datetime.time`, optional):
                Latest possible time for the job to run. This parameter will be interpreted
                depending on its type. See :paramref:`first` for details.

                If :paramref:`last` is :obj:`datetime.datetime` or :obj:`datetime.time` type
                and ``last.tzinfo`` is :obj:`None`, the default timezone of the bot will be
                assumed, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used.

                Defaults to :obj:`None`.
            data (:obj:`object`, optional): Additional data needed for the callback function.
                Can be accessed through :attr:`Job.data` in the callback. Defaults to
                :obj:`None`.

                .. versionchanged:: 20.0
                    Renamed the parameter ``context`` to :paramref:`data`.
            name (:obj:`str`, optional): The name of the new job. Defaults to
                :external:attr:`callback.__name__ <definition.__name__>`.
            chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will
                be available in the callback.

                .. versionadded:: 20.0

            user_id (:obj:`int`, optional): User id of the user associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will
                be available in the callback.

                .. versionadded:: 20.0
            job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the
                :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`.

        Returns:
            :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job
            queue.

        ri   z"'last' must not be before 'first'!rr   )rj   rl   
start_dateend_daterJ   rd   )rm   r   rG   
ValueErrorr:   r@   rP   total_secondsr   rn   r`   ro   )r*   ra   rr   rs   rt   rc   rd   re   rf   rg   r\   dt_firstdt_lastrp   s                 r+   run_repeatingzJobQueue.run_repeatingD  s   D  	J(x(8$T7T[\\\))%00((.. 	Cx 	CGh$6$6ABBBh 233 	0--//H"DN"	
	
 	
 	
 	
 
r-   dayc	                     |si }|p|j         }t          |||||          }	 | j        j        | j        fd| |	f||dk    rdn||j        |j        |j        |j        p| j        j	        d|}
|
|	_
        |	S )a	  Creates a new :class:`Job` that runs on a monthly basis and adds it to the queue.

        .. versionchanged:: 20.0
            The ``day_is_strict`` argument was removed. Instead one can now pass ``-1`` to the
            :paramref:`day` parameter to have the job run on the last day of the month.

        Args:
            callback (:term:`coroutine function`): The callback function that should be executed by
                the new job. Callback signature::

                    async def callback(context: CallbackContext)

            when (:obj:`datetime.time`): Time of day at which the job should run. If the timezone
                (``when.tzinfo``) is :obj:`None`, the default timezone of the bot will be used,
                which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used.
            day (:obj:`int`): Defines the day of the month whereby the job would run. It should
                be within the range of ``1`` and ``31``, inclusive. If a month has fewer days than
                this number, the job will not run in this month. Passing ``-1`` leads to the job
                running on the last day of the month.
            data (:obj:`object`, optional): Additional data needed for the callback function.
                Can be accessed through :attr:`Job.data` in the callback. Defaults to
                :obj:`None`.

                .. versionchanged:: 20.0
                    Renamed the parameter ``context`` to :paramref:`data`.
            name (:obj:`str`, optional): The name of the new job. Defaults to
                :external:attr:`callback.__name__ <definition.__name__>`.
            chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will
                be available in the callback.

                .. versionadded:: 20.0

            user_id (:obj:`int`, optional): User id of the user associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will
                be available in the callback.

                .. versionadded:: 20.0
            job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the
                :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`.

        Returns:
            :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job
            queue.

        ri   cronrt   )rj   rl   rd   r}   hourminutesecondr6   )rm   r   r   rn   r`   r   r   r   r=   r6   ro   )r*   ra   rb   r}   rc   rd   re   rf   rg   r\   rp   s              r+   run_monthlyzJobQueue.run_monthly  s    r  	J(x(8$T7T[\\\"DN"
));;[;DN$;
 
 
 
 
r-   rM   .c	                     |si }|p|j         }t          |||||          }	  j        j         j        f| |	fdd                     fd|D                       |j        |j        |j        |j	        p j        j
        d|}
|
|	_        |	S )a	  Creates a new :class:`Job` that runs on a daily basis and adds it to the queue.

        Note:
            For a note about DST, please see the documentation of `APScheduler`_.

        .. _`APScheduler`: https://apscheduler.readthedocs.io/en/stable/modules/triggers/cron.html
                           #daylight-saving-time-behavior

        Args:
            callback (:term:`coroutine function`): The callback function that should be executed by
                the new job. Callback signature::

                    async def callback(context: CallbackContext)

            time (:obj:`datetime.time`): Time of day at which the job should run. If the timezone
                (:obj:`datetime.time.tzinfo`) is :obj:`None`, the default timezone of the bot will
                be used, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used.
            days (Tuple[:obj:`int`], optional): Defines on which days of the week the job should
                run (where ``0-6`` correspond to sunday - saturday). By default, the job will run
                every day.

                .. versionchanged:: 20.0
                    Changed day of the week mapping of 0-6 from monday-sunday to sunday-saturday.

            data (:obj:`object`, optional): Additional data needed for the callback function.
                Can be accessed through :attr:`Job.data` in the callback. Defaults to
                :obj:`None`.

                .. versionchanged:: 20.0
                    Renamed the parameter ``context`` to :paramref:`data`.
            name (:obj:`str`, optional): The name of the new job. Defaults to
                :external:attr:`callback.__name__ <definition.__name__>`.
            chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will
                be available in the callback.

                .. versionadded:: 20.0

            user_id (:obj:`int`, optional): User id of the user associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will
                be available in the callback.

                .. versionadded:: 20.0
            job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the
                :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`.

        Returns:
            :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job
            queue.

        ri   r   ,c                 *    g | ]}j         |         S r%   )_CRON_MAPPING).0dr*   s     r+   
<listcomp>z&JobQueue.run_daily.<locals>.<listcomp>Z  s!    !F!F!FA$"4Q"7!F!F!Fr-   )rd   rl   rj   day_of_weekr   r   r   r6   )rm   r   r   rn   r`   joinr   r   r   r=   r6   ro   )r*   ra   rC   rM   rc   rd   re   rf   rg   r\   rp   s   `          r+   	run_dailyzJobQueue.run_daily  s    |  	J(x(8$T7T[\\\"DN"
!F!F!F!F!F!F!FGG;;[;DN$;
 
 
 
 
r-   c                     |p|j         }t          |||||          } | j        j        | j        f| |f|d|}||_        |S )aL  Creates a new custom defined :class:`Job`.

        Args:
            callback (:term:`coroutine function`): The callback function that should be executed by
                the new job. Callback signature::

                    async def callback(context: CallbackContext)

            job_kwargs (:obj:`dict`): Arbitrary keyword arguments. Used as arguments for
                :meth:`apscheduler.schedulers.base.BaseScheduler.add_job`.
            data (:obj:`object`, optional): Additional data needed for the callback function.
                Can be accessed through :attr:`Job.data` in the callback. Defaults to
                :obj:`None`.

                .. versionchanged:: 20.0
                    Renamed the parameter ``context`` to :paramref:`data`.
            name (:obj:`str`, optional): The name of the new job. Defaults to
                :external:attr:`callback.__name__ <definition.__name__>`.
            chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will
                be available in the callback.

                .. versionadded:: 20.0

            user_id (:obj:`int`, optional): User id of the user associated with this job. If
                passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will
                be available in the callback.

                .. versionadded:: 20.0

        Returns:
            :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job
            queue.

        ri   )rl   rd   )rm   r   r   rn   r`   ro   )	r*   ra   rg   rc   rd   re   rf   r\   rp   s	            r+   
run_customzJobQueue.run_custome  sb    X (x(8$T7T[\\\"DN"4#4`D#;T``U_``
r-   c                 X   K   | j         j        s| j                                          dS dS )z+Starts the :class:`~telegram.ext.JobQueue`.N)r   runningstartr)   s    r+   r   zJobQueue.start  s9       ~% 	#N  """""	# 	#r-   Twaitc                    K   |r!t          j        | j        j        ddi d{V  | j        j        r7| j                            |           t          j        d           d{V  dS dS )zShuts down the :class:`~telegram.ext.JobQueue`.

        Args:
            wait (:obj:`bool`, optional): Whether to wait until all currently running jobs
                have finished. Defaults to :obj:`True`.

        return_exceptionsTN)r   g{Gz?)asynciogatherr   _pending_futuresr   r   shutdownsleep)r*   r   s     r+   stopzJobQueue.stop  s        	.0"&         >! 	&N###... -%%%%%%%%%%%		& 	&r-   )r]   .c                 b    t          d | j                                        D                       S )zReturns a tuple of all *scheduled* jobs that are currently in the :class:`JobQueue`.

        Returns:
            Tuple[:class:`Job`]: Tuple of all *scheduled* jobs.
        c              3   J   K   | ]}t                               |          V  d S r?   )r   from_aps_job)r   r\   s     r+   	<genexpr>z JobQueue.jobs.<locals>.<genexpr>  s0      PPsS%%c**PPPPPPr-   )tupler   get_jobsr)   s    r+   jobszJobQueue.jobs  s/     PPdn6M6M6O6OPPPPPPr-   c                 ^    t          fd|                                 D                       S )zReturns a tuple of all *pending/scheduled* jobs with the given name that are currently
        in the :class:`JobQueue`.

        Returns:
            Tuple[:class:`Job`]: Tuple of all *pending* or *scheduled* jobs matching the name.
        c              3   2   K   | ]}|j         k    |V  d S r?   rd   )r   r\   rd   s     r+   r   z,JobQueue.get_jobs_by_name.<locals>.<genexpr>  s/      DDS38t3C3CS3C3C3C3CDDr-   )r   r   )r*   rd   s    `r+   get_jobs_by_namezJobQueue.get_jobs_by_name  s0     DDDDDIIKKDDDDDDr-   r#   N)r#   r1   )Fr/   r1   r#   N)rZ   r[   r\   r]   r#   N)NNNNN)NNNNNNNNNNN)T))rm   
__module____qualname____doc__	__slots__r   r,   strr0   propertyr/   r   r(   r@   rB   r
   boolrG   r   rO   rP   rC   r   rY   staticmethodr`   r   r   objectrN   rq   r|   r   	_ALL_DAYSr   r   r   r   r   r   r   r%   r-   r+   r   r   3   s*       + +Z ;IEM	^ 	^ 	^ 	^	R# 	R 	R 	R 	R K K K XK "
 "
 "
 "
 X"
H>* > > > > QQdQtQQQQ XQ     E8-x/@(-OP    
		      X    E8-x/@(-QUUV  
(#	$	   ,
AP
A	
A 
A 
A 
A - - - \-6 "&"!%!%)-R Rc"R E8-x/@(-OPR v	R
 smR #R #R X&R 
R R R Rp _c]a!%"!%!%)-} }c"} x112} eX%79JHMYZ[	}
 uUH$68I8=XYZ} v} sm} #} #} X&} 
} } } }H "&"!%!%)-L Lc"L mL 	L
 vL smL #L #L X&L 
L L L Ld !*!%"!%!%)-R Rc"R mR CHo	R
 vR smR #R #R X&R 
R R R Rp "&"!%!%2 2c"2 2 v	2
 sm2 #2 #2 
2 2 2 2h# # # #& &t &t & & & &.QeO, Q Q Q QES EU?-C E E E E E Er-   c                      e Zd ZdZdZ	 	 	 	 d dee         dee         dee	         dee
         dee
         f
d	Zd
e	defdZdedefdZde
fdZde	fdZed!d            Zedefd            Zedefd            Zej        deddfd            Zedeej                 fd            Zed"d            Z	 	 	 	 d#dZ	 	 	 	 d#dZd$dZdS )%r   a
  This class is a convenience wrapper for the jobs held in a :class:`telegram.ext.JobQueue`.
    With the current backend APScheduler, :attr:`job` holds a :class:`apscheduler.job.Job`
    instance.

    Objects of this class are comparable in terms of equality. Two objects of this class are
    considered equal, if their :class:`id <apscheduler.job.Job>` is equal.

    This class is a :class:`~typing.Generic` class and accepts one type variable that specifies
    the type of the argument ``context`` of :paramref:`callback`.

    Important:
        If you want to use this class, you must install PTB with the optional requirement
        ``job-queue``, i.e.

        .. code-block:: bash

           pip install "python-telegram-bot[job-queue]"

    Note:
        All attributes and instance methods of :attr:`job` are also directly available as
        attributes/methods of the corresponding :class:`telegram.ext.Job` object.

    Warning:
        This class should not be instantiated manually.
        Use the methods of :class:`telegram.ext.JobQueue` to schedule jobs.

    .. seealso:: :wiki:`Job Queue <Extensions---JobQueue>`

    .. versionchanged:: 20.0

       * Removed argument and attribute ``job_queue``.
       * Renamed ``Job.context`` to :attr:`Job.data`.
       * Removed argument ``job``
       * To use this class, PTB must be installed via
         ``pip install "python-telegram-bot[job-queue]"``.

    Args:
        callback (:term:`coroutine function`): The callback function that should be executed by the
            new job. Callback signature::

                async def callback(context: CallbackContext)

        data (:obj:`object`, optional): Additional data needed for the :paramref:`callback`
            function. Can be accessed through :attr:`Job.data` in the callback. Defaults to
            :obj:`None`.
        name (:obj:`str`, optional): The name of the new job. Defaults to
            :external:obj:`callback.__name__ <definition.__name__>`.
        chat_id (:obj:`int`, optional): Chat id of the chat that this job is associated with.

            .. versionadded:: 20.0
        user_id (:obj:`int`, optional): User id of the user that this job is associated with.

            .. versionadded:: 20.0
    Attributes:
        callback (:term:`coroutine function`): The callback function that should be executed by the
            new job.
        data (:obj:`object`): Optional. Additional data needed for the :attr:`callback` function.
        name (:obj:`str`): Optional. The name of the new job.
        chat_id (:obj:`int`): Optional. Chat id of the chat that this job is associated with.

            .. versionadded:: 20.0
        user_id (:obj:`int`): Optional. User id of the user that this job is associated with.

            .. versionadded:: 20.0
    )_enabledro   _removedra   re   rc   rd   rf   Nra   rc   rd   re   rf   c                     t           st          d          || _        || _        |p|j        | _        || _        || _        d| _        d| _	        t          dd           | _        d S )NzWTo use `Job`, PTB must be installed via `pip install "python-telegram-bot[job-queue]"`.FAPSJob)r&   r'   ra   rc   rm   rd   re   rf   r   r   r	   ro   )r*   ra   rc   rd   re   rf   s         r+   r,   zJob.__init__  ss      	5  
 +3&*	#'#<8+<	&-&-4((			r-   itemr#   c                 z    	 t          | j        |          S # t          $ r}t          d| d          |d}~ww xY w)a  Overrides :py:meth:`object.__getattr__` to get specific attribute of the
        :class:`telegram.ext.Job` object or of its attribute :class:`apscheduler.job.Job`,
        if exists.

        Args:
           item (:obj:`str`): The name of the attribute.

        Returns:
            :object: The value of the attribute.

        Raises:
            :exc:`AttributeError`: If the attribute does not exist in both
                :class:`telegram.ext.Job` and :class:`apscheduler.job.Job` objects.
        zDNeither 'telegram.ext.Job' nor 'apscheduler.job.Job' has attribute ''N)getattrr\   AttributeError)r*   r   excs      r+   __getattr__zJob.__getattr__/  s\    	48T*** 	 	 	 ^W[^^^ 	s    
:5:otherc                 P    t          || j                  r| j        |j        k    S dS )aP  Defines equality condition for the :class:`telegram.ext.Job` object.
        Two objects of this class are considered to be equal if their
        :class:`id <apscheduler.job.Job>` are equal.

        Returns:
            :obj:`True` if both objects have :paramref:`id` parameters identical.
            :obj:`False` otherwise.
        F)r:   	__class__id)r*   r   s     r+   __eq__z
Job.__eq__E  s,     eT^,, 	'7eh&&ur-   c                 *    t          | j                  S )zBuilds a hash value for this object such that the hash of two objects is
        equal if and only if the objects are equal in terms of :meth:`__eq__`.

        Returns:
            :obj:`int`: The hash value of the object.
        )hashr   r)   s    r+   __hash__zJob.__hash__R  s     DG}}r-   c                 p    t          | | j        j        | j        | j        j        | j        j                  S )a>  Give a string representation of the job in the form
        ``Job[id=..., name=..., callback=..., trigger=...]``.

        As this class doesn't implement :meth:`object.__str__`, the default implementation
        will be used, which is equivalent to :meth:`__repr__`.

        Returns:
            :obj:`str`
        )r   rd   ra   rj   )r   r\   r   rd   ra   rm   rj   r)   s    r+   r0   zJob.__repr__[  s:     .x{]+H$
 
 
 	
r-   r   c                     | j         S )z:class:`apscheduler.job.Job`: The APS Job this job is a wrapper for.

        .. versionchanged:: 20.0
            This property is now read-only.
        )ro   r)   s    r+   r\   zJob.jobm  s     yr-   c                     | j         S )z3:obj:`bool`: Whether this job is due to be removed.)r   r)   s    r+   removedzJob.removedv       }r-   c                     | j         S )z):obj:`bool`: Whether this job is enabled.)r   r)   s    r+   enabledzJob.enabled{  r   r-   statusc                 ~    |r| j                                          n| j                                          || _        d S r?   )r\   resumepauser   )r*   r   s     r+   r   zJob.enabled  s<     	HOOHNNr-   c                     | j         j        S )a  
        :class:`datetime.datetime`: Datetime for the next job execution.
        Datetime is localized according to :attr:`datetime.datetime.tzinfo`.
        If job is removed or already ran it equals to :obj:`None`.

        Warning:
            This attribute is only available, if the :class:`telegram.ext.JobQueue` this job
            belongs to is already started. Otherwise APScheduler raises an :exc:`AttributeError`.
        )r\   next_run_timer)   s    r+   next_tz
Job.next_t  s     x%%r-   aps_jobr]   c                 .    |j         d         }||_        |S )a  Provides the :class:`telegram.ext.Job` that is associated with the given APScheduler
        job.

        Tip:
            This method can be useful when using advanced APScheduler features along with
            :class:`telegram.ext.JobQueue`.

        .. versionadded:: 20.4

        Args:
            aps_job (:class:`apscheduler.job.Job`): The APScheduler job

        Returns:
            :class:`telegram.ext.Job`
        rL   )rl   ro   )clsr   ext_jobs      r+   r   zJob.from_aps_job  s    " ,q/r-   r/   r1   c                 d   K   t          j        |                     |                     d{V  dS )a  Executes the callback function independently of the jobs schedule. Also calls
        :meth:`telegram.ext.Application.update_persistence`.

        .. versionchanged:: 20.0
            Calls :meth:`telegram.ext.Application.update_persistence`.

        Args:
            application (:class:`telegram.ext.Application`): The application this job is associated
                with.
        N)r   shield_runr3   s     r+   r_   zJob.run  s<       nTYY{3344444444444r-   c                 d  K   	 	 |j         j                            | |          }nP# t          $ rC}t                              d| j        |           Y d }~|                    |            d S d }~ww xY w|                                 d {V  | 	                    |           d {V  nS# t          $ rF}|
                    |                    d ||           d| j         d           d {V  Y d }~nd }~ww xY w|                    |            d S # |                    |            w xY w)NzEError while building CallbackContext for job %s. Job will not be run.)exc_info)r\   zJob:z:run:process_errorr   )context_typescontextfrom_job	Exception_LOGGERcriticalro   _mark_for_persistence_updaterefresh_datara   create_taskprocess_errorr   )r*   r/   r   r   s       r+   r   zJob._run  s     	?%3;DDT;WW     [I  !   
  444>>>>># &&(((((((((--(((((((((( 	 	 	))))$)>>7DG777 *              	 444>>>>>K444>>>>sO    & B, 
A3"A.B, .A338B, +D ,
C<6<C72D 7C<<D D/c                 F    | j                                          d| _        dS )z
        Schedules this job for removal from the :class:`JobQueue`. It will be removed without
        executing its callback function again.
        TN)r\   remover   r)   s    r+   schedule_removalzJob.schedule_removal  s!    
 	r-   r   )r#   r   )r   r   r#   r]   r   r   )rm   r   r   r   r   r   r   r   r   r   rN   r,   r   r   r   r   r0   r   r\   r   r   setterr@   r   classmethodr   r_   r   r   r%   r-   r+   r   r     sX       @ @D	I "&"!%!%) )c") v) sm	)
 #) #) ) ) )2     ,F t    #    
# 
 
 
 
$    X     X     X ^d t    ^ 
&!23 
& 
& 
& X
&    [(5P5	5 5 5 5 ?P?	? ? ? ?2     r-   r   )*r   r   r@   rV   typingr   r   r   r   r   r   r	   r
   r8   apscheduler.executors.asyncior   apscheduler.schedulers.asyncior   r&   ImportErrortelegram._utils.loggingr   telegram._utils.reprr   telegram._utils.typesr   telegram.ext._extbotr   telegram.ext._utils.typesr   r   apscheduler.jobr   r   telegram.extr   r   ranger   rm   r   r   r%   r-   r+   <module>r      s  & 9 8    V V V V V V V V V V V V V V V V V V V VKKK======??????MM   MMM / . . . . . ? ? ? ? ? ? * * * * * * ' ' ' ' ' ' 6 6 6 6 6 6 6 6 ) 2111111(((((( E%%((OO	
*X*
5
5
5R
E R
E R
E R
E R
Ews| R
E R
E R
EjQ Q Q Q Q'#, Q Q Q Q Qs   7 A A