mirror of
http://10.0.2.1:3031/sauer/claude-code.git
synced 2026-06-30 19:46:58 +10:00
243 lines
30 KiB
TypeScript
243 lines
30 KiB
TypeScript
|
|
import { c as _c } from "react/compiler-runtime";
|
||
|
|
import * as React from 'react';
|
||
|
|
import { useEffect, useRef, useState } from 'react';
|
||
|
|
import { useInterval } from 'usehooks-ts';
|
||
|
|
import type { CommandResultDisplay } from '../../commands.js';
|
||
|
|
import { Markdown } from '../../components/Markdown.js';
|
||
|
|
import { SpinnerGlyph } from '../../components/Spinner/SpinnerGlyph.js';
|
||
|
|
import { DOWN_ARROW, UP_ARROW } from '../../constants/figures.js';
|
||
|
|
import { getSystemPrompt } from '../../constants/prompts.js';
|
||
|
|
import { useModalOrTerminalSize } from '../../context/modalContext.js';
|
||
|
|
import { getSystemContext, getUserContext } from '../../context.js';
|
||
|
|
import { useTerminalSize } from '../../hooks/useTerminalSize.js';
|
||
|
|
import ScrollBox, { type ScrollBoxHandle } from '../../ink/components/ScrollBox.js';
|
||
|
|
import type { KeyboardEvent } from '../../ink/events/keyboard-event.js';
|
||
|
|
import { Box, Text } from '../../ink.js';
|
||
|
|
import type { LocalJSXCommandOnDone } from '../../types/command.js';
|
||
|
|
import type { Message } from '../../types/message.js';
|
||
|
|
import { createAbortController } from '../../utils/abortController.js';
|
||
|
|
import { saveGlobalConfig } from '../../utils/config.js';
|
||
|
|
import { errorMessage } from '../../utils/errors.js';
|
||
|
|
import { type CacheSafeParams, getLastCacheSafeParams } from '../../utils/forkedAgent.js';
|
||
|
|
import { getMessagesAfterCompactBoundary } from '../../utils/messages.js';
|
||
|
|
import type { ProcessUserInputContext } from '../../utils/processUserInput/processUserInput.js';
|
||
|
|
import { runSideQuestion } from '../../utils/sideQuestion.js';
|
||
|
|
import { asSystemPrompt } from '../../utils/systemPromptType.js';
|
||
|
|
type BtwComponentProps = {
|
||
|
|
question: string;
|
||
|
|
context: ProcessUserInputContext;
|
||
|
|
onDone: (result?: string, options?: {
|
||
|
|
display?: CommandResultDisplay;
|
||
|
|
}) => void;
|
||
|
|
};
|
||
|
|
const CHROME_ROWS = 5;
|
||
|
|
const OUTER_CHROME_ROWS = 6;
|
||
|
|
const SCROLL_LINES = 3;
|
||
|
|
function BtwSideQuestion(t0) {
|
||
|
|
const $ = _c(25);
|
||
|
|
const {
|
||
|
|
question,
|
||
|
|
context,
|
||
|
|
onDone
|
||
|
|
} = t0;
|
||
|
|
const [response, setResponse] = useState(null);
|
||
|
|
const [error, setError] = useState(null);
|
||
|
|
const [frame, setFrame] = useState(0);
|
||
|
|
const scrollRef = useRef(null);
|
||
|
|
const {
|
||
|
|
rows
|
||
|
|
} = useModalOrTerminalSize(useTerminalSize());
|
||
|
|
let t1;
|
||
|
|
if ($[0] === Symbol.for("react.memo_cache_sentinel")) {
|
||
|
|
t1 = () => setFrame(_temp);
|
||
|
|
$[0] = t1;
|
||
|
|
} else {
|
||
|
|
t1 = $[0];
|
||
|
|
}
|
||
|
|
useInterval(t1, response || error ? null : 80);
|
||
|
|
let t2;
|
||
|
|
if ($[1] !== onDone) {
|
||
|
|
t2 = function handleKeyDown(e) {
|
||
|
|
if (e.key === "escape" || e.key === "return" || e.key === " " || e.ctrl && (e.key === "c" || e.key === "d")) {
|
||
|
|
e.preventDefault();
|
||
|
|
onDone(undefined, {
|
||
|
|
display: "skip"
|
||
|
|
});
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
if (e.key === "up" || e.ctrl && e.key === "p") {
|
||
|
|
e.preventDefault();
|
||
|
|
scrollRef.current?.scrollBy(-SCROLL_LINES);
|
||
|
|
}
|
||
|
|
if (e.key === "down" || e.ctrl && e.key === "n") {
|
||
|
|
e.preventDefault();
|
||
|
|
scrollRef.current?.scrollBy(SCROLL_LINES);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
$[1] = onDone;
|
||
|
|
$[2] = t2;
|
||
|
|
} else {
|
||
|
|
t2 = $[2];
|
||
|
|
}
|
||
|
|
const handleKeyDown = t2;
|
||
|
|
let t3;
|
||
|
|
let t4;
|
||
|
|
if ($[3] !== context || $[4] !== question) {
|
||
|
|
t3 = () => {
|
||
|
|
const abortController = createAbortController();
|
||
|
|
const fetchResponse = async function fetchResponse() {
|
||
|
|
;
|
||
|
|
try {
|
||
|
|
const cacheSafeParams = await buildCacheSafeParams(context);
|
||
|
|
const result = await runSideQuestion({
|
||
|
|
question,
|
||
|
|
cacheSafeParams
|
||
|
|
});
|
||
|
|
if (!abortController.signal.aborted) {
|
||
|
|
if (result.response) {
|
||
|
|
setResponse(result.response);
|
||
|
|
} else {
|
||
|
|
setError("No response received");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} catch (t5) {
|
||
|
|
const err = t5;
|
||
|
|
if (!abortController.signal.aborted) {
|
||
|
|
setError(errorMessage(err) || "Failed to get response");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
};
|
||
|
|
fetchResponse();
|
||
|
|
return () => {
|
||
|
|
abortController.abort();
|
||
|
|
};
|
||
|
|
};
|
||
|
|
t4 = [question, context];
|
||
|
|
$[3] = context;
|
||
|
|
$[4] = question;
|
||
|
|
$[5] = t3;
|
||
|
|
$[6] = t4;
|
||
|
|
} else {
|
||
|
|
t3 = $[5];
|
||
|
|
t4 = $[6];
|
||
|
|
}
|
||
|
|
useEffect(t3, t4);
|
||
|
|
const maxContentHeight = Math.max(5, rows - CHROME_ROWS - OUTER_CHROME_ROWS);
|
||
|
|
let t5;
|
||
|
|
if ($[7] === Symbol.for("react.memo_cache_sentinel")) {
|
||
|
|
t5 = <Text color="warning" bold={true}>/btw{" "}</Text>;
|
||
|
|
$[7] = t5;
|
||
|
|
} else {
|
||
|
|
t5 = $[7];
|
||
|
|
}
|
||
|
|
let t6;
|
||
|
|
if ($[8] !== question) {
|
||
|
|
t6 = <Box>{t5}<Text dimColor={true}>{question}</Text></Box>;
|
||
|
|
$[8] = question;
|
||
|
|
$[9] = t6;
|
||
|
|
} else {
|
||
|
|
t6 = $[9];
|
||
|
|
}
|
||
|
|
let t7;
|
||
|
|
if ($[10] !== error || $[11] !== frame || $[12] !== response) {
|
||
|
|
t7 = <ScrollBox ref={scrollRef} flexDirection="column" flexGrow={1}>{error ? <Text color="error">{error}</Text> : response ? <Markdown>{response}</Markdown> : <Box><SpinnerGlyph frame={frame} messageColor="warning" /><Text color="warning">Answering...</Text></Box>}</ScrollBox>;
|
||
|
|
$[10] = error;
|
||
|
|
$[11] = frame;
|
||
|
|
$[12] = response;
|
||
|
|
$[13] = t7;
|
||
|
|
} else {
|
||
|
|
t7 = $[13];
|
||
|
|
}
|
||
|
|
let t8;
|
||
|
|
if ($[14] !== maxContentHeight || $[15] !== t7) {
|
||
|
|
t8 = <Box marginTop={1} marginLeft={2} maxHeight={maxContentHeight}>{t7}</Box>;
|
||
|
|
$[14] = maxContentHeight;
|
||
|
|
$[15] = t7;
|
||
|
|
$[16] = t8;
|
||
|
|
} else {
|
||
|
|
t8 = $[16];
|
||
|
|
}
|
||
|
|
let t9;
|
||
|
|
if ($[17] !== error || $[18] !== response) {
|
||
|
|
t9 = (response || error) && <Box marginTop={1}><Text dimColor={true}>{UP_ARROW}/{DOWN_ARROW} to scroll · Space, Enter, or Escape to dismiss</Text></Box>;
|
||
|
|
$[17] = error;
|
||
|
|
$[18] = response;
|
||
|
|
$[19] = t9;
|
||
|
|
} else {
|
||
|
|
t9 = $[19];
|
||
|
|
}
|
||
|
|
let t10;
|
||
|
|
if ($[20] !== handleKeyDown || $[21] !== t6 || $[22] !== t8 || $[23] !== t9) {
|
||
|
|
t10 = <Box flexDirection="column" paddingLeft={2} marginTop={1} tabIndex={0} autoFocus={true} onKeyDown={handleKeyDown}>{t6}{t8}{t9}</Box>;
|
||
|
|
$[20] = handleKeyDown;
|
||
|
|
$[21] = t6;
|
||
|
|
$[22] = t8;
|
||
|
|
$[23] = t9;
|
||
|
|
$[24] = t10;
|
||
|
|
} else {
|
||
|
|
t10 = $[24];
|
||
|
|
}
|
||
|
|
return t10;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Build CacheSafeParams for the side question fork.
|
||
|
|
*
|
||
|
|
* The preferred source is getLastCacheSafeParams — the exact
|
||
|
|
* systemPrompt/userContext/systemContext bytes the main thread sent on its
|
||
|
|
* last request (captured in stopHooks). Reusing them guarantees a byte-
|
||
|
|
* identical prefix and thus a prompt cache hit. We pair these with the
|
||
|
|
* current toolUseContext (for thinkingConfig/tools) and current messages
|
||
|
|
* (for up-to-date context).
|
||
|
|
*
|
||
|
|
* Fallback (first turn before stop hooks fire, or prompt-suggestion
|
||
|
|
* disabled): rebuild from scratch. This may miss the cache if the main loop
|
||
|
|
* applied buildEffectiveSystemPrompt extras (--agent, --system-prompt,
|
||
|
|
* --append-system-prompt, coordinator mode).
|
||
|
|
*/
|
||
|
|
function _temp(f) {
|
||
|
|
return f + 1;
|
||
|
|
}
|
||
|
|
function stripInProgressAssistantMessage(messages: Message[]): Message[] {
|
||
|
|
const last = messages.at(-1);
|
||
|
|
if (last?.type === 'assistant' && last.message.stop_reason === null) {
|
||
|
|
return messages.slice(0, -1);
|
||
|
|
}
|
||
|
|
return messages;
|
||
|
|
}
|
||
|
|
async function buildCacheSafeParams(context: ProcessUserInputContext): Promise<CacheSafeParams> {
|
||
|
|
const forkContextMessages = getMessagesAfterCompactBoundary(stripInProgressAssistantMessage(context.messages));
|
||
|
|
const saved = getLastCacheSafeParams();
|
||
|
|
if (saved) {
|
||
|
|
return {
|
||
|
|
systemPrompt: saved.systemPrompt,
|
||
|
|
userContext: saved.userContext,
|
||
|
|
systemContext: saved.systemContext,
|
||
|
|
toolUseContext: context,
|
||
|
|
forkContextMessages
|
||
|
|
};
|
||
|
|
}
|
||
|
|
const [rawSystemPrompt, userContext, systemContext] = await Promise.all([getSystemPrompt(context.options.tools, context.options.mainLoopModel, [], context.options.mcpClients), getUserContext(), getSystemContext()]);
|
||
|
|
return {
|
||
|
|
systemPrompt: asSystemPrompt(rawSystemPrompt),
|
||
|
|
userContext,
|
||
|
|
systemContext,
|
||
|
|
toolUseContext: context,
|
||
|
|
forkContextMessages
|
||
|
|
};
|
||
|
|
}
|
||
|
|
export async function call(onDone: LocalJSXCommandOnDone, context: ProcessUserInputContext, args: string): Promise<React.ReactNode> {
|
||
|
|
const question = args?.trim();
|
||
|
|
if (!question) {
|
||
|
|
onDone('Usage: /btw <your question>', {
|
||
|
|
display: 'system'
|
||
|
|
});
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
saveGlobalConfig(current => ({
|
||
|
|
...current,
|
||
|
|
btwUseCount: current.btwUseCount + 1
|
||
|
|
}));
|
||
|
|
return <BtwSideQuestion question={question} context={context} onDone={onDone} />;
|
||
|
|
}
|
||
|
|
//# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJ2ZXJzaW9uIjozLCJuYW1lcyI6WyJSZWFjdCIsInVzZUVmZmVjdCIsInVzZVJlZiIsInVzZVN0YXRlIiwidXNlSW50ZXJ2YWwiLCJDb21tYW5kUmVzdWx0RGlzcGxheSIsIk1hcmtkb3duIiwiU3Bpbm5lckdseXBoIiwiRE9XTl9BUlJPVyIsIlVQX0FSUk9XIiwiZ2V0U3lzdGVtUHJvbXB0IiwidXNlTW9kYWxPclRlcm1pbmFsU2l6ZSIsImdldFN5c3RlbUNvbnRleHQiLCJnZXRVc2VyQ29udGV4dCIsInVzZVRlcm1pbmFsU2l6ZSIsIlNjcm9sbEJveCIsIlNjcm9sbEJveEhhbmRsZSIsIktleWJvYXJkRXZlbnQiLCJCb3giLCJUZXh0IiwiTG9jYWxKU1hDb21tYW5kT25Eb25lIiwiTWVzc2FnZSIsImNyZWF0ZUFib3J0Q29udHJvbGxlciIsInNhdmVHbG9iYWxDb25maWciLCJlcnJvck1lc3NhZ2UiLCJDYWNoZVNhZmVQYXJhbXMiLCJnZXRMYXN0Q2FjaGVTYWZlUGFyYW1zIiwiZ2V0TWVzc2FnZXNBZnRlckNvbXBhY3RCb3VuZGFyeSIsIlByb2Nlc3NVc2VySW5wdXRDb250ZXh0IiwicnVuU2lkZVF1ZXN0aW9uIiwiYXNTeXN0ZW1Qcm9tcHQiLCJCdHdDb21wb25lbnRQcm9wcyIsInF1ZXN0aW9uIiwiY29udGV4dCIsIm9uRG9uZSIsInJlc3VsdCIsIm9wdGlvbnMiLCJkaXNwbGF5IiwiQ0hST01FX1JPV1MiLCJPVVRFUl9DSFJPTUVfUk9XUyIsIlNDUk9MTF9MSU5FUyIsIkJ0d1NpZGVRdWVzdGlvbiIsInQwIiwiJCIsIl9jIiwicmVzcG9uc2UiLCJzZXRSZXNwb25zZSIsImVycm9yIiwic2V0RXJyb3IiLCJmcmFtZSIsInNldEZyYW1lIiwic2Nyb2xsUmVmIiwicm93cyIsInQxIiwiU3ltYm9sIiwiZm9yIiwiX3RlbXAiLCJ0MiIsImhhbmRsZUtleURvd24iLCJlIiwia2V5IiwiY3RybCIsInByZXZlbnREZWZhdWx0IiwidW5kZWZpbmVkIiwiY3VycmVudCIsInNjcm9sbEJ5IiwidDMiLCJ0NCIsImFib3J0Q29udHJvbGxlciIsImZldGNoUmVzcG9uc2UiLCJjYWNoZVNhZmVQYXJhbXMiLCJidWlsZENhY2hlU2FmZVBhcmFtcyIsInNpZ25hbCIsImFib3J0ZWQiLCJ0NSIsImVyciIsImFib3J0IiwibWF4Q29udGVudEhlaWdodCIsIk1hdGgiLCJtYXgiLCJ0NiIsInQ3IiwidDgiLCJ0OSIsInQxMCIsImYiLCJzdHJpcEluUHJvZ3Jlc3NBc3Npc3RhbnRNZXNzYWdlIiwibWVzc2FnZXMiLCJsYXN0IiwiYXQiLCJ0eXBlIiwibWVzc2FnZSIsInN0b3BfcmVhc29uIiwic2xpY2UiLCJQcm9taXNlIiwiZm9ya0NvbnRleHRNZXNzYWdlcyIsInNhdmVkIiwic3lzdGVtUHJvbXB0IiwidXNlckNvbnRleHQiLCJzeXN0ZW1Db250ZXh0IiwidG9vbFVzZUNvbnRleHQiLCJyYXdTeXN0ZW1Qcm9tcHQiLCJhbGwiLCJ0b29scyIsIm1haW5Mb29wTW9kZWwiLCJtY3BDbGllbnRzIiwiY2FsbCIsImFyZ3MiLCJSZWFjdE5vZGUiLCJ0cmltIiwiYnR3VXNlQ291bnQiXSwic291cmNlcyI6WyJidHcudHN4Il0sInNvdXJjZXNDb250ZW50IjpbImltcG9ydCAqIGFzIFJlYWN0IGZyb20gJ3JlYWN0J1xuaW1wb3J0IHsgdXNlRWZmZWN0LCB1c2VSZWYsIHVzZVN0YXRlIH0gZnJvbSAncmVhY3QnXG5pbXBvcnQgeyB1c2VJbnRlcnZhbCB9IGZyb20gJ3VzZWhvb2tzLXRzJ1xuaW1wb3J0IHR5cGUgeyBDb21tYW5kUmVzdWx0RGlzcGxheSB9IGZyb20gJy4uLy4uL2NvbW1hbmRzLmpzJ1xuaW1wb3J0IHsgTWFya2Rvd24gfSBmcm9tICcuLi8uLi9jb21wb25lbnRzL01hcmtkb3duLmpzJ1xuaW1wb3J0IHsgU3Bpbm5lckdseXBoIH0gZnJvbSAnLi4vLi4vY29tcG9uZW50cy9TcGlubmVyL1NwaW5uZXJHbHlwaC5qcydcbmltcG9ydCB7IERPV05fQVJST1csIFVQX0FSUk9XIH0gZnJvbSAnLi4vLi4vY29uc3RhbnRzL2ZpZ3VyZXMuanMnXG5pbXBvcnQgeyBnZXRTeXN0ZW1Qcm9tcHQgfSBmcm9tICcuLi8uLi9jb25zdGFudHMvcHJvbXB0cy5qcydcbmltcG9ydCB7IHVzZU1vZGFsT3JUZXJtaW5hbFNpemUgfSBmcm9tICcuLi8uLi9jb250ZXh0L21vZGFsQ29udGV4dC5qcydcbmltcG9ydCB7IGdldFN5c3RlbUNvbnRleHQsIGdldFVzZXJDb250ZXh0IH0gZnJvbSAnLi4vLi4vY29udGV4dC5qcydcbmltcG9ydCB7IHVzZVRlcm1pbmFsU2l6ZSB9IGZyb20gJy4uLy4uL2hvb2tzL3VzZVRlcm1pbmFsU2l6ZS5qcydcbmltcG9ydCBTY3JvbGxCb3gsIHtcbiAgdHlwZSBTY3JvbGxCb3hIYW5kbGUsXG59IGZyb20gJy4uLy4uL2luay9jb21wb25lbnRzL1Njcm9sbEJveC5qcydcbmltcG9ydCB0eXBlIHsgS2V5Ym9hcmRFdmVudCB9IGZyb20gJy4uLy4uL2luay9ldmVudHMva2V5Ym9hcmQtZXZlbnQuanMnXG5pbXBvcnQgeyBCb3gsIFRleHQgfSBmcm9tICcuLi8uLi9pbmsuanMnXG5pbXBvcnQgdHlwZSB7IExvY2FsSlNYQ29tbWFuZE9uRG9uZSB9IGZyb20gJy4uLy4uL3R5cGVzL2NvbW1hbmQuanMnXG5pbXBvcnQgdHlwZSB7IE1lc3NhZ2UgfSBmcm9tICcuLi8uLi90eXBlcy9tZXNzYWdlLmpzJ1xuaW1wb3J0IHsgY3JlYXRlQWJvcnRDb250cm9sbGVyIH0gZnJvbSAnLi4vLi4vdXRpbHMvYWJvcnRDb250cm9sbGVyLmpzJ1xuaW1wb3J0IHsgc2F2ZUdsb2JhbENvbmZpZyB9IGZyb20gJy4uLy4uL3V0aWxzL2NvbmZpZy5qcydcbmltcG9ydCB7IGVycm9yTWVzc2FnZSB9IGZyb20gJy4uLy4uL3V0aWxzL2Vycm9ycy5qcydcbmltcG9ydCB7XG4gIHR5cGUgQ2FjaGVTYWZlUGFyYW1zLFxuICBnZXRMYXN0Q2FjaGVTYWZlUGFyYW1zLFxufSBmcm9tICcuLi8uLi91dGlscy9mb3JrZWRBZ2VudC5qcydcbmltcG9ydCB7IGdldE1lc3NhZ2VzQWZ0ZXJDb21wYWN0Qm91bmRhcnkgfSBmcm9tICcuLi8uLi91dGlscy9tZXNzYWdlcy5qcydcbmltcG9ydCB0eXBlIHsgUHJvY2Vzc1VzZXJJbnB1dENvbnRleHQgfSBmcm9tICcuLi8uLi91dGlscy9wcm9jZXNzVXNlcklucHV0L3Byb2Nlc3NVc2VySW5wdXQuanMnXG5pbXBvcnQgeyBydW5TaWRlUXVlc3Rpb24gfSBmcm9tICcuLi8uLi91dGlscy9zaWRlUXVlc3Rpb24uanMnXG5pbXBvcnQgeyBhc1N5c3RlbVByb21wdCB9IGZyb20gJy4uLy4uL3V0aWxzL3N5c3RlbVByb21wdFR5cGUuanMnXG5cbnR5cGUgQnR3Q29tcG9uZW50UHJvcHMgPSB
|