{% from "_macros.html" import filter_flags %}
{% from "_macros_ui.html" import empty_state %}
<h1>Очистка каналов</h1>

{% if pending_rename_count %}
<div class="alert alert-warning d-flex justify-content-between align-items-center mb-3">
    <span>
        <strong>{{ pending_rename_count }}</strong> канал(ов) переименовались и ждут вашего решения.
    </span>
    <a href="/channels/renames" class="btn btn-sm btn-warning">Разобрать</a>
</div>
{% endif %}

<div class="d-flex gap-2 flex-wrap mb-3">
    <button type="button" class="btn btn-primary btn-sm" onclick="refreshFilters(this)">Обновить фильтры</button>
    <form method="post" action="/channels/filter/precheck" class="d-inline" data-busy>
        <button type="submit" class="btn btn-outline-primary btn-sm">Предпроверка подписчиков</button>
    </form>
    <form method="post" action="/channels/filter/reset" class="d-inline" data-busy>
        <button type="submit" class="btn btn-outline-secondary btn-sm">Сброс фильтров</button>
    </form>
    {% if channels %}
    <form method="post" action="/channels/filter/purge-all" class="d-inline" data-busy
          data-confirm="Очистить сообщения у ВСЕХ {{ total }} отфильтрованных каналов?">
        <button type="submit" class="btn btn-warning btn-sm">Очистить все сообщения</button>
    </form>
    {% if dev_mode %}
    <form method="post" action="/channels/filter/hard-delete-all"
          class="d-inline-flex align-items-center gap-2" data-busy>
        <input type="text" name="confirm" required autocomplete="off" spellcheck="false"
               placeholder="Введите DELETE_ALL_FILTERED" class="form-control form-control-sm"
               style="width: 14rem;"
               aria-label="Подтверждение удаления">
        <input type="hidden" name="confirm_pks"
               value="{% for ch in channels %}{% if ch.id is not none and ch.channel_id is not none %}{{ ch.id }}:{{ ch.channel_id }}{% if not loop.last %},{% endif %}{% endif %}{% endfor %}">
        <button type="submit" class="btn btn-danger btn-sm">Удалить все {{ total }} из БД</button>
    </form>
    {% endif %}
    {% endif %}
</div>

{% if channels %}
<p>Отфильтровано: <strong>{{ total }}</strong> каналов из {{ total_channels }}</p>

<div class="table-responsive">
<table class="tga-table-striped">
    <thead>
        <tr>
            <th><input type="checkbox" id="select-all" class="form-check-input"></th>
            <th>Название</th>
            <th class="d-none d-sm-table-cell">Username</th>
            <th class="d-none d-sm-table-cell">Сообщений</th>
            <th>Причины</th>
        </tr>
    </thead>
    <tbody>
        {% for ch in channels %}
        <tr class="table-danger">
            <td>
                {% if ch.id is not none %}
                <input type="checkbox" value="{{ ch.id }}" class="form-check-input ch-check">
                {% endif %}
            </td>
            <td>{{ ch.title or "-" }}</td>
            <td class="d-none d-sm-table-cell">{% if ch.username %}@{{ ch.username }}{% else %}-{% endif %}</td>
            <td class="d-none d-sm-table-cell">{{ ch.message_count }}</td>
            <td>
                {{ filter_flags(ch.filter_flags, margin='margin-right:0.25rem;') }}
            </td>
        </tr>
        {% endfor %}
    </tbody>
</table>
</div>

<div class="d-flex gap-2 flex-wrap">
    <form method="post" action="/channels/filter/purge-selected" id="purge-form" class="d-inline" data-busy>
        <button type="submit" class="btn btn-warning action-btn" disabled>
            Очистить сообщения (<span class="selected-count">0</span>)
        </button>
    </form>
    <form method="post" action="/channels/filter/reset-selected" id="reset-selected-form" class="d-inline" data-busy>
        <button type="submit" class="btn btn-outline-secondary action-btn" disabled>
            Сбросить выбранные (<span class="selected-count">0</span>)
        </button>
    </form>
    {% if dev_mode %}
    <form method="post" action="/channels/filter/hard-delete-selected" id="hard-delete-form" class="d-inline" data-busy>
        <button type="submit" class="btn btn-danger action-btn" disabled>
            Удалить из БД (<span class="selected-count">0</span>)
        </button>
    </form>
    {% endif %}
</div>
{% else %}
{{ empty_state('Нет отфильтрованных каналов. Нажмите "Обновить фильтры" для анализа.') }}
{% endif %}

<script>
(function() {
    var selectAll = document.getElementById('select-all');
    if (!selectAll) return;

    var checkboxes = document.querySelectorAll('.ch-check');
    var countSpans = document.querySelectorAll('.selected-count');
    var actionBtns = document.querySelectorAll('.action-btn');

    function getCheckedPks() {
        var pks = [];
        checkboxes.forEach(function(cb) { if (cb.checked) pks.push(cb.value); });
        return pks;
    }

    function syncHiddenInputs() {
        document.querySelectorAll('.synced-pk').forEach(function(el) { el.remove(); });
        var pks = getCheckedPks();
        document.querySelectorAll('#purge-form, #hard-delete-form, #reset-selected-form').forEach(function(form) {
            pks.forEach(function(pk) {
                var input = document.createElement('input');
                input.type = 'hidden';
                input.name = 'pks';
                input.value = pk;
                input.className = 'synced-pk';
                form.appendChild(input);
            });
        });
    }

    function updateCount() {
        var checked = getCheckedPks().length;
        countSpans.forEach(function(s) { s.textContent = checked; });
        actionBtns.forEach(function(b) { b.disabled = checked === 0; });
        syncHiddenInputs();
    }

    selectAll.addEventListener('change', function() {
        checkboxes.forEach(function(cb) { cb.checked = selectAll.checked; });
        updateCount();
    });
    checkboxes.forEach(function(cb) {
        cb.addEventListener('change', updateCount);
    });

    // Dynamic confirm for purge / hard-delete (count computed at submit time).
    function attachDynamicConfirm(formId, messageFn) {
        var form = document.getElementById(formId);
        if (!form) return;
        form.addEventListener('submit', async function(e) {
            if (form._confirming || form._confirmPending) return;
            e.preventDefault();
            var count = document.querySelectorAll('.ch-check:checked').length;
            if (count === 0) return;
            form._confirmPending = true;
            try {
                var ok = await window.TGConfirm.show(messageFn(count));
                if (ok) {
                    form._confirming = true;
                    try {
                        if (typeof form.requestSubmit === 'function') form.requestSubmit();
                        else form.submit();
                    } finally {
                        delete form._confirming;
                    }
                }
            } finally {
                delete form._confirmPending;
            }
        }, true);
    }
    attachDynamicConfirm('purge-form', function(n) {
        return 'Очистить сообщения у ' + n + ' канал(ов)? Каналы останутся в базе.';
    });
    attachDynamicConfirm('hard-delete-form', function(n) {
        return 'ПОЛНОСТЬЮ удалить ' + n + ' канал(ов) из базы данных? Это действие необратимо.';
    });
    attachDynamicConfirm('reset-selected-form', function(n) {
        return 'Сбросить флаг отфильтрованности у ' + n + ' канал(ов)?';
    });
})();

async function refreshFilters(button) {
    setAsyncButtonBusy(button, true, 'Обновляю...');
    try {
        var resp = await fetch('/channels/filter/has-stats');
        if (!resp.ok) throw new Error('stats probe failed');

        var data = await resp.json();
        var actionUrl = '/channels/filter/analyze';
        var queueStatsOnly = false;
        if (!data.has_stats) {
            var ok = await window.TGConfirm.show('У некоторых каналов нет статистики. Сейчас запустится только сбор статистики. После завершения вернитесь и снова нажмите "Обновить фильтры". Продолжить?');
            if (!ok) {
                setAsyncButtonBusy(button, false);
                return;
            }
            actionUrl = '/channels/stats/all';
            queueStatsOnly = true;
        }

        var actionResp = await fetch(actionUrl, {method: 'POST'});
        if (!actionResp.ok) throw new Error('refresh action failed');
        if (queueStatsOnly) {
            await window.TGConfirm.alert('Сбор статистики запущен. После завершения вернитесь на эту страницу и снова обновите фильтры.');
            window.location = actionResp.url || window.location.href;
            return;
        }
        // Анализ выполняется фоновой задачей (#793) — поллим её статус, чтобы
        // кнопка не «висела» молча и страница обновилась с готовым отчётом.
        setAsyncButtonBusy(button, true, 'Анализ выполняется...');
        await pollAnalyzeStatus(button);
    } catch (e) {
        console.error('Failed to refresh filters:', e);
        setAsyncButtonBusy(button, false);
        await window.TGConfirm.alert('Не удалось обновить фильтры. Попробуйте еще раз.');
    }
}

async function pollAnalyzeStatus(button) {
    // 200 попыток × 3с = 10 минут: если задача висит (например, воркер не
    // запущен в --no-worker деплое), не зацикливаем вкладку навсегда.
    var maxAttempts = 200;
    for (var attempt = 0; attempt < maxAttempts; attempt++) {
        await new Promise(function(resolve) { setTimeout(resolve, 3000); });
        var resp;
        try {
            resp = await fetch('/channels/filter/analyze/status');
        } catch (e) {
            continue; // временный сбой сети — продолжаем поллить
        }
        if (!resp.ok) continue;
        var data = await resp.json();
        if (data.status === 'completed') {
            window.location = '/channels/filter/manage?msg=filter_applied';
            return;
        }
        if (data.status === 'failed' || data.status === 'cancelled') {
            setAsyncButtonBusy(button, false);
            await window.TGConfirm.alert('Анализ фильтров не завершился: ' + (data.error || data.status));
            return;
        }
    }
    setAsyncButtonBusy(button, false);
    await window.TGConfirm.alert('Анализ выполняется дольше обычного. Обновите страницу позже, чтобы увидеть результат.');
}
</script>