{% extends "base.html" %}
{% from "_macros.html" import icon %}
{% from "_macros_ui.html" import loading %}
{% block title %}Агент — TG Agent{% endblock %}

{% block head_scripts %}
<script src="https://cdn.jsdelivr.net/npm/marked@12.0.2/marked.min.js" integrity="sha384-/TQbtLCAerC3jgaim+N78RZSDYV7ryeoBCVqTuzRrFec2akfBkHS7ACQ3PQhvMVi" crossorigin="anonymous"></script>
<script src="https://cdn.jsdelivr.net/npm/dompurify@3.2.4/dist/purify.min.js" integrity="sha384-eEu5CTj3qGvu9PdJuS+YlkNi7d2XxQROAFYOr59zgObtlcux1ae1Il3u7jvdCSWu" crossorigin="anonymous"></script>
<style>
.agent-layout {
    display: flex;
    gap: 1rem;
    height: calc(100vh - 220px);
    min-height: 400px;
}
.agent-sidebar {
    width: 240px;
    flex-shrink: 0;
    display: flex;
    flex-direction: column;
    gap: 0.5rem;
    overflow-y: auto;
    padding: 0.85rem;
    border: 1px solid var(--bs-border-color);
    border-radius: 8px;
    background: var(--bs-body-bg);
    box-shadow: 0 0.5rem 1rem rgba(15, 23, 42, 0.04);
}
.thread-item {
    display: flex;
    align-items: center;
    gap: 0.3rem;
    padding: 0.4rem 0.6rem;
    border-radius: 6px;
    border: 1px solid var(--bs-border-color);
    cursor: pointer;
    text-decoration: none;
    color: inherit;
    font-size: 0.9rem;
    background: transparent;
    transition: background 0.15s;
}
.thread-item:hover { background: var(--bs-tertiary-bg); color: inherit; }
.thread-item.active {
    background: var(--bs-primary);
    border-color: var(--bs-primary);
    color: #fff;
    font-weight: 600;
}
.thread-item .thread-title {
    flex: 1;
    overflow: hidden;
    text-overflow: ellipsis;
    white-space: nowrap;
}
.thread-delete-btn {
    background: none;
    border: none;
    cursor: pointer;
    padding: 0 2px;
    color: var(--bs-secondary-color);
    font-size: 0.8rem;
    line-height: 1;
    flex-shrink: 0;
    min-height: unset;
    width: auto;
}
.thread-delete-btn:hover { color: #dc3545; }

.agent-chat {
    flex: 1;
    display: flex;
    flex-direction: column;
    min-width: 0;
    min-height: 0;
    gap: 0.9rem;
}
.chat-status-panel {
    display: flex;
    flex-direction: column;
    gap: 0.7rem;
    padding: 1rem 1.1rem;
    border: 1px solid var(--bs-border-color);
    border-radius: 8px;
    background:
        linear-gradient(135deg, var(--bs-primary-bg-subtle), transparent 55%),
        var(--bs-body-bg);
    box-shadow: 0 0.5rem 1rem rgba(15, 23, 42, 0.05);
}
.chat-header {
    display: flex;
    justify-content: space-between;
    align-items: center;
    gap: 1rem;
    padding-bottom: 0.7rem;
    border-bottom: 1px solid var(--bs-border-color);
}
.chat-header-title {
    font-size: 1.45rem;
    font-weight: 600;
    line-height: 1.2;
    margin: 0;
}
.chat-header-badges {
    display: flex;
    flex-wrap: wrap;
    gap: 0.4rem;
    justify-content: flex-end;
}
.chat-runtime {
    display: flex;
    flex-wrap: wrap;
    gap: 0.5rem;
    align-items: center;
    font-size: 0.82rem;
}
.runtime-chip {
    display: inline-flex;
    align-items: center;
    gap: 0.35rem;
    padding: 0.28rem 0.55rem;
    border-radius: 999px;
    border: 1px solid var(--bs-border-color);
    background: var(--bs-body-bg);
    color: var(--bs-secondary-color);
    line-height: 1.1;
}
.runtime-chip code {
    font-size: 0.78rem;
    color: inherit;
}
.runtime-chip-on {
    border-color: var(--bs-success-border-subtle);
    background: var(--bs-success-bg-subtle);
    color: var(--bs-success-text-emphasis);
}
.runtime-chip-off {
    border-color: var(--bs-secondary-border-subtle);
    background: var(--bs-secondary-bg);
}
.runtime-chip-accent {
    border-color: var(--bs-warning-border-subtle);
    background: var(--bs-warning-bg-subtle);
    color: var(--bs-warning-text-emphasis);
}
.chat-stage {
    flex: 1;
    min-height: 0;
    display: flex;
    flex-direction: column;
    border: 1px solid var(--bs-border-color);
    border-radius: 8px;
    background: var(--bs-body-bg);
    box-shadow: 0 0.5rem 1rem rgba(15, 23, 42, 0.05);
    overflow: hidden;
}
.chat-messages {
    flex: 1;
    overflow-y: auto;
    display: flex;
    flex-direction: column;
    gap: 0.75rem;
    padding: 1.1rem 1rem 0.9rem 1rem;
    background:
        radial-gradient(circle at top right, rgba(13, 110, 253, 0.05), transparent 28%),
        var(--bs-body-bg);
}
.message-bubble {
    max-width: 85%;
    padding: 0.6rem 0.9rem;
    border-radius: 10px;
    font-size: 0.9rem;
    line-height: 1.5;
    word-break: break-word;
}
.message-user {
    white-space: pre-wrap;
    align-self: flex-end;
    background: var(--bs-primary);
    color: #fff;
    border-bottom-right-radius: 3px;
}
.message-assistant {
    align-self: flex-start;
    background: var(--bs-body-bg);
    border: 1px solid var(--bs-border-color);
    border-bottom-left-radius: 3px;
}
.message-assistant p:first-child { margin-top: 0; }
.message-assistant p:last-child { margin-bottom: 0; }
.message-assistant table {
    font-size: 0.8rem;
    border-collapse: collapse;
    margin: 0.5rem 0;
    width: 100%;
}
.message-assistant th,
.message-assistant td {
    border: 1px solid var(--bs-border-color);
    padding: 0.3rem 0.5rem;
}
.message-assistant pre {
    background: var(--bs-tertiary-bg);
    padding: 0.5rem;
    border-radius: 4px;
    overflow-x: auto;
    font-size: 0.8rem;
}
.message-assistant code { font-size: 0.8rem; }
.message-assistant h1 { font-size: 1.15rem; }
.message-assistant h2 { font-size: 1.05rem; }
.message-assistant h3 { font-size: 0.95rem; }
.message-assistant h4,
.message-assistant h5,
.message-assistant h6 { font-size: 0.9rem; }
.message-assistant h1,
.message-assistant h2,
.message-assistant h3,
.message-assistant h4,
.message-assistant h5,
.message-assistant h6 {
    margin: 0.5rem 0 0.25rem 0;
    line-height: 1.3;
}
.message-assistant hr {
    border: none;
    border-top: 1px solid var(--bs-border-color);
    margin: 0.75rem 0;
}
.message-error {
    align-self: flex-start;
    background: var(--bs-danger-bg-subtle);
    border: 1px solid var(--bs-danger-border-subtle);
    color: var(--bs-danger-text-emphasis);
    border-radius: 10px;
    padding: 0.6rem 0.9rem;
    font-size: 0.9rem;
    max-width: 85%;
}
.retry-btn {
    background: none;
    border: none;
    cursor: pointer;
    font-size: 1.2rem;
    margin-left: 10px;
    vertical-align: middle;
    padding: 0;
    line-height: 1;
    transition: transform 0.3s;
}
.retry-btn:hover {
    transform: rotate(180deg);
}
.typing-indicator {
    display: inline-block;
    color: var(--bs-secondary-color);
    font-style: italic;
}

.chat-composer {
    padding: 0.95rem 1rem 1rem 1rem;
    border-top: 1px solid var(--bs-border-color);
    display: flex;
    flex-direction: column;
    gap: 0.7rem;
    background: var(--bs-body-bg);
}
.chat-composer-meta {
    display: flex;
    justify-content: space-between;
    align-items: center;
    gap: 0.75rem;
    flex-wrap: wrap;
    min-height: 1.4rem;
}
.composer-caption {
    font-size: 0.78rem;
    color: var(--bs-secondary-color);
}
.composer-subtle {
    font-size: 0.78rem;
    color: var(--bs-secondary-color);
    text-align: right;
}
.chat-input-area {
    display: flex;
    gap: 0.75rem;
    align-items: stretch;
}
.chat-input-area textarea {
    flex: 1;
    resize: none;
    min-height: 110px;
    max-height: 180px;
    font-size: 0.9rem;
    padding: 0.9rem 1rem;
    border-radius: 8px;
}
.composer-actions {
    width: 230px;
    flex-shrink: 0;
    display: flex;
    flex-direction: column;
    gap: 0.55rem;
    justify-content: flex-end;
}
.chat-send-btn,
.model-select {
    width: 100%;
    min-width: 0;
    font-size: 0.9rem;
}
.chat-send-btn {
    min-height: 46px;
    border-radius: 8px;
    font-weight: 600;
}
.composer-hint {
    padding: 0.5rem 0.65rem;
    border-radius: 8px;
    border: 1px solid var(--bs-border-color);
    background: var(--bs-tertiary-bg);
    color: var(--bs-secondary-color);
    font-size: 0.8rem;
    line-height: 1.35;
}
.composer-hint strong {
    display: block;
    margin-bottom: 0.2rem;
    color: var(--bs-body-color);
}

.empty-state {
    display: flex;
    flex-direction: column;
    align-items: center;
    justify-content: center;
    height: 100%;
    color: var(--bs-secondary-color);
    gap: 1rem;
    text-align: center;
}

.agent-context {
    width: 220px;
    flex-shrink: 0;
    display: flex;
    flex-direction: column;
    gap: 0.6rem;
    padding: 0.85rem;
    font-size: 0.8rem;
    border: 1px solid var(--bs-border-color);
    border-radius: 8px;
    background: var(--bs-body-bg);
    box-shadow: 0 0.5rem 1rem rgba(15, 23, 42, 0.04);
}
.agent-context h3 {
    margin: 0 0 0.25rem 0;
    font-size: 0.8rem;
    color: var(--bs-secondary-color);
    text-transform: uppercase;
}
.agent-context label { margin-bottom: 0.1rem; }
.agent-context select,
.agent-context input[type=number] { margin-bottom: 0; font-size: 0.85rem; }
.message-context {
    max-width: 95%;
    align-self: stretch;
    background: var(--bs-tertiary-bg);
    border: 1px dashed var(--bs-border-color);
    border-radius: 6px;
    padding: 0.5rem 0.75rem;
    font-size: 0.8rem;
    color: var(--bs-secondary-color);
    white-space: pre-wrap;
    word-break: break-word;
}

@media (max-width: 991.98px) {
    .agent-sidebar {
        display: none;
    }
    .agent-context {
        display: none;
    }
    .agent-layout {
        height: calc(100vh - 180px);
    }
    .agent-chat {
        flex: 1;
    }
    .message-bubble {
        max-width: 95%;
    }
    .mobile-agent-toolbar {
        display: flex !important;
    }
}
@media (min-width: 992px) {
    .mobile-agent-toolbar {
        display: none !important;
    }
}
@media (max-width: 767.98px) {
    .agent-layout {
        height: auto;
        min-height: 0;
        gap: 0.6rem;
    }
    .chat-header {
        flex-direction: column;
        align-items: flex-start;
        gap: 0.45rem;
        padding-bottom: 0.45rem;
    }
    .chat-header-title {
        font-size: 1.25rem;
    }
    .chat-header-badges {
        justify-content: flex-start;
    }
    .chat-status-panel {
        padding: 0.65rem 0.8rem;
        border-radius: 8px;
    }
    .chat-stage {
        border-radius: 8px;
    }
    .chat-messages {
        flex: 0 1 auto;
        min-height: 185px;
        max-height: 28vh;
        padding: 0.8rem 0.75rem;
    }
    .empty-state {
        min-height: 150px;
    }
    .chat-composer {
        padding: 0.75rem;
        gap: 0.55rem;
    }
    .chat-input-area {
        flex-wrap: wrap;
        align-items: stretch;
        gap: 0.55rem;
    }
    .chat-input-area textarea {
        width: 100%;
        flex: 1 1 100%;
        min-height: 64px;
        max-height: 110px;
        padding: 0.7rem 0.8rem;
    }
    .composer-actions {
        width: 100%;
        gap: 0.45rem;
    }
    .chat-composer-meta {
        align-items: flex-start;
        gap: 0.35rem;
    }
    .composer-subtle {
        width: 100%;
        text-align: left;
    }
    .chat-send-btn {
        min-height: 42px;
    }
}

/* Permission request dialog */
#permission-modal {
    position: fixed;
    inset: 0;
    z-index: 2000;
    background: rgba(0,0,0,0.5);
    display: flex;
    align-items: flex-end;
    justify-content: center;
    padding-bottom: 1rem;
}
#permission-box {
    background: var(--bs-dark-bg-subtle, #1e1e2e);
    border: 1px solid var(--bs-primary);
    border-radius: 6px;
    padding: 1rem 1.5rem;
    min-width: 360px;
    max-width: 520px;
    font-family: var(--bs-font-monospace, monospace);
}
.perm-header { color: var(--bs-secondary-color); margin-bottom: 0.25rem; font-size: 0.85rem; }
.perm-tool { color: var(--bs-info); font-weight: 600; margin-bottom: 0.75rem; }
.perm-item {
    padding: 0.2rem 0;
    cursor: pointer;
    white-space: pre;
    color: var(--bs-body-color);
}
.perm-item.perm-selected { color: var(--bs-primary); }
.perm-hint { margin-top: 0.75rem; color: var(--bs-secondary-color); font-size: 0.8rem; }
.perm-error {
    margin-top: 0.75rem;
    color: var(--bs-danger-text-emphasis);
    font-size: 0.8rem;
    white-space: normal;
}

/* Tool call visibility */
.tool-status-line {
    display: flex;
    align-items: center;
    gap: 0.4rem;
    font-size: 0.82rem;
    color: var(--bs-secondary-color);
    font-style: italic;
    padding: 0.15rem 0;
    min-height: 1.4em;
}
.tool-status-line.tool-done { color: var(--bs-success-text-emphasis); font-style: normal; }

.tool-log { margin-top: 0.4rem; border-top: 1px dashed var(--bs-border-color); padding-top: 0.35rem; }
.tool-log summary {
    cursor: pointer;
    font-size: 0.78rem;
    color: var(--bs-secondary-color);
    user-select: none;
    list-style: none;
    display: flex;
    align-items: center;
    gap: 0.3rem;
}
.tool-log summary::before { content: "\25b6"; font-size: 0.65rem; transition: transform 0.15s; }
.tool-log[open] summary::before { transform: rotate(90deg); }
.tool-log-entry {
    font-size: 0.78rem;
    font-family: var(--bs-font-monospace);
    padding: 0.2rem 0.4rem;
    margin-top: 0.2rem;
    border-radius: 4px;
    background: var(--bs-tertiary-bg);
    border-left: 2px solid var(--bs-border-color);
    white-space: pre-wrap;
    word-break: break-all;
}
.tool-log-entry.tool-entry-running { border-left-color: var(--bs-warning); }
.tool-log-entry.tool-entry-done { border-left-color: var(--bs-success); }
.tool-log-entry.tool-entry-error { border-left-color: var(--bs-danger); }
</style>
{% endblock %}

{% block content %}
<h1>Агент</h1>

{% if agent_disabled_reason %}
<div class="alert alert-warning" role="alert">
    <strong>{{ agent_disabled_title }}</strong> {{ agent_disabled_reason }}
</div>
{% endif %}

<!-- Mobile toolbar -->
<div class="mobile-agent-toolbar gap-2 mb-2" style="display:none">
    <button class="btn btn-outline-secondary btn-sm" type="button" data-bs-toggle="offcanvas" data-bs-target="#sidebar-offcanvas">Треды</button>
    <button class="btn btn-outline-secondary btn-sm" type="button" data-bs-toggle="offcanvas" data-bs-target="#context-offcanvas">Контекст</button>
</div>

<!-- Offcanvas: sidebar -->
<div class="offcanvas offcanvas-start" tabindex="-1" id="sidebar-offcanvas">
    <div class="offcanvas-header">
        <h5 class="offcanvas-title">Треды</h5>
        <button type="button" class="btn-close" data-bs-dismiss="offcanvas"></button>
    </div>
    <div class="offcanvas-body d-flex flex-column gap-2">
        {# Thread list loads lazily via the threads fragment (OOB-swapped, #949). #}
        <div id="offcanvas-threads">
            {{ loading() }}
        </div>
        <form method="post" action="/agent/threads" style="margin-top:auto" data-busy>
            <button type="submit" class="btn btn-outline-primary btn-sm w-100">+ Новый тред</button>
        </form>
    </div>
</div>

<!-- Offcanvas: context -->
<div class="offcanvas offcanvas-end" tabindex="-1" id="context-offcanvas">
    <div class="offcanvas-header">
        <h5 class="offcanvas-title">Контекст</h5>
        <button type="button" class="btn-close" data-bs-dismiss="offcanvas"></button>
    </div>
    <div class="offcanvas-body d-flex flex-column gap-2">
        <label for="ctx-channel-m">Канал</label>
        <select id="ctx-channel-m" class="form-select form-select-sm">
            <option value="">— выберите —</option>
        </select>
        <label for="ctx-limit-m">Сообщений</label>
        <input type="number" id="ctx-limit-m" class="form-control form-control-sm" placeholder="все" min="1" max="10000">
        <button id="ctx-load-btn-m" class="btn btn-outline-primary btn-sm" {% if not active_thread %}disabled{% endif %}>
            Загрузить
        </button>
        <small id="ctx-status-m" class="text-muted"></small>
    </div>
</div>

<div class="agent-layout">
    <!-- Sidebar: thread list -->
    <div class="agent-sidebar">
        <h3 class="text-muted text-uppercase small">Треды</h3>

        {# Thread list + runtime status + composer footer load lazily here; the fragment
           also OOB-swaps the offcanvas list, runtime panel and composer footer (#949). #}
        <div id="sidebar-threads"
             hx-get="/agent/fragments/threads{{ '?thread_id=' ~ active_thread.id if active_thread else '' }}"
             hx-trigger="load"
             hx-swap="innerHTML">
            {{ loading() }}
        </div>

        <form method="post" action="/agent/threads" style="margin-top:auto" data-busy>
            <button type="submit" class="btn btn-outline-primary btn-sm w-100 mt-2">+ Новый тред</button>
        </form>
    </div>

    <!-- Main chat area -->
    <div class="agent-chat">
        {% if active_thread %}
        {# Runtime chips/badges depend on the lazily-probed backend; the threads
           fragment OOB-swaps this slot once it knows the runtime status (#949). #}
        <div class="chat-status-panel" id="chat-runtime-slot">
            <div class="chat-header">
                <div class="chat-header-title">{{ active_thread.title }}</div>
            </div>
        </div>

        <div class="chat-stage">
            <div class="chat-messages" id="chat-messages">
                {% for msg in messages %}
                {% if msg.role == 'assistant' %}
                <div class="message-bubble message-{{ msg.role }}" data-md>{{ msg.content }}</div>
                {% else %}
                <div class="message-bubble message-{{ msg.role }}">{{ msg.content }}</div>
                {% endif %}
                {% else %}
                <div class="empty-state">
                    <span style="font-size:2rem">{{ icon("ai") }}</span>
                    <p>Напишите первое сообщение</p>
                </div>
                {% endfor %}
            </div>

            <div class="chat-composer">
                <div class="chat-composer-meta">
                    <span class="composer-caption">Сообщение отправится в текущий тред.</span>
                    {# composer-subtle hint depends on the lazy backend; OOB-filled (#949). #}
                    <span id="composer-subtle-slot"></span>
                </div>
                <div class="chat-input-area">
                    <textarea id="chat-input" class="form-control"
                              placeholder="Введите сообщение… (Enter — отправить, Shift+Enter — перенос строки)"
                              ></textarea>
                    <div class="composer-actions">
                        {# Model select vs deepagents hint depends on the lazy backend; the
                           threads fragment OOB-swaps this slot (#949). #}
                        <span id="composer-actions-slot"></span>
                        <button class="btn btn-primary chat-send-btn" id="send-btn"
                                onclick="sendMessage()">Отправить</button>
                    </div>
                </div>
            </div>
        </div>
        {% endif %}
    </div>

    <!-- Right context panel -->
    <div class="agent-context" id="context-panel">
        <h3>Контекст</h3>
        <label for="ctx-channel">Канал</label>
        <select id="ctx-channel" class="form-select form-select-sm">
            <option value="">— выберите —</option>
        </select>
        <div id="ctx-topic-wrap" style="display:none">
            <label for="ctx-topic">Тема форума</label>
            <select id="ctx-topic" class="form-select form-select-sm">
                <option value="">Все темы</option>
            </select>
        </div>
        <label for="ctx-limit">Сообщений</label>
        <input type="number" id="ctx-limit" class="form-control form-control-sm" placeholder="все" min="1" max="10000">
        <button id="ctx-load-btn" class="btn btn-outline-primary btn-sm" {% if not active_thread %}disabled{% endif %}>
            Загрузить
        </button>
        <small id="ctx-status" class="text-muted"></small>
    </div>
</div>

<script>
(function() {
    var threadId = {{ active_thread.id if active_thread else 'null' }};
    var sending = false;
    var abortController = null;

    // Model selector: persist in localStorage. The <select> loads lazily via the
    // threads fragment (OOB swap, #949), so restore its saved value whenever it
    // (re)appears and delegate the change handler off the document.
    function restoreModelSelect() {
        var modelSelect = document.getElementById('model-select');
        if (modelSelect) modelSelect.value = localStorage.getItem('agent_model') || '';
    }
    // localStorage is the source of truth for the chosen model — read it (not the
    // possibly-not-yet-loaded <select>) at send time so a message sent before the
    // lazy composer fragment lands still carries the user's saved model (#949).
    function selectedModel() {
        var modelSelect = document.getElementById('model-select');
        if (modelSelect) return modelSelect.value || '';
        return localStorage.getItem('agent_model') || '';
    }
    restoreModelSelect();
    document.addEventListener('change', function(e) {
        if (e.target && e.target.id === 'model-select') {
            localStorage.setItem('agent_model', e.target.value);
        }
    });
    // Re-seed on ANY swap once the select is present. The select arrives via an
    // OOB swap into #composer-actions-slot (not the primary #sidebar-threads
    // target), and the base-layout #rename-badge polls on `every 60s`, so its
    // afterSwap keeps bubbling to document.body — gating on a specific target id
    // would couple correctness to HTMX's event order and miss the OOB insertion.
    // restoreModelSelect() is idempotent, self-guards on the element, and only
    // ever writes back the localStorage value the change-handler already persisted,
    // so a broad listener can't clobber an in-session pick (#949).
    document.body.addEventListener('htmx:afterSwap', restoreModelSelect);

    // Configure marked
    marked.setOptions({breaks: true, gfm: true});

    function renderMd(text) {
        var raw = marked.parse(text || '');
        // Markdown may contain raw HTML; sanitize before innerHTML to block XSS (issue #633).
        if (window.DOMPurify) return DOMPurify.sanitize(raw);
        // Fail closed: if the sanitizer is unavailable, render escaped plain text.
        return escapeHtml(text || '');
    }

    // Permission request dialog — menu style with keyboard shortcuts (1/2/3 + Enter)
    function escapeHtml(s) {
        var d = document.createElement('div');
        d.textContent = s;
        return d.innerHTML;
    }

    function showPermissionDialog(toolName, phone, errorMessage) {
        return new Promise(function(resolve) {
            document.querySelectorAll('#permission-modal').forEach(function(el) {
                if (el.parentNode) el.parentNode.removeChild(el);
            });
            var phoneStr = phone ? ' (' + escapeHtml(phone) + ')' : '';
            var errorHtml = errorMessage
                ? '<div class="perm-error">' + escapeHtml(errorMessage) + '</div>'
                : '';
            var modal = document.createElement('div');
            modal.id = 'permission-modal';
            modal.innerHTML =
                '<div id="permission-box">' +
                '<div class="perm-header">Агент хочет использовать:</div>' +
                '<div class="perm-tool">' + escapeHtml(toolName) + phoneStr + '</div>' +
                '<div class="perm-menu">' +
                '<div class="perm-item" data-choice="once" tabindex="0"><span class="perm-cursor">&gt;</span> 1. Разрешить один раз</div>' +
                '<div class="perm-item" data-choice="session" tabindex="0"><span class="perm-cursor"> </span> 2. Разрешить в этой сессии</div>' +
                '<div class="perm-item" data-choice="deny" tabindex="0"><span class="perm-cursor"> </span> 3. Запретить</div>' +
                '</div>' +
                errorHtml +
                '<div class="perm-hint">↑↓ навигация &nbsp;·&nbsp; Enter выбор &nbsp;·&nbsp; Esc = Запретить</div>' +
                '</div>';
            document.body.appendChild(modal);

            var items = modal.querySelectorAll('.perm-item');
            var selected = 0;
            var settled = false;

            function highlight() {
                items.forEach(function(el, i) {
                    el.querySelector('.perm-cursor').textContent = i === selected ? '>' : ' ';
                    el.classList.toggle('perm-selected', i === selected);
                });
            }

            function pick(choice) {
                if (settled) return;
                settled = true;
                if (modal.parentNode) modal.parentNode.removeChild(modal);
                document.removeEventListener('keydown', onKey, true);
                resolve(choice);
            }

            function consume(e) {
                e.preventDefault();
                e.stopPropagation();
                if (e.stopImmediatePropagation) e.stopImmediatePropagation();
            }

            function onKey(e) {
                var key = e.key || '';
                var code = e.code || '';
                if (key === 'ArrowUp' || key === 'k') {
                    selected = (selected + items.length - 1) % items.length;
                    highlight();
                    consume(e);
                } else if (key === 'ArrowDown' || key === 'j') {
                    selected = (selected + 1) % items.length;
                    highlight();
                    consume(e);
                } else if (key === 'Enter') {
                    pick(items[selected].dataset.choice);
                    consume(e);
                } else if (key === 'Escape') {
                    pick('deny');
                    consume(e);
                } else if (key === '1' || code === 'Digit1' || code === 'Numpad1') {
                    pick('once');
                    consume(e);
                } else if (key === '2' || code === 'Digit2' || code === 'Numpad2') {
                    pick('session');
                    consume(e);
                } else if (key === '3' || code === 'Digit3' || code === 'Numpad3') {
                    pick('deny');
                    consume(e);
                }
            }

            items.forEach(function(el, i) {
                el.addEventListener('click', function() { pick(el.dataset.choice); });
            });

            document.addEventListener('keydown', onKey, true);
            highlight();
        });
    }

    async function resolvePermissionRequest(requestId, choice) {
        console.info('Resolving permission request', requestId, choice);
        var permissionResp = await fetch('/agent/threads/' + threadId + '/permission/' + requestId, {
            method: 'POST',
            headers: {'Content-Type': 'application/json'},
            body: JSON.stringify({choice: choice})
        });
        var permissionResult = await permissionResp.json().catch(function() { return {}; });
        if (!permissionResp.ok || !permissionResult.ok) {
            var err = new Error(permissionResult.detail || ('Permission resolve failed: HTTP ' + permissionResp.status));
            err.status = permissionResp.status;
            throw err;
        }
    }

    // Render existing assistant messages loaded from DB
    document.querySelectorAll('[data-md]').forEach(function(el) {
        el.innerHTML = renderMd(el.textContent);
    });

    // Scroll to bottom on load
    var chatMessages = document.getElementById('chat-messages');
    if (chatMessages) {
        chatMessages.scrollTop = chatMessages.scrollHeight;
    }

    // Enter to send
    var input = document.getElementById('chat-input');
    if (input) {
        input.addEventListener('keydown', function(e) {
            if (e.key === 'Enter' && !e.shiftKey) {
                e.preventDefault();
                sendMessage();
            }
        });
    }

    function setStopMode(active) {
        var sendBtn = document.getElementById('send-btn');
        var inputEl = document.getElementById('chat-input');
        if (active) {
            sendBtn.textContent = 'Стоп';
            sendBtn.classList.remove('btn-primary');
            sendBtn.classList.add('btn-secondary');
            sendBtn.onclick = function() { stopGeneration(); };
            sendBtn.disabled = false;
            inputEl.disabled = true;
        } else {
            sendBtn.textContent = 'Отправить';
            sendBtn.classList.remove('btn-secondary');
            sendBtn.classList.add('btn-primary');
            sendBtn.onclick = function() { sendMessage(); };
            sendBtn.disabled = false;
            inputEl.disabled = false;
        }
    }

    window.stopGeneration = async function() {
        if (!sending || !threadId) return;
        var sendBtn = document.getElementById('send-btn');
        sendBtn.disabled = true;

        if (abortController) {
            abortController.abort();
            abortController = null;
        }

        try {
            await fetch('/agent/threads/' + threadId + '/stop', {method: 'POST'});
        } catch(e) { /* ignore */ }

        var container = document.getElementById('chat-messages');
        container.querySelectorAll('.message-bubble[data-pending]').forEach(function(el) {
            el.remove();
        });

        if (!container.querySelector('.message-bubble') && !container.querySelector('.message-context')) {
            var empty = document.createElement('div');
            empty.className = 'empty-state';
            empty.innerHTML = '<span style="font-size:2rem">{{ icon("ai") }}</span><p>Напишите первое сообщение</p>';
            container.appendChild(empty);
        }

        sending = false;
        setStopMode(false);
        document.getElementById('chat-input').focus();
    };

    function addRegenerateButton(bubble, text, removeUserBubble) {
        var btn = document.createElement('button');
        btn.className = 'retry-btn';
        btn.innerHTML = '{{ icon("refresh") }}';
        btn.title = 'Повторить';
        btn.onclick = function() {
            if (removeUserBubble) {
                var prev = bubble.previousElementSibling;
                if (prev && prev.classList.contains('message-user') && prev.textContent === text) {
                    prev.remove();
                }
            }
            bubble.remove();
            sendMessage(text);
        };
        bubble.appendChild(btn);
    }

    function createStatusTracker(bubble) {
        var statusEl = null;
        var logDetails = null;
        var logBody = null;
        var entryCount = 0;
        var currentEntryEl = null;
        var timerInterval = null;
        var timerStart = 0;
        var destroyed = false;

        function _clearTimer() {
            if (timerInterval) { clearInterval(timerInterval); timerInterval = null; }
        }
        function _ensureElements() {
            if (statusEl) return;
            statusEl = document.createElement('div');
            statusEl.className = 'tool-status-line';
            bubble.innerHTML = '';
            bubble.appendChild(statusEl);
            logDetails = document.createElement('details');
            logDetails.className = 'tool-log';
            var sum = document.createElement('summary');
            sum.textContent = 'Вызовы инструментов';
            logDetails.appendChild(sum);
            logBody = document.createElement('div');
            logDetails.appendChild(logBody);
            logDetails.style.display = 'none';
            bubble.appendChild(logDetails);
        }
        function _startTimer(labelFn) {
            _clearTimer();
            timerStart = Date.now();
            statusEl.textContent = labelFn('0.0');
            timerInterval = setInterval(function() {
                if (destroyed || !statusEl) { _clearTimer(); return; }
                var s = ((Date.now() - timerStart) / 1000).toFixed(1);
                statusEl.textContent = labelFn(s);
            }, 200);
        }

        return {
            start: function() {
                _ensureElements();
                _startTimer(function(s) { return '\u23f3 \u0414\u0443\u043c\u0430\u0435\u0442... (' + s + 's)'; });
            },
            onThinking: function() {
                if (destroyed) return;
                _ensureElements();
                _clearTimer();
                statusEl.textContent = '\ud83d\udcac \u0413\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u0442 \u043e\u0442\u0432\u0435\u0442...';
                statusEl.className = 'tool-status-line';
            },
            onToolStart: function(toolName) {
                if (destroyed) return;
                _ensureElements();
                entryCount++;
                logDetails.style.display = '';
                currentEntryEl = document.createElement('div');
                currentEntryEl.className = 'tool-log-entry tool-entry-running';
                currentEntryEl.textContent = '\ud83d\udd27 ' + toolName + ' ...';
                logBody.appendChild(currentEntryEl);
                _startTimer(function(s) { return '\ud83d\udd27 ' + toolName + '... (' + s + 's)'; });
            },
            onToolEnd: function(toolName, duration, isError, summary) {
                if (destroyed) return;
                _ensureElements();
                _clearTimer();
                var icon = isError ? '\u274c' : '\u2705';
                statusEl.textContent = '\ud83d\udd27 ' + toolName + ' ' + icon + ' (' + duration + 's)';
                statusEl.className = 'tool-status-line' + (isError ? '' : ' tool-done');
                if (currentEntryEl) {
                    currentEntryEl.className = 'tool-log-entry ' + (isError ? 'tool-entry-error' : 'tool-entry-done');
                    var txt = icon + ' ' + toolName + ' (' + duration + 's)';
                    if (summary) txt += ' \u2192 ' + summary;
                    currentEntryEl.textContent = txt;
                    currentEntryEl = null;
                }
            },
            onToolResult: function(toolName, isError, summary) {
                if (destroyed) return;
                if (!currentEntryEl && logBody) {
                    var entries = logBody.querySelectorAll('.tool-log-entry');
                    if (entries.length > 0) {
                        var last = entries[entries.length - 1];
                        if (summary) {
                            var resultLine = document.createElement('div');
                            resultLine.style.cssText = 'font-size:0.75rem;color:var(--bs-secondary-color);padding-left:0.4rem;margin-top:0.1rem;word-break:break-all;';
                            resultLine.textContent = (isError ? '\u274c ' : '\u2192 ') + summary;
                            last.appendChild(resultLine);
                        }
                    }
                }
            },
            onWarning: function(text) {
                if (destroyed) return;
                _ensureElements();
                logDetails.style.display = '';
                var warnLine = document.createElement('div');
                warnLine.className = 'tool-log-entry tool-entry-error';
                warnLine.textContent = '\u26a0\ufe0f ' + text;
                logBody.appendChild(warnLine);
            },
            onStatus: function(text) {
                if (destroyed) return;
                _ensureElements();
                _clearTimer();
                statusEl.textContent = '\u23f3 ' + text;
                statusEl.className = 'tool-status-line';
            },
            destroyStatusOnly: function() {
                destroyed = true;
                _clearTimer();
                if (statusEl && statusEl.parentNode) { statusEl.parentNode.removeChild(statusEl); statusEl = null; }
            },
            destroy: function() {
                destroyed = true;
                _clearTimer();
                if (statusEl && statusEl.parentNode) { statusEl.parentNode.removeChild(statusEl); statusEl = null; }
                if (logDetails && logDetails.parentNode && entryCount === 0) {
                    logDetails.parentNode.removeChild(logDetails);
                    logDetails = null;
                }
            },
            hasToolEntries: function() { return entryCount > 0; }
        };
    }

    window.sendMessage = async function(textToRetry) {
        if (sending || !threadId) return;
        var inputEl = document.getElementById('chat-input');
        var text = textToRetry || (inputEl.value || '').trim();
        if (!text) return;

        sending = true;
        if (!textToRetry) {
            inputEl.value = '';
        }
        setStopMode(true);

        abortController = new AbortController();

        var container = document.getElementById('chat-messages');

        var emptyState = container.querySelector('.empty-state');
        if (emptyState) emptyState.remove();

        var userBubble = document.createElement('div');
        userBubble.className = 'message-bubble message-user';
        userBubble.setAttribute('data-pending', 'true');
        userBubble.textContent = text;
        container.appendChild(userBubble);
        container.scrollTop = container.scrollHeight;

        var aiBubble = document.createElement('div');
        aiBubble.className = 'message-bubble message-assistant';
        aiBubble.setAttribute('data-pending', 'true');
        var statusTracker = createStatusTracker(aiBubble);
        statusTracker.start();
        container.appendChild(aiBubble);
        container.scrollTop = container.scrollHeight;

        try {
            var resp = await fetch('/agent/threads/' + threadId + '/chat', {
                method: 'POST',
                headers: {'Content-Type': 'application/json'},
                body: JSON.stringify({message: text, model: selectedModel()}),
                signal: abortController.signal
            });

            if (!resp.ok) {
                var errBody = await resp.json().catch(function() { return {}; });
                throw new Error(errBody.detail || 'HTTP ' + resp.status);
            }

            var reader = resp.body.getReader();
            var decoder = new TextDecoder();
            var buffer = '';
            var fullText = '';

            while (true) {
                var result = await reader.read();
                if (result.done) break;

                buffer += decoder.decode(result.value, {stream: true});
                var lines = buffer.split('\n');
                buffer = lines.pop();

                for (var line of lines) {
                    line = line.trim();
                    if (!line.startsWith('data:')) continue;
                    var jsonStr = line.slice(5).trim();
                    try {
                        var data = JSON.parse(jsonStr);
                        if (data.type === 'permission_request') {
                            var permissionError = '';
                            while (true) {
                                var choice = await showPermissionDialog(data.tool, data.phone || '', permissionError);
                                try {
                                    await resolvePermissionRequest(data.request_id, choice);
                                    break;
                                } catch (fetchErr) {
                                    console.error('Permission POST failed:', fetchErr);
                                    if (fetchErr.status && fetchErr.status < 500) {
                                        statusTracker.onWarning(
                                            'Запрос разрешения уже обработан или был отменён. Повторите действие, если нужно.'
                                        );
                                        break;
                                    }
                                    permissionError = 'Не удалось отправить выбор. Проверьте соединение и выберите ещё раз.';
                                    statusTracker.onWarning(permissionError);
                                }
                            }
                        } else if (data.type === 'thinking') {
                            statusTracker.onThinking();
                        } else if (data.type === 'tool_start') {
                            statusTracker.onToolStart(data.tool || 'tool');
                        } else if (data.type === 'tool_end') {
                            statusTracker.onToolEnd(data.tool || 'tool', data.duration || 0, !!data.is_error, data.summary || '');
                        } else if (data.type === 'tool_result') {
                            statusTracker.onToolResult(data.tool || 'tool', !!data.is_error, data.summary || '');
                        } else if (data.type === 'warning') {
                            statusTracker.onWarning(data.text || '');
                        } else if (data.type === 'status' || data.type === 'countdown') {
                            statusTracker.onStatus(data.text || '');
                        } else if (data.error) {
                            statusTracker.destroy();
                            aiBubble.className = 'message-error';
                            aiBubble.textContent = data.error;
                            fullText = data.error;
                            addRegenerateButton(aiBubble, text, true);
                        } else if (data.text !== undefined) {
                            var textNode = aiBubble.querySelector('.agent-text-content');
                            if (!textNode) {
                                textNode = document.createElement('div');
                                textNode.className = 'agent-text-content';
                                aiBubble.appendChild(textNode);
                            }
                            fullText += data.text;
                            textNode.innerHTML = renderMd(fullText);
                            container.scrollTop = container.scrollHeight;
                        } else if (data.done) {
                            fullText = data.full_text || fullText;
                            if (statusTracker.hasToolEntries()) {
                                statusTracker.destroyStatusOnly();
                                var textNode = aiBubble.querySelector('.agent-text-content');
                                if (!textNode) {
                                    textNode = document.createElement('div');
                                    textNode.className = 'agent-text-content';
                                    aiBubble.appendChild(textNode);
                                }
                                textNode.innerHTML = renderMd(fullText);
                            } else {
                                statusTracker.destroy();
                                aiBubble.innerHTML = renderMd(fullText);
                            }
                            // Persistence warning travels inside the done payload (#676/#729):
                            // appended AFTER fullText render so the innerHTML reset above can't
                            // wipe it, and not subject to the destroyed-tracker onWarning guard.
                            if (data.save_warning) {
                                var saveWarnEl = document.createElement('div');
                                saveWarnEl.className = 'alert alert-warning mt-2 mb-0 py-1 px-2 small';
                                saveWarnEl.textContent = data.save_warning;
                                aiBubble.appendChild(saveWarnEl);
                            }
                            container.scrollTop = container.scrollHeight;
                        }
                    } catch(e) { /* skip bad JSON */ }
                }
            }

            statusTracker.destroy();
            if (!fullText && !aiBubble.querySelector('.agent-text-content')) {
                aiBubble.textContent = 'Нет ответа от агента.';
            }

            userBubble.removeAttribute('data-pending');
            aiBubble.removeAttribute('data-pending');

        } catch(err) {
            statusTracker.destroy();
            if (err.name === 'AbortError') return;
            aiBubble.className = 'message-error';
            aiBubble.textContent = 'Ошибка соединения: ' + err.message;
        }

        sending = false;
        abortController = null;
        setStopMode(false);
        inputEl.focus();
        container.scrollTop = container.scrollHeight;
    };

    window.deleteThread = async function(e, tid) {
        e.preventDefault();
        e.stopPropagation();
        if (!(await window.TGConfirm.show('Удалить тред?'))) return;
        var btn = e.target.closest('button') || e.target;
        setAsyncButtonBusy(btn, true, '');
        try {
            await fetch('/agent/threads/' + tid, {method: 'DELETE'});
            window.location.href = '/agent';
        } catch(err) {
            setAsyncButtonBusy(btn, false);
            await window.TGConfirm.alert('Ошибка удаления: ' + err.message);
        }
    };

    // Context panel
    async function loadChannels() {
        try {
            var resp = await fetch('/agent/channels-json');
            var channels = await resp.json();
            var sel = document.getElementById('ctx-channel');
            channels.forEach(function(ch) {
                var opt = document.createElement('option');
                opt.value = ch.id;
                opt.dataset.type = ch.channel_type;
                opt.textContent = ch.title;
                sel.appendChild(opt);
            });
        } catch(e) {
            console.error('Failed to load channels:', e);
            document.getElementById('ctx-status').textContent = 'Ошибка загрузки каналов';
        }
    }

    var ctxChannel = document.getElementById('ctx-channel');
    if (ctxChannel) {
        ctxChannel.addEventListener('change', async function() {
            var opt = this.options[this.selectedIndex];
            var topicWrap = document.getElementById('ctx-topic-wrap');
            var topicSel = document.getElementById('ctx-topic');
            topicSel.innerHTML = '<option value="">Все темы</option>';
            if (opt && opt.value) {
                var knownType = opt.dataset.type;
                var shouldFetch = !knownType || knownType === 'null' || knownType === 'undefined'
                                  || knownType === 'forum';
                if (shouldFetch) {
                    try {
                        var resp = await fetch('/agent/forum-topics?channel_id=' + opt.value);
                        var topics = await resp.json();
                        if (topics.length > 0) {
                            topicWrap.style.display = '';
                            opt.dataset.type = 'forum';
                            topics.forEach(function(t) {
                                var o = document.createElement('option');
                                o.value = t.id;
                                o.textContent = t.title;
                                topicSel.appendChild(o);
                            });
                        } else if (knownType === 'forum') {
                            topicWrap.style.display = '';
                            var o = document.createElement('option');
                            o.value = '';
                            o.textContent = '(темы не загружены)';
                            o.disabled = true;
                            topicSel.appendChild(o);
                        } else {
                            topicWrap.style.display = 'none';
                        }
                    } catch(e) {
                        console.error('Failed to load topics:', e);
                        topicWrap.style.display = knownType === 'forum' ? '' : 'none';
                    }
                } else {
                    topicWrap.style.display = 'none';
                }
            } else {
                topicWrap.style.display = 'none';
            }
        });
    }

    var ctxLoadBtn = document.getElementById('ctx-load-btn');
    if (ctxLoadBtn) {
        ctxLoadBtn.addEventListener('click', async function() {
            if (!threadId) return;
            var channelId = document.getElementById('ctx-channel').value;
            if (!channelId) return;
            var limitVal = document.getElementById('ctx-limit').value.trim();
            var limit = limitVal ? parseInt(limitVal) : 0;
            var topicId = document.getElementById('ctx-topic').value || null;
            var status = document.getElementById('ctx-status');
            setAsyncButtonBusy(this, true, 'Загрузить');
            status.textContent = 'Загрузка…';
            var self = this;
            try {
                var resp = await fetch('/agent/threads/' + threadId + '/context', {
                    method: 'POST',
                    headers: {'Content-Type': 'application/json'},
                    body: JSON.stringify({channel_id: channelId, limit: limit, topic_id: topicId})
                });
                var data = await resp.json();
                var bubble = document.createElement('div');
                bubble.className = 'message-bubble message-context';
                bubble.textContent = data.content;
                var msgContainer = document.getElementById('chat-messages');
                if (msgContainer) {
                    var emptyState = msgContainer.querySelector('.empty-state');
                    if (emptyState) emptyState.remove();
                    msgContainer.appendChild(bubble);
                    msgContainer.scrollTop = msgContainer.scrollHeight;
                }
                status.innerHTML = 'Загружено {{ icon("success") }}';
            } catch(e) {
                status.textContent = 'Ошибка: ' + e.message;
            } finally {
                setAsyncButtonBusy(self, false);
            }
        });
    }

    loadChannels();
})();
</script>
{% endblock %}