feat: add createOrUpdatePullRequest function with tests for PR creation and updates

Author: CasperKristiansson

docs/tasks.md

@@ -149,7 +149,7 @@ Use Context7 MCP for up to date documentation.
         Create `chore/bump-python-<track>`. Commit updated files.
         Verify: Local e2e shows new branch and commit.
 
-19. [ ] **Create PR via Octokit**
+19. [x] **Create PR via Octokit**
         Title, body with changelog links, manifest evidence, diff summary, rollback. Labels.
         Verify: Sandbox repo e2e PR opens with exact content.
 

package-lock.json

@@ -39,6 +39,7 @@
   "homepage": "https://github.com/CasperKristiansson/python-version-patch-pr#readme",
   "dependencies": {
     "@actions/core": "^1.10.1",
+    "@octokit/rest": "^22.0.0",
     "cheerio": "^1.1.2",
     "fast-glob": "^3.3.3",
     "semver": "^7.7.3",

package.json

@@ -1,2 +1,5 @@
 export { createBranchAndCommit } from './branch';
 export type { BranchCommitOptions, BranchCommitResult } from './branch';
+
+export { createOrUpdatePullRequest } from './pull-request';
+export type { PullRequestOptions, PullRequestResult, OctokitClient } from './pull-request';

src/git/index.ts

@@ -0,0 +1,100 @@
+import { Octokit } from '@octokit/rest';
+
+export interface OctokitClient {
+  pulls: {
+    list: (params: {
+      owner: string;
+      repo: string;
+      head: string;
+      state: 'open';
+      per_page?: number;
+    }) => Promise<{ data: Array<{ number: number; html_url?: string }> }>;
+    create: (params: {
+      owner: string;
+      repo: string;
+      head: string;
+      base: string;
+      title: string;
+      body: string;
+      draft?: boolean;
+      maintainer_can_modify?: boolean;
+    }) => Promise<{ data: { number: number; html_url?: string } }>;
+    update: (params: {
+      owner: string;
+      repo: string;
+      pull_number: number;
+      title: string;
+      body: string;
+      maintainer_can_modify?: boolean;
+    }) => Promise<{ data: { number: number; html_url?: string } }>;
+  };
+}
+
+export interface PullRequestOptions {
+  owner: string;
+  repo: string;
+  head: string;
+  base: string;
+  title: string;
+  body: string;
+  authToken: string;
+  draft?: boolean;
+  maintainerCanModify?: boolean;
+  client?: OctokitClient;
+}
+
+export interface PullRequestResult {
+  action: 'created' | 'updated';
+  number: number;
+  url: string | undefined;
+}
+
+const USER_AGENT = 'python-version-patch-pr/0.1.0';
+
+function createClient(authToken: string): OctokitClient {
+  return new Octokit({ auth: authToken, userAgent: USER_AGENT });
+}
+
+export async function createOrUpdatePullRequest(
+  options: PullRequestOptions,
+): Promise<PullRequestResult> {
+  const { owner, repo, head, base, title, body, authToken, draft, maintainerCanModify, client } =
+    options;
+
+  const octokit = client ?? createClient(authToken);
+
+  const { data: existing } = await octokit.pulls.list({
+    owner,
+    repo,
+    head: `${owner}:${head}`,
+    state: 'open',
+    per_page: 1,
+  });
+
+  if (existing.length > 0) {
+    const pull = existing[0];
+    const response = await octokit.pulls.update({
+      owner,
+      repo,
+      pull_number: pull.number,
+      title,
+      body,
+      maintainer_can_modify: maintainerCanModify,
+    });
+
+    return { action: 'updated', number: response.data.number, url: response.data.html_url };
+  }
+
+  const response = await octokit.pulls.create({
+    owner,
+    repo,
+    head,
+    base,
+    title,
+    body,
+    draft,
+    maintainer_can_modify: maintainerCanModify,
+  });
+
+  return { action: 'created', number: response.data.number, url: response.data.html_url };
+}