import { email } from "https://esm.town/v/std/email"; export async function sendDailyEmail( owner: string = "apache", repo: string = "arrow", ) { const GITHUB_TOKEN = Deno.env.get("GITHUB_TOKEN"); const today = new Date().toLocaleDateString(); const twentyFourHoursAgo = new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString(); const headers = { "Authorization": `token ${GITHUB_TOKEN}`, "Accept": "application/vnd.github.v3+json", }; // Fetch issues const issuesResponse = await fetch( `https://api.github.com/repos/${owner}/${repo}/issues?since=${twentyFourHoursAgo}&state=all`, { headers }, ); const issues = await issuesResponse.json(); // Fetch PRs const prsResponse = await fetch( `https://api.github.com/repos/${owner}/${repo}/pulls?state=all&since=${twentyFourHoursAgo}`, { headers }, ); const prs = await prsResponse.json(); const categorizedIssues = { opened: issues.filter(issue => !issue.pull_request && new Date(issue.created_at) > new Date(twentyFourHoursAgo)), updated: issues.filter(issue => !issue.pull_request && issue.updated_at !== issue.created_at && new Date(issue.updated_at) > new Date(twentyFourHoursAgo) ), closed: issues.filter(issue => !issue.pull_request && issue.state === "closed" && new Date(issue.closed_at) > new Date(twentyFourHoursAgo) ), }; const categorizedPRs = { opened: prs.filter(pr => new Date(pr.created_at) > new Date(twentyFourHoursAgo)), updated: prs.filter(pr => pr.updated_at !== pr.created_at && new Date(pr.updated_at) > new Date(twentyFourHoursAgo) ), closed: prs.filter(pr => pr.state === "closed" && new Date(pr.closed_at) > new Date(twentyFourHoursAgo) ), }; const htmlDigest = `

Daily GitHub Digest for ${owner}/${repo}

Generated on: ${today}

Type	Opened	Updated	Closed	Total
Issues	${categorizedIssues.opened.length}	${categorizedIssues.updated.length}	${categorizedIssues.closed.length}	${ categorizedIssues.opened.length + categorizedIssues.updated.length + categorizedIssues.closed.length }
Pull Requests	${categorizedPRs.opened.length}	${categorizedPRs.updated.length}	${categorizedPRs.closed.length}	${categorizedPRs.opened.length + categorizedPRs.updated.length + categorizedPRs.closed.length}
Total	${categorizedIssues.opened.length + categorizedPRs.opened.length}	${ categorizedIssues.updated.length + categorizedPRs.updated.length }	${categorizedIssues.closed.length + categorizedPRs.closed.length}	${ categorizedIssues.opened.length + categorizedIssues.updated.length + categorizedIssues.closed.length + categorizedPRs.opened.length + categorizedPRs.updated.length + categorizedPRs.closed.length }

Issues

Newly Opened Issues (${categorizedIssues.opened.length})

#${issue.number} ${issue.title} by ${issue.user.login}

Updated Issues (${categorizedIssues.updated.length})

#${issue.number} ${issue.title} last updated by ${issue.user.login}

Closed Issues (${categorizedIssues.closed.length})

#${issue.number} ${issue.title} closed by ${issue.user.login}

Pull Requests

Newly Opened PRs (${categorizedPRs.opened.length})

#${pr.number} ${pr.title} by ${pr.user.login}

Updated PRs (${categorizedPRs.updated.length})

#${pr.number} ${pr.title} last updated by ${pr.user.login}

Closed PRs (${categorizedPRs.closed.length})

#${pr.number} ${pr.title} closed by ${pr.user.login}

`; await email({ subject: `Daily GitHub Digest for ${owner}/${repo} - ${today}`, html: htmlDigest, }); return { issues: categorizedIssues, prs: categorizedPRs, }; } /** * Cron function that runs automatically */ export default async function(interval: Interval) { await sendDailyEmail(); } /** * Manual trigger function * Can be called directly to test */ export async function manualTrigger( owner: string = "val-town", repo: string = "val-town", ) { const result = await sendDailyEmail(owner, repo); console.log("Daily email sent successfully"); console.log( `Issues: ${result.issues.opened.length} opened, ${result.issues.updated.length} updated, ${result.issues.closed.length} closed`, ); console.log( `PRs: ${result.prs.opened.length} opened, ${result.prs.updated.length} updated, ${result.prs.closed.length} closed`, ); return result; }

amoeba