import { charLengthAt, CSI, emitKeys } from "./utils.mjs";import { kSawKeyPress } from "./symbols.mjs";import { clearTimeout, setTimeout } from "../../timers.ts";
const { kEscape,} = CSI;
import { StringDecoder } from "../../string_decoder.ts";
const KEYPRESS_DECODER = Symbol("keypress-decoder");const ESCAPE_DECODER = Symbol("escape-decoder");
const ESCAPE_CODE_TIMEOUT = 500;
export function emitKeypressEvents(stream, iface = {}) { if (stream[KEYPRESS_DECODER]) return;
stream[KEYPRESS_DECODER] = new StringDecoder("utf8");
stream[ESCAPE_DECODER] = emitKeys(stream); stream[ESCAPE_DECODER].next();
const triggerEscape = () => stream[ESCAPE_DECODER].next(""); const { escapeCodeTimeout = ESCAPE_CODE_TIMEOUT } = iface; let timeoutId;
function onData(input) { if (stream.listenerCount("keypress") > 0) { const string = stream[KEYPRESS_DECODER].write(input); if (string) { clearTimeout(timeoutId);
iface[kSawKeyPress] = charLengthAt(string, 0) === string.length; iface.isCompletionEnabled = false;
let length = 0; for (const character of string[Symbol.iterator]()) { length += character.length; if (length === string.length) { iface.isCompletionEnabled = true; }
try { stream[ESCAPE_DECODER].next(character); if (length === string.length && character === kEscape) { timeoutId = setTimeout(triggerEscape, escapeCodeTimeout); } } catch (err) { stream[ESCAPE_DECODER] = emitKeys(stream); stream[ESCAPE_DECODER].next(); throw err; } } } } else { stream.removeListener("data", onData); stream.on("newListener", onNewListener); } }
function onNewListener(event) { if (event === "keypress") { stream.on("data", onData); stream.removeListener("newListener", onNewListener); } }
if (stream.listenerCount("keypress") > 0) { stream.on("data", onData); } else { stream.on("newListener", onNewListener); }}