vrr/qwen-code
2
0
Fork 0
mirror of https://github.com/QwenLM/qwen-code.git synced 2026-05-05 23:42:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 11

fix(cli): enhance KeypressProvider with kitty sequence timeout management

Browse source
This commit is contained in:
qqqys 2026-03-23 20:41:36 +08:00
parent 38caa0b218
commit 61fb9425a2
1 changed files with 48 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

48
packages/cli/src/ui/contexts/KeypressContext.tsx
View file

@ -173,11 +173,37 @@ export function KeypressProvider({
let isPaste = false;
let pasteBuffer = Buffer.alloc(0);
let kittySequenceBuffer = '';
let kittySequenceTimeout: NodeJS.Timeout | null = null;
const KITTY_SEQUENCE_TIMEOUT_MS = 200;
const kittySequenceBufferRef = { current: '' };
let backslashTimeout: NodeJS.Timeout | null = null;
let waitingForEnterAfterBackslash = false;
let rawDataBuffer = Buffer.alloc(0);
let rawFlushTimeout: NodeJS.Timeout | null = null;
const clearKittyTimeout = () => {
if (kittySequenceTimeout) {
clearTimeout(kittySequenceTimeout);
kittySequenceTimeout = null;
}
};
const startKittyTimeout = () => {
clearKittyTimeout();
kittySequenceTimeout = setTimeout(() => {
if (kittySequenceBufferRef.current) {
if (debugKeystrokeLogging) {
debugLogger.debug(
'[DEBUG] Kitty buffer timeout, clearing:',
kittySequenceBufferRef.current,
);
}
kittySequenceBufferRef.current = '';
kittySequenceBuffer = '';
}
}, KITTY_SEQUENCE_TIMEOUT_MS);
};
const createPrintableKey = (char: string): Key => {
const printableName =
char === ' '
@ -685,6 +711,8 @@ export function KeypressProvider({
!key.sequence.startsWith(FOCUS_OUT))
) {
kittySequenceBuffer += key.sequence;
kittySequenceBufferRef.current = kittySequenceBuffer;
startKittyTimeout();
if (debugKeystrokeLogging) {
debugLogger.debug(
@ -720,6 +748,10 @@ export function KeypressProvider({
}
// Consume the parsed prefix and broadcast it.
kittySequenceBuffer = kittySequenceBuffer.slice(parsed.length);
kittySequenceBufferRef.current = kittySequenceBuffer;
if (!kittySequenceBuffer) {
clearKittyTimeout();
}
broadcast(parsed.key);
bufferedInputHandled = true;
continue;
@ -737,6 +769,10 @@ export function KeypressProvider({
kittySequenceBuffer = kittySequenceBuffer.slice(
completeUnsupportedCsiLength,
);
kittySequenceBufferRef.current = kittySequenceBuffer;
if (!kittySequenceBuffer) {
clearKittyTimeout();
}
bufferedInputHandled = true;
continue;
}
@ -752,6 +788,10 @@ export function KeypressProvider({
kittySequenceBuffer = kittySequenceBuffer.slice(
plainTextPrefix.length,
);
kittySequenceBufferRef.current = kittySequenceBuffer;
if (!kittySequenceBuffer) {
clearKittyTimeout();
}
broadcast(plainTextPrefix.key);
bufferedInputHandled = true;
continue;
@ -767,6 +807,10 @@ export function KeypressProvider({
);
}
kittySequenceBuffer = kittySequenceBuffer.slice(nextStart);
kittySequenceBufferRef.current = kittySequenceBuffer;
if (!kittySequenceBuffer) {
clearKittyTimeout();
}
bufferedInputHandled = true;
continue;
}
@ -796,6 +840,8 @@ export function KeypressProvider({
logKittySequenceOverflow(config, event);
}
kittySequenceBuffer = '';
kittySequenceBufferRef.current = '';
clearKittyTimeout();
} else {
return;
}
@ -956,6 +1002,8 @@ export function KeypressProvider({
backslashTimeout = null;
}
clearKittyTimeout();
if (rawFlushTimeout) {
clearTimeout(rawFlushTimeout);
rawFlushTimeout = null;