FilesExpand file tree

main

/

index.ts

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

208 lines (173 loc) · 6.9 KB

main

/

index.ts

Copy path

Top

File metadata and controls

• Code
• Blame

208 lines (173 loc) · 6.9 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

import type { ReleasePlan, ComprehensiveRelease, VersionType } from "@changesets/types";

import type { EmitterWebhookEvent } from "@octokit/webhooks";

import { captureException } from "@sentry/node";

import { humanId } from "human-id";

import markdownTable from "markdown-table";

import type { Probot, Context } from "probot";

import { getChangedPackages, UserValidationError } from "./get-changed-packages.ts";

import { isChangeset } from "./is-changeset.ts";

const getReleasePlanMessage = (releasePlan: ReleasePlan | null) => {

if (!releasePlan) return "";

const publishableReleases = releasePlan.releases.filter(

(release): release is ComprehensiveRelease & { type: Exclude<VersionType, "none"> } =>

release.type !== "none",

);

let table = markdownTable([

["Name", "Type"],

...publishableReleases.map((release) => {

return [

release.name,

{

major: "Major",

minor: "Minor",

patch: "Patch",

}[release.type],

];

}),

]);

return `<details><summary>This PR includes ${

releasePlan.changesets.length > 0

? `changesets to release ${

publishableReleases.length === 1 ? "1 package" : `${publishableReleases.length} packages`

}`

: "no changesets"

}</summary>

${

publishableReleases.length > 0

? 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://changesets.dev/faq).

[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://changesets.dev/faq).

[Click here if you're a maintainer who wants to add another changeset to this PR](${addChangesetUrl})

`;

const getNewChangesetTemplate = (changedPackages: ReadonlyArray<string>, title: string) =>

encodeURIComponent(`---

${changedPackages.map((pkgName) => `"${pkgName}": patch`).join("\n")}

---

${title}

`);

export 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((commentsResponse) => {

const changesetBotComment = commentsResponse.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((filesResponse) =>

filesResponse.data.some((file) => file.status === "added" && isChangeset(file.filename)),

);

export default (app: Probot) => {

void 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((filesResponse) =>

filesResponse.data.map(({ filename }) => filename),

),

octokit: context.octokit,

installationToken: (

await (await app.auth()).apps.createInstallationAccessToken({

installation_id: context.payload.installation!.id,

})

).data.token,

}).catch((err) => {

if (err instanceof UserValidationError) {

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,

};

}),

]);

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,

issue_number: number,

body:

(hasChangeset

? getApproveMessage(latestCommitSha, addChangesetUrl, releasePlan)

: getAbsentMessage(latestCommitSha, addChangesetUrl, releasePlan)) +

errFromFetchingChangedFiles,

};

if (typeof commentId === "number") {

await context.octokit.issues.updateComment({

...prComment,

comment_id: commentId,

});

return;

}

await context.octokit.issues.createComment(prComment);

} catch (err) {

console.error(err);

throw err;

}

});

};