Function jobStatusHandler

src/StatusHandler.js:76–129

(config)

}

export function jobStatusHandler(config) {
  let jobStatus;
  const objectId = newObjectId(config.objectIdSize);
  const database = config.database;
  const handler = statusHandler(JOB_STATUS_COLLECTION, database);
  const setRunning = function (jobName) {
    const now = new Date();
    jobStatus = {
      objectId,
      jobName,
      status: 'running',
      source: 'api',
      createdAt: now,
      // lockdown!
      ACL: {},
    };

    return handler.create(jobStatus);
  };

  const setMessage = function (message) {
    if (!message || typeof message !== 'string') {
      return Promise.resolve();
    }
    return handler.update({ objectId }, { message });
  };

  const setSucceeded = function (message) {
    return setFinalStatus('succeeded', message);
  };

  const setFailed = function (message) {
    return setFinalStatus('failed', message);
  };

  const setFinalStatus = function (status, message = undefined) {
    const finishedAt = new Date();
    const update = { status, finishedAt };
    if (message && typeof message === 'string') {
      update.message = message;
    }
    if (Utils.isNativeError(message) && typeof message.message === 'string') {
      update.message = message.message;
    }
    return handler.update({ objectId }, update);
  };

  return Object.freeze({
    setRunning,
    setSucceeded,
    setMessage,
    setFailed,
  });
}

export function pushStatusHandler(config, existingObjectId) {
  let pushStatus;