Tool: Кейтаро

Модуль agent/tools/keitaro.py — управление потоками в Кейтаро.

Методы

keitaro.create_flow

Создание нового потока.

Примеры фраз:

• «Залей поток на оффер 1234, гео Ру, вес 50»
• «Поставь поток» → бот спросит все параметры по очереди

keitaro.update_weight

Изменение веса существующего потока.

Примеры фраз:

• «Поменяй вес на оффере 1234, Ру, поставь 80»
• «Обнови вес потока»

keitaro.delete_flow

Удаление потока (вес ставится в 0).

Примеры фраз:

• «Удали поток на оффере 1234, гео UA»
• «Убери поток Ру с 5678»

keitaro.list_flows

Получение списка всех потоков на оффере.

Примеры фраз:

• «Какие потоки на оффере 1234?»
• «Что стоит на 5678?»

Подключение реального API

Сейчас все методы — заглушки. Для подключения реального Кейтаро:

1. Установите в .env:

KEITARO_API_URL=https://your-keitaro.com/api
KEITARO_API_KEY=your-api-key

2. В keitaro.py раскомментируйте httpx-вызовы и замените заглушки:

async def create_flow(offer_id, geo, weight, user_id="", channel_id=""):
    async with httpx.AsyncClient(timeout=15.0) as client:
        r = await client.post(
            f"{KEITARO_API_URL}/flows",
            headers={"Api-Key": KEITARO_API_KEY},
            json={"offer_id": offer_id, "geo": geo, "weight": weight}
        )
        r.raise_for_status()
        data = r.json()
        return f"✅ Поток создан! ID: {data['id']}"