send_message.py

import logging
import argparse
import threading

from utils import setup_logging
from telegram.client import Telegram

"""
Sends a message to a chat

Usage:
    python examples/send_message.py api_id api_hash phone chat_id text
"""


if __name__ == "__main__":
    setup_logging(level=logging.INFO)

    parser = argparse.ArgumentParser()
    parser.add_argument("api_id", help="API id")  # https://my.telegram.org/apps
    parser.add_argument("api_hash", help="API hash")
    parser.add_argument("phone", help="Phone")
    parser.add_argument("chat_id", help="Chat id", type=int)
    parser.add_argument("text", help="Message text")
    args = parser.parse_args()

    tg = Telegram(
        api_id=args.api_id,
        api_hash=args.api_hash,
        phone=args.phone,
        database_encryption_key="changeme1234",
    )
    # you must call login method before others
    tg.login()

    # if this is the first run, library needs to preload all chats
    # otherwise the message will not be sent
    get_chats_result = tg.get_chats()
    # `tdlib` is asynchronous, so `python-telegram` always returns you an `AsyncResult` object.
    # You can wait for a result with the blocking `wait` method.
    get_chats_result.wait()

    if get_chats_result.error:
        print(f"get chats error: {get_chats_result.error_info}")
    else:
        print(f"chats: {get_chats_result.update}")

    send_message_result = tg.send_message(
        chat_id=args.chat_id,
        text=args.text,
    )
    send_message_result.wait()

    if send_message_result.error:
        print(f"Failed to send the message: {send_message_result.error_info}")

    # When python-telegram sends a message to tdlib,
    # it does not send it immediately. When the message is sent, tdlib sends an updateMessageSendSucceeded event.

    message_has_been_sent = threading.Event()

    # The handler is called when the tdlib sends updateMessageSendSucceeded event
    def update_message_send_succeeded_handler(update):
        print(f"Received updateMessageSendSucceeded: {update}")
        # When we sent the message, it got a temporary id. The server assigns permanent id to the message
        # when it receives it, and tdlib sends the updateMessageSendSucceeded event with the new id.
        #
        # Check that this event is for the message we sent.
        if update["old_message_id"] == send_message_result.update["id"]:
            new_message_id = update["message"]["id"]
            print(f"Message has been sent. New message id: {new_message_id}")
            message_has_been_sent.set()

    # When the event is received, the handler is called.
    tg.add_update_handler("updateMessageSendSucceeded", update_message_send_succeeded_handler)

    # Wait for the message to be sent
    message_has_been_sent.wait(timeout=60)
    print("Message has been sent.")

    tg.stop()