tasks.js

import {sparqlEscapeUri} from 'mu';
import {updateSudo as update} from '@lblod/mu-auth-sudo';
import {v4 as uuid} from 'uuid';

export async function sendSavedOrderTask(orderId) {
    const query = `
    PREFIX ext: <http://mu.semte.ch/vocabularies/ext/>
    INSERT DATA { GRAPH <http://mu.semte.ch/graphs/tasks> {
        <http://mu.semte.ch/graphs/tasks#${uuid()}> a ext:Task;
            ext:taskType ext:SavedOrderTask;
            ext:dataFlow ext:DbToPod;
            ext:order ${sparqlEscapeUri(orderId)};
            ext:taskStatus "pending";
            ext:taskCreatedAt "${new Date().toISOString()}".
    } }`;

    return update(query);
}

export async function sendUpdatedOrderTask(orderId) {
    const query = `
    PREFIX ext: <http://mu.semte.ch/vocabularies/ext/>
    INSERT DATA { GRAPH <http://mu.semte.ch/graphs/tasks> {
        <http://mu.semte.ch/graphs/tasks#${uuid()}> a ext:Task;
            ext:taskType ext:UpdatedOrderTask;
            ext:dataFlow ext:DbToPod;
            ext:order ${sparqlEscapeUri(orderId)};
            ext:taskStatus "pending";
            ext:taskCreatedAt "${new Date().toISOString()}".
    } }`;

    return update(query);
}

export async function sendSyncOfferingsTask(webId, pod) {
    const query = `
    PREFIX ext: <http://mu.semte.ch/vocabularies/ext/>
    INSERT DATA { GRAPH <http://mu.semte.ch/graphs/tasks> {
        <http://mu.semte.ch/graphs/tasks#${uuid()}> a ext:Task;
            ext:taskType ext:SyncOfferingsTask;
            ext:dataFlow ext:PodToDb;
            ext:webId ${sparqlEscapeUri(webId)};
            ext:pod ${sparqlEscapeUri(pod)};
            ext:taskStatus "pending";
            ext:taskCreatedAt "${new Date().toISOString()}".
    } }`;

    return update(query);
}