Send order purchase messages to telegram

boxoffice/messageclient.py

@@ -0,0 +1,26 @@
+import requests
+
+from baseframe import _
+
+from . import app, rq
+from .models import Order
+
+
+@rq.job('boxoffice')
+def send_telegram_message(order_id):
+    with app.test_request_context():
+        order = Order.query.get(order_id)
+        message_text = ""
+        for line_item in order.line_items:
+            message_text += _("{user} purchased {title}\n").format(
+                user=order.buyer_fullname, title=line_item.item.title
+            )
+        send_text = (
+            f'https://api.telegram.org/bot{app.config["TELEGRAM_APIKEY"]}/sendMessage'
+        )
+        params = {
+            'chat_id': app.config['TELEGRAM_CHATID'],
+            'message_thread_id': app.config.get['TELEGRAM_THREADID'],
+            'text': message_text,
+        }
+        requests.post(send_text, data=params, timeout=30)

boxoffice/views/order.py

@@ -24,6 +24,7 @@
     send_order_refund_mail,
     send_receipt_mail,
 )
+from ..messageclient import send_telegram_message
 from ..models import (
     CURRENCY,
     CURRENCY_SYMBOL,
@@ -438,6 +439,8 @@ def payment(order):
                 invoice_no=order.invoice_no,
             ),
         )
+        if app.config['TELEGRAM_APIKEY'] and app.config['TELEGRAM_CHATID']:
+            send_telegram_message.queue(order_id=order.id)
         return api_success(
             result={'invoice_id': invoice.id},
             doc=_("Payment verified"),

instance/settings-sample.py

@@ -40,3 +40,7 @@
 #: RQ settings
 RQ_REDIS_URL = 'redis://localhost:6379/0'
 RQ_SCHEDULER_INTERVAL = 1
+#: Telegram settings
+TELEGRAM_APIKEY = ''  # nosec
+TELEGRAM_CHATID = ''  # nosec
+TELEGRAM_THREADID = ''