preview.js

const { readFileSync } = require('fs');
const Handlebars = require('handlebars');
const _ = require('lodash');

const { registerHelpers } = require('./helpers');
const jsonEscape = require('./utils/json-escape');

const testFileName = 'targeting-rule-update.json';
const flagUpdateContext = require(`./sample-context/flag/${testFileName}`);

// Update the context to have a more recent timestamp. This is important
// because some third-party services reject event payloads which are
// identified as having happened in the more distant past.
const now = new Date().getTime();
flagUpdateContext.timestamp.milliseconds = now;
flagUpdateContext.timestamp.seconds = Math.floor(now / 1000);

const args = process.argv;

const getFormVariableContext = formVariables => {
  const endpointContext = {};
  if (formVariables) {
    formVariables.forEach(formVariable => {
      const unsubstitutedKey = '$' + _.toUpper(formVariable.key);
      switch (formVariable.type) {
        case 'string':
          endpointContext[formVariable.key] = unsubstitutedKey;
          break;
        case 'boolean':
          endpointContext[formVariable.key] = true;
          break;
        case 'uri':
          endpointContext[formVariable.key] = unsubstitutedKey;
          break;
        case 'enum':
          endpointContext[formVariable.key] = unsubstitutedKey;
          break;
        case 'dynamicEnum':
          endpointContext[formVariable.key] = unsubstitutedKey;
          break;
      }
    });
  }
  return endpointContext;
};

const getOAuthContext = requiresOAuth => {
  if (requiresOAuth) {
    const oauthContext = {
      baseURI: '$OAUTH_BASE_URI',
      accessToken: '$OAUTH_ACCESS_TOKEN',
    };
    return oauthContext;
  }
  return null;
};

registerHelpers();

const curl = _.includes(args, '--curl');
const integrationNameIndex = curl ? 3 : 2;

if (args.length <= integrationNameIndex) {
  console.log('Provide an integration directory name:');
  console.log('    npm run preview <INTEGRATION_NAME>');
  console.log('    npm run curl <INTEGRATION_NAME>\n');
  process.exit(1);
}

const integrationName = args[integrationNameIndex];

let manifest;
try {
  manifest = require(`./integrations/${integrationName}/manifest.json`);
} catch (e) {
  console.log(
    `The "${integrationName}" integration does not exist. This value should be your integration directory name.\n`
  );
  process.exit(1);
}
const formVariables = _.get(manifest, 'formVariables', null);
const endpoint = _.get(
  manifest,
  'capabilities.auditLogEventsHook.endpoint',
  null
);
const requiresOAuth = _.get(manifest, 'requiresOAuth', null);

if (endpoint) {
  const endpointContext = getFormVariableContext(formVariables);
  endpointContext.oauth = getOAuthContext(requiresOAuth);
  endpointContext.context = flagUpdateContext;
  const urlTemplate = Handlebars.compile(endpoint.url, {
    strict: true,
  });

  const flagTemplatePath = _.get(
    manifest,
    'capabilities.auditLogEventsHook.templates.flag',
    null
  );
  const defaultTemplatePath = _.get(
    manifest,
    'capabilities.auditLogEventsHook.templates.default',
    null
  );
  if (!(flagTemplatePath || defaultTemplatePath)) {
    console.log('Could not find a flag/default template in manifest');
    process.exit(1);
  }

  const path = `./integrations/${integrationName}/${
    flagTemplatePath || defaultTemplatePath
  }`;
  const headers = endpoint.headers.map(header => {
    const headerTemplate = Handlebars.compile(header.value, {
      strict: true,
    });
    return {
      name: header.name,
      value: headerTemplate(endpointContext),
    };
  });

  const fullContext = jsonEscape(Object.assign({}, flagUpdateContext));
  fullContext.formVariables = getFormVariableContext(formVariables);

  const templateString = readFileSync(path, { encoding: 'utf-8' });
  const flagTemplate = Handlebars.compile(templateString, { strict: true });
  const body = flagTemplate(fullContext);

  if (curl) {
    let command =
      `curl -X ${endpoint.method} \\\n` +
      `  ${urlTemplate(endpointContext)} \\\n`;
    headers.forEach(header => {
      command += `  -H '${header.name}: ${header.value}' \\\n`;
    });
    command += `  -d '${_.trimEnd(body)}'`;

    console.log(
      'Before running the following curl command, be sure to replace all variables denoted with $.'
    );
    console.log(
      `The following command was generated with the test file ${testFileName}.\n`
    );
    console.log(command);
  } else {
    console.log('URL:   ', urlTemplate(endpointContext));
    console.log('METHOD:', endpoint.method);
    headers.forEach(header => {
      console.log(`HEADER: ${header.name}: ${header.value}`);
    });
    console.log(`BODY:\t${testFileName}`);
    console.log(body);
  }
} else {
  console.log(
    `The "${integrationName}" integration does not make any outbound requests from LaunchDarkly.\n`
  );
  process.exit(0);
}