scriptoriumadmin/Roo-Code
1
0
Fork 0
mirror of https://github.com/RooVetGit/Roo-Code.git synced 2026-09-05 08:10:14 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Use GH_TOKEN to fetch pull request data (#186)

Browse source
This commit is contained in:
Chris Estreich 2025-07-02 08:51:09 -08:00 • committed by GitHub
parent 495d1bdf51
commit f9ab282322
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 24 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
apps/roomote/src/app/api/webhooks/github/handlers/issueCommentHandler.ts
View file

@ -3,7 +3,7 @@ import { z } from 'zod';
import type { JobPayload } from '@roo-code-cloud/db';
import { createAndEnqueueJob } from './utils';
import { createAndEnqueueJob, fetchGitHubAPI } from './utils';
const githubIssueCommentWebhookSchema = z.object({
action: z.string(),
@ -48,9 +48,14 @@ export async function handleIssueCommentEvent(body: string) {
// Handle PR comments (when comment is on a pull request)
if (issue.pull_request) {
const response = await fetch(issue.pull_request.url);
const response = await fetchGitHubAPI(issue.pull_request.url);
if (!response.ok) {
console.error(
`🔴 Failed to fetch pull request -> ${issue.pull_request.url}`,
`Status: ${response.status}`,
);
return NextResponse.json({ message: 'failed_to_fetch_pull_request' });
}
@ -59,6 +64,7 @@ export async function handleIssueCommentEvent(body: string) {
const pull_request = githubPullRequestWebhookSchema.parse(
await response.json(),
);
console.log(`🗄️ Pull Request -> ${issue.pull_request.url}`, pull_request);
const payload: JobPayload<'github.pr.comment.respond'> = {
@ -79,6 +85,7 @@ export async function handleIssueCommentEvent(body: string) {
'github.pr.comment.respond',
payload,
);
return NextResponse.json({
message: 'pr_comment_job_enqueued',
jobId,
@ -101,6 +108,7 @@ export async function handleIssueCommentEvent(body: string) {
};
const { jobId, enqueuedJobId } = await createAndEnqueueJob(type, payload);
return NextResponse.json({
message: 'issue_comment_job_enqueued',
jobId,

14
apps/roomote/src/app/api/webhooks/github/handlers/utils.ts
View file

@ -43,3 +43,17 @@ export async function createAndEnqueueJob<T extends JobType>(
return { jobId: job.id, enqueuedJobId: enqueuedJob.id };
}
export async function fetchGitHubAPI(url: string, options: RequestInit = {}) {
const headers: Record<string, string> = {
Accept: 'application/vnd.github.v3+json',
'User-Agent': 'Roomote-Webhook-Handler',
...((options.headers as Record<string, string>) || {}),
};
if (process.env.GH_TOKEN) {
headers['Authorization'] = `Bearer ${process.env.GH_TOKEN}`;
}
return fetch(url, { ...options, headers });
}