ExecutorHelper.js

/* globals define */
define([
    'superagent',
    'module',
    'q'
], function(
    superagent,
    module,
    Q
) {

    const WORKER_ENDPOINT = '/rest/executor/worker';
    const JOBS_ENDPOINT = '/rest/executor';
    const ExecutorHelper = {};

    ExecutorHelper.url = function(urlPath) {
        if (typeof window === 'undefined') {
            const modulePath = 'src/common/compute/backends/gme/ExecutorHelper.js';
            const configPath = module.uri.replace(modulePath, 'config/index.js');
            const gmeConfig = require.nodeRequire(configPath);
            return `http://127.0.0.1:${gmeConfig.server.port}${urlPath}`;
        }
        return urlPath;
    };

    ExecutorHelper.get = function(urlPath, token) {
        const deferred = Q.defer();
        const url = this.url(urlPath);

        const req = superagent.get(url);
        if (token) {
            req.set('Authorization', 'Bearer ' + token);
        }
        req.end((err, res) => {
            if (err) {
                return deferred.reject(err);
            }
            deferred.resolve(JSON.parse(res.text));
        });

        return deferred.promise;
    };

    ExecutorHelper.getWorkers = function(webgmeToken) {
        return this.get(WORKER_ENDPOINT, webgmeToken)
            .then(workerDict => Object.values(workerDict));
    };

    ExecutorHelper.getJobs = function(webgmeToken) {
        return this.get(JOBS_ENDPOINT, webgmeToken);
    };

    ExecutorHelper.cancelJob = function(jobId, token) {
        const endpoint = `/rest/executor/cancel/${jobId}`;

        const deferred = Q.defer();
        const url = this.url(endpoint);
        const req = superagent.post(url);
        if (token) {
            req.set('Authorization', 'Bearer ' + token);
        }
        req.end(err => {
            if (err) {
                return deferred.reject(err);
            }
            deferred.resolve();
        });

        return deferred.promise;
    };

    return ExecutorHelper;
});