added purchased paid media

Author: coder2020official

telebot/__init__.py

@@ -248,6 +248,7 @@ def __init__(
         self.business_message_handlers = []
         self.edited_business_message_handlers = []
         self.deleted_business_messages_handlers = []
+        self.purchased_paid_media_handlers = []
 
         self.custom_filters = {}
         self.state_handlers = []
@@ -724,6 +725,7 @@ def process_new_updates(self, updates: List[types.Update]):
         new_business_messages = None
         new_edited_business_messages = None
         new_deleted_business_messages = None
+        new_purchased_paid_media = None
 
         for update in updates:
             if apihelper.ENABLE_MIDDLEWARE and not self.use_class_middlewares:
@@ -805,8 +807,10 @@ def process_new_updates(self, updates: List[types.Update]):
             if update.deleted_business_messages:
                 if new_deleted_business_messages is None: new_deleted_business_messages = []
                 new_deleted_business_messages.append(update.deleted_business_messages)
-
-
+            if update.purchased_paid_media:
+                if new_purchased_paid_media is None: new_purchased_paid_media = []
+                new_purchased_paid_media.append(update.purchased_paid_media)
+                
         if new_messages:
             self.process_new_messages(new_messages)
         if new_edited_messages:
@@ -851,6 +855,8 @@ def process_new_updates(self, updates: List[types.Update]):
             self.process_new_edited_business_message(new_edited_business_messages)
         if new_deleted_business_messages:
             self.process_new_deleted_business_messages(new_deleted_business_messages)
+        if new_purchased_paid_media:
+            self.process_new_purchased_paid_media(new_purchased_paid_media)
 
     def process_new_messages(self, new_messages):
         """
@@ -987,8 +993,11 @@ def process_new_deleted_business_messages(self, new_deleted_business_messages):
         """
         self._notify_command_handlers(self.deleted_business_messages_handlers, new_deleted_business_messages, 'deleted_business_messages')
 
-
-
+    def process_new_purchased_paid_media(self, new_purchased_paid_media):
+        """
+        :meta private:
+        """
+        self._notify_command_handlers(self.purchased_paid_media_handlers, new_purchased_paid_media, 'purchased_paid_media')
 
     def process_middlewares(self, update):
         """
@@ -8035,6 +8044,55 @@ def register_pre_checkout_query_handler(self, callback: Callable, func: Callable
         handler_dict = self._build_handler_dict(callback, func=func, pass_bot=pass_bot, **kwargs)
         self.add_pre_checkout_query_handler(handler_dict)
 
+    def purchased_paid_media_handler(self, func=None, **kwargs):
+        """
+        Handles new incoming purchased paid media.
+
+        :param func: Function executed as a filter
+        :type func: :obj:`function`
+
+        :param kwargs: Optional keyword arguments(custom filters)
+
+        :return: None
+        """
+        def decorator(handler):
+            handler_dict = self._build_handler_dict(handler, func=func, **kwargs)
+            self.add_purchased_paid_media_handler(handler_dict)
+            return handler
+        
+        return decorator
+    
+    def add_purchased_paid_media_handler(self, handler_dict):
+        """
+        Adds a purchased paid media handler
+        Note that you should use register_purchased_paid_media_handler to add purchased_paid_media_handler to the bot.
+
+        :meta private:
+
+        :param handler_dict:
+        :return:
+        """
+        self.purchased_paid_media_handlers.append(handler_dict)
+
+    def register_purchased_paid_media_handler(self, callback: Callable, func: Callable, pass_bot: Optional[bool]=False, **kwargs):
+        """
+        Registers purchased paid media handler.
+
+        :param callback: function to be called
+        :type callback: :obj:`function`
+        
+        :param func: Function executed as a filter
+        :type func: :obj:`function`
+
+        :param pass_bot: True if you need to pass TeleBot instance to handler(useful for separating handlers into different files)
+        :type pass_bot: :obj:`bool`
+
+        :param kwargs: Optional keyword arguments(custom filters)
+
+        :return: None
+        """
+        handler_dict = self._build_handler_dict(callback, func=func, pass_bot=pass_bot, **kwargs)
+        self.add_purchased_paid_media_handler(handler_dict)
 
     def poll_handler(self, func, **kwargs):
         """

telebot/async_telebot.py

@@ -183,6 +183,7 @@ def __init__(self, token: str, parse_mode: Optional[str]=None, offset: Optional[
         self.business_message_handlers = []
         self.edited_business_message_handlers = []
         self.deleted_business_messages_handlers = []
+        self.purchased_paid_media_handlers = []
 
         self.custom_filters = {}
         self.state_handlers = []
@@ -636,6 +637,7 @@ async def process_new_updates(self, updates: List[types.Update]):
         new_business_messages = None
         new_edited_business_messages = None
         new_deleted_business_messages = None
+        new_purchased_paid_media = None
 
 
         for update in updates:
@@ -706,6 +708,9 @@ async def process_new_updates(self, updates: List[types.Update]):
             if update.deleted_business_messages:
                 if new_deleted_business_messages is None: new_deleted_business_messages = []
                 new_deleted_business_messages.append(update.deleted_business_messages)
+            if update.purchased_paid_media:
+                if new_purchased_paid_media is None: new_purchased_paid_media = []
+                new_purchased_paid_media.append(update.purchased_paid_media)
 
 
         if new_messages:
@@ -750,6 +755,8 @@ async def process_new_updates(self, updates: List[types.Update]):
             await self.process_new_edited_business_message(new_edited_business_messages)
         if new_deleted_business_messages:
             await self.process_new_deleted_business_messages(new_deleted_business_messages)
+        if new_purchased_paid_media:
+            await self.process_new_purchased_paid_media(new_purchased_paid_media)
 
     async def process_new_messages(self, new_messages):
         """
@@ -884,6 +891,12 @@ async def process_new_deleted_business_messages(self, new_deleted_business_messa
         """
         await self._process_updates(self.deleted_business_messages_handlers, new_deleted_business_messages, 'deleted_business_messages')
 
+    async def process_new_purchased_paid_media(self, new_purchased_paid_media):
+        """
+        :meta private:
+        """
+        await self._process_updates(self.purchased_paid_media_handlers, new_purchased_paid_media, 'purchased_paid_media')
+
     async def _get_middlewares(self, update_type):
         """
         :meta private:
@@ -1867,6 +1880,56 @@ def register_pre_checkout_query_handler(self, callback: Callable[[Any], Awaitabl
         handler_dict = self._build_handler_dict(callback, func=func, pass_bot=pass_bot, **kwargs)
         self.add_pre_checkout_query_handler(handler_dict)
 
+    def purchased_paid_media_handler(self, func=None, **kwargs):
+        """
+        Handles new incoming purchased paid media.
+
+        :param func: Function executed as a filter
+        :type func: :obj:`function`
+
+        :param kwargs: Optional keyword arguments(custom filters)
+
+        :return: None
+        """
+        def decorator(handler):
+            handler_dict = self._build_handler_dict(handler, func=func, **kwargs)
+            self.add_purchased_paid_media_handler(handler_dict)
+            return handler
+        
+        return decorator
+    
+    def add_purchased_paid_media_handler(self, handler_dict):
+        """
+        Adds a purchased paid media handler
+        Note that you should use register_purchased_paid_media_handler to add purchased_paid_media_handler to the bot.
+
+        :meta private:
+
+        :param handler_dict:
+        :return:
+        """
+        self.purchased_paid_media_handlers.append(handler_dict)
+
+    def register_purchased_paid_media_handler(self, callback: Callable, func: Callable, pass_bot: Optional[bool]=False, **kwargs):
+        """
+        Registers purchased paid media handler.
+
+        :param callback: function to be called
+        :type callback: :obj:`function`
+        
+        :param func: Function executed as a filter
+        :type func: :obj:`function`
+
+        :param pass_bot: True if you need to pass TeleBot instance to handler(useful for separating handlers into different files)
+        :type pass_bot: :obj:`bool`
+
+        :param kwargs: Optional keyword arguments(custom filters)
+
+        :return: None
+        """
+        handler_dict = self._build_handler_dict(callback, func=func, pass_bot=pass_bot, **kwargs)
+        self.add_purchased_paid_media_handler(handler_dict)
+
     def poll_handler(self, func, **kwargs):
         """
         Handles new state of a poll. Bots receive only updates about stopped polls and polls, which are sent by the bot

telebot/types.py

@@ -153,6 +153,9 @@ class Update(JsonDeserializable):
         checkout
     :type pre_checkout_query: :class:`telebot.types.PreCheckoutQuery`
 
+    :purchased_paid_media: Optional. A user purchased paid media with a non-empty payload sent by the bot in a non-channel chat
+    :type purchased_paid_media: :class:`telebot.types.PaidMediaPurchased`
+
     :param poll: Optional. New poll state. Bots receive only updates about stopped polls and polls, which are sent by the 
         bot
     :type poll: :class:`telebot.types.Poll`
@@ -222,18 +225,19 @@ def de_json(cls, json_string):
         business_message = Message.de_json(obj.get('business_message'))
         edited_business_message = Message.de_json(obj.get('edited_business_message'))
         deleted_business_messages = BusinessMessagesDeleted.de_json(obj.get('deleted_business_messages'))
+        purchased_paid_media = PaidMediaPurchased.de_json(obj.get('purchased_paid_media'))
 
         return cls(update_id, message, edited_message, channel_post, edited_channel_post, inline_query,
                    chosen_inline_result, callback_query, shipping_query, pre_checkout_query, poll, poll_answer,
                    my_chat_member, chat_member, chat_join_request, message_reaction, message_reaction_count,
                    removed_chat_boost, chat_boost, business_connection, business_message, edited_business_message,
-                   deleted_business_messages)
+                   deleted_business_messages, purchased_paid_media)
 
     def __init__(self, update_id, message, edited_message, channel_post, edited_channel_post, inline_query,
                  chosen_inline_result, callback_query, shipping_query, pre_checkout_query, poll, poll_answer,
                  my_chat_member, chat_member, chat_join_request, message_reaction, message_reaction_count,
                  removed_chat_boost, chat_boost, business_connection, business_message, edited_business_message,
-                 deleted_business_messages, **kwargs):
+                 deleted_business_messages, purchased_paid_media):
         self.update_id: int = update_id
         self.message: Optional[Message] = message
         self.edited_message: Optional[Message] = edited_message
@@ -257,6 +261,7 @@ def __init__(self, update_id, message, edited_message, channel_post, edited_chan
         self.business_message: Optional[Message] = business_message
         self.edited_business_message: Optional[Message] = edited_business_message
         self.deleted_business_messages: Optional[BusinessMessagesDeleted] = deleted_business_messages
+        self.purchased_paid_media: Optional[PaidMediaPurchased] = purchased_paid_media
 
 
 
@@ -10857,3 +10862,30 @@ def de_json(cls, json_string):
         return cls(**obj)
 
 
+class PaidMediaPurchased(JsonDeserializable):
+    """
+    This object contains information about a paid media purchase.
+
+    Telegram documentation: https://core.telegram.org/bots/api#paidmediapurchased
+
+    :param from_user: User who purchased the media
+    :type from_user: :class:`User`
+
+    :param paid_media_payload: Bot-specified paid media payload
+    :type paid_media_payload: :obj:`str`
+
+    :return: Instance of the class
+    :rtype: :class:`PaidMediaPurchased`
+    """
+
+    def __init__(self, from_user, paid_media_payload, **kwargs):
+        self.from_user: User = from_user
+        self.paid_media_payload: str = paid_media_payload
+
+    @classmethod
+    def de_json(cls, json_string):
+        if json_string is None: return None
+        obj = cls.check_json(json_string)
+        obj['from_user'] = User.de_json(obj['from_user'])
+        return cls(**obj)
+