|
|
|
@@ -3,8 +3,9 @@
|
|
|
|
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
|
|
|
|
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
|
|
|
|
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
|
|
|
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
|
|
|
import { z } from "zod";
|
|
|
|
import { z } from "zod";
|
|
|
|
import { readFile } from "fs/promises";
|
|
|
|
import { readFile, stat } from "fs/promises";
|
|
|
|
import { join } from "path";
|
|
|
|
import { join } from "path";
|
|
|
|
|
|
|
|
import { constants } from "fs";
|
|
|
|
import fetch from "node-fetch";
|
|
|
|
import fetch from "node-fetch";
|
|
|
|
import { GITHUB_API_URL } from "../github/api/config";
|
|
|
|
import { GITHUB_API_URL } from "../github/api/config";
|
|
|
|
import { retryWithBackoff } from "../utils/retry";
|
|
|
|
import { retryWithBackoff } from "../utils/retry";
|
|
|
|
@@ -162,6 +163,34 @@ async function getOrCreateBranchRef(
|
|
|
|
return baseSha;
|
|
|
|
return baseSha;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Get the appropriate Git file mode for a file
|
|
|
|
|
|
|
|
async function getFileMode(filePath: string): Promise<string> {
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
const fileStat = await stat(filePath);
|
|
|
|
|
|
|
|
if (fileStat.isFile()) {
|
|
|
|
|
|
|
|
// Check if execute bit is set for user
|
|
|
|
|
|
|
|
if (fileStat.mode & constants.S_IXUSR) {
|
|
|
|
|
|
|
|
return "100755"; // Executable file
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
return "100644"; // Regular file
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
} else if (fileStat.isDirectory()) {
|
|
|
|
|
|
|
|
return "040000"; // Directory (tree)
|
|
|
|
|
|
|
|
} else if (fileStat.isSymbolicLink()) {
|
|
|
|
|
|
|
|
return "120000"; // Symbolic link
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// Fallback for unknown file types
|
|
|
|
|
|
|
|
return "100644";
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
} catch (error) {
|
|
|
|
|
|
|
|
// If we can't stat the file, default to regular file
|
|
|
|
|
|
|
|
console.warn(
|
|
|
|
|
|
|
|
`Could not determine file mode for ${filePath}, using default: ${error}`,
|
|
|
|
|
|
|
|
);
|
|
|
|
|
|
|
|
return "100644";
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Commit files tool
|
|
|
|
// Commit files tool
|
|
|
|
server.tool(
|
|
|
|
server.tool(
|
|
|
|
"commit_files",
|
|
|
|
"commit_files",
|
|
|
|
@@ -223,6 +252,9 @@ server.tool(
|
|
|
|
? filePath
|
|
|
|
? filePath
|
|
|
|
: join(REPO_DIR, filePath);
|
|
|
|
: join(REPO_DIR, filePath);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Get the proper file mode based on file permissions
|
|
|
|
|
|
|
|
const fileMode = await getFileMode(fullPath);
|
|
|
|
|
|
|
|
|
|
|
|
// Check if file is binary (images, etc.)
|
|
|
|
// Check if file is binary (images, etc.)
|
|
|
|
const isBinaryFile =
|
|
|
|
const isBinaryFile =
|
|
|
|
/\.(png|jpg|jpeg|gif|webp|ico|pdf|zip|tar|gz|exe|bin|woff|woff2|ttf|eot)$/i.test(
|
|
|
|
/\.(png|jpg|jpeg|gif|webp|ico|pdf|zip|tar|gz|exe|bin|woff|woff2|ttf|eot)$/i.test(
|
|
|
|
@@ -261,7 +293,7 @@ server.tool(
|
|
|
|
// Return tree entry with blob SHA
|
|
|
|
// Return tree entry with blob SHA
|
|
|
|
return {
|
|
|
|
return {
|
|
|
|
path: filePath,
|
|
|
|
path: filePath,
|
|
|
|
mode: "100644",
|
|
|
|
mode: fileMode,
|
|
|
|
type: "blob",
|
|
|
|
type: "blob",
|
|
|
|
sha: blobData.sha,
|
|
|
|
sha: blobData.sha,
|
|
|
|
};
|
|
|
|
};
|
|
|
|
@@ -270,7 +302,7 @@ server.tool(
|
|
|
|
const content = await readFile(fullPath, "utf-8");
|
|
|
|
const content = await readFile(fullPath, "utf-8");
|
|
|
|
return {
|
|
|
|
return {
|
|
|
|
path: filePath,
|
|
|
|
path: filePath,
|
|
|
|
mode: "100644",
|
|
|
|
mode: fileMode,
|
|
|
|
type: "blob",
|
|
|
|
type: "blob",
|
|
|
|
content: content,
|
|
|
|
content: content,
|
|
|
|
};
|
|
|
|
};
|
|
|
|
@@ -335,6 +367,7 @@ server.tool(
|
|
|
|
// We're seeing intermittent 403 "Resource not accessible by integration" errors
|
|
|
|
// We're seeing intermittent 403 "Resource not accessible by integration" errors
|
|
|
|
// on certain repos when updating git references. These appear to be transient
|
|
|
|
// on certain repos when updating git references. These appear to be transient
|
|
|
|
// GitHub API issues that succeed on retry.
|
|
|
|
// GitHub API issues that succeed on retry.
|
|
|
|
|
|
|
|
let lastErrorDetails: any = null;
|
|
|
|
await retryWithBackoff(
|
|
|
|
await retryWithBackoff(
|
|
|
|
async () => {
|
|
|
|
async () => {
|
|
|
|
const updateRefResponse = await fetch(updateRefUrl, {
|
|
|
|
const updateRefResponse = await fetch(updateRefUrl, {
|
|
|
|
@@ -353,17 +386,48 @@ server.tool(
|
|
|
|
|
|
|
|
|
|
|
|
if (!updateRefResponse.ok) {
|
|
|
|
if (!updateRefResponse.ok) {
|
|
|
|
const errorText = await updateRefResponse.text();
|
|
|
|
const errorText = await updateRefResponse.text();
|
|
|
|
|
|
|
|
let errorJson: any = {};
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
errorJson = JSON.parse(errorText);
|
|
|
|
|
|
|
|
} catch {
|
|
|
|
|
|
|
|
// If not JSON, use the text as-is
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Collect debugging information
|
|
|
|
|
|
|
|
const debugInfo = {
|
|
|
|
|
|
|
|
status: updateRefResponse.status,
|
|
|
|
|
|
|
|
statusText: updateRefResponse.statusText,
|
|
|
|
|
|
|
|
headers: Object.fromEntries(updateRefResponse.headers.entries()),
|
|
|
|
|
|
|
|
errorBody: errorJson || errorText,
|
|
|
|
|
|
|
|
context: {
|
|
|
|
|
|
|
|
repository: `${owner}/${repo}`,
|
|
|
|
|
|
|
|
branch: branch,
|
|
|
|
|
|
|
|
baseBranch: process.env.BASE_BRANCH,
|
|
|
|
|
|
|
|
targetSha: newCommitData.sha,
|
|
|
|
|
|
|
|
parentSha: baseSha,
|
|
|
|
|
|
|
|
isGitHubAction: !!process.env.GITHUB_ACTIONS,
|
|
|
|
|
|
|
|
eventName: process.env.GITHUB_EVENT_NAME,
|
|
|
|
|
|
|
|
isPR: process.env.IS_PR,
|
|
|
|
|
|
|
|
tokenLength: githubToken?.length || 0,
|
|
|
|
|
|
|
|
tokenPrefix: githubToken?.substring(0, 10) + "...",
|
|
|
|
|
|
|
|
apiUrl: updateRefUrl,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
lastErrorDetails = debugInfo;
|
|
|
|
|
|
|
|
|
|
|
|
const error = new Error(
|
|
|
|
const error = new Error(
|
|
|
|
`Failed to update reference: ${updateRefResponse.status} - ${errorText}`,
|
|
|
|
`Failed to update reference: ${updateRefResponse.status} - ${errorText}\n\nDebug Info: ${JSON.stringify(debugInfo, null, 2)}`,
|
|
|
|
);
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
// Only retry on 403 errors - these are the intermittent failures we're targeting
|
|
|
|
// Only retry on 403 errors - these are the intermittent failures we're targeting
|
|
|
|
if (updateRefResponse.status === 403) {
|
|
|
|
if (updateRefResponse.status === 403) {
|
|
|
|
|
|
|
|
console.error("403 Error encountered (will retry):", debugInfo);
|
|
|
|
throw error;
|
|
|
|
throw error;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// For non-403 errors, fail immediately without retry
|
|
|
|
// For non-403 errors, fail immediately without retry
|
|
|
|
console.error("Non-retryable error:", updateRefResponse.status);
|
|
|
|
console.error("Non-retryable error:", debugInfo);
|
|
|
|
throw error;
|
|
|
|
throw error;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
},
|
|
|
|
@@ -373,7 +437,23 @@ server.tool(
|
|
|
|
maxDelayMs: 5000, // Max 5 seconds delay
|
|
|
|
maxDelayMs: 5000, // Max 5 seconds delay
|
|
|
|
backoffFactor: 2, // Double the delay each time
|
|
|
|
backoffFactor: 2, // Double the delay each time
|
|
|
|
},
|
|
|
|
},
|
|
|
|
|
|
|
|
).catch((error) => {
|
|
|
|
|
|
|
|
// If all retries failed, enhance the error message with collected details
|
|
|
|
|
|
|
|
if (lastErrorDetails) {
|
|
|
|
|
|
|
|
throw new Error(
|
|
|
|
|
|
|
|
`All retry attempts failed for ref update.\n\n` +
|
|
|
|
|
|
|
|
`Final error: ${error.message}\n\n` +
|
|
|
|
|
|
|
|
`Debugging hints:\n` +
|
|
|
|
|
|
|
|
`- Check if branch '${branch}' is protected and the GitHub App has bypass permissions\n` +
|
|
|
|
|
|
|
|
`- Verify the token has 'contents:write' permission for ${owner}/${repo}\n` +
|
|
|
|
|
|
|
|
`- Check for concurrent operations updating the same branch\n` +
|
|
|
|
|
|
|
|
`- Token appears to be: ${lastErrorDetails.context.tokenPrefix}\n` +
|
|
|
|
|
|
|
|
`- This may be a transient GitHub API issue if it works on retry\n\n` +
|
|
|
|
|
|
|
|
`Full debug details: ${JSON.stringify(lastErrorDetails, null, 2)}`,
|
|
|
|
);
|
|
|
|
);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
throw error;
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
const simplifiedResult = {
|
|
|
|
const simplifiedResult = {
|
|
|
|
commit: {
|
|
|
|
commit: {
|
|
|
|
@@ -541,6 +621,7 @@ server.tool(
|
|
|
|
// We're seeing intermittent 403 "Resource not accessible by integration" errors
|
|
|
|
// We're seeing intermittent 403 "Resource not accessible by integration" errors
|
|
|
|
// on certain repos when updating git references. These appear to be transient
|
|
|
|
// on certain repos when updating git references. These appear to be transient
|
|
|
|
// GitHub API issues that succeed on retry.
|
|
|
|
// GitHub API issues that succeed on retry.
|
|
|
|
|
|
|
|
let lastErrorDetails: any = null;
|
|
|
|
await retryWithBackoff(
|
|
|
|
await retryWithBackoff(
|
|
|
|
async () => {
|
|
|
|
async () => {
|
|
|
|
const updateRefResponse = await fetch(updateRefUrl, {
|
|
|
|
const updateRefResponse = await fetch(updateRefUrl, {
|
|
|
|
@@ -559,18 +640,52 @@ server.tool(
|
|
|
|
|
|
|
|
|
|
|
|
if (!updateRefResponse.ok) {
|
|
|
|
if (!updateRefResponse.ok) {
|
|
|
|
const errorText = await updateRefResponse.text();
|
|
|
|
const errorText = await updateRefResponse.text();
|
|
|
|
|
|
|
|
let errorJson: any = {};
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
errorJson = JSON.parse(errorText);
|
|
|
|
|
|
|
|
} catch {
|
|
|
|
|
|
|
|
// If not JSON, use the text as-is
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Collect debugging information
|
|
|
|
|
|
|
|
const debugInfo = {
|
|
|
|
|
|
|
|
status: updateRefResponse.status,
|
|
|
|
|
|
|
|
statusText: updateRefResponse.statusText,
|
|
|
|
|
|
|
|
headers: Object.fromEntries(updateRefResponse.headers.entries()),
|
|
|
|
|
|
|
|
errorBody: errorJson || errorText,
|
|
|
|
|
|
|
|
context: {
|
|
|
|
|
|
|
|
operation: "delete_files",
|
|
|
|
|
|
|
|
repository: `${owner}/${repo}`,
|
|
|
|
|
|
|
|
branch: branch,
|
|
|
|
|
|
|
|
baseBranch: process.env.BASE_BRANCH,
|
|
|
|
|
|
|
|
targetSha: newCommitData.sha,
|
|
|
|
|
|
|
|
parentSha: baseSha,
|
|
|
|
|
|
|
|
isGitHubAction: !!process.env.GITHUB_ACTIONS,
|
|
|
|
|
|
|
|
eventName: process.env.GITHUB_EVENT_NAME,
|
|
|
|
|
|
|
|
isPR: process.env.IS_PR,
|
|
|
|
|
|
|
|
tokenLength: githubToken?.length || 0,
|
|
|
|
|
|
|
|
tokenPrefix: githubToken?.substring(0, 10) + "...",
|
|
|
|
|
|
|
|
apiUrl: updateRefUrl,
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
lastErrorDetails = debugInfo;
|
|
|
|
|
|
|
|
|
|
|
|
const error = new Error(
|
|
|
|
const error = new Error(
|
|
|
|
`Failed to update reference: ${updateRefResponse.status} - ${errorText}`,
|
|
|
|
`Failed to update reference: ${updateRefResponse.status} - ${errorText}\n\nDebug Info: ${JSON.stringify(debugInfo, null, 2)}`,
|
|
|
|
);
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
// Only retry on 403 errors - these are the intermittent failures we're targeting
|
|
|
|
// Only retry on 403 errors - these are the intermittent failures we're targeting
|
|
|
|
if (updateRefResponse.status === 403) {
|
|
|
|
if (updateRefResponse.status === 403) {
|
|
|
|
console.log("Received 403 error, will retry...");
|
|
|
|
console.error(
|
|
|
|
|
|
|
|
"403 Error encountered during delete (will retry):",
|
|
|
|
|
|
|
|
debugInfo,
|
|
|
|
|
|
|
|
);
|
|
|
|
throw error;
|
|
|
|
throw error;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// For non-403 errors, fail immediately without retry
|
|
|
|
// For non-403 errors, fail immediately without retry
|
|
|
|
console.error("Non-retryable error:", updateRefResponse.status);
|
|
|
|
console.error("Non-retryable error during delete:", debugInfo);
|
|
|
|
throw error;
|
|
|
|
throw error;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
},
|
|
|
|
@@ -580,7 +695,23 @@ server.tool(
|
|
|
|
maxDelayMs: 5000, // Max 5 seconds delay
|
|
|
|
maxDelayMs: 5000, // Max 5 seconds delay
|
|
|
|
backoffFactor: 2, // Double the delay each time
|
|
|
|
backoffFactor: 2, // Double the delay each time
|
|
|
|
},
|
|
|
|
},
|
|
|
|
|
|
|
|
).catch((error) => {
|
|
|
|
|
|
|
|
// If all retries failed, enhance the error message with collected details
|
|
|
|
|
|
|
|
if (lastErrorDetails) {
|
|
|
|
|
|
|
|
throw new Error(
|
|
|
|
|
|
|
|
`All retry attempts failed for ref update during file deletion.\n\n` +
|
|
|
|
|
|
|
|
`Final error: ${error.message}\n\n` +
|
|
|
|
|
|
|
|
`Debugging hints:\n` +
|
|
|
|
|
|
|
|
`- Check if branch '${branch}' is protected and the GitHub App has bypass permissions\n` +
|
|
|
|
|
|
|
|
`- Verify the token has 'contents:write' permission for ${owner}/${repo}\n` +
|
|
|
|
|
|
|
|
`- Check for concurrent operations updating the same branch\n` +
|
|
|
|
|
|
|
|
`- Token appears to be: ${lastErrorDetails.context.tokenPrefix}\n` +
|
|
|
|
|
|
|
|
`- This may be a transient GitHub API issue if it works on retry\n\n` +
|
|
|
|
|
|
|
|
`Full debug details: ${JSON.stringify(lastErrorDetails, null, 2)}`,
|
|
|
|
);
|
|
|
|
);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
throw error;
|
|
|
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
const simplifiedResult = {
|
|
|
|
const simplifiedResult = {
|
|
|
|
commit: {
|
|
|
|
commit: {
|
|
|
|
|