auth0-extensions/auth0-source-control-extension-tools

import Ajv from 'ajv/lib/ajv';

import pagedClient from './client';
import schema from './schema';
import * as handlers from './handlers';

const defaultOrder = 50;

function sortByOrder(toSort, stage) {
  const sorted = [ ...toSort ];
  sorted.sort((a, b) => {
    const aOrder = a[stage].order || defaultOrder;
    const bOrder = b[stage].order || defaultOrder;
    return aOrder - bOrder;
  });
  return sorted;
}

export default class Auth0 {
  constructor(client, assets, config) {
    this.client = pagedClient(client);
    this.config = config;
    this.assets = assets;
    this.handlers = [];
    Object.values(handlers).forEach((h) => {
      const handler = new h.default({ client: this.client, config });
      this.handlers.push(handler);
    });
  }

  async runStage(stage) {
    // Sort by priority
    for (const handler of sortByOrder(this.handlers, stage)) { // eslint-disable-line
      try {
        const stageFn = Object.getPrototypeOf(handler)[stage];
        this.assets = {
          ...this.assets,
          ...await stageFn.apply(handler, [ this.assets ]) || {}
        };
      } catch (err) {
        err.type = handler.type;
        err.stage = stage;
        throw err;
      }
    }
  }

  async validate() {
    const ajv = new Ajv({ useDefaults: true });
    const valid = ajv.validate(schema, this.assets);
    if (!valid) {
      throw new Error(`Schema validation failed loading ${JSON.stringify(ajv.errors, null, 4)}`);
    }

    await this.runStage('validate');
  }

  async loadAll() {
    // Populate assets from auth0 tenant
    await this.runStage('load');
  }

  async processChanges() {
    await this.runStage('processChanges');
  }
}