Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
232 changes: 232 additions & 0 deletions .github/scripts/record-linear-release.cjs
Original file line number Diff line number Diff line change
@@ -0,0 +1,232 @@
// Records a deploy or a release as a Linear release. Run it from actions/github-script:
//
// script: return require('./.github/scripts/record-linear-release.cjs')({ github, context, core })
//
// Environment:
// LINEAR_ACCESS_KEY The pipeline's access key. Without one, nothing is recorded.
// LINEAR_RELEASE_MODE "live" records the release. Anything else only logs what would be sent.
// RELEASE_SHA The commit that was deployed or tagged.
// RELEASE_VERSION The release tag, or for a deploy its short SHA (the default).
// RELEASE_BRANCH The branch PRs merge into. Defaults to main.
// RELEASE_NOTES "prs" (the default) lists the PRs. "github-release" copies the body of
// the GitHub release tagged RELEASE_VERSION.
//
// Output: release-url, the release's page in Linear. It stays empty when the release is only logged.
'use strict';

const LINEAR_API = 'https://api.linear.app/graphql';
const MAX_BASE_CANDIDATES = 20;

/**
* Splits markdown into fenced code blocks and the text between them. A fence opens with three or more
* backticks or tildes, and closes with the same character, at least as many, on a line of its own.
* Fences inside block quotes count, and end with their quote. A fence that never closes runs to the
* end, as in CommonMark.
* @returns {{ code: boolean, text: string }[]}
*/
function splitFences(text) {
const parts = [];
let buffer = '';
let fence = null;
for (const line of text.split(/(?<=\n)/)) {
const quote = line.match(/^(?: {0,3}> ?)*/)[0];
const depth = (quote.match(/>/g) || []).length;
const rest = line.slice(quote.length);
if (fence && depth < fence.depth) {
parts.push({ code: true, text: buffer });
buffer = '';
fence = null;
}
if (fence) {
buffer += line;
const close = rest.match(/^ {0,3}(`{3,}|~{3,})[ \t]*\r?\n?$/);
if (close && close[1][0] === fence.marker[0] && close[1].length >= fence.marker.length) {
parts.push({ code: true, text: buffer });
buffer = '';
fence = null;
}
continue;
}
const open = rest.match(/^ {0,3}(`{3,}|~{3,})/);
// A backtick fence's info string can't contain a backtick.
if (open && !(open[1][0] === '`' && rest.slice(open[0].length).includes('`'))) {
parts.push({ code: false, text: buffer });
buffer = line;
fence = { marker: open[1], depth };
} else {
buffer += line;
}
}
parts.push({ code: fence !== null, text: buffer });
return parts;
}

/**
* Writes every GitHub reference out as a full link. On GitHub, "#12" is a PR or issue of the same repo;
* Linear matches a bare "#12" against every repo it knows, so it can link a PR from another repo.
* Code (fenced, or inline with any number of backticks), existing links and URLs are left alone.
* GitHub redirects /pull/N to /issues/N when N is an issue.
*/
function linkReferences(text, owner, repo) {
const untouched = /(?<!`)(`+)(?!`)[\s\S]*?(?<!`)\1(?!`)|\[[^\]\n]*\]\([^)\n]*\)|<[^>\n]*>|https?:\/\/[^\s)]+/g;
const linkPlain = (plain) =>
plain
.replace(
/(^|[^\w/#&])([\w.-]+)\/([\w.-]+)#(\d+)\b/g,
(_, pre, o, r, n) => `${pre}[${o}/${r}#${n}](https://github.com/${o}/${r}/pull/${n})`,
)
.replace(/(^|[^\w/#&[]|\bPR ?)#(\d+)\b/g, (_, pre, n) => `${pre}[#${n}](https://github.com/${owner}/${repo}/pull/${n})`);
const linkProse = (prose) => {
let out = '';
let last = 0;
for (const match of prose.matchAll(untouched)) {
out += linkPlain(prose.slice(last, match.index)) + match[0];
last = match.index + match[0].length;
}
return out + linkPlain(prose.slice(last));
};
return splitFences(text)
.map((part) => (part.code ? part.text : linkProse(part.text)))
.join('');
}

/** The release notes of a deploy: one line per PR, with Dependabot's PRs folded into one. */
function prNotes(prs, owner, repo) {
const link = (n) => `[#${n}](https://github.com/${owner}/${repo}/pull/${n})`;
const dependabot = prs.filter((pr) => pr.user.login === 'dependabot[bot]');
const lines = prs
.filter((pr) => !dependabot.includes(pr))
.map((pr) => `- ${link(pr.number)} ${linkReferences(pr.title, owner, repo)} · ${pr.user.login}`);
if (dependabot.length) {
const s = dependabot.length > 1 ? 's' : '';
lines.push(`- ${dependabot.length} Dependabot update${s}: ${dependabot.map((pr) => link(pr.number)).join(', ')}`);
}
return lines.join('\n');
}

/** The PRs merged into `branch` since the newest earlier release in this pipeline. */
async function pullRequestsSince({ github, owner, repo, branch, head, version, releases }) {
const compare = async (base, target, page = 1, perPage = 1) =>
(await github.rest.repos.compareCommitsWithBasehead({ owner, repo, basehead: `${base}...${target}`, page, per_page: perPage }))
.data;

// Testing can be deployed from a branch. Such a deploy gets no PRs; they count once they reach the branch.
if (!['ahead', 'identical'].includes((await compare(head, branch)).status)) {
return { prs: [], reason: `${head.slice(0, 7)} is not on ${branch}` };
}

// Sorted by completion time, since an older release whose notes were edited can be listed first.
// A release that is not on the branch is a branch deploy and is never a base. A re-run of a
// recorded version only looks at releases before it. Another version at the same commit is a
// base, and leaves no new PRs.
const time = (r) => Date.parse(r.completedAt || r.createdAt);
const own = releases.find((r) => r.version === version);
const candidates = releases
.filter((r) => r.commitSha && r.version !== version && (!own || time(r) < time(own)))
.sort((a, b) => time(b) - time(a))
.slice(0, MAX_BASE_CANDIDATES);
let base;
for (const release of candidates) {
const { status } = await compare(release.commitSha, head);
if (status === 'diverged') continue;
// "behind": the newest release is ahead of this commit, so this deploy is a rollback.
if (status === 'behind') return { prs: [], reason: `rollback: ${release.version} is newer` };
base = release;
break;
}
if (!base) return { prs: [], reason: 'no earlier release on the branch' };

const commits = [];
for (let page = 1; ; page++) {
const data = await compare(base.commitSha, head, page, 100);
commits.push(...data.commits);
if (data.commits.length < 100 || commits.length >= data.total_commits) break;
}

// GitHub knows each commit's PR, whatever the merge method.
const prs = new Map();
for (const { sha } of commits) {
const { data } = await github.rest.repos.listPullRequestsAssociatedWithCommit({ owner, repo, commit_sha: sha });
for (const pr of data) {
if (pr.merged_at && pr.base.ref === branch && !prs.has(pr.number)) prs.set(pr.number, pr);
}
}
return { prs: [...prs.values()], base };
}

/** Records the release in Linear, or logs what it would record. */
module.exports = async ({ github, context, core }) => {
const key = process.env.LINEAR_ACCESS_KEY;
const live = process.env.LINEAR_RELEASE_MODE === 'live';
if (!key) {
if (live) throw new Error('LINEAR_RELEASE_MODE is live, but this pipeline has no Linear access key');
core.notice('No Linear access key for this pipeline, so the release is not recorded.');
return;
}
const required = (name) => {
if (!process.env[name]) throw new Error(`${name} is not set`);
return process.env[name];
};
const head = required('RELEASE_SHA');
const version = process.env.RELEASE_VERSION || head.slice(0, 7);
const branch = process.env.RELEASE_BRANCH || 'main';
const { owner, repo } = context.repo;

const linear = async (query, variables) => {
const res = await fetch(LINEAR_API, {
method: 'POST',
headers: { 'Content-Type': 'application/json', Authorization: key },
body: JSON.stringify({ query, variables }),
signal: AbortSignal.timeout(30_000),
});
const body = await res.json().catch(() => ({}));
if (!res.ok || body.errors) throw new Error(`Linear API ${res.status}: ${JSON.stringify(body.errors || body)}`);
return body.data;
};

const { recentReleasesByAccessKey: releases } = await linear(
'query { recentReleasesByAccessKey(limit: 50) { commitSha version completedAt createdAt } }',
);
const { prs, base, reason } = await pullRequestsSince({ github, owner, repo, branch, head, version, releases });

const links = [{ label: 'GitHub run', url: `${context.serverUrl}/${owner}/${repo}/actions/runs/${context.runId}` }];
let notes;
if (process.env.RELEASE_NOTES === 'github-release') {
const { data } = await github.rest.repos.getReleaseByTag({ owner, repo, tag: version });
notes = linkReferences((data.body || '').replace(/\r\n/g, '\n').trim(), owner, repo);
links.unshift({ label: 'GitHub release', url: data.html_url });
} else {
notes = prNotes(prs, owner, repo);
}

const input = {
name: version,
version,
commitSha: head,
repository: { owner, name: repo, provider: 'github', url: `https://github.com/${owner}/${repo}` },
pullRequestReferences: prs.map((pr) => ({ repositoryOwner: owner, repositoryName: repo, number: pr.number })),
links,
...(notes ? { releaseNotes: { title: version, content: notes } } : {}),
};

const since = base ? `since ${base.version}` : `none (${reason})`;
core.info(`PRs ${since}: ${prs.map((pr) => `#${pr.number}`).join(', ') || '-'}`);
if (!live) {
core.notice(`Log-only: ${version} would be recorded in Linear with ${prs.length} PRs. Set LINEAR_RELEASE_MODE=live to record it.`);
core.info(JSON.stringify(input, null, 2));
return;
}

const { releaseSyncByAccessKey: result } = await linear(
'mutation ($input: ReleaseSyncInputBase!) { releaseSyncByAccessKey(input: $input) { success release { url } } }',
{ input },
);
// Linear can report a failed sync with HTTP 200.
if (!result.success || !result.release) throw new Error(`Linear did not record ${version}: ${JSON.stringify(result)}`);
core.setOutput('release-url', result.release.url);
core.notice(`Recorded ${version} in Linear: ${result.release.url}`);
};

module.exports.linkReferences = linkReferences;
module.exports.prNotes = prNotes;
module.exports.pullRequestsSince = pullRequestsSince;
47 changes: 45 additions & 2 deletions .github/workflows/release.yml
Original file line number Diff line number Diff line change
Expand Up @@ -124,12 +124,52 @@ jobs:
VERSION: ${{ steps.version.outputs.version }}
run: echo "Released v${VERSION} at $(git rev-parse --short HEAD)." >> "$GITHUB_STEP_SUMMARY"

# Stable releases only; pre-releases stay out of the Linear pipeline.
linear-release:
name: Record release in Linear
needs: release
if: ${{ needs.release.outputs.prerelease == 'false' }}
runs-on: ubuntu-latest
# pull-requests lets the step look up each commit's PR.
permissions:
contents: read
pull-requests: read
outputs:
# The notify job links the release, or says recording it failed.
release-url: ${{ steps.linear.outputs.release-url }}
outcome: ${{ steps.linear.outcome }}

steps:
- uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
with:
persist-credentials: false

# The release gets the PRs merged since the previous one, and the GitHub
# release text as notes; a re-run updates it. Log-only until
# LINEAR_RELEASE_MODE is "live". Non-fatal: the release is already out.
- name: Record release in Linear
id: linear
continue-on-error: true
# A hung API call must not hold up the Slack notice.
timeout-minutes: 10
uses: actions/github-script@3a2844b7e9c422d3c10d287c895573f7108da1b3 # v9.0.0
env:
LINEAR_ACCESS_KEY: ${{ secrets.LINEAR_ACCESS_KEY }}
LINEAR_RELEASE_MODE: ${{ vars.LINEAR_RELEASE_MODE }}
RELEASE_VERSION: v${{ needs.release.outputs.version }}
RELEASE_SHA: ${{ github.sha }}
RELEASE_BRANCH: dev
RELEASE_NOTES: github-release
with:
script: return require('./.github/scripts/record-linear-release.cjs')({ github, context, core })

# End-of-run notices run in their own job: a failed Slack post fails only this
# job, not the release, and "Re-run failed jobs" re-posts without releasing
# again.
notify:
name: Notify Slack
needs: release
# linear-release is skipped for pre-releases and failed releases; this job still runs.
needs: [release, linear-release]
# Pushes to dev that are not release commits skip the release job and post
# nothing.
if: ${{ !cancelled() && vars.SLACK_CHANNEL_ID != '' && contains(fromJSON('["success", "failure"]'), needs.release.result) }}
Expand Down Expand Up @@ -180,6 +220,9 @@ jobs:

- name: Notify Slack (release published)
if: ${{ needs.release.result == 'success' && needs.release.outputs.prerelease == 'false' }}
env:
# Empty while the release step only logs, or when it failed.
RELEASE_URL: ${{ needs.linear-release.outputs.release-url }}
uses: slackapi/slack-github-action@dcb1066f776dd043e64d0e8ba94ca15cc7e1875d # v4.0.0
with:
method: chat.postMessage
Expand All @@ -190,7 +233,7 @@ jobs:
thread_ts: ${{ env.THREAD_TS }}
text: >-
*pyro*: `v${{ env.VERSION }}` released :white_check_mark: and `main` moved to it.
Update with `claude plugin marketplace update pyro && claude plugin update pyro`, then restart. <${{ github.server_url }}/${{ github.repository }}/releases/tag/v${{ env.VERSION }}|Release notes>.
Update with `claude plugin marketplace update pyro && claude plugin update pyro`, then restart. <${{ github.server_url }}/${{ github.repository }}/releases/tag/v${{ env.VERSION }}|Release notes>.${{ env.RELEASE_URL != '' && format(' <{0}|View release>.', env.RELEASE_URL) || (needs.linear-release.result == 'failure' || needs.linear-release.outputs.outcome == 'failure') && ' Recording it in Linear failed :warning:.' || '' }}

# Success also puts a ✅ on the start notice, so the result shows in the
# channel without another message. Needs the app's reactions:write scope.
Expand Down
4 changes: 3 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -153,4 +153,6 @@ There are two kinds of release, and they differ in how the PR opens:

Merges into `dev` and releases post to the team's Slack channel. A release
posts a start message and replies with the result in its thread; failures also
go to the channel, and success adds a ✅ to the start message.
go to the channel, and success adds a ✅ to the start message. Stable releases
are also recorded in the team's Linear release tracker, with the PRs merged since
the previous release and the GitHub release notes.
Loading