implement createPromptSession

packages/inquirer/inquirer.test.mts

@@ -783,6 +783,45 @@ describe('inquirer.prompt(...)', () => {
   });
 });
 
+describe('createPromptSession', () => {
+  it('should expose a Reactive subject across a session', async () => {
+    const localPrompt = inquirer.createPromptModule<TestQuestions>();
+    localPrompt.registerPrompt('stub', StubPrompt);
+    const session = localPrompt.createPromptSession();
+    const spy = vi.fn();
+
+    await session.run([
+      {
+        type: 'stub',
+        name: 'nonSubscribed',
+        message: 'nonSubscribedMessage',
+        answer: 'nonSubscribedAnswer',
+      },
+    ]);
+
+    session.process.subscribe(spy);
+    expect(spy).not.toHaveBeenCalled();
+
+    await session.run([
+      {
+        type: 'stub',
+        name: 'name1',
+        message: 'message',
+        answer: 'bar',
+      },
+      {
+        type: 'stub',
+        name: 'name',
+        message: 'message',
+        answer: 'doe',
+      },
+    ]);
+
+    expect(spy).toHaveBeenCalledWith({ name: 'name1', answer: 'bar' });
+    expect(spy).toHaveBeenCalledWith({ name: 'name', answer: 'doe' });
+  });
+});
+
 describe('AbortSignal support', () => {
   it('throws on aborted signal', async () => {
     const localPrompt = inquirer.createPromptModule<TestQuestions>({

packages/inquirer/src/index.mts

@@ -98,9 +98,8 @@ export function createPromptModule<
     questions: PromptSession<A>,
     answers?: Partial<A>,
   ): PromptReturnType<A> {
-    const runner = new PromptsRunner<A>(promptModule.prompts, opt);
-
-    const promptPromise = runner.run(questions, answers);
+    const runner = promptModule.createPromptSession<A>({ answers });
+    const promptPromise = runner.run(questions);
     return Object.assign(promptPromise, { ui: runner });
   }
 
@@ -124,6 +123,12 @@ export function createPromptModule<
     promptModule.prompts = { ...builtInPrompts };
   };
 
+  promptModule.createPromptSession = function <A extends Answers>({
+    answers,
+  }: { answers?: Partial<A> } = {}) {
+    return new PromptsRunner<A>(promptModule.prompts, { ...opt, answers });
+  };
+
   return promptModule;
 }
 

packages/inquirer/src/ui/prompt.mts

@@ -1,16 +1,18 @@
 /* eslint-disable @typescript-eslint/no-explicit-any, @typescript-eslint/no-unsafe-return, @typescript-eslint/no-unsafe-assignment */
 import readline from 'node:readline';
+import { isProxy } from 'node:util/types';
 import {
   defer,
-  EMPTY,
   from,
   of,
   concatMap,
   filter,
   reduce,
   isObservable,
   Observable,
+  Subject,
   lastValueFrom,
+  tap,
 } from 'rxjs';
 import runAsync from 'run-async';
 import MuteStream from 'mute-stream';
@@ -40,11 +42,7 @@ export const _ = {
       pointer = pointer[key] as Record<string, unknown>;
     });
   },
-  get: (
-    obj: object,
-    path: string | number | symbol = '',
-    defaultValue?: unknown,
-  ): any => {
+  get: (obj: object, path: string = '', defaultValue?: unknown): any => {
     const travel = (regexp: RegExp) =>
       String.prototype.split
         .call(path, regexp)
@@ -193,23 +191,47 @@ function isPromptConstructor(
  */
 export default class PromptsRunner<A extends Answers> {
   private prompts: PromptCollection;
-  answers: Partial<A> = {};
-  process: Observable<any> = EMPTY;
+  answers: Partial<A>;
+  process: Subject<{ name: string; answer: any }> = new Subject();
   private abortController: AbortController = new AbortController();
   private opt: StreamOptions;
   rl?: InquirerReadline;
 
-  constructor(prompts: PromptCollection, opt: StreamOptions = {}) {
+  constructor(
+    prompts: PromptCollection,
+    { answers, ...opt }: StreamOptions & { answers?: Partial<A> } = {},
+  ) {
     this.opt = opt;
     this.prompts = prompts;
+
+    this.answers = isProxy(answers)
+      ? answers
+      : new Proxy(
+          { ...answers },
+          {
+            get: (target: any, prop) => {
+              if (typeof prop === 'string') {
+                return _.get(target, prop);
+              }
+              return target[prop];
+            },
+            set: (target: any, prop, value) => {
+              if (typeof prop === 'string') {
+                _.set(target, prop, value);
+              } else {
+                target[prop] = value;
+              }
+              return true;
+            },
+          },
+        );
   }
 
-  async run(questions: PromptSession<A>, answers?: Partial<A>): Promise<A> {
+  async run<Session extends PromptSession<A> = PromptSession<A>>(
+    questions: Session,
+  ): Promise<A> {
     this.abortController = new AbortController();
 
-    // Keep global reference to the answers
-    this.answers = typeof answers === 'object' ? { ...answers } : {};
-
     let obs: Observable<AnyQuestion<A>>;
     if (isQuestionArray(questions)) {
       obs = from(questions);
@@ -224,34 +246,36 @@ export default class PromptsRunner<A extends Answers> {
       );
     } else {
       // Case: Called with a single question config
-      obs = from([questions]);
+      obs = from([questions as AnyQuestion<A>]);
     }
 
-    this.process = obs.pipe(
-      concatMap((question) =>
-        of(question).pipe(
+    return lastValueFrom(
+      obs
+        .pipe(
           concatMap((question) =>
-            from(
-              this.shouldRun(question).then((shouldRun: boolean | void) => {
-                if (shouldRun) {
-                  return question;
-                }
-                return;
-              }),
-            ).pipe(filter((val) => val != null)),
+            of(question)
+              .pipe(
+                concatMap((question) =>
+                  from(
+                    this.shouldRun(question).then((shouldRun: boolean | void) => {
+                      if (shouldRun) {
+                        return question;
+                      }
+                      return;
+                    }),
+                  ).pipe(filter((val) => val != null)),
+                ),
+                concatMap((question) => defer(() => from(this.fetchAnswer(question)))),
+              )
+              .pipe(tap((answer) => this.process.next(answer))),
           ),
-          concatMap((question) => defer(() => from(this.fetchAnswer(question)))),
+        )
+        .pipe(
+          reduce((answersObj: any, answer: { name: string; answer: unknown }) => {
+            answersObj[answer.name] = answer.answer;
+            return answersObj;
+          }, this.answers),
         ),
-      ),
-    );
-
-    return lastValueFrom(
-      this.process.pipe(
-        reduce((answersObj, answer: { name: string; answer: unknown }) => {
-          _.set(answersObj, answer.name, answer.answer);
-          return answersObj;
-        }, this.answers),
-      ),
     )
       .then(() => this.answers as A)
       .finally(() => this.close());
@@ -389,10 +413,7 @@ export default class PromptsRunner<A extends Answers> {
   };
 
   private shouldRun = async (question: AnyQuestion<A>): Promise<boolean> => {
-    if (
-      question.askAnswered !== true &&
-      _.get(this.answers, question.name) !== undefined
-    ) {
+    if (question.askAnswered !== true && this.answers[question.name] !== undefined) {
       return false;
     }