Function queryOsc11

apps/kimi-code/src/tui/theme/detect.ts:59–105

(opts: { timeoutMs: number })

}

async function queryOsc11(opts: { timeoutMs: number }): Promise<ResolvedTheme | null> {
  const stdin = process.stdin as unknown as RawModeStdin;
  if (typeof stdin.setRawMode !== "function") return null;
  // If something else is already listening on stdin (e.g. another raw-mode
  // consumer), don't fight for it — punt to COLORFGBG instead.
  if (process.stdin.listenerCount("data") > 0) return null;

  const wasRaw = stdin.isRaw === true;
  let buffer = "";
  let listener: ((data: Buffer) => void) | null = null;
  let timer: NodeJS.Timeout | null = null;

  try {
    if (!wasRaw) stdin.setRawMode(true);

    const result = await new Promise<ResolvedTheme | null>((resolve) => {
      listener = (chunk: Buffer): void => {
        buffer += chunk.toString("utf8");
        const theme = parseOsc11BackgroundTheme(buffer);
        if (theme !== null) resolve(theme);
      };
      stdin.on("data", listener);
      timer = setTimeout(() => {
        resolve(null);
      }, opts.timeoutMs);
      try {
        process.stdout.write(OSC11_QUERY);
      } catch {
        resolve(null);
      }
    });

    return result;
  } catch {
    return null;
  } finally {
    if (timer !== null) clearTimeout(timer);
    if (listener !== null) stdin.off("data", listener);
    if (!wasRaw) {
      try {
        stdin.setRawMode(false);
      } catch {
        /* ignore — raw mode restoration best-effort */
      }
    }
  }
}

/**
 * COLORFGBG is `"fg;bg"` (sometimes `"fg;default;bg"`). The last token is