A small script implementing a tiny software factory

A developer has created a small script that acts as a software factory, automatically finding Linear issues labeled 'factory' and using Claude and Polygraph to classify and execute them end-to-end. The script queries Linear for Todo issues, asks Claude whether an agent can handle each, and then launches a detached Polygraph session to do the work, updating the issue status accordingly.

| /usr/bin/env bun | | | // The factory trigger: finds workable Linear issues and hands each one to a | | | // detached Polygraph session that does the work end to end. | | | // | | | // FIND WORK here query Linear for Todo issues project + label | | | // CLASSIFY here claude -p: can an agent run this issue? | | | // DO THE WORK Polygraph one detached session, end to end | | | // COMPLETE here attach the session to the issue, move to In Progress | | | import { mkdirSync, openSync, readFileSync, writeFileSync } from "node:fs"; | | | import { homedir } from "node:os"; | | | import { join } from "node:path"; | | | const LINEAR API URL = "https://api.linear.app/graphql"; | | | const LOGS DIR = join import.meta.dir, "logs" ; | | | const PROJECT NAME = process.env.LINEAR PROJECT NAME; | | | const LABEL NAME = "factory"; | | | const START TIMEOUT MS = 30 60 000; | | | const apiKey = process.env.LINEAR API KEY; | | | if apiKey { | | | console.error "LINEAR API KEY is not set." ; | | | console.error "Create a personal API key at https://linear.app/settings/api and export it:" ; | | | console.error " set -x LINEAR API KEY lin api ... fish" ; | | | process.exit 1 ; | | | } | | | if PROJECT NAME { | | | console.error "LINEAR PROJECT NAME is not set." ; | | | console.error 'Add it to .env, e.g.: LINEAR PROJECT NAME="My Project"' ; | | | process.exit 1 ; | | | } | | | // --------------------------------------------------------------------------- | | | // The factory | | | // --------------------------------------------------------------------------- | | | async function main { | | | const runStartedAt = Date.now ; | | | if process.argv.includes "--scheduled" { | | | if shouldSkipScheduledRun { | | | log "scheduled run: already ran today — exiting max one scheduled run per day " ; | | | return; | | | } | | | log "scheduled run: first invocation today" ; | | | } | | | log factory starting — project "${PROJECT NAME}", label "${LABEL NAME}", state Todo ; | | | const viewer = await findWork ; | | | const issues = viewer.assignedIssues.nodes; | | | log ${issues.length} issue s to process for ${viewer.name} ; | | | for const issue of issues { | | | log - ${issue.identifier} ${issue.title} ; | | | } | | | if issues.length === 0 { | | | log nothing to do — run finished in ${elapsed runStartedAt } ; | | | return; | | | } | | | log "loading account info ..." ; | | | const account = await whoami ; | | | log account: ${account.selectedOrganization?.name} ${account.selectedOrgId} ; | | | const counts = { started: 0, skipped: 0, error: 0 }; | | | for const issue of issues { | | | log processing ${issue.identifier} ${issue.title} ; | | | try { | | | const outcome = await processIssue issue, account ; | | | counts outcome ++; | | | } catch error { | | | log error: ${error.message} — continuing with next issue ; | | | counts.error++; | | | } | | | } | | | log | | | run finished in ${elapsed runStartedAt } — ${counts.started} started, ${counts.skipped} skipped, ${counts.error} error s , | | | ; | | | } | | | // Returns "started", "skipped", or "error". | | | async function processIssue issue, account { | | | const classification = await canRunByAgent issue ; | | | if classification.verdict == "yes" { | | | log skipped: ${classification.reason} ; | | | return "skipped"; | | | } | | | log "verdict: yes" ; | | | // The session agent does the rest: repos, implementation, review, PRs. | | | const session = await launchSession issue, account ; | | | if session { | | | log "warning: could not determine session id — leaving issue in Todo so the next run retries" ; | | | return "error"; | | | } | | | await complete issue, session ; | | | log ${issue.identifier} done: session running, Linear updated ; | | | return "started"; | | | } | | | // --------------------------------------------------------------------------- | | | // The steps | | | // --------------------------------------------------------------------------- | | | // Todo issues assigned to the current user, filtered by project and label. | | | async function findWork { | | | const data = await linearQuery | | | | | | query MyTodoIssues $project: String , $label: String { | | | viewer { | | | name | | | assignedIssues | | | first: 50 | | | filter: { | | | state: { name: { eq: "Todo" } } | | | project: { name: { eq: $project } } | | | labels: { name: { eq: $label } } | | | } | | | { | | | nodes { | | | id | | | identifier | | | title | | | description | | | url | | | team { | | | id | | | } | | | state { | | | name | | | type | | | } | | | } | | | } | | | } | | | } | | | , | | | { project: PROJECT NAME, label: LABEL NAME }, | | | ; | | | return data.viewer; | | | } | | | // Ask Claude Code headless whether an agent can solve the issue | | | // autonomously. Returns { verdict: "yes" } or { verdict: "skip", reason }. | | | async function canRunByAgent issue { | | | const prompt = You are screening Linear issues to decide whether a coding agent can pick them up and solve them autonomously. | | | Issue ${issue.identifier}: ${issue.title} | | | Description: | | | ${issue.description?.trim || " no description provided "} | | | Answer "yes" only if all of these hold: | | | 1. Actionable: it describes a concrete task or change, not a vague idea or open discussion. | | | 2. Somewhat straightforward: it does not require major open-ended design or product decisions. | | | 3. Enough context: the description gives enough detail what to do, where, or how to tell it's done to start without asking clarifying questions. | | | Respond with ONLY a single line of JSON, no markdown, in one of these forms: | | | {"verdict":"yes"} | | | {"verdict":"skip","reason":"<one short sentence explaining which criterion failed and why "} ; | | | log "classifying with claude -p ..." ; | | | const startedAt = Date.now ; | | | const proc = Bun.spawn "claude", "-p", prompt , { | | | stdout: "pipe", | | | stderr: "pipe", | | | } ; | | | const output, errors = await Promise.all | | | new Response proc.stdout .text , | | | new Response proc.stderr .text , | | | ; | | | const exitCode = await proc.exited; | | | if exitCode == 0 { | | | throw new Error claude -p failed exit ${exitCode} : ${errors.trim } ; | | | } | | | log classification finished in ${elapsed startedAt } ; | | | const match = output.match /\{. \}/s ; | | | if match { | | | throw new Error Could not parse classification output: ${output.trim } ; | | | } | | | return JSON.parse match 0 ; | | | } | | | // In Progress rather than Done: the work is only done once the PRs merge. | | | async function complete issue, session { | | | log "attaching session to the Linear issue ..." ; | | | await attachSessionToIssue issue, session ; | | | log moving ${issue.identifier} to In Progress ... ; | | | await moveIssueToInProgress issue ; | | | } | | | // --------------------------------------------------------------------------- | | | // Linear machinery | | | // --------------------------------------------------------------------------- | | | async function linearQuery query, variables = {} { | | | const opName = query.match / ?:query|mutation \s+ \w+ / ?. 1 ?? "anonymous"; | | | const startedAt = Date.now ; | | | const res = await fetch LINEAR API URL, { | | | method: "POST", | | | headers: { | | | "Content-Type": "application/json", | | | Authorization: apiKey, | | | }, | | | body: JSON.stringify { query, variables } , | | | } ; | | | if res.ok { | | | throw new Error Linear API request failed: ${res.status} ${await res.text } ; | | | } | | | const json = await res.json ; | | | if json.errors { | | | throw new Error Linear API errors: ${JSON.stringify json.errors } ; | | | } | | | log linear: ${opName} ok in ${elapsed startedAt } ; | | | return json.data; | | | } | | | // Attachments are idempotent per URL, so re-runs do not create duplicates. | | | async function attachSessionToIssue issue, session { | | | await linearQuery | | | | | | mutation AttachSession $issueId: String , $url: String , $title: String , $subtitle: String { | | | attachmentCreate | | | input: { issueId: $issueId, url: $url, title: $title, subtitle: $subtitle } | | | { | | | success | | | } | | | } | | | , | | | { | | | issueId: issue.id, | | | url: session.url, | | | title: "Polygraph session", | | | subtitle: session.sessionId, | | | }, | | | ; | | | } | | | async function moveIssueToInProgress issue { | | | const data = await linearQuery | | | | | | query InProgressState $teamId: ID { | | | workflowStates | | | filter: { team: { id: { eq: $teamId } }, name: { eq: "In Progress" } } | | | { | | | nodes { | | | id | | | } | | | } | | | } | | | , | | | { teamId: issue.team.id }, | | | ; | | | const state = data.workflowStates.nodes 0 ; | | | if state { | | | throw new Error No "In Progress" state found for team of ${issue.identifier} ; | | | } | | | await linearQuery | | | | | | mutation MoveToInProgress $id: String , $stateId: String { | | | issueUpdate id: $id, input: { stateId: $stateId } { | | | success | | | } | | | } | | | , | | | { id: issue.id, stateId: state.id }, | | | ; | | | } | | | // --------------------------------------------------------------------------- | | | // Polygraph machinery | | | // --------------------------------------------------------------------------- | | | // Returns { sessionId, url }, or null when no session id could be obtained. | | | async function launchSession issue, account { | | | const sessionId = await startSession issue ; | | | if sessionId return null; | | | const url = ${account.url}/orgs/${account.selectedOrgId}/sessions/${sessionId} ; | | | log session url: ${url} ; | | | return { sessionId, url }; | | | } | | | function sessionPrompt issue { | | | return You are working on a Linear issue. All context is below. | | | Linear issue: ${issue.identifier} — ${issue.title} | | | Linear issue id: ${issue.id} | | | Linear issue URL: ${issue.url} | | | Description: | | | ${issue.description?.trim || " no description provided "} | | | Complete this task. After you are done with the implementation, check whether it is trivial; if it is not, use the adversarial review skill to review the changes and address the feedback it provides. Open pull requests with your changes, mark them ready for review, and make sure CI is green. Link the Linear issue as a reference on this session. ; | | | } | | | // session start launches the agent detached, prints a final JSON result | | | // line with the session id, and exits. --no-primary: the agent picks its | | | // repos once inside. Returns the sessionId, or null on timeout. | | | async function startSession issue { | | | const title = slugify ${issue.identifier} ${issue.title} .slice 0, 60 ; | | | const prompt = sessionPrompt issue ; | | | mkdirSync LOGS DIR, { recursive: true } ; | | | const logPath = join LOGS DIR, ${issue.identifier}-start.log ; | | | // The log file is append mode; skip lines from any previous run. | | | let previousLines = 0; | | | try { | | | previousLines = await Bun.file logPath .text .split "\n" .length - 1; | | | } catch {} | | | const args = | | | "session", | | | "start", | | | "--json", | | | "--title", | | | title, | | | "--no-primary", | | | "--multiplexer", | | | "none", | | | "--agent", | | | "claude", | | | "--", | | | prompt, | | | ; | | | const logFile = openSync logPath, "a" ; | | | const startedAt = Date.now ; | | | log | | | $ polygraph ${args | | | .map a = / \s'" /.test a ? '${a.replaceAll "'", "'\\''" }' : a | | | .join " " } , | | | ; | | | log full output: ${logPath} ; | | | const proc = Bun.spawn | | | "polygraph", ...args , | | | // A git cwd would bind the session to this unconnected repo. | | | { cwd: homedir , stdin: "ignore", stdout: logFile, stderr: logFile }, | | | ; | | | let timer; | | | const timedOut = await Promise.race | | | proc.exited.then = false , | | | new Promise resolve = { | | | timer = setTimeout = resolve true , START TIMEOUT MS ; | | | } , | | | ; | | | clearTimeout timer ; | | | if timedOut { | | | log session start still running after ${elapsed startedAt } — giving up on its output ; | | | return null; | | | } | | | let result = null; | | | for const line of await Bun.file logPath .text .split "\n" .slice previousLines { | | | try { | | | const event = JSON.parse line ; | | | if event.type === "result" result = event; | | | } catch {} | | | } | | | if result { | | | log "session start exited without a result line" ; | | | return null; | | | } | | | if result.success { | | | throw new Error | | | polygraph session start failed for ${issue.identifier}: ${ | | | result.error?.message ?? see ${logPath} | | | } , | | | ; | | | } | | | log session created in ${elapsed startedAt }: ${result.sessionId} ; | | | return result.sessionId; | | | } | | | async function polygraphJson args { | | | const startedAt = Date.now ; | | | const proc = Bun.spawn "polygraph", ...args, "--json" , { | | | stdin: "ignore", | | | stdout: "pipe", | | | stderr: "pipe", | | | } ; | | | const output = await new Response proc.stdout .text ; | | | const exitCode = await proc.exited; | | | if exitCode == 0 { | | | throw new Error polygraph ${args.join " " } failed exit ${exitCode} ; | | | } | | | log polygraph: ${args.join " " } ok in ${elapsed startedAt } ; | | | return JSON.parse output ; | | | } | | | function whoami { | | | return polygraphJson "whoami" ; | | | } | | | function slugify text { | | | return text | | | .toLowerCase | | | .replace / ^a-z0-9 +/g, "-" | | | .replace /^-+|-+$/g, "" ; | | | } | | | // --------------------------------------------------------------------------- | | | // Trigger plumbing | | | // --------------------------------------------------------------------------- | | | function log message { | | | const time = new Date .toTimeString .slice 0, 8 ; | | | console.log ${time} ${message} ; | | | } | | | function elapsed since { | | | return ${ Date.now - since / 1000 .toFixed 1 }s ; | | | } | | | // --scheduled the LaunchAgent runs at most once per calendar day; a stamp | | | // file dedupes the morning + login/wake firings. Manual runs are never blocked. | | | function shouldSkipScheduledRun { | | | const stampPath = join LOGS DIR, "last-scheduled-run.txt" ; | | | const today = new Date .toLocaleDateString "en-CA" ; | | | let last = null; | | | try { | | | last = readFileSync stampPath, "utf8" .trim ; | | | } catch {} | | | if last === today return true; | | | mkdirSync LOGS DIR, { recursive: true } ; | | | writeFileSync stampPath, today ; | | | return false; | | | } | | | await main ; |