Function enterConversation

src/cli-main.ts:82–133

(credential)

}

async function enterConversation(credential) {
  console.log('Start chatting with', credential.name + ':');
  const chat = new ChatService({
    name: credential.name,
    api: apiManager.createAPIForCredential(credential) as ChatServiceSupportedAPIs,
  });

  // Create terminal chat interface.
  let spinner;
  const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout,
  });
  // Print ChatGPT answers with streaming interface.
  let state = 'waitUser';
  chat.onMessageDelta.connect((message, info) => {
    if (spinner) {
      // Clear spinner and print bot name.
      spinner.clear();
      spinner.reset();
      spinner = null;
      process.stdout.write('\x1b[?25h');  // restore cursor
      process.stdout.write(`${chat.name}> `);
    }
    if (state == 'waitAnswer') {
      // Print content.
      if (message.content)
        process.stdout.write(message.content);
    }
    if (info.pending)  // more messages coming.
      return;
    process.stdout.write('\n');
    state = 'waitUser';
  });
  // Quite on EOF.
  rl.once('close', () => chat.abort());
  // Make user ask question infinitely.
  while (!chat.isAborted()) {
    if (state != 'waitUser')
      throw new Error('Did not receive an answer.');
    try {
      const content = await rl.question('You> ', {signal: chat.aborter.signal});
      state = 'waitAnswer';
      spinner = createSpinner().start();
      await chat.sendMessage({content});
    } catch (error) {
      // Ignore abort error.
      if (error.name != 'AbortError')
        throw error;
    }
  }
}