TelegramSendTool

def __init__(self, *, api_id: str, api_hash: str, chat_id: str) -> None:
    """
    Initialize the TelegramSendTool.

    Args:
        api_id: Telegram API ID from https://my.telegram.org/apps.
        api_hash: Telegram API hash from https://my.telegram.org/apps.
        chat_id: The ID of the destination (Channel, Group, or User ID).
    """
    BaseTelegramTool.__init__(self, api_id, api_hash, "telegram_send_session")

    async def telegram_send_message(
        message: Annotated[str, "Message to send to the chat."],
        chat_id: Annotated[str, Depends(on(chat_id))],
    ) -> Any:
        """
        Sends a message to a Telegram chat.

        Args:
            message: The message to send.
            chat_id: The ID of the destination. (uses dependency injection)
        """
        try:
            client = self._get_client()
            async with client:
                # Initialize and cache the entity
                entity = await self._initialize_entity(client, chat_id)

                if len(message) > MAX_MESSAGE_LENGTH:
                    chunks = [
                        message[i : i + (MAX_MESSAGE_LENGTH - 1)]
                        for i in range(0, len(message), (MAX_MESSAGE_LENGTH - 1))
                    ]
                    first_message: Union[Message, None] = None  # type: ignore[no-any-unimported]

                    for i, chunk in enumerate(chunks):
                        sent = await client.send_message(
                            entity=entity,
                            message=chunk,
                            parse_mode="html",
                            reply_to=first_message.id if first_message else None,
                        )

                        # Store the first message to chain replies
                        if i == 0:
                            first_message = sent
                            sent_message_id = str(sent.id)

                    return (
                        f"Message sent successfully ({len(chunks)} chunks, first ID: {sent_message_id}):\n{message}"
                    )
                else:
                    sent = await client.send_message(entity=entity, message=message, parse_mode="html")
                    return f"Message sent successfully (ID: {sent.id}):\n{message}"

        except Exception as e:
            return f"Message send failed, exception: {str(e)}"

    Tool.__init__(
        self,
        name="telegram_send",
        description="Sends a message to a personal channel, bot channel, group, or channel.",
        func_or_tool=telegram_send_message,
    )