Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| c31824144b | |||
| 0a63f3da9d | |||
| 42b023cc86 | |||
| 854e3d5e4d | |||
| 5bb1b779a8 |
+100
-1
@@ -1,16 +1,113 @@
|
|||||||
|
import { execSync } from "node:child_process";
|
||||||
|
import { createWriteStream, existsSync, rmSync } from "node:fs";
|
||||||
|
import { mkdtemp } from "node:fs/promises";
|
||||||
|
import { tmpdir } from "node:os";
|
||||||
|
import { join } from "node:path";
|
||||||
|
import { pipeline } from "node:stream/promises";
|
||||||
import { query, type SDKMessage } from "@anthropic-ai/claude-agent-sdk";
|
import { query, type SDKMessage } from "@anthropic-ai/claude-agent-sdk";
|
||||||
|
import packageJson from "../package.json" with { type: "json" };
|
||||||
import { log } from "../utils/cli.ts";
|
import { log } from "../utils/cli.ts";
|
||||||
import { type Agent, instructions } from "./shared.ts";
|
import { type Agent, instructions } from "./shared.ts";
|
||||||
|
|
||||||
|
let cachedCliPath: string | undefined;
|
||||||
|
|
||||||
export const claude: Agent = {
|
export const claude: Agent = {
|
||||||
|
install: async (): Promise<string> => {
|
||||||
|
if (cachedCliPath) {
|
||||||
|
log.info(`Using cached Claude Code CLI at ${cachedCliPath}`);
|
||||||
|
return cachedCliPath;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Get the SDK version from package.json and resolve to actual version
|
||||||
|
const versionRange = packageJson.dependencies["@anthropic-ai/claude-agent-sdk"] || "latest";
|
||||||
|
let sdkVersion: string;
|
||||||
|
|
||||||
|
// If it's a range (starts with ^ or ~), query npm registry for the latest matching version
|
||||||
|
if (versionRange.startsWith("^") || versionRange.startsWith("~")) {
|
||||||
|
const npmRegistry = process.env.NPM_REGISTRY || "https://registry.npmjs.org";
|
||||||
|
log.info(`Resolving version for range ${versionRange}...`);
|
||||||
|
try {
|
||||||
|
const registryResponse = await fetch(`${npmRegistry}/@anthropic-ai/claude-agent-sdk`);
|
||||||
|
if (!registryResponse.ok) {
|
||||||
|
throw new Error(`Failed to query registry: ${registryResponse.status}`);
|
||||||
|
}
|
||||||
|
const registryData = (await registryResponse.json()) as {
|
||||||
|
"dist-tags": { latest: string };
|
||||||
|
versions: Record<string, unknown>;
|
||||||
|
};
|
||||||
|
// Get the latest version that matches the range (simplified: just use latest)
|
||||||
|
sdkVersion = registryData["dist-tags"].latest;
|
||||||
|
log.info(`Resolved to version ${sdkVersion}`);
|
||||||
|
} catch (error) {
|
||||||
|
log.warning(
|
||||||
|
`Failed to resolve version from registry, using latest: ${error instanceof Error ? error.message : String(error)}`
|
||||||
|
);
|
||||||
|
sdkVersion = "latest";
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
sdkVersion = versionRange;
|
||||||
|
}
|
||||||
|
|
||||||
|
log.info(`📦 Installing Claude Code CLI from @anthropic-ai/claude-agent-sdk@${sdkVersion}...`);
|
||||||
|
|
||||||
|
// Create temp directory
|
||||||
|
const tempDir = await mkdtemp(join(tmpdir(), "claude-cli-"));
|
||||||
|
const tarballPath = join(tempDir, "package.tgz");
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Download tarball from npm
|
||||||
|
const npmRegistry = process.env.NPM_REGISTRY || "https://registry.npmjs.org";
|
||||||
|
const tarballUrl = `${npmRegistry}/@anthropic-ai/claude-agent-sdk/-/claude-agent-sdk-${sdkVersion}.tgz`;
|
||||||
|
|
||||||
|
log.info(`Downloading from ${tarballUrl}...`);
|
||||||
|
const response = await fetch(tarballUrl);
|
||||||
|
if (!response.ok) {
|
||||||
|
throw new Error(`Failed to download tarball: ${response.status} ${response.statusText}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Write tarball to file
|
||||||
|
const fileStream = createWriteStream(tarballPath);
|
||||||
|
await pipeline(response.body as any, fileStream);
|
||||||
|
log.info(`Downloaded tarball to ${tarballPath}`);
|
||||||
|
|
||||||
|
// Extract tarball
|
||||||
|
log.info(`Extracting tarball...`);
|
||||||
|
execSync(`tar -xzf "${tarballPath}" -C "${tempDir}"`, { stdio: "pipe" });
|
||||||
|
|
||||||
|
// Find cli.js in the extracted package
|
||||||
|
const extractedDir = join(tempDir, "package");
|
||||||
|
const cliPath = join(extractedDir, "cli.js");
|
||||||
|
|
||||||
|
if (!existsSync(cliPath)) {
|
||||||
|
throw new Error(`cli.js not found in extracted package at ${cliPath}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
cachedCliPath = cliPath;
|
||||||
|
log.info(`✓ Claude Code CLI installed at ${cliPath}`);
|
||||||
|
return cliPath;
|
||||||
|
} catch (error) {
|
||||||
|
// Cleanup on error
|
||||||
|
try {
|
||||||
|
rmSync(tempDir, { recursive: true, force: true });
|
||||||
|
} catch {
|
||||||
|
// Ignore cleanup errors
|
||||||
|
}
|
||||||
|
throw error;
|
||||||
|
}
|
||||||
|
},
|
||||||
run: async ({ prompt, mcpServers, apiKey }) => {
|
run: async ({ prompt, mcpServers, apiKey }) => {
|
||||||
process.env.ANTHROPIC_API_KEY = apiKey;
|
process.env.ANTHROPIC_API_KEY = apiKey;
|
||||||
|
|
||||||
|
if (!cachedCliPath) {
|
||||||
|
throw new Error("Claude CLI not installed. Call install() before run().");
|
||||||
|
}
|
||||||
|
|
||||||
const queryInstance = query({
|
const queryInstance = query({
|
||||||
prompt: `${instructions}\n\n${prompt}`,
|
prompt: `${instructions}\n\n****** USER PROMPT ******\n${prompt}`,
|
||||||
options: {
|
options: {
|
||||||
permissionMode: "bypassPermissions",
|
permissionMode: "bypassPermissions",
|
||||||
mcpServers,
|
mcpServers,
|
||||||
|
pathToClaudeCodeExecutable: cachedCliPath,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -142,4 +239,6 @@ const messageHandlers: SDKMessageHandlers = {
|
|||||||
},
|
},
|
||||||
system: () => {},
|
system: () => {},
|
||||||
stream_event: () => {},
|
stream_event: () => {},
|
||||||
|
tool_progress: () => {},
|
||||||
|
auth_status: () => {},
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -22,6 +22,7 @@ export interface AgentConfig {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export type Agent = {
|
export type Agent = {
|
||||||
|
install: () => Promise<string>;
|
||||||
run: (config: AgentConfig) => Promise<AgentResult>;
|
run: (config: AgentConfig) => Promise<AgentResult>;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -5,26 +5,27 @@
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
import * as core from "@actions/core";
|
import * as core from "@actions/core";
|
||||||
import { type } from "arktype";
|
import { type Inputs, main } from "./main.ts";
|
||||||
import { Inputs, main } from "./main.ts";
|
|
||||||
import { createMcpServer } from "./mcp/server.ts";
|
import { createMcpServer } from "./mcp/server.ts";
|
||||||
import packageJson from "./package.json" with { type: "json" };
|
|
||||||
import { log } from "./utils/cli.ts";
|
import { log } from "./utils/cli.ts";
|
||||||
|
|
||||||
// Export createMcpServer so it can be called from the spawned MCP process
|
// Export createMcpServer so it can be called from the spawned MCP process
|
||||||
export { createMcpServer };
|
export { createMcpServer };
|
||||||
|
|
||||||
async function run(): Promise<void> {
|
async function run(): Promise<void> {
|
||||||
|
// Change to GITHUB_WORKSPACE if set (this is where actions/checkout puts the repo)
|
||||||
|
// JavaScript actions run from the action's directory, not the checked-out repo
|
||||||
|
if (process.env.GITHUB_WORKSPACE && process.cwd() !== process.env.GITHUB_WORKSPACE) {
|
||||||
|
log.debug(`Changing to GITHUB_WORKSPACE: ${process.env.GITHUB_WORKSPACE}`);
|
||||||
|
process.chdir(process.env.GITHUB_WORKSPACE);
|
||||||
|
log.debug(`New working directory: ${process.cwd()}`);
|
||||||
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
log.info(`🐸 Running pullfrog/action@${packageJson.version}...`);
|
const inputs: Inputs = {
|
||||||
|
prompt: core.getInput("prompt", { required: true }),
|
||||||
const inputsJson = process.env.INPUTS_JSON;
|
anthropic_api_key: core.getInput("anthropic_api_key") || undefined,
|
||||||
if (!inputsJson) {
|
};
|
||||||
throw new Error("INPUTS_JSON environment variable not found");
|
|
||||||
}
|
|
||||||
|
|
||||||
const parsed = type("string.json.parse").assert(inputsJson);
|
|
||||||
const inputs = Inputs.assert(parsed);
|
|
||||||
|
|
||||||
const result = await main(inputs);
|
const result = await main(inputs);
|
||||||
|
|
||||||
|
|||||||
+3
-2
@@ -9,7 +9,7 @@ await build({
|
|||||||
format: "esm",
|
format: "esm",
|
||||||
platform: "node",
|
platform: "node",
|
||||||
target: "node20",
|
target: "node20",
|
||||||
minify: true,
|
minify: false,
|
||||||
sourcemap: false,
|
sourcemap: false,
|
||||||
// Bundle all dependencies - GitHub Actions doesn't have node_modules
|
// Bundle all dependencies - GitHub Actions doesn't have node_modules
|
||||||
// Only mark optional peer dependencies as external
|
// Only mark optional peer dependencies as external
|
||||||
@@ -19,8 +19,9 @@ await build({
|
|||||||
"sury",
|
"sury",
|
||||||
],
|
],
|
||||||
// Provide a proper require shim for CommonJS modules bundled into ESM
|
// Provide a proper require shim for CommonJS modules bundled into ESM
|
||||||
|
// We use a unique variable name to avoid conflicts with bundled imports
|
||||||
banner: {
|
banner: {
|
||||||
js: `import { createRequire } from 'module'; import { fileURLToPath } from 'url'; import { dirname } from 'path'; const require = createRequire(import.meta.url); const __filename = fileURLToPath(import.meta.url); const __dirname = dirname(__filename);`,
|
js: `import { createRequire as __createRequire } from 'module'; import { fileURLToPath as __fileURLToPath } from 'url'; import { dirname as __dirnameFn } from 'path'; const require = __createRequire(import.meta.url); const __filename = __fileURLToPath(import.meta.url); const __dirname = __dirnameFn(__filename);`,
|
||||||
},
|
},
|
||||||
// Enable tree-shaking to remove unused code
|
// Enable tree-shaking to remove unused code
|
||||||
treeShaking: true,
|
treeShaking: true,
|
||||||
|
|||||||
@@ -1,6 +1,9 @@
|
|||||||
|
import { readdir } from "node:fs/promises";
|
||||||
|
import { join } from "node:path";
|
||||||
import { type } from "arktype";
|
import { type } from "arktype";
|
||||||
import { claude } from "./agents/claude.ts";
|
import { claude } from "./agents/claude.ts";
|
||||||
import { createMcpConfigs } from "./mcp/config.ts";
|
import { createMcpConfigs } from "./mcp/config.ts";
|
||||||
|
import packageJson from "./package.json" with { type: "json" };
|
||||||
import { log } from "./utils/cli.ts";
|
import { log } from "./utils/cli.ts";
|
||||||
import { parseRepoContext, setupGitHubInstallationToken } from "./utils/github.ts";
|
import { parseRepoContext, setupGitHubInstallationToken } from "./utils/github.ts";
|
||||||
import { setupGitAuth, setupGitConfig } from "./utils/setup.ts";
|
import { setupGitAuth, setupGitConfig } from "./utils/setup.ts";
|
||||||
@@ -20,9 +23,43 @@ export interface MainResult {
|
|||||||
|
|
||||||
export type PromptJSON = {};
|
export type PromptJSON = {};
|
||||||
|
|
||||||
|
async function printDirectoryTree(dir: string, prefix = "", rootDir = dir): Promise<string> {
|
||||||
|
const entries = await readdir(dir, { withFileTypes: true });
|
||||||
|
const lines: string[] = [];
|
||||||
|
|
||||||
|
for (let i = 0; i < entries.length; i++) {
|
||||||
|
const entry = entries[i];
|
||||||
|
const isLast = i === entries.length - 1;
|
||||||
|
const currentPrefix = isLast ? "└── " : "├── ";
|
||||||
|
const nextPrefix = isLast ? " " : "│ ";
|
||||||
|
|
||||||
|
const fullPath = join(dir, entry.name);
|
||||||
|
lines.push(`${prefix}${currentPrefix}${entry.name}`);
|
||||||
|
|
||||||
|
if (entry.isDirectory()) {
|
||||||
|
const subTree = await printDirectoryTree(fullPath, `${prefix}${nextPrefix}`, rootDir);
|
||||||
|
lines.push(subTree);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return lines.join("\n");
|
||||||
|
}
|
||||||
|
|
||||||
export async function main(inputs: Inputs): Promise<MainResult> {
|
export async function main(inputs: Inputs): Promise<MainResult> {
|
||||||
try {
|
try {
|
||||||
log.info("Starting agent run...");
|
// Debug: Print current directory tree before anything runs
|
||||||
|
const cwd = process.cwd();
|
||||||
|
log.info(`Current working directory: ${cwd}`);
|
||||||
|
try {
|
||||||
|
const tree = await printDirectoryTree(cwd);
|
||||||
|
log.info(`Directory tree:\n${tree}`);
|
||||||
|
} catch (error) {
|
||||||
|
log.warning(
|
||||||
|
`Failed to print directory tree: ${error instanceof Error ? error.message : String(error)}`
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
log.info(`🐸 Running pullfrog/action@${packageJson.version}...`);
|
||||||
|
|
||||||
setupGitConfig();
|
setupGitConfig();
|
||||||
|
|
||||||
@@ -35,6 +72,9 @@ export async function main(inputs: Inputs): Promise<MainResult> {
|
|||||||
|
|
||||||
log.debug(`📋 MCP Config: ${JSON.stringify(mcpServers, null, 2)}`);
|
log.debug(`📋 MCP Config: ${JSON.stringify(mcpServers, null, 2)}`);
|
||||||
|
|
||||||
|
// Install Claude CLI before running
|
||||||
|
await claude.install();
|
||||||
|
|
||||||
log.info("Running Claude Agent SDK...");
|
log.info("Running Claude Agent SDK...");
|
||||||
log.box(inputs.prompt, { title: "Prompt" });
|
log.box(inputs.prompt, { title: "Prompt" });
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pullfrog/action",
|
"name": "@pullfrog/action",
|
||||||
"version": "0.0.77",
|
"version": "0.0.82",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"files": [
|
"files": [
|
||||||
"index.js",
|
"index.js",
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import { fromHere } from "@ark/fs";
|
|||||||
import arg from "arg";
|
import arg from "arg";
|
||||||
import { config } from "dotenv";
|
import { config } from "dotenv";
|
||||||
import { type Inputs, main } from "./main.ts";
|
import { type Inputs, main } from "./main.ts";
|
||||||
import packageJson from "./package.json" with { type: "json" };
|
|
||||||
import { log } from "./utils/cli.ts";
|
import { log } from "./utils/cli.ts";
|
||||||
import { setupTestRepo } from "./utils/setup.ts";
|
import { setupTestRepo } from "./utils/setup.ts";
|
||||||
|
|
||||||
@@ -15,8 +14,6 @@ export async function run(
|
|||||||
prompt: string
|
prompt: string
|
||||||
): Promise<{ success: boolean; output?: string | undefined; error?: string | undefined }> {
|
): Promise<{ success: boolean; output?: string | undefined; error?: string | undefined }> {
|
||||||
try {
|
try {
|
||||||
log.info(`🐸 Running pullfrog/action@${packageJson.version}...`);
|
|
||||||
|
|
||||||
const tempDir = join(process.cwd(), ".temp");
|
const tempDir = join(process.cwd(), ".temp");
|
||||||
setupTestRepo({ tempDir, forceClean: true });
|
setupTestRepo({ tempDir, forceClean: true });
|
||||||
|
|
||||||
|
|||||||
+11
-4
@@ -47,13 +47,21 @@ export function setupGitConfig(): void {
|
|||||||
// Only set up git config in GitHub Actions environment
|
// Only set up git config in GitHub Actions environment
|
||||||
// In local development, use the user's existing git config
|
// In local development, use the user's existing git config
|
||||||
if (!process.env.GITHUB_ACTIONS) {
|
if (!process.env.GITHUB_ACTIONS) {
|
||||||
log.info("⚠️ Skipping git configuration setup (not in GitHub Actions)");
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
log.info("🔧 Setting up git configuration...");
|
log.info("🔧 Setting up git configuration...");
|
||||||
execSync('git config user.email "action@pullfrog.ai"', { stdio: "inherit" });
|
try {
|
||||||
execSync('git config user.name "Pullfrog Action"', { stdio: "inherit" });
|
execSync('git config user.email "action@pullfrog.ai"', { stdio: "pipe" });
|
||||||
|
execSync('git config user.name "Pullfrog Action"', { stdio: "pipe" });
|
||||||
|
log.debug("setupGitConfig: ✓ Git configuration set successfully");
|
||||||
|
} catch (error) {
|
||||||
|
// If git config fails, log warning but don't fail the action
|
||||||
|
// This can happen if we're not in a git repo or git isn't available
|
||||||
|
log.warning(
|
||||||
|
`Failed to set git config: ${error instanceof Error ? error.message : String(error)}`
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -64,7 +72,6 @@ export function setupGitAuth(githubToken: string, repoContext: RepoContext): voi
|
|||||||
// Only set up git auth in GitHub Actions environment
|
// Only set up git auth in GitHub Actions environment
|
||||||
// In local testing, this would overwrite the real git remote with fake credentials
|
// In local testing, this would overwrite the real git remote with fake credentials
|
||||||
if (!process.env.GITHUB_ACTIONS) {
|
if (!process.env.GITHUB_ACTIONS) {
|
||||||
log.info("⚠️ Skipping git authentication setup (not in GitHub Actions)");
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user