1. /**
  2. * Buffers string input with a timeout for dry-run scenarios.
  3. *
  4. * @param {number} timeoutMs The timeout in milliseconds.
  5. * @returns {Promise<string>} A promise that resolves with the buffered input string
  6. * or rejects with an error if the timeout is exceeded.
  7. */
  8. async function bufferedInput(timeoutMs) {
  9. let buffer = "";
  10. let startTime = Date.now();
  12. return new Promise((resolve, reject) => {
  13. const inputHandler = (e) => {
  14. if (e.length > 0) {
  15. buffer += e;
  16. }
  17. };
  19. // Capture input events
  20. process.stdin.setEncoding('utf8');
  21. process.stdin.on('data', inputHandler);
  22. process.stdin.resume();
  24. process.stdin.on('timeout', () => {
  25. process.stdin.off('data', inputHandler);
  26. process.stdin.off('timeout');
  28. if (buffer.length > 0) {
  29. resolve(buffer);
  30. } else {
  31. reject(new Error("Timeout: No input received"));
  32. }
  33. });
  35. process.stdin.on('close', () => {
  36. process.stdin.off('data', inputHandler);
  37. process.stdin.off('timeout');
  38. resolve(buffer);
  39. });
  43. // Timeout implementation
  44. setTimeout(() => {
  45. process.stdin.off('data', inputHandler);
  46. process.stdin.off('timeout');
  47. resolve(buffer);
  48. }, timeoutMs);
  49. });
  50. }

Add your comment