{% extends "base.html" %}

{% block title %}Jobs - IceProd{% end %}

{% block page_title %}Jobs{% end %}

{% block body %}

<table class='task_table'>
    <tr>
        <th>Job Index</th>
        <th>Status</th>
        <th>Status Changed</th>
        {% if (current_user) %}
        <th><button class="set_status" onclick='job_reset(job_ids_on_page);'>Reset All</button></th>
        <th><button class="set_status" onclick='job_hard_reset(job_ids_on_page);'>Hard Reset All</button></th>
        <th><button class="set_status" onclick='job_suspend(job_ids_on_page);'>Suspend All</button></th>
        {% end %}
    </tr>
    {% for j in jobs %}
    <tr>
        <td><a href="/dataset/{{ url_escape(jobs[j]['dataset_id']) }}/job/{{ url_escape(jobs[j]['job_id']) }}">{{ jobs[j]['job_index'] }}</a></td>
        <td>{{ jobs[j]['status'] }}</td>
        <td>{{ jobs[j]['status_changed'] }}</td>
        {% if (current_user) %}
        <td>{% if jobs[j]['status'] in states.job_prev_statuses(states.JOB_STATUS_START) %}
        <button class="set_status" onclick='job_reset(["{{ jobs[j]["job_id"] }}"]);'>Reset</button>
        {% end %}</td>
        <td><button class="set_status" onclick='job_hard_reset(["{{ jobs[j]["job_id"] }}"]);'>Hard Reset</button></td>
        <td>{% if jobs[j]['status'] in states.job_prev_statuses('suspended') %}
        <button class="set_status" onclick='job_suspend(["{{ jobs[j]["job_id"] }}"]);'>Suspend</button>
        {% end %}</td>
        {% end %}
    </tr>
    {% end %}
</table>

{% end %}

{% block body_scripts %}

{% if (current_user) %}
<script type="text/javascript" src="/static/fetch.js"></script>
<script type="text/javascript" src="/static/rest.js"></script>
{% module SecureScript(content=f"""
var rest_api = '{ rest_api }';
const passkey = "{ passkey }";
const dataset_id = "{ list(jobs.values())[0]['dataset_id'] if jobs else '' }";
const job_ids_on_page = [{ ','.join('"' + jobs[j]['job_id'] + '"' for j in jobs) }];
""") %}
{% module SecureScript(content="""
function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

async function service_worker(action, job_ids) {
    try {
        const url = '/actions/job_status';
        const args = {
            dataset_id: dataset_id,
            action: action,
            job_ids: job_ids,
        };
        const ret = await fetch_json('POST', url, args, passkey);
        if ('error' in ret) {
            message_alert('error - '+ret['error']);
            return false;
        }
        const id = ret['result'];

        while (true) {
            await sleep(1000);
            const url = '/actions/job_status/'+id;
            const ret = await fetch_json('GET', url, null, passkey);
            if (ret['status'] == 'error') {
                if ('error_message' in ret) {
                    message_alert('error - '+ret['error_message']);
                } else {
                    message_alert('error - '+action+' failed');
                }
                return false;
            } else if (ret['status'] == 'complete') {
                message('complete');
                break;
            } else if ('payload' in ret && 'progress' in ret['payload']) {
                message('progress - '+ret['payload']['progress']+'%')
            }
        }
    } catch(err) {
        message_alert('error - '+err);
        return false;
    }
    reload();
    return true;
}

async function job_reset(job_ids) {
    return await service_worker('reset', job_ids)
}

async function job_hard_reset(job_ids) {
    return await service_worker('hard_reset', job_ids)
}

async function job_suspend(job_ids) {
    return await service_worker('suspend', job_ids)
}
""") %}
{% end %}

{% end %}