TaskMan

[ingalls]

Context

There is a need for async task management for longer running tasks than are acceptable during an http request/response cycle.

This PR introduces a framework for task management and status monitoring

• Allow listing tasks

[nathanielrindlaub]

Ref: #148

[ingalls]

Example Usage

const Authorization = `Bearer [TOKEN]`

async function getStats() {
    const res = await fetch('https://oogwqd3v1f.execute-api.us-west-2.amazonaws.com/dev/external', {
        headers: {
            Authorization,
            'content-type': 'application/json',
            'x-selected-project': 'catalina'
        },
        method: 'POST',
        body: JSON.stringify({
            query: `
                query GetStats($input: QueryStatsInput!) {
                    stats(input: $input) {
                        _id
                    }
                }
            `,
            variables: {
                "input":{
                    "filters":{
                        "cameras":null,
                        "deployments":null,
                        "labels":null,
                        "createdStart":null,
                        "createdEnd":null,
                        "addedStart":null,
                        "addedEnd":null,
                        "reviewed":null,
                        "notReviewed":null,
                        "custom":null
                    }
                }
           }
        })
    });

    return await res.json();
}

async function getTask(task) {
    const res = await fetch('https://oogwqd3v1f.execute-api.us-west-2.amazonaws.com/dev/external', {
        headers: {
            Authorization,
            'content-type': 'application/json',
            'x-selected-project': 'catalina'
        },
        method: 'POST',
        body: JSON.stringify({
            query: `
                query task($input: String!) {
                    task(input: $input) {
                        _id
                        projectId
                        user
                        type
                        status
                        created
                        updated
                        output
                    }
                }
            `,
            variables: {
                input: task
           }
        })
    });

    return await res.json();
}

let stats = await getStats('default_project');
console.error(JSON.stringify(stats));

do {
    const task = await getTask(stats.data.stats._id);
    console.error(JSON.stringify(task));
    await sleep()
} while (true)


async function sleep(num = 1000) {
    return new Promise((resolve) => {
        setTimeout(resolve, num);
    })
}

[nathanielrindlaub]

Looking great @ingalls - just a few comments in there.