{% extends "base.html" %}

{% block title %}Automation - {{ job.name }} - Memorizz{% endblock %}

{% block content %}
{% from '_ui.html' import page_header, empty_state, id_chip %}
{% set status_pill = {'succeeded': 'pill--success', 'failed': 'pill--danger', 'running': 'pill--info'} %}
{% call page_header(job.name, 'Schedule, status and run history for this job. Select a run to open its trace.', 'Execution', back=('/automations' ~ ('?agent_id=' ~ job.agent_id if job.agent_id else ''), 'All automations')) %}
    <a class="btn" href="/automations/{{ job.job_id }}/edit">Edit</a>
    {% if job.enabled %}
    <form method="post" action="/automations/{{ job.job_id }}/pause">
        <button type="submit" class="btn">Pause</button>
    </form>
    {% else %}
    <form method="post" action="/automations/{{ job.job_id }}/resume">
        <button type="submit" class="btn">Resume</button>
    </form>
    {% endif %}
    <form method="post" action="/automations/{{ job.job_id }}/run-now">
        <button type="submit" class="btn btn-primary">Run now</button>
    </form>
{% endcall %}

{% if error %}
<div class="error-message">
    <span>!</span> {{ error }}
</div>
{% endif %}

<section class="panel" aria-labelledby="automation-job-title">
    <div class="panel-header">
        <h2 class="panel-title" id="automation-job-title">Job</h2>
    </div>
    <dl class="detail-list">
        <div>
            <dt>Status</dt>
            <dd id="job-status-badge">
                {% if job.enabled %}
                <span class="pill pill--success">Enabled</span>
                {% else %}
                <span class="pill">Paused</span>
                {% endif %}
            </dd>
        </div>
        <div>
            <dt>Job ID</dt>
            <dd>{{ id_chip(job.job_id, 40) }}</dd>
        </div>
        <div>
            <dt>Agent</dt>
            <dd>{{ id_chip(job.agent_id, 40) }}</dd>
        </div>
        <div>
            <dt>Schedule</dt>
            <dd>
                {{ job.schedule_type|replace('_', '-')|capitalize }}
                {% if job.schedule_type == 'cron' and job.cron_expr %}
                <code>{{ job.cron_expr }}</code>
                {% elif job.schedule_type == 'interval' and job.interval_seconds %}
                <code>{{ job.interval_seconds }}s</code>
                {% endif %}
            </dd>
        </div>
        <div>
            <dt>Timezone</dt>
            <dd>{{ job.timezone }}</dd>
        </div>
        <div>
            <dt>Next run</dt>
            <dd><code id="job-next-run">{{ job.next_run_at }}</code></dd>
        </div>
        <div>
            <dt>Last run</dt>
            <dd><code id="job-last-run">{{ job.last_run_at or '-' }}</code></dd>
        </div>
    </dl>
    <form class="automation-delete" method="post" action="/automations/{{ job.job_id }}/delete">
        <label>
            <input type="checkbox" name="confirm" value="1">
            I understand this deletes the job
        </label>
        <button type="submit" class="btn btn-danger">Delete automation</button>
    </form>
</section>

<section class="panel observability-section automation-runs" aria-labelledby="automation-runs-title">
    <div class="panel-header">
        <h2 class="panel-title" id="automation-runs-title">Run history</h2>
        <span class="panel-meta">Latest 50 runs</span>
    </div>

    {% if runs %}
    <div class="traces-table-wrap table-scroll">
        <table class="traces-agents-table data-table">
            <thead>
                <tr>
                    <th>Scheduled for</th>
                    <th>Status</th>
                    <th>Started</th>
                    <th>Finished</th>
                    <th>Deliveries</th>
                    <th>Error</th>
                </tr>
            </thead>
            <tbody>
                {% for run in runs %}
                {% set payload = run.result_payload or {} %}
                {% set deliveries = payload.get('deliveries', []) if payload else [] %}
                {% set delivery_summary = payload.get('delivery_summary', {}) if payload else {} %}
                {% set delivery_sent = delivery_summary.get('sent', 0) if delivery_summary else 0 %}
                {% set delivery_failed = delivery_summary.get('failed', 0) if delivery_summary else 0 %}
                {% set run_memory_id = payload.get('memory_id', '') if payload else '' %}
                {% set trace_url = '/traces?agent_id=' + job.agent_id + ('&thread_memory_id=' + run_memory_id if run_memory_id else '') + '&scroll=timeline' %}
                <tr class="automation-run-row" data-trace-url="{{ trace_url }}" style="cursor: pointer;">
                    <td><code>{{ run.scheduled_for }}</code></td>
                    <td><span class="pill {{ status_pill.get(run.status, '') }}">{{ run.status|capitalize }}</span></td>
                    <td><code>{{ run.started_at or '-' }}</code></td>
                    <td><code>{{ run.finished_at or '-' }}</code></td>
                    <td>
                        {{ deliveries|length }}
                        {% if delivery_failed %}
                        <span class="pill pill--warning">{{ delivery_failed }} failed</span>
                        {% elif delivery_sent %}
                        <span class="pill pill--success">{{ delivery_sent }} sent</span>
                        {% endif %}
                    </td>
                    <td>
                        {% if run.error %}
                        <span title="{{ run.error }}">{{ run.error|truncate(120) }}</span>
                        {% else %}
                        -
                        {% endif %}
                    </td>
                </tr>
                {% endfor %}
            </tbody>
        </table>
    </div>
    {% else %}
    <div class="empty-pane">
        {{ empty_state('No runs yet', 'A run is recorded when a worker picks up this job at its next run time. Start a worker with memorizz automations run, or select Run now.') }}
    </div>
    {% endif %}
</section>

<style>
.automation-delete {
    display: flex;
    flex-wrap: wrap;
    align-items: center;
    justify-content: flex-end;
    gap: 12px;
    margin-top: 20px;
    padding-top: 16px;
    border-top: 1px solid var(--border-subtle);
    color: var(--text-secondary);
    font-size: 13px;
}
.automation-delete label {
    display: inline-flex;
    align-items: center;
    gap: 8px;
}
.automation-runs > .empty-pane {
    display: block;
    min-height: 0;
    padding: 0;
}
</style>

<script>
var AUTOMATION_JOB_ID = {{ job.job_id|tojson }};
var AUTOMATION_AGENT_ID = {{ job.agent_id|tojson }};
var _pollTimer = null;
var _pollInterval = 3000;

function _fmtTs(v) {
    if (!v) return '-';
    var s = String(v);
    // Trim fractional seconds beyond 0 and timezone suffix for readability
    return s.replace(/\.\d+/, '').replace('T', ' ');
}

function _escHtml(s) {
    var d = document.createElement('div');
    d.textContent = s;
    return d.innerHTML;
}

var _STATUS_PILLS = {succeeded: ' pill--success', failed: ' pill--danger', running: ' pill--info'};

function _buildStatusBadge(status) {
    var label = String(status || '');
    label = label.charAt(0).toUpperCase() + label.slice(1);
    return '<span class="pill' + (_STATUS_PILLS[status] || '') + '">' + _escHtml(label) + '</span>';
}

function _buildDeliveriesCell(payload) {
    if (!payload) return '0';
    var deliveries = payload.deliveries || [];
    var summary = payload.delivery_summary || {};
    if (!deliveries.length) return '0';
    var html = deliveries.length + ' ';
    if (summary.failed) {
        html += '<span class="pill pill--warning">' + summary.failed + ' failed</span>';
    } else if (summary.sent) {
        html += '<span class="pill pill--success">' + summary.sent + ' sent</span>';
    }
    return html;
}

function _buildRunRow(run, agentId) {
    var payload = run.result_payload || {};
    var memId = payload.memory_id || '';
    var traceUrl = '/traces?agent_id=' + encodeURIComponent(agentId) +
        (memId ? '&thread_memory_id=' + encodeURIComponent(memId) : '') + '&scroll=timeline';

    var errorCell = run.error
        ? '<span title="' + _escHtml(run.error) + '">' + _escHtml(run.error.substring(0, 120)) + '</span>'
        : '-';

    return '<tr class="automation-run-row" data-trace-url="' + _escHtml(traceUrl) + '" style="cursor:pointer;">'
        + '<td><code>' + _escHtml(_fmtTs(run.scheduled_for)) + '</code></td>'
        + '<td>' + _buildStatusBadge(run.status) + '</td>'
        + '<td><code>' + _escHtml(_fmtTs(run.started_at)) + '</code></td>'
        + '<td><code>' + _escHtml(_fmtTs(run.finished_at)) + '</code></td>'
        + '<td>' + _buildDeliveriesCell(payload) + '</td>'
        + '<td>' + errorCell + '</td>'
        + '</tr>';
}

function _bindRowClicks() {
    document.querySelectorAll('.automation-run-row[data-trace-url]').forEach(function(row) {
        row.onclick = function() {
            if (row.dataset.traceUrl) window.location.href = row.dataset.traceUrl;
        };
        row.onmouseenter = function() { row.style.backgroundColor = 'var(--bg-hover)'; };
        row.onmouseleave = function() { row.style.backgroundColor = ''; };
    });
}

function _updateJobMeta(job) {
    // Update status badge
    var statusEl = document.getElementById('job-status-badge');
    if (statusEl) {
        statusEl.innerHTML = job.enabled
            ? '<span class="pill pill--success">Enabled</span>'
            : '<span class="pill">Paused</span>';
    }
    // Update next/last run
    var nextEl = document.getElementById('job-next-run');
    if (nextEl) nextEl.textContent = _fmtTs(job.next_run_at);
    var lastEl = document.getElementById('job-last-run');
    if (lastEl) lastEl.textContent = _fmtTs(job.last_run_at) || '-';
}

function pollRuns() {
    fetch('/api/automations/' + encodeURIComponent(AUTOMATION_JOB_ID) + '/runs')
        .then(function(r) { return r.ok ? r.json() : null; })
        .then(function(data) {
            if (!data) return;

            _updateJobMeta(data.job);

            var tbody = document.querySelector('.traces-agents-table tbody');
            var emptyPane = document.querySelector('.observability-section .empty-pane');
            var tableWrap = document.querySelector('.traces-table-wrap');

            if (data.runs.length === 0) return;

            // If there was an empty pane, replace with table
            if (emptyPane && !tableWrap) {
                var section = document.querySelector('.observability-section');
                emptyPane.remove();
                section.insertAdjacentHTML('beforeend',
                    '<div class="traces-table-wrap table-scroll"><table class="traces-agents-table data-table">'
                    + '<thead><tr><th>Scheduled for</th><th>Status</th><th>Started</th>'
                    + '<th>Finished</th><th>Deliveries</th><th>Error</th></tr></thead>'
                    + '<tbody></tbody></table></div>');
                tbody = section.querySelector('tbody');
            }

            if (!tbody) return;

            // Rebuild rows
            var html = '';
            for (var i = 0; i < data.runs.length; i++) {
                html += _buildRunRow(data.runs[i], AUTOMATION_AGENT_ID);
            }
            tbody.innerHTML = html;
            _bindRowClicks();

            // If any run is still "running", poll faster
            var hasRunning = data.runs.some(function(r) { return r.status === 'running'; });
            _pollInterval = hasRunning ? 2000 : 5000;
        })
        .catch(function() {})
        .finally(function() {
            _pollTimer = setTimeout(pollRuns, _pollInterval);
        });
}

document.addEventListener('DOMContentLoaded', function() {
    _bindRowClicks();
    // Start polling
    _pollTimer = setTimeout(pollRuns, _pollInterval);
});
</script>
{% endblock %}