Method add

src/index.js:684–728

(jobs)

  }

  async add(jobs) {
    debug('add', jobs);

    if (!this._init) await this.init();

    //
    // make sure jobs is an array
    //
    if (!Array.isArray(jobs)) {
      jobs = [jobs];
    }

    const errors = [];
    const addedJobs = [];

    await Promise.all(
      // handle `jobs` in case it is a Set or an Array
      // <https://stackoverflow.com/a/42624575>
      [...jobs].map(async (job_, index) => {
        try {
          const names = [
            ...getJobNames(jobs, index),
            ...getJobNames(this.config.jobs)
          ];

          await validateJob(job_, index, names, this.config);
          const job = buildJob(job_, this.config);

          addedJobs.push(job);
        } catch (err) {
          errors.push(err);
        }
      })
    );

    debug('jobs added', this.config.jobs);

    // If there were any errors then throw them
    if (errors.length > 0) {
      throw combineErrors(errors);
    }

    this.config.jobs.push(...addedJobs);
    return addedJobs;
  }

  async remove(name) {
    debug('remove', name);