up
This commit is contained in:
190
modules/_ai-tools/extensions/no-git.ts
Normal file
190
modules/_ai-tools/extensions/no-git.ts
Normal file
@@ -0,0 +1,190 @@
|
||||
/**
|
||||
* No Git Extension
|
||||
*
|
||||
* Blocks direct git invocations and tells the LLM to use jj (Jujutsu) instead.
|
||||
* Mentions of the word "git" in search patterns, strings, comments, etc. are allowed.
|
||||
*/
|
||||
|
||||
import type { ExtensionAPI } from "@mariozechner/pi-coding-agent";
|
||||
import { isToolCallEventType } from "@mariozechner/pi-coding-agent";
|
||||
|
||||
type ShellToken =
|
||||
| { type: "word"; value: string }
|
||||
| { type: "operator"; value: string };
|
||||
|
||||
const COMMAND_PREFIXES = new Set(["env", "command", "builtin", "time", "sudo", "nohup", "nice"]);
|
||||
const SHELL_KEYWORDS = new Set(["if", "then", "elif", "else", "do", "while", "until", "case", "in"]);
|
||||
const SHELL_INTERPRETERS = new Set(["bash", "sh", "zsh", "fish", "nu"]);
|
||||
|
||||
function isAssignmentWord(value: string): boolean {
|
||||
return /^[A-Za-z_][A-Za-z0-9_]*=.*/.test(value);
|
||||
}
|
||||
|
||||
function tokenizeShell(command: string): ShellToken[] {
|
||||
const tokens: ShellToken[] = [];
|
||||
let current = "";
|
||||
let quote: "'" | '"' | null = null;
|
||||
|
||||
const pushWord = () => {
|
||||
if (!current) return;
|
||||
tokens.push({ type: "word", value: current });
|
||||
current = "";
|
||||
};
|
||||
|
||||
for (let i = 0; i < command.length; i++) {
|
||||
const char = command[i];
|
||||
|
||||
if (quote) {
|
||||
if (quote === "'") {
|
||||
if (char === "'") {
|
||||
quote = null;
|
||||
} else {
|
||||
current += char;
|
||||
}
|
||||
continue;
|
||||
}
|
||||
|
||||
if (char === '"') {
|
||||
quote = null;
|
||||
continue;
|
||||
}
|
||||
|
||||
if (char === "\\") {
|
||||
if (i + 1 < command.length) {
|
||||
current += command[i + 1];
|
||||
i += 1;
|
||||
}
|
||||
continue;
|
||||
}
|
||||
|
||||
current += char;
|
||||
continue;
|
||||
}
|
||||
|
||||
if (char === "'" || char === '"') {
|
||||
quote = char;
|
||||
continue;
|
||||
}
|
||||
|
||||
if (char === "\\") {
|
||||
if (i + 1 < command.length) {
|
||||
current += command[i + 1];
|
||||
i += 1;
|
||||
}
|
||||
continue;
|
||||
}
|
||||
|
||||
if (/\s/.test(char)) {
|
||||
pushWord();
|
||||
if (char === "\n") {
|
||||
tokens.push({ type: "operator", value: "\n" });
|
||||
}
|
||||
continue;
|
||||
}
|
||||
|
||||
const twoCharOperator = command.slice(i, i + 2);
|
||||
if (twoCharOperator === "&&" || twoCharOperator === "||") {
|
||||
pushWord();
|
||||
tokens.push({ type: "operator", value: twoCharOperator });
|
||||
i += 1;
|
||||
continue;
|
||||
}
|
||||
|
||||
if (char === ";" || char === "|" || char === "(" || char === ")") {
|
||||
pushWord();
|
||||
tokens.push({ type: "operator", value: char });
|
||||
continue;
|
||||
}
|
||||
|
||||
current += char;
|
||||
}
|
||||
|
||||
pushWord();
|
||||
return tokens;
|
||||
}
|
||||
|
||||
function findCommandWord(words: string[]): { word?: string; index: number } {
|
||||
for (let i = 0; i < words.length; i++) {
|
||||
const word = words[i];
|
||||
if (SHELL_KEYWORDS.has(word)) {
|
||||
continue;
|
||||
}
|
||||
if (isAssignmentWord(word)) {
|
||||
continue;
|
||||
}
|
||||
if (COMMAND_PREFIXES.has(word)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
return { word, index: i };
|
||||
}
|
||||
|
||||
return { index: words.length };
|
||||
}
|
||||
|
||||
function getInlineShellCommand(words: string[], commandIndex: number): string | null {
|
||||
for (let i = commandIndex + 1; i < words.length; i++) {
|
||||
const word = words[i];
|
||||
if (/^(?:-[A-Za-z]*c[A-Za-z]*|--command)$/.test(word)) {
|
||||
return words[i + 1] ?? null;
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
function segmentContainsBlockedGit(words: string[]): boolean {
|
||||
const { word, index } = findCommandWord(words);
|
||||
if (!word) {
|
||||
return false;
|
||||
}
|
||||
|
||||
if (word === "git") {
|
||||
return true;
|
||||
}
|
||||
|
||||
if (word === "jj") {
|
||||
return false;
|
||||
}
|
||||
|
||||
if (SHELL_INTERPRETERS.has(word)) {
|
||||
const inlineCommand = getInlineShellCommand(words, index);
|
||||
return inlineCommand ? containsBlockedGitInvocation(inlineCommand) : false;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
function containsBlockedGitInvocation(command: string): boolean {
|
||||
const tokens = tokenizeShell(command);
|
||||
let words: string[] = [];
|
||||
|
||||
for (const token of tokens) {
|
||||
if (token.type === "operator") {
|
||||
if (segmentContainsBlockedGit(words)) {
|
||||
return true;
|
||||
}
|
||||
words = [];
|
||||
continue;
|
||||
}
|
||||
|
||||
words.push(token.value);
|
||||
}
|
||||
|
||||
return segmentContainsBlockedGit(words);
|
||||
}
|
||||
|
||||
export default function (pi: ExtensionAPI) {
|
||||
pi.on("tool_call", async (event, _ctx) => {
|
||||
if (!isToolCallEventType("bash", event)) return;
|
||||
|
||||
const command = event.input.command.trim();
|
||||
|
||||
if (containsBlockedGitInvocation(command)) {
|
||||
return {
|
||||
block: true,
|
||||
reason: "git is not used in this project. Use jj (Jujutsu) instead.",
|
||||
};
|
||||
}
|
||||
});
|
||||
}
|
||||
28
modules/_ai-tools/extensions/no-scripting.ts
Normal file
28
modules/_ai-tools/extensions/no-scripting.ts
Normal file
@@ -0,0 +1,28 @@
|
||||
/**
|
||||
* No Scripting Extension
|
||||
*
|
||||
* Blocks python, perl, ruby, php, lua, node -e, and inline bash/sh scripts.
|
||||
* Tells the LLM to use `nu -c` instead.
|
||||
*/
|
||||
|
||||
import type { ExtensionAPI } from "@mariozechner/pi-coding-agent";
|
||||
import { isToolCallEventType } from "@mariozechner/pi-coding-agent";
|
||||
|
||||
const SCRIPTING_PATTERN =
|
||||
/(?:^|[;&|]\s*|&&\s*|\|\|\s*|\$\(\s*|`\s*)(?:python[23]?|perl|ruby|php|lua|node\s+-e|bash\s+-c|sh\s+-c)\s/;
|
||||
|
||||
export default function (pi: ExtensionAPI) {
|
||||
pi.on("tool_call", async (event, _ctx) => {
|
||||
if (!isToolCallEventType("bash", event)) return;
|
||||
|
||||
const command = event.input.command.trim();
|
||||
|
||||
if (SCRIPTING_PATTERN.test(command)) {
|
||||
return {
|
||||
block: true,
|
||||
reason:
|
||||
"Do not use python, perl, ruby, php, lua, node -e, or inline bash/sh for scripting. Use `nu -c` instead.",
|
||||
};
|
||||
}
|
||||
});
|
||||
}
|
||||
2376
modules/_ai-tools/extensions/review.ts
Normal file
2376
modules/_ai-tools/extensions/review.ts
Normal file
File diff suppressed because it is too large
Load Diff
260
modules/_ai-tools/extensions/session-name.ts
Normal file
260
modules/_ai-tools/extensions/session-name.ts
Normal file
@@ -0,0 +1,260 @@
|
||||
import type { ExtensionAPI, ExtensionContext } from "@mariozechner/pi-coding-agent";
|
||||
import {
|
||||
createAgentSession,
|
||||
DefaultResourceLoader,
|
||||
getAgentDir,
|
||||
SessionManager,
|
||||
SettingsManager,
|
||||
} from "@mariozechner/pi-coding-agent";
|
||||
|
||||
interface SessionNameState {
|
||||
hasAutoNamed: boolean;
|
||||
}
|
||||
|
||||
const TITLE_MODEL = {
|
||||
provider: "openai-codex",
|
||||
id: "gpt-5.4-mini",
|
||||
} as const;
|
||||
|
||||
const MAX_TITLE_LENGTH = 50;
|
||||
const MAX_RETRIES = 2;
|
||||
const FALLBACK_LENGTH = 50;
|
||||
const TITLE_ENTRY_TYPE = "vendored-session-title";
|
||||
|
||||
const TITLE_SYSTEM_PROMPT = `You are generating a succinct title for a coding session based on the provided conversation.
|
||||
|
||||
Requirements:
|
||||
- Maximum 50 characters
|
||||
- Sentence case (capitalize only first word and proper nouns)
|
||||
- Capture the main intent or task
|
||||
- Reuse the user's exact words and technical terms
|
||||
- Match the user's language
|
||||
- No quotes, colons, or markdown formatting
|
||||
- No generic titles like "Coding session" or "Help with code"
|
||||
- No explanations or commentary
|
||||
|
||||
Output ONLY the title text. Nothing else.`;
|
||||
|
||||
function isTurnCompleted(event: unknown): boolean {
|
||||
if (!event || typeof event !== "object") return false;
|
||||
const message = (event as { message?: unknown }).message;
|
||||
if (!message || typeof message !== "object") return false;
|
||||
const stopReason = (message as { stopReason?: unknown }).stopReason;
|
||||
return typeof stopReason === "string" && stopReason.toLowerCase() === "stop";
|
||||
}
|
||||
|
||||
function buildFallbackTitle(userText: string): string {
|
||||
const text = userText.trim();
|
||||
if (text.length <= FALLBACK_LENGTH) return text;
|
||||
const truncated = text.slice(0, FALLBACK_LENGTH - 3);
|
||||
const lastSpace = truncated.lastIndexOf(" ");
|
||||
return `${lastSpace > 0 ? truncated.slice(0, lastSpace) : truncated}...`;
|
||||
}
|
||||
|
||||
function postProcessTitle(raw: string): string {
|
||||
let title = raw;
|
||||
|
||||
title = title.replace(/<thinking[\s\S]*?<\/thinking>\s*/g, "");
|
||||
title = title.replace(/^["'`]+|["'`]+$/g, "");
|
||||
title = title.replace(/^#+\s*/, "");
|
||||
title = title.replace(/\*{1,2}(.*?)\*{1,2}/g, "$1");
|
||||
title = title.replace(/_{1,2}(.*?)_{1,2}/g, "$1");
|
||||
title = title.replace(/^(Title|Summary|Session)\s*:\s*/i, "");
|
||||
title =
|
||||
title
|
||||
.split("\n")
|
||||
.map((line) => line.trim())
|
||||
.find((line) => line.length > 0) ?? title;
|
||||
title = title.trim();
|
||||
|
||||
if (title.length > MAX_TITLE_LENGTH) {
|
||||
const truncated = title.slice(0, MAX_TITLE_LENGTH - 3);
|
||||
const lastSpace = truncated.lastIndexOf(" ");
|
||||
title = `${lastSpace > 0 ? truncated.slice(0, lastSpace) : truncated}...`;
|
||||
}
|
||||
|
||||
return title;
|
||||
}
|
||||
|
||||
function getLatestUserText(ctx: ExtensionContext): string | null {
|
||||
const entries = ctx.sessionManager.getEntries();
|
||||
for (let i = entries.length - 1; i >= 0; i -= 1) {
|
||||
const entry = entries[i];
|
||||
if (!entry || entry.type !== "message") continue;
|
||||
if (entry.message.role !== "user") continue;
|
||||
|
||||
const { content } = entry.message as { content: unknown };
|
||||
if (typeof content === "string") return content;
|
||||
if (!Array.isArray(content)) return null;
|
||||
|
||||
return content
|
||||
.filter(
|
||||
(part): part is { type: string; text?: string } =>
|
||||
typeof part === "object" && part !== null && "type" in part,
|
||||
)
|
||||
.filter((part) => part.type === "text" && typeof part.text === "string")
|
||||
.map((part) => part.text ?? "")
|
||||
.join(" ");
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
function getLatestAssistantText(ctx: ExtensionContext): string | null {
|
||||
const entries = ctx.sessionManager.getEntries();
|
||||
for (let i = entries.length - 1; i >= 0; i -= 1) {
|
||||
const entry = entries[i];
|
||||
if (!entry || entry.type !== "message") continue;
|
||||
if (entry.message.role !== "assistant") continue;
|
||||
|
||||
const { content } = entry.message as { content: unknown };
|
||||
if (typeof content === "string") return content;
|
||||
if (!Array.isArray(content)) return null;
|
||||
|
||||
return content
|
||||
.filter(
|
||||
(part): part is { type: string; text?: string } =>
|
||||
typeof part === "object" && part !== null && "type" in part,
|
||||
)
|
||||
.filter((part) => part.type === "text" && typeof part.text === "string")
|
||||
.map((part) => part.text ?? "")
|
||||
.join("\n");
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
function resolveModel(ctx: ExtensionContext) {
|
||||
const available = ctx.modelRegistry.getAvailable();
|
||||
const model = available.find(
|
||||
(candidate) => candidate.provider === TITLE_MODEL.provider && candidate.id === TITLE_MODEL.id,
|
||||
);
|
||||
if (model) return model;
|
||||
|
||||
const existsWithoutKey = ctx.modelRegistry
|
||||
.getAll()
|
||||
.some((candidate) => candidate.provider === TITLE_MODEL.provider && candidate.id === TITLE_MODEL.id);
|
||||
if (existsWithoutKey) {
|
||||
throw new Error(
|
||||
`Model ${TITLE_MODEL.provider}/${TITLE_MODEL.id} exists but has no configured API key.`,
|
||||
);
|
||||
}
|
||||
|
||||
throw new Error(`Model ${TITLE_MODEL.provider}/${TITLE_MODEL.id} is not available.`);
|
||||
}
|
||||
|
||||
async function generateTitle(userText: string, assistantText: string, ctx: ExtensionContext): Promise<string> {
|
||||
const agentDir = getAgentDir();
|
||||
const settingsManager = SettingsManager.create(ctx.cwd, agentDir);
|
||||
const resourceLoader = new DefaultResourceLoader({
|
||||
cwd: ctx.cwd,
|
||||
agentDir,
|
||||
settingsManager,
|
||||
noExtensions: true,
|
||||
noPromptTemplates: true,
|
||||
noThemes: true,
|
||||
noSkills: true,
|
||||
systemPromptOverride: () => TITLE_SYSTEM_PROMPT,
|
||||
appendSystemPromptOverride: () => [],
|
||||
agentsFilesOverride: () => ({ agentsFiles: [] }),
|
||||
});
|
||||
await resourceLoader.reload();
|
||||
|
||||
const { session } = await createAgentSession({
|
||||
model: resolveModel(ctx),
|
||||
thinkingLevel: "off",
|
||||
sessionManager: SessionManager.inMemory(),
|
||||
modelRegistry: ctx.modelRegistry,
|
||||
resourceLoader,
|
||||
});
|
||||
|
||||
let accumulated = "";
|
||||
const unsubscribe = session.subscribe((event) => {
|
||||
if (event.type === "message_update" && event.assistantMessageEvent.type === "text_delta") {
|
||||
accumulated += event.assistantMessageEvent.delta;
|
||||
}
|
||||
});
|
||||
|
||||
const description = assistantText
|
||||
? `<user>${userText}</user>\n<assistant>${assistantText}</assistant>`
|
||||
: `<user>${userText}</user>`;
|
||||
const userMessage = `<conversation>\n${description}\n</conversation>\n\nGenerate a title:`;
|
||||
|
||||
try {
|
||||
await session.prompt(userMessage);
|
||||
} finally {
|
||||
unsubscribe();
|
||||
session.dispose();
|
||||
}
|
||||
|
||||
return postProcessTitle(accumulated);
|
||||
}
|
||||
|
||||
async function generateAndSetTitle(pi: ExtensionAPI, ctx: ExtensionContext): Promise<void> {
|
||||
const userText = getLatestUserText(ctx);
|
||||
if (!userText?.trim()) return;
|
||||
|
||||
const assistantText = getLatestAssistantText(ctx) ?? "";
|
||||
if (!assistantText.trim()) return;
|
||||
|
||||
let lastError: Error | null = null;
|
||||
for (let attempt = 1; attempt <= MAX_RETRIES; attempt += 1) {
|
||||
try {
|
||||
const title = await generateTitle(userText, assistantText, ctx);
|
||||
if (!title) continue;
|
||||
|
||||
pi.setSessionName(title);
|
||||
pi.appendEntry(TITLE_ENTRY_TYPE, {
|
||||
title,
|
||||
rawUserText: userText,
|
||||
rawAssistantText: assistantText,
|
||||
attempt,
|
||||
model: `${TITLE_MODEL.provider}/${TITLE_MODEL.id}`,
|
||||
});
|
||||
ctx.ui.notify(`Session: ${title}`, "info");
|
||||
return;
|
||||
} catch (error) {
|
||||
lastError = error instanceof Error ? error : new Error(String(error));
|
||||
}
|
||||
}
|
||||
|
||||
const fallback = buildFallbackTitle(userText);
|
||||
pi.setSessionName(fallback);
|
||||
pi.appendEntry(TITLE_ENTRY_TYPE, {
|
||||
title: fallback,
|
||||
fallback: true,
|
||||
error: lastError?.message ?? "Unknown error",
|
||||
rawUserText: userText,
|
||||
rawAssistantText: assistantText,
|
||||
model: `${TITLE_MODEL.provider}/${TITLE_MODEL.id}`,
|
||||
});
|
||||
ctx.ui.notify(`Title generation failed, using fallback: ${fallback}`, "warning");
|
||||
}
|
||||
|
||||
export default function setupSessionNameHook(pi: ExtensionAPI) {
|
||||
const state: SessionNameState = {
|
||||
hasAutoNamed: false,
|
||||
};
|
||||
|
||||
pi.on("session_start", async () => {
|
||||
state.hasAutoNamed = false;
|
||||
});
|
||||
|
||||
pi.on("session_switch", async () => {
|
||||
state.hasAutoNamed = false;
|
||||
});
|
||||
|
||||
pi.on("turn_end", async (event, ctx) => {
|
||||
if (state.hasAutoNamed) return;
|
||||
|
||||
if (pi.getSessionName()) {
|
||||
state.hasAutoNamed = true;
|
||||
return;
|
||||
}
|
||||
|
||||
if (!isTurnCompleted(event)) return;
|
||||
|
||||
await generateAndSetTitle(pi, ctx);
|
||||
state.hasAutoNamed = true;
|
||||
});
|
||||
}
|
||||
Reference in New Issue
Block a user