ecom-store/scripts/telegram_user_monitor.py

#!/usr/bin/env python3
"""
Monitora a conta de usuário do Telegram via Telethon.
Reenvia mensagens recebidas para o Hermes processar.
Mantém diálogo contínuo em /root/.hermes/telegram_user.session
"""
import asyncio
import logging
import os
import sys
from datetime import datetime

# Setup
API_ID = 35430577
API_HASH = "bf7926bd5830a1d2ebf502e538a0d816"
SESSION_FILE = "/root/.hermes/telegram_user.session"

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s [%(levelname)s] %(message)s",
    handlers=[
        logging.FileHandler("/root/.hermes/logs/telegram_user.log"),
        logging.StreamHandler(sys.stdout),
    ],
)
log = logging.getLogger("telegram_user")

# Pasta para salvar state
STATE_FILE = "/root/.hermes/telegram_user_state.json"


async def main():
    from telethon import TelegramClient

    client = TelegramClient(SESSION_FILE, API_ID, API_HASH)

    async with client:
        me = await client.get_me()
        log.info(f"=== Monitorando conta: {me.first_name} (@{me.username}) ===")
        log.info(f"User ID: {me.id}")
        log.info("Aguardando mensagens...")

        from telethon import events

        @client.on(events.NewMessage(incoming=True))
        async def handler(event):
            chat = await event.get_chat()
            sender = await event.get_sender()

            # Ignora bots (inclusive o @Hermes_M5 / @m5onBot)
            if getattr(sender, "bot", False):
                log.info(f"Ignorando mensagem de bot: {getattr(sender, 'username', 'sem username')}")
                return

            # Ignora mensagens enviadas por nós mesmos
            if event.out:
                return

            # Texto da mensagem
            if hasattr(event, "message") and event.message:
                text = event.message.text or event.message.message or ""
                if not text:
                    return
            else:
                text = str(event)[:100]

            timestamp = datetime.now().strftime("%d/%m %H:%M")
            chat_name = getattr(chat, "title", None) or getattr(chat, "first_name", "Desconhecido")
            sender_name = f"{getattr(sender, 'first_name', '')} {getattr(sender, 'last_name', '')}".strip()
            username = f"(@{sender.username})" if getattr(sender, "username", None) else ""

            log.info("")
            log.info(f"╔══════════════════════════════════════════════════════╗")
            log.info(f"║ {timestamp} | {chat_name}                           ║")
            log.info(f"║ De: {sender_name} {username}                       ║")
            log.info(f"╠══════════════════════════════════════════════════════╣")
            # Quebra texto em linhas de até 58 chars
            for i in range(0, len(text), 58):
                line = text[i : i + 58]
                log.info(f"║ {line:<58} ║")
            log.info(f"╚══════════════════════════════════════════════════════╝")
            log.info("")

            # SEM auto-resposta — só loga as mensagens
            # (auto-resposta desativada em 21/jun/2026)

        await client.run_until_disconnected()


if __name__ == "__main__":
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        log.info("Monitoramento interrompido.")