+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 +168 +169 +170 +171 +172 +173 +174 +175 +176 +177 +178 +179 +180 +181 +182 +183 +184 +185 +186 +187 +188 +189 +190 +191 +192 +193 +194 +195 +196 +197 +198 +199 | 1x +1x + +1x +1x + +1x +1x + +1x + +1x + + + + + + + + + + + + + + +3x +3x + + + + +6x + + + + + + + + + + +6x +6x + + + + + + + + + + + + + + + + + + + + + + + + + +3x +3x + +3x + + + + + + + +3x +3x +3x +3x + +3x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +3x + + + + + +3x + +3x + + + + + + + + + + + +3x + + + + + + + + + + +3x + +3x + + + + + + + + +3x + + + + + + + + + + + + +3x + +3x + + + +3x + + +3x + + + +3x + + + + + +3x + + + + | import nodePath from "path";
+import micromatch from "micromatch";
+import { ProbotOctokit } from "probot";
+import fetch from "node-fetch";
+import { safeLoad } from "js-yaml";
+import { Packages, Tool } from "@manypkg/get-packages";
+import assembleReleasePlan from "@changesets/assemble-release-plan";
+import { parse as parseConfig } from "@changesets/config";
+import { PreState, NewChangeset } from "@changesets/types";
+import parseChangeset from "@changesets/parse";
+
+export let getChangedPackages = async ({
+ owner,
+ repo,
+ ref,
+ changedFiles: changedFilesPromise,
+ octokit,
+ installationToken,
+}: {
+ owner: string;
+ repo: string;
+ ref: string;
+ changedFiles: string[] | Promise<string[]>;
+ octokit: InstanceType<typeof ProbotOctokit>;
+ installationToken: string;
+}) => {
+ let hasErrored = false;
+ let encodedCredentials = Buffer.from(
+ `x-access-token:${installationToken}`
+ ).toString("base64");
+
+ function fetchFile(path: string) {
+ return fetch(
+ `https://raw.githubusercontent.com/${owner}/${repo}/${ref}/${path}`,
+ {
+ headers: {
+ Authorization: `Basic ${encodedCredentials}`,
+ },
+ }
+ );
+ }
+
+ function fetchJsonFile(path: string) {
+ return fetchFile(path)
+ .then((x) => x.json())
+ .catch((err) => {
+ hasErrored = true;
+ console.error(err);
+ return {};
+ });
+ }
+
+ function fetchTextFile(path: string) {
+ return fetchFile(path)
+ .then((x) => x.text())
+ .catch((err) => {
+ hasErrored = true;
+ console.error(err);
+ return "";
+ });
+ }
+
+ async function getPackage(pkgPath: string) {
+ let jsonContent = await fetchJsonFile(pkgPath + "/package.json");
+ return {
+ packageJson: jsonContent,
+ dir: pkgPath,
+ };
+ }
+
+ let rootPackageJsonContentsPromise = fetchJsonFile("package.json");
+ let configPromise: Promise<any> = fetchJsonFile(".changeset/config.json");
+
+ let tree = await octokit.git.getTree({
+ owner,
+ repo,
+ recursive: "1",
+ tree_sha: ref,
+ });
+
+ let preStatePromise: Promise<PreState> | undefined;
+ let changesetPromises: Promise<NewChangeset>[] = [];
+ let potentialWorkspaceDirectories: string[] = [];
+ let isPnpm = false;
+ let changedFiles = await changedFilesPromise;
+
+ for (let item of tree.data.tree) {
+ Iif (!item.path) continue;
+ if (item.path.endsWith("/package.json")) {
+ let dirPath = nodePath.dirname(item.path);
+ potentialWorkspaceDirectories.push(dirPath);
+ } else if (item.path === "pnpm-workspace.yaml") {
+ isPnpm = true;
+ } else if (item.path === ".changeset/pre.json") {
+ preStatePromise = fetchJsonFile(".changeset/pre.json");
+ } else Iif (
+ item.path !== ".changeset/README.md" &&
+ item.path.startsWith(".changeset") &&
+ item.path.endsWith(".md") &&
+ changedFiles.includes(item.path)
+ ) {
+ let res = /\.changeset\/([^\.]+)\.md/.exec(item.path);
+ Iif (!res) {
+ throw new Error("could not get name from changeset filename");
+ }
+ let id = res[1];
+ changesetPromises.push(
+ fetchTextFile(item.path).then((text) => {
+ return { ...parseChangeset(text), id };
+ })
+ );
+ }
+ }
+ let tool:
+ | {
+ tool: Tool;
+ globs: string[];
+ }
+ | undefined;
+
+ Iif (isPnpm) {
+ tool = {
+ tool: "pnpm",
+ globs: safeLoad(await fetchTextFile("pnpm-workspace.yaml")).packages,
+ };
+ } else {
+ let rootPackageJsonContent = await rootPackageJsonContentsPromise;
+
+ Iif (rootPackageJsonContent.workspaces) {
+ if (!Array.isArray(rootPackageJsonContent.workspaces)) {
+ tool = {
+ tool: "yarn",
+ globs: rootPackageJsonContent.workspaces.packages,
+ };
+ } else {
+ tool = {
+ tool: "yarn",
+ globs: rootPackageJsonContent.workspaces,
+ };
+ }
+ } else Iif (
+ rootPackageJsonContent.bolt &&
+ rootPackageJsonContent.bolt.workspaces
+ ) {
+ tool = {
+ tool: "bolt",
+ globs: rootPackageJsonContent.bolt.workspaces,
+ };
+ }
+ }
+
+ let rootPackageJsonContent = await rootPackageJsonContentsPromise;
+
+ let packages: Packages = {
+ root: {
+ dir: "/",
+ packageJson: rootPackageJsonContent,
+ },
+ tool: tool ? tool.tool : "root",
+ packages: [],
+ };
+
+ Iif (tool) {
+ Iif (
+ !Array.isArray(tool.globs) ||
+ !tool.globs.every((x) => typeof x === "string")
+ ) {
+ throw new Error("globs are not valid: " + JSON.stringify(tool.globs));
+ }
+ let matches = micromatch(potentialWorkspaceDirectories, tool.globs);
+
+ packages.packages = await Promise.all(
+ matches.map((dir) => getPackage(dir))
+ );
+ } else {
+ packages.packages.push(packages.root);
+ }
+ Iif (hasErrored) {
+ throw new Error("an error occurred when fetching files");
+ }
+
+ const releasePlan = assembleReleasePlan(
+ await Promise.all(changesetPromises),
+ packages,
+ await configPromise.then((rawConfig) => parseConfig(rawConfig, packages)),
+ await preStatePromise
+ );
+
+ return {
+ changedPackages: (packages.tool === "root"
+ ? packages.packages
+ : packages.packages.filter((pkg) =>
+ changedFiles.some((changedFile) => changedFile.includes(pkg.dir))
+ )
+ ).map((x) => x.packageJson.name),
+ releasePlan,
+ };
+};
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| get-changed-packages.ts | +
+
+ |
+ 46.66% | +35/75 | +18.75% | +6/32 | +37.5% | +6/16 | +47.22% | +34/72 | +
| index.ts | +
+
+ |
+ 82.45% | +47/57 | +59.09% | +13/22 | +83.33% | +15/18 | +83.63% | +46/55 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 +129 +130 +131 +132 +133 +134 +135 +136 +137 +138 +139 +140 +141 +142 +143 +144 +145 +146 +147 +148 +149 +150 +151 +152 +153 +154 +155 +156 +157 +158 +159 +160 +161 +162 +163 +164 +165 +166 +167 +168 +169 +170 +171 +172 +173 +174 +175 +176 +177 +178 +179 +180 +181 +182 +183 +184 +185 +186 +187 +188 +189 +190 +191 +192 +193 +194 +195 +196 +197 +198 +199 +200 +201 +202 +203 +204 +205 +206 +207 +208 +209 +210 +211 +212 +213 +214 +215 +216 +217 +218 +219 +220 +221 +222 +223 +224 +225 +226 +227 +228 +229 +230 +231 +232 +233 +234 +235 +236 +237 +238 +239 +240 +241 +242 | +1x + + +1x + + + + + +1x +1x +1x + +1x +3x + +3x + + + + +3x + + + + + + + + + + + + + +3x + + + + + + + + + + + + + + + + + + +1x + + + +1x + + + + + + + + + + + + + +1x + + + +2x + + + + + + + + + + + + + +1x +3x +3x + + + + + + + + + + +1x + + + +1x +1x + + +1x + + +1x + + +1x + + +3x +3x + +3x + + + + + +1x +4x +4x + +4x + + +4x + + +1x + + +3x + +3x +3x + +3x + + + + +3x +3x + + + + + +3x + + + + + + + + + + + + + +3x + + + + + + + + + + + + + + + + + + + + + + + +3x + + + + + + + + + + + +3x + + + + + + + + + + + +3x +1x + + + + +2x + + + + + + + + + + +4x + + | // @ts-ignore
+import humanId from "human-id";
+import { Probot, Context } from "probot";
+import { EmitterWebhookEvent } from "@octokit/webhooks";
+import { getChangedPackages } from "./get-changed-packages";
+import {
+ ReleasePlan,
+ ComprehensiveRelease,
+ VersionType,
+} from "@changesets/types";
+import markdownTable from "markdown-table";
+import { captureException } from "@sentry/node";
+import { ValidationError } from "@changesets/errors";
+
+const getReleasePlanMessage = (releasePlan: ReleasePlan | null) => {
+ Iif (!releasePlan) return "";
+
+ const publishableReleases = releasePlan.releases.filter(
+ (x): x is ComprehensiveRelease & { type: Exclude<VersionType, "none"> } =>
+ x.type !== "none"
+ );
+
+ let table = markdownTable([
+ ["Name", "Type"],
+ ...publishableReleases.map((x) => {
+ return [
+ x.name,
+ {
+ major: "Major",
+ minor: "Minor",
+ patch: "Patch",
+ }[x.type],
+ ];
+ }),
+ ]);
+
+ return `<details><summary>This PR includes ${
+ releasePlan.changesets.length
+ ? `changesets to release ${
+ publishableReleases.length === 1
+ ? "1 package"
+ : `${publishableReleases.length} packages`
+ }`
+ : "no changesets"
+ }</summary>
+
+ ${
+ publishableReleases.length
+ ? table
+ : "When changesets are added to this PR, you'll see the packages that this PR includes changesets for and the associated semver types"
+ }
+
+</details>`;
+};
+
+const getAbsentMessage = (
+ commitSha: string,
+ addChangesetUrl: string,
+ releasePlan: ReleasePlan | null
+) => `### ⚠️ No Changeset found
+
+Latest commit: ${commitSha}
+
+Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. **If these changes should result in a version bump, you need to add a changeset.**
+
+${getReleasePlanMessage(releasePlan)}
+
+[Click here to learn what changesets are, and how to add one](https://github.com/changesets/changesets/blob/main/docs/adding-a-changeset.md).
+
+[Click here if you're a maintainer who wants to add a changeset to this PR](${addChangesetUrl})
+
+`;
+
+const getApproveMessage = (
+ commitSha: string,
+ addChangesetUrl: string,
+ releasePlan: ReleasePlan | null
+) => `### 🦋 Changeset detected
+
+Latest commit: ${commitSha}
+
+**The changes in this PR will be included in the next version bump.**
+
+${getReleasePlanMessage(releasePlan)}
+
+Not sure what this means? [Click here to learn what changesets are](https://github.com/changesets/changesets/blob/main/docs/adding-a-changeset.md).
+
+[Click here if you're a maintainer who wants to add another changeset to this PR](${addChangesetUrl})
+
+`;
+
+const getNewChangesetTemplate = (changedPackages: string[], title: string) =>
+ encodeURIComponent(`---
+${changedPackages.map((x) => `"${x}": patch`).join("\n")}
+---
+
+${title}
+`);
+
+type PRContext = EmitterWebhookEvent<
+ "pull_request.opened" | "pull_request.synchronize"
+> &
+ Omit<Context, keyof EmitterWebhookEvent>;
+
+const getCommentId = (
+ context: PRContext,
+ params: { repo: string; owner: string; issue_number: number }
+) =>
+ context.octokit.issues.listComments(params).then((comments) => {
+ const changesetBotComment = comments.data.find(
+ // TODO: find what the current user is in some way or something
+ (comment) =>
+ comment.user?.login === "changeset-bot[bot]" ||
+ comment.user?.login === "changesets-test-bot[bot]"
+ );
+ return changesetBotComment ? changesetBotComment.id : null;
+ });
+
+const hasChangesetBeenAdded = (
+ changedFilesPromise: ReturnType<PRContext["octokit"]["pulls"]["listFiles"]>
+) =>
+ changedFilesPromise.then((files) =>
+ files.data.some(
+ (file) =>
+ file.status === "added" &&
+ /^\.changeset\/.+\.md$/.test(file.filename) &&
+ file.filename !== ".changeset/README.md"
+ )
+ );
+
+export default (app: Probot) => {
+ app.auth();
+ app.log("Yay, the app was loaded!");
+
+ app.on(
+ ["pull_request.opened", "pull_request.synchronize"],
+ async (context) => {
+ if (
+ context.payload.pull_request.head.ref.startsWith("changeset-release")
+ ) {
+ return;
+ }
+
+ let errFromFetchingChangedFiles = "";
+
+ try {
+ let number = context.payload.number;
+
+ let repo = {
+ repo: context.payload.repository.name,
+ owner: context.payload.repository.owner.login,
+ };
+
+ const latestCommitSha = context.payload.pull_request.head.sha;
+ let changedFilesPromise = context.octokit.pulls.listFiles({
+ ...repo,
+ pull_number: number,
+ });
+
+ const [commentId, hasChangeset, { changedPackages, releasePlan }] =
+ await Promise.all([
+ // we know the comment won't exist on opened events
+ // ok, well like technically that's wrong
+ // but reducing time is nice here so that
+ // deploying this doesn't cost money
+ context.payload.action === "synchronize"
+ ? getCommentId(context, { ...repo, issue_number: number })
+ : undefined,
+ hasChangesetBeenAdded(changedFilesPromise),
+ getChangedPackages({
+ repo: context.payload.pull_request.head.repo.name,
+ owner: context.payload.pull_request.head.repo.owner.login,
+ ref: context.payload.pull_request.head.ref,
+ changedFiles: changedFilesPromise.then((x) =>
+ x.data.map((x) => x.filename)
+ ),
+ octokit: context.octokit,
+ installationToken: (
+ await (
+ await app.auth()
+ ).apps.createInstallationAccessToken({
+ installation_id: context.payload.installation!.id,
+ })
+ ).data.token,
+ }).catch((err) => {
+ if (err instanceof ValidationError) {
+ errFromFetchingChangedFiles = `<details><summary>💥 An error occurred when fetching the changed packages and changesets in this PR</summary>\n\n\`\`\`\n${err.message}\n\`\`\`\n\n</details>\n`;
+ } else {
+ console.error(err);
+ captureException(err);
+ }
+ return {
+ changedPackages: ["@fake-scope/fake-pkg"],
+ releasePlan: null,
+ };
+ }),
+ ] as const);
+
+ let addChangesetUrl = `${
+ context.payload.pull_request.head.repo.html_url
+ }/new/${
+ context.payload.pull_request.head.ref
+ }?filename=.changeset/${humanId({
+ separator: "-",
+ capitalize: false,
+ })}.md&value=${getNewChangesetTemplate(
+ changedPackages,
+ context.payload.pull_request.title
+ )}`;
+
+ let prComment = {
+ ...repo,
+ body:
+ (hasChangeset
+ ? getApproveMessage(latestCommitSha, addChangesetUrl, releasePlan)
+ : getAbsentMessage(
+ latestCommitSha,
+ addChangesetUrl,
+ releasePlan
+ )) + errFromFetchingChangedFiles,
+ };
+
+ if (commentId != null) {
+ return context.octokit.issues.updateComment({
+ ...prComment,
+ comment_id: commentId,
+ });
+ }
+ return context.octokit.issues.createComment({
+ ...prComment,
+ issue_number: number,
+ });
+ } catch (err) {
+ console.error(err);
+ throw err;
+ }
+ }
+ );
+
+ return app
+};
+ |