fix: input based on read library

src/clients/user.client.ts

@@ -16,19 +16,10 @@ export class TelegramUserClient extends TelegramBotClient {
       password: async () => await input.password('Enter your password: '),
       phoneCode: async () => await input.text('Enter the code sent to your phone: '),
       onError: async (err) => {
-        const errMessage = formatErrorMessage(err);
-
-        if (errMessage === 'Input closed unexpectedly') {
-          process.stdout.write('\n');
-        }
-
-        input.close();
-        throw new TelegramClientException(errMessage);
+        throw new TelegramClientException(formatErrorMessage(err));
       }
     });
 
-    input.close();
-
     // Save the session if it doesn't exist
     if (!Store.get(this.sessionName, '')) {
       Store.set(this.sessionName, this.session.save());

src/helpers/input.helper.ts

@@ -1,68 +1,21 @@
-import readline from 'readline';
+import { read } from 'read';
 import { HelperException } from '../exceptions.js';
 
 class InputHelper {
-  private rl: readline.Interface;
-
-  constructor() {
-    this.rl = readline.createInterface({
-      input: process.stdin,
-      output: process.stdout
-    });
-  }
-
   public async text(question: string): Promise<string> {
-    return new Promise<string>((resolve, reject) => {
-      this.rl.question(question, (answer: string) => {
-        resolve(answer);
-      });
-      this.rl.on('close', () => {
-        reject(new HelperException('Input closed unexpectedly'));
-      });
-    });
+    try {
+      return await read({ prompt: question });
+    } catch (error) {
+      throw new HelperException(`Error reading text: ${(<Error>error).message}`);
+    }
   }
 
   public async password(question: string): Promise<string> {
-    return new Promise<string>((resolve, reject) => {
-      const stdin = process.openStdin();
-      let password = '';
-
-      const onKeyPress = (char: string) => {
-        char = char.toString().trim();
-        switch (char) {
-          case '\n':
-          case '\r':
-          case '\u0004':
-            cleanUp();
-            resolve(password);
-            break;
-          default:
-            process.stdout.write('\u001B[2K\u001B[200D' + question + Array(password.length + 1).join('*'));
-            password += char;
-            break;
-        }
-      };
-
-      const cleanUp = () => {
-        stdin.removeListener('data', onKeyPress);
-        process.stdin.removeListener('keypress', onKeyPress);
-        stdin.pause();
-        this.rl.removeListener('close', onClose);
-      };
-
-      const onClose = () => {
-        cleanUp();
-        reject(new HelperException('Input closed unexpectedly'));
-      };
-
-      stdin.on('data', onKeyPress);
-      process.stdin.on('keypress', onKeyPress);
-      this.rl.on('close', onClose);
-    });
-  }
-
-  public close(): void {
-    this.rl.close();
+    try {
+      return await read({ prompt: question, silent: true });
+    } catch (error) {
+      throw new HelperException(`Error reading password: ${(<Error>error).message}`);
+    }
   }
 }