Агент автоответчик на электронные письма

Пользователь отправляет письмо → AgentInbox получает → агент обрабатывает → пользователь получает ответ
                         ↓
              "Привет Андрей, спасибо за письмо!
               Я получил сообщение и отвечу тебе
               в течение 24 часов..."

mkdir auto-reply-agent
cd auto-reply-agent

agentinbox
flask>=3.0.0
ngrok>=1.0.0
python-dotenv>=1.0.0

pip install -r requirements.txt

# Конфигурация AgentInbox
AGENTINBOX_API_KEY=your_agentinbox_api_key_here

# Конфигурация Ngrok
NGROK_AUTHTOKEN=your_ngrok_authtoken_here
WEBHOOK_DOMAIN=your-name.ngrok-free.app

# Параметры входящего ящика
INBOX_USERNAME=auto-reply

┌─────────────┐
│  Кто-то     │
│  отправляет │ ──────► ┌──────────────┐
│  письмо     │         │  AgentInbox  │
└─────────────┘         │   Inbox      │
                        └──────┬───────┘
                               │ Webhook
                               ▼
                        ┌──────────────┐
                        │   Ngrok      │
                        │   Tunnel     │
                        └──────┬───────┘
                               │
                               ▼
                        ┌──────────────┐
                        │  Ваш Flask   │
                        │    Server    │
                        └──────┬───────┘
                               │
                               ▼
                        ┌──────────────┐
                        │   Generate   │
                        │   & Send     │
                        │   Reply      │
                        └──────────────┘

import os
from dotenv import load_dotenv

# Загрузите переменные окружения СНАЧАЛА
load_dotenv()

from flask import Flask, request, Response
import ngrok
from agentinbox import AgentInbox

# Инициализируйте клиент AgentInbox
client = AgentInbox()  # Читает AGENTINBOX_API_KEY из окружения
app = Flask(__name__)

def setup_agentinbox():
    """Создайте входящий ящик и веб-хук с идемпотентностью."""

    # Создайте входящий ящик (или получите существующий)
    try:
        inbox = client.inboxes.create(
            username=INBOX_USERNAME,
            client_id=f"{INBOX_USERNAME}-inbox"  # ← Ключ идемпотентности
        )
        print(f"✓ Входящий ящик создан: {inbox.inbox_id}")
    except Exception as e:
        if "already exists" in str(e).lower():
            # Входящий ящик уже существует, это нормально!
            inbox_id = f"{INBOX_USERNAME}@agentmail.to"
            inbox = SimpleInbox(inbox_id)

    # Запустите туннель ngrok
    listener = ngrok.forward(PORT, domain=WEBHOOK_DOMAIN, authtoken_from_env=True)

    # Создайте веб-хук
    webhook = client.webhooks.create(
        url=f"{listener.url()}/webhook/agentmail",
        event_types=["message.received"],  # ← Подпишитесь только на входящие письма
        client_id=f"{INBOX_USERNAME}-webhook"  # ← Идемпотентность
    )

@app.route('/webhook/agentinbox', methods=['POST'])
def receive_webhook():
    """Конечная точка веб-хука для получения уведомлений о входящих письмах."""
    payload = request.json
    event_type = payload.get('type') or payload.get('event_type')

    # Игнорируйте исходящие сообщения (предотвращает бесконечные циклы!)
    if event_type == 'message.sent':
        return Response(status=200)

    message = payload.get('message', {})
    message_id = message.get('message_id')
    inbox_id = message.get('inbox_id')
    from_field = message.get('from_', '') or message.get('from', '')

    # Проверьте обязательные поля
    if not message_id or not inbox_id or not from_field:
        return Response(status=200)  # Gracefully пропустите неполные данные

{
  "type": "message.received",
  "message": {
    "message_id": "abc123...",
    "inbox_id": "auto-reply@agentinbox.ru",
    "from_": "John Doe <john@example.com>",
    "subject": "Hello",
    "text": "Email body content..."
  }
}

# Извлеките адрес электронной почты и имя отправителя
if '<' in from_field and '>' in from_field:
    # Формат: "John Doe <john@example.com>"
    sender_email = from_field.split('<')[1].split('>')[0].strip()
    sender_name = from_field.split('<')[0].strip()
    if not sender_name or ',' in sender_name:
        # Имя пусто или содержит запятую, используйте имя пользователя электронной почты
        sender_name = sender_email.split('@')[0].title()
else:
    # Формат: "john@example.com"
    sender_email = from_field.strip()
    sender_name = sender_email.split('@')[0].title()

def generate_reply(sender_name, subject):
    """Создайте сообщение автоответчика, используя шаблон."""
    return (
        f"Привет {sender_name},\n\n"
        f"Спасибо за ваше письмо! Я получил ваше сообщение и отвечу вам в течение 24 часов.\n\n"
        f"Если ваше дело срочно, пожалуйста, ответьте с \"СРОЧНО\" в строке темы.\n\n"
        f"С уважением,\n"
        f"Агент автоответчик"
    )

try:
    reply_text = generate_reply(sender_name, subject)
    client.inboxes.messages.reply(
        inbox_id=inbox_id,
        message_id=message_id,
        to=[sender_email],  # ← Должен быть список!
        text=reply_text
    )
    print(f"Автоответ отправлен на {sender_email}\n")
except Exception as e:
    print(f"Ошибка: {e}\n")

return Response(status=200)  # Всегда возвращайте 200 для подтверждения веб-хука

python agent.py

============================================================
AGENT АВТООТВЕТЧИКА НА ЭЛЕКТРОННЫЕ ПИСЬМА
============================================================

Настройка инфраструктуры AgentInbox...
✓ Входящий ящик создан: auto-reply@agentinbox.ru
✓ Веб-хук создан

✓ Настройка завершена!
  Входящий ящик: auto-reply@agentinbox.ru
  Веб-хук: https://your-name.ngrok-free.app/webhook/agentinbox

Агент готов!
Отправляйте письма на: auto-reply@agentinbox.ru
Режим ответа: на основе шаблона

Ожидание входящих писем...

 * Running on http://127.0.0.1:8080

   На: auto-reply@agentinbox.ru
   Тема: Тестирование моего агента автоответчика
   Текст: Привет! Это тестовое сообщение.

Email from youremail@gmail.com: Testing my auto-reply agent
Auto-reply sent to youremail@gmail.com

Привет Youremail,

Спасибо за ваше письмо! Я получил ваше сообщение и отвечу вам в течение 24 часов.

Если ваше дело срочно, пожалуйста, ответьте с "СРОЧНО" в строке темы.

С уважением,
Агент автоответчик

pip install openai

# Конфигурация ИИ
USE_AI_REPLY=true
OPENAI_API_KEY=sk-your_actual_openai_api_key_here

def get_thread_history(thread_id):
    """Получите историю беседы для потока."""
    try:
        thread = client.threads.get(thread_id=thread_id)
        return thread.messages if hasattr(thread, 'messages') else []
    except Exception as e:
        print(f"Failed to fetch thread history: {e}")
        return []


def format_thread_for_ai(messages):
    """Отформатируйте сообщения потока в историю беседы для ИИ."""
    conversation = []

    for msg in messages:
        if hasattr(msg, 'from_'):
            sender = msg.from_
            text = msg.text or msg.html or ""
        else:
            sender = msg.get('from_', '') or msg.get('from', '')
            text = msg.get('text', '') or msg.get('html', '') or msg.get('body', '')

        if '<' in sender and '>' in sender:
            sender = sender.split('<')[1].split('>')[0].strip()

        if text:
            conversation.append(f"From: {sender}\n{text}")

    return "\n\n---\n\n".join(reversed(conversation))


def generate_ai_reply(sender_name, email_body, subject, thread_history=""):
    """Создайте ответ на основе ИИ, используя OpenAI с контекстом потока."""
    try:
        context = f"Email thread history:\n\n{thread_history}\n\n---\n\nLatest message from {sender_name}:\nSubject: {subject}\n{email_body}" if thread_history else f"Subject: {subject}\nFrom: {sender_name}\n{email_body}"

        response = openai_client.chat.completions.create(
            model="gpt-4o-mini",
            messages=[
                {
                    "role": "system",
                    "content": "You are an intelligent email assistant. Read the email thread and respond in a helpful, contextual way. If this is a follow-up in a conversation, acknowledge what was previously discussed. If you can provide helpful information based on the context, do so. If the question requires detailed research or expertise you don't have, acknowledge receipt and set expectations. Be conversational, professional, and concise."
                },
                {
                    "role": "user",
                    "content": f"{context}\n\nGenerate a helpful reply that considers the conversation history. Keep it concise (2-4 sentences) but be actually helpful if you can address their question or continue the conversation meaningfully."
                }
            ],
            max_tokens=250,
            temperature=0.7
        )
        return response.choices[0].message.content
    except Exception as e:
        print(f"AI generation failed, using template: {e}")
        return generate_reply(sender_name, subject)

    subject = message.get('subject', '(нет темы)')
    thread_id = message.get('thread_id', '')  # Добавьте эту строку

    # Залогируйте входящее письмо
    print(f"Email from {sender_email}: {subject}")

    # Создайте и отправьте автоответ
    try:
        if USE_AI_REPLY:
            email_body = message.get('text', '') or message.get('body', '')

            # Получите историю потока для контекста
            thread_history = ""
            if thread_id:
                print(f"Fetching thread history for: {thread_id[:20]}...")
                messages = get_thread_history(thread_id)
                if messages:
                    thread_history = format_thread_for_ai(messages)
                    print(f"Found {len(messages)} messages in thread")

            reply_text = generate_ai_reply(sender_name, email_body, subject, thread_history)
            print("Using AI-generated reply with thread context")
        else:
            reply_text = generate_reply(sender_name, subject)
            print("Using template reply")

        client.inboxes.messages.reply(
            inbox_id=inbox_id,
            message_id=message_id,
            to=[sender_email],
            text=reply_text
        )
        print(f"Auto-reply sent to {sender_email}\n")
    except Exception as e:
        print(f"Error: {e}\n")