export function run()

in src/commands/run.ts [22:46]

• 24 lines of code
• 2 McCabe index (conditional complexity)

export function run(config: RunConfig, callback?: any) {
  const inputConnector = getInputConnector(
    config.input.type,
    config.input.config
  );
  const transformer = new Transformer(config.transform);
  const outputConnector = getOutputConnector(
    config.output.type,
    config.output.config
  );

  async.waterfall(
    [
      (cb: any) => inputConnector.readInput(cb),
      (data: any[], cb: any) =>
        transformer.transformInput(data, graphSchema, cb),
      (data: GraphInfo, cb: any) => outputConnector.saveOutput(data, cb),
    ],
    err => {
      if (callback) {
        callback(err);
      }
    }
  );
}