Боты, которые отвечают за заведение

                bs.status = "sent"
                bs.sent_at = datetime.utcnow()
                sent_local += 1
            except Exception as exc:
                bs.status = "failed"
                bs.error = str(exc)[:500]

            sess.add(bs)
            # КОММИТ status ПОСЛЕ КАЖДОГО send (24.07 фикс дублей): раньше commit пачкой по 5 —
            # при БД-локе между send() и commit сообщение уходило в ВК, но status оставался
            # "pending" → сбой → retry слал ПОВТОРНО = дубль (спам, бан-риск).
            bc.sent_count = (bc.sent_count or 0) + sent_local
            sess.add(bc)
            _safe_commit(sess)

for i in range(tries):
    try:
        sess.commit()
        return
    except (_OpErr, _PendErr) as e:
        last = i >= tries - 1
        locked = "locked" in str(e).lower() or isinstance(e, _PendErr)
        if locked and not last:
            # ⚠️ Без rollback следующий commit падает сразу с PendingRollbackError:
            # транзакция уже помечена сломанной. Именно этого не хватало рассылкам.
            sess.rollback()
            _t.sleep(0.8 * (i + 1))
            continue
        raise

_AI_SYSTEM_BY_ORG = {"chili": _CHILI_AI_SYSTEM}

def _ai_system_for(org_id):
    return _AI_SYSTEM_BY_ORG.get(org_id, _AI_SYSTEM_PROMPT)

# Контекст: последние 5 сообщений (in/out) этого подписчика
prompt = (
    f"{_ai_system_for(getattr(subscriber, 'org_id', ''))}\n\n"
    f"История диалога:\n{history_str}\n\n"
    f"Последнее сообщение пользователя: {user_text}\n\n"
    f"Твой ответ:"
)

# Нормализация формата: и редактор /chatbots, и визуальный конструктор
# хранят кнопки ПЛОСКИМ списком [{...}], а тут ожидаются СТРОКИ [[{...}]].
# Плоский список → по одной кнопке в строку (вертикально).
if buttons and isinstance(buttons[0], dict):
    buttons = [[b] for b in buttons]

vk_rows: list[list[dict]] = []
for row in buttons:
    vk_row: list[dict] = []
    for btn in row:
        url = btn.get("url")