'use strict';
|
var _ = {
|
isPlainObject: require('lodash/isPlainObject'),
|
clone: require('lodash/clone'),
|
isArray: require('lodash/isArray'),
|
set: require('lodash/set'),
|
isFunction: require('lodash/isFunction'),
|
};
|
var { defer, empty, from, of } = require('rxjs');
|
var { concatMap, filter, publish, reduce } = require('rxjs/operators');
|
var runAsync = require('run-async');
|
var utils = require('../utils/utils');
|
var Base = require('./baseUI');
|
|
/**
|
* Base interface class other can inherits from
|
*/
|
|
class PromptUI extends Base {
|
constructor(prompts, opt) {
|
super(opt);
|
this.prompts = prompts;
|
}
|
|
run(questions, answers) {
|
// Keep global reference to the answers
|
if (_.isPlainObject(answers)) {
|
this.answers = _.clone(answers);
|
} else {
|
this.answers = {};
|
}
|
|
// Make sure questions is an array.
|
if (_.isPlainObject(questions)) {
|
questions = [questions];
|
}
|
|
// Create an observable, unless we received one as parameter.
|
// Note: As this is a public interface, we cannot do an instanceof check as we won't
|
// be using the exact same object in memory.
|
var obs = _.isArray(questions) ? from(questions) : questions;
|
|
this.process = obs.pipe(
|
concatMap(this.processQuestion.bind(this)),
|
publish() // Creates a hot Observable. It prevents duplicating prompts.
|
);
|
|
this.process.connect();
|
|
return this.process
|
.pipe(
|
reduce((answers, answer) => {
|
_.set(answers, answer.name, answer.answer);
|
return answers;
|
}, this.answers)
|
)
|
.toPromise(Promise)
|
.then(this.onCompletion.bind(this), this.onError.bind(this));
|
}
|
|
/**
|
* Once all prompt are over
|
*/
|
|
onCompletion() {
|
this.close();
|
|
return this.answers;
|
}
|
|
onError(error) {
|
this.close();
|
return Promise.reject(error);
|
}
|
|
processQuestion(question) {
|
question = _.clone(question);
|
return defer(() => {
|
var obs = of(question);
|
|
return obs.pipe(
|
concatMap(this.setDefaultType.bind(this)),
|
concatMap(this.filterIfRunnable.bind(this)),
|
concatMap(() =>
|
utils.fetchAsyncQuestionProperty(question, 'message', this.answers)
|
),
|
concatMap(() =>
|
utils.fetchAsyncQuestionProperty(question, 'default', this.answers)
|
),
|
concatMap(() =>
|
utils.fetchAsyncQuestionProperty(question, 'choices', this.answers)
|
),
|
concatMap(this.fetchAnswer.bind(this))
|
);
|
});
|
}
|
|
fetchAnswer(question) {
|
var Prompt = this.prompts[question.type];
|
this.activePrompt = new Prompt(question, this.rl, this.answers);
|
return defer(() =>
|
from(
|
this.activePrompt
|
.run()
|
.then((answer) => ({ name: question.name, answer: answer }))
|
)
|
);
|
}
|
|
setDefaultType(question) {
|
// Default type to input
|
if (!this.prompts[question.type]) {
|
question.type = 'input';
|
}
|
|
return defer(() => of(question));
|
}
|
|
filterIfRunnable(question) {
|
if (question.askAnswered !== true && this.answers[question.name] !== undefined) {
|
return empty();
|
}
|
|
if (question.when === false) {
|
return empty();
|
}
|
|
if (!_.isFunction(question.when)) {
|
return of(question);
|
}
|
|
var answers = this.answers;
|
return defer(() =>
|
from(
|
runAsync(question.when)(answers).then((shouldRun) => {
|
if (shouldRun) {
|
return question;
|
}
|
})
|
).pipe(filter((val) => val != null))
|
);
|
}
|
}
|
|
module.exports = PromptUI;
|
