openAgent

1#!/usr/bin/env bun
2 
3const repo = "anomalyco/opencode"
4const days = 60
5const msg = `To stay organized issues are automatically closed after ${days} days of no activity. If the issue is still relevant please open a new one.`
6 
7const token = process.env.GITHUB_TOKEN
8if (!token) {
9  console.error("GITHUB_TOKEN environment variable is required")
10  process.exit(1)
11}
12 
13const cutoff = new Date(Date.now() - days * 24 * 60 * 60 * 1000)
14const agentLogin = "opencode-agent[bot]"
15const teamMembers = new Set(
16  (await Bun.file(new URL("../../.github/TEAM_MEMBERS", import.meta.url)).text())
17    .split("\n")
18    .map((line) => line.trim().toLowerCase())
19    .filter(Boolean),
20)
21const teamAssociations = new Set(["OWNER", "MEMBER"])
22 
23type Issue = {
24  number: number
25  updated_at: string
26  author_association: string
27  user: { login: string } | null
28}
29 
30const headers = {
31  Authorization: `Bearer ${token}`,
32  "Content-Type": "application/json",
33  Accept: "application/vnd.github+json",
34  "X-GitHub-Api-Version": "2022-11-28",
35}
36 
37function shouldSkip(i: Issue) {
38  const login = i.user?.login.toLowerCase()
39  return login === agentLogin || (login ? teamMembers.has(login) : false) || teamAssociations.has(i.author_association)
40}
41 
42async function close(num: number) {
43  const base = `https://api.github.com/repos/${repo}/issues/${num}`
44 
45  const comment = await fetch(`${base}/comments`, {
46    method: "POST",
47    headers,
48    body: JSON.stringify({ body: msg }),
49  })
50  if (!comment.ok) throw new Error(`Failed to comment #${num}: ${comment.status} ${comment.statusText}`)
51 
52  const patch = await fetch(base, {
53    method: "PATCH",
54    headers,
55    body: JSON.stringify({ state: "closed", state_reason: "not_planned" }),
56  })
57  if (!patch.ok) throw new Error(`Failed to close #${num}: ${patch.status} ${patch.statusText}`)
58 
59  console.log(`Closed https://github.com/${repo}/issues/${num}`)
60}
61 
62async function main() {
63  let page = 1
64  let closed = 0
65 
66  while (true) {
67    const res = await fetch(
68      `https://api.github.com/repos/${repo}/issues?state=open&sort=updated&direction=asc&per_page=100&page=${page}`,
69      { headers },
70    )
71    if (!res.ok) throw new Error(res.statusText)
72 
73    const all = (await res.json()) as Issue[]
74    if (all.length === 0) break
75    console.log(`Fetched page ${page} ${all.length} issues`)
76 
77    const stale: number[] = []
78    for (const i of all) {
79      const updated = new Date(i.updated_at)
80      if (updated < cutoff) {
81        if (shouldSkip(i)) {
82          console.log(`Skipping stale issue #${i.number}; author ${i.user?.login ?? "unknown"} is exempt`)
83          continue
84        }
85        stale.push(i.number)
86      } else {
87        console.log(`\nFound fresh issue #${i.number}, stopping`)
88        if (stale.length > 0) {
89          for (const num of stale) {
90            await close(num)
91            closed++
92          }
93        }
94        console.log(`Closed ${closed} issues total`)
95        return
96      }
97    }
98 
99    if (stale.length > 0) {
100      for (const num of stale) {
101        await close(num)
102        closed++
103      }
104    }
105 
106    page++
107  }
108 
109  console.log(`Closed ${closed} issues total`)
110}
111 
112main().catch((err) => {
113  console.error("Error:", err)
114  process.exit(1)
115})
116