Files
oh-my-pi/packages/coding-agent/test/tools/python-execution.test.ts
T
can1357 52da3674a4 feat(coding-agent): added auto-rebase for stale atom/hashline anchors
- Added auto-rebasing for stale atom and hashline anchors within ±2 lines, with warning diagnostics.
- Removed atom range-locator support and dropped `between` ops, updating docs/tests for `sub` over `set` nudges.
- Changed no-op handling to track unchanged hashline edits and emit contextual hints for unchanged ranges.
- Expanded Anthropic strict error handling to retry on schema-too-complex and compiled-grammar-too-large errors.
- Added anchor-retargeting warning checks and updated edit tests to expect locator and range-locator rejections.
- Updated python tool-call fixtures by adding `title` to executed-cell payloads and adjusting related test expectations.
2026-04-26 05:22:15 +02:00

85 lines
2.6 KiB
TypeScript

import { afterEach, describe, expect, it, vi } from "bun:test";
import { Settings } from "@oh-my-pi/pi-coding-agent/config/settings";
import * as pythonExecutor from "@oh-my-pi/pi-coding-agent/ipy/executor";
import type { ToolSession } from "@oh-my-pi/pi-coding-agent/tools";
import { PythonTool } from "@oh-my-pi/pi-coding-agent/tools/python";
import { TempDir } from "@oh-my-pi/pi-utils";
function createSession(cwd: string, kernelOwnerId?: string): ToolSession {
return {
cwd,
hasUI: false,
getSessionFile: () => `${cwd}/session-file.jsonl`,
getSessionSpawns: () => "*",
getPythonKernelOwnerId: () => kernelOwnerId ?? null,
settings: Settings.isolated({
"lsp.formatOnWrite": true,
"bashInterceptor.enabled": true,
"python.toolMode": "ipy-only",
"python.kernelMode": "per-call",
}),
};
}
describe("python tool execution", () => {
afterEach(() => {
pythonExecutor.resetPreludeDocsCache();
vi.restoreAllMocks();
});
it("passes kernel owner and kernel options from settings and args", async () => {
const tempDir = TempDir.createSync("@python-tool-");
vi.spyOn(pythonExecutor, "getPreludeDocs").mockReturnValue([]);
const warmupSpy = vi.spyOn(pythonExecutor, "warmPythonEnvironment").mockResolvedValue({ ok: true, docs: [] });
const executeSpy = vi.spyOn(pythonExecutor, "executePython").mockResolvedValue({
output: "ok",
exitCode: 0,
cancelled: false,
truncated: false,
totalLines: 1,
totalBytes: 2,
outputLines: 1,
outputBytes: 2,
displayOutputs: [],
stdinRequested: false,
});
const kernelOwnerId = "owner-123";
const tool = new PythonTool(createSession(tempDir.path(), kernelOwnerId));
const result = await tool.execute(
"call-id",
{ cells: [{ title: "hello-world", code: "print('hi')" }], timeout: 5, reset: true },
undefined,
undefined,
undefined,
);
expect(warmupSpy).toHaveBeenCalledWith(
tempDir.path(),
`session:${tempDir.path()}/session-file.jsonl:cwd:${tempDir.path()}`,
true,
`${tempDir.path()}/session-file.jsonl`,
kernelOwnerId,
expect.any(AbortSignal),
);
expect(executeSpy).toHaveBeenCalledWith(
"print('hi')",
expect.objectContaining({
cwd: tempDir.path(),
deadlineMs: expect.any(Number),
signal: expect.any(AbortSignal),
sessionFile: `${tempDir.path()}/session-file.jsonl`,
sessionId: `session:${tempDir.path()}/session-file.jsonl:cwd:${tempDir.path()}`,
kernelOwnerId,
kernelMode: "per-call",
useSharedGateway: true,
reset: true,
}),
);
const text = result.content.find(item => item.type === "text")?.text;
expect(text).toBe("ok");
tempDir.removeSync();
});
});