feat(cli): add branch push check before PR creation

Extract duplicate menu rendering logic from `index.ts` into a new `src/menu.ts` module, providing generic `selectOne` and `selectMany` functions. This reduces code duplication, improves maintainability, and adds consistent UI controls display across the commit flow and platform selection.

Reviewed-on: #3

README.md

@@ -60,10 +60,12 @@ gai --version      Show version
 $ gai
 
   gai
+  Choose a workflow
+  ↑/↓ navigate · enter/space select · ctrl+c cancel
 
-  ↑/↓ navigate, space/enter select
+  ❯ ● commit  Generate AI commit message
-
+    ○ pr      Create a PR with AI-generated title
-  ❯ ◉ commit          Generate AI commit message
+    ○ config  Configure API settings
 ```
 
 ### Commit Flow
@@ -74,14 +76,13 @@ $ gai commit
   Staged files (will be included):
     ✓ src/git.ts (modified)
 
-  Unstaged files:
-    1. src/ai.ts (modified)
-    2. src/newfile.ts (new)
-
   Select files to stage:
-    ❯ ◉ Select all
+  2 unstaged files available
-      ○ src/ai.ts (modified)
+  ↑/↓ navigate · space toggle · enter confirm · ctrl+c cancel
-      ◉ src/newfile.ts (new)
+
+  ❯ □ Select all
+    □ src/ai.ts      modified
+    ■ src/newfile.ts new
 
   Generating commit message...
 

index.ts

@@ -13,12 +13,29 @@ import {
   commit,
 } from "./src/git";
 import { selectFiles } from "./src/selector";
+import { selectOne } from "./src/menu";
 import { collectProjectContext } from "./src/context";
 import { buildPrompt, SYSTEM_PROMPT } from "./src/prompt";
 import { generateCommitMessage } from "./src/ai";
 import { copyToClipboard } from "./src/clipboard";
 import { BOLD, GREEN, YELLOW, CYAN, RED, DIM, RESET } from "./src/terminal";
 import type { Config } from "./src/types";
+import {
+  getDefaultBranch,
+  getBranchName,
+  getBranchPushStatus,
+  pushCurrentBranch,
+  getBranchCommits,
+  getBranchDiff,
+  detectPlatform,
+  getRemoteHostname,
+  checkCLI,
+  checkAuth,
+  createPR,
+} from "./src/pr";
+import type { Platform } from "./src/pr";
+import { PR_SYSTEM_PROMPT, buildPRPrompt } from "./src/prompt";
+import { generatePRMessage } from "./src/ai";
 
 const args = process.argv.slice(2);
 
@@ -31,6 +48,8 @@ ${BOLD}Usage:${RESET}
   gai commit         Generate commit message for staged/changed files
   gai commit --auto  Auto-stage all changed files
   gai commit -d      Generate message without committing
+  gai pr             Create a PR with AI-generated title and body
+  gai pr --draft     Create a draft PR
   gai config         Configure API settings
   gai --help         Show this help message
   gai --version      Show version
@@ -270,129 +289,51 @@ function printCommitResult(
 }
 
 interface MenuAction {
-  key: string;
+  key: "commit" | "pr" | "config";
   label: string;
   description: string;
 }
 
 const MENU_ACTIONS: MenuAction[] = [
   { key: "commit", label: "commit", description: "Generate AI commit message" },
+  { key: "pr", label: "pr", description: "Create a PR with AI-generated title" },
   { key: "config", label: "config", description: "Configure API settings" },
 ];
 
 async function showMenu(): Promise<void> {
-  const actions = MENU_ACTIONS;
-  let cursor = 0;
-
-  const headerLines = 4;
-
-  process.stdout.write(`\n  ${BOLD}gai${RESET}\n`);
-  process.stdout.write(`  ${DIM}↑/↓ navigate, space/enter select${RESET}\n\n`);
-
-  const totalLines = headerLines + actions.length;
-
-  function render() {
-    for (let i = 0; i < actions.length; i++) {
-      process.stdout.write("\x1b[2K\r");
-      const a = actions[i]!;
-      const pointer = i === cursor ? `${CYAN}❯${RESET} ` : "  ";
-      const dot = i === cursor ? `${GREEN}◉${RESET}` : `${DIM}○${RESET}`;
-      const name = i === cursor ? `${BOLD}${a.label}${RESET}` : a.label;
-      const desc = i === cursor ? a.description : `${DIM}${a.description}${RESET}`;
-      process.stdout.write(`${pointer} ${dot} ${name}${" ".repeat(Math.max(1, 14 - a.label.length))}${desc}\n`);
-    }
-    process.stdout.write(`\x1b[${actions.length}A`);
-  }
-
-  function clearMenu() {
-    process.stdout.write(`\x1b[${headerLines}A`);
-    for (let i = 0; i < totalLines; i++) {
-      process.stdout.write("\r\x1b[2K\n");
-    }
-    process.stdout.write(`\x1b[${totalLines}A`);
-  }
-
   if (!process.stdin.isTTY) {
     console.error(`  ${RED}Error: Interactive menu requires a TTY.${RESET}`);
     process.exit(1);
   }
 
-  const savedRaw = process.stdin.isRaw;
+  const selected = await selectOne({
-  process.stdin.setRawMode(true);
+    title: "gai",
-  process.stdin.resume();
+    subtitle: "Choose a workflow",
-  process.stdout.write("\x1b[?25l");
+    items: MENU_ACTIONS.map((action) => ({
+      label: action.label,
+      value: action.key,
+      description: action.description,
+    })),
+  });
 
-  render();
+  if (selected === "commit") await handleCommit(false, false);
+  if (selected === "pr") await handlePR(false);
+  if (selected === "config") await handleConfig();
+}
 
-  return new Promise((resolve) => {
+async function selectPlatform(hostname: string): Promise<Platform | null> {
-    let escapeBuf = "";
+  if (!process.stdin.isTTY) {
+    console.error(`  ${RED}Error: Platform selection requires a TTY.${RESET}`);
+    process.exit(1);
+  }
 
-    function handleSeq(seq: string) {
+  return selectOne({
-      if (seq === "\x1b[A" || seq === "\x1bOA") {
+    title: "Select remote platform",
-        if (cursor > 0) {
+    subtitle: `Remote ${hostname} could not be auto-detected`,
-          cursor--;
+    items: [
-          render();
+      { label: "GitHub", value: "github" as Platform, description: "Use gh CLI" },
-        }
+      { label: "Gitea", value: "gitea" as Platform, description: "Use tea CLI" },
-      } else if (seq === "\x1b[B" || seq === "\x1bOB") {
+    ],
-        if (cursor < actions.length - 1) {
-          cursor++;
-          render();
-        }
-      }
-    }
-
-    process.stdin.on("data", (data: Buffer) => {
-      const key = data.toString();
-
-      if (key === "\x03") {
-        process.stdin.setRawMode(savedRaw === true);
-        process.stdin.pause();
-        process.stdin.removeAllListeners("data");
-        clearMenu();
-        process.stdout.write("\x1b[?25h");
-        resolve();
-        return;
-      }
-
-      if (key === "\x1b" || key.startsWith("\x1b[")) {
-        escapeBuf = key;
-        if (key.length >= 3) {
-          handleSeq(key);
-          escapeBuf = "";
-        }
-        return;
-      }
-
-      if (escapeBuf) {
-        escapeBuf += key;
-        if (/^[A-Za-z~]$/.test(key)) {
-          handleSeq(escapeBuf);
-          escapeBuf = "";
-        } else if (escapeBuf.length > 8) {
-          escapeBuf = "";
-        }
-        return;
-      }
-
-      if (key === " " || key === "\r") {
-        const selected = actions[cursor]!;
-        process.stdin.setRawMode(savedRaw === true);
-        process.stdin.pause();
-        process.stdin.removeAllListeners("data");
-
-        clearMenu();
-        process.stdout.write("\x1b[?25h");
-
-        if (selected.key === "commit") {
-          handleCommit(false, false).then(resolve);
-        } else if (selected.key === "config") {
-          handleConfig().then(resolve);
-        } else {
-          resolve();
-        }
-        return;
-      }
-    });
   });
 }
 
@@ -517,6 +458,180 @@ async function handleCommit(autoMode: boolean, dryRun: boolean): Promise<void> {
   }
 }
 
+async function handlePR(draft: boolean): Promise<void> {
+  const config = await loadConfig();
+
+  if (!config.apiKey) {
+    console.error(
+      `  ${RED}Error: API key not set. Run ${BOLD}gai config${RESET}${RED} to configure.${RESET}`,
+    );
+    process.exit(1);
+  }
+
+  if (!(await isGitRepo())) {
+    console.error(`  ${RED}Error: Not a git repository.${RESET}`);
+    process.exit(1);
+  }
+
+  let platform = await detectPlatform();
+  if (!platform) {
+    const hostname = (await getRemoteHostname()) || "unknown";
+    const chosen = await selectPlatform(hostname);
+    if (!chosen) {
+      console.log("  Aborted.");
+      process.exit(0);
+    }
+    platform = chosen;
+  }
+
+  const platformLabel = platform === "github" ? "GitHub" : "Gitea";
+  console.log(`  Using: ${CYAN}${platformLabel}${RESET}`);
+
+  const cliError = checkCLI(platform);
+  if (cliError) {
+    console.error(`  ${RED}Error: ${cliError}${RESET}`);
+    process.exit(1);
+  }
+
+  const authError = await checkAuth(platform);
+  if (authError) {
+    console.error(`  ${RED}Error: ${authError}${RESET}`);
+    process.exit(1);
+  }
+
+  const baseBranch = await getDefaultBranch();
+  const branchName = await getBranchName();
+
+  if (branchName === baseBranch) {
+    console.error(
+      `  ${RED}Error: You are on the default branch (${baseBranch}). Switch to a feature branch first.${RESET}`,
+    );
+    process.exit(1);
+  }
+
+  console.log(
+    `  Branch: ${CYAN}${branchName}${RESET} → base: ${CYAN}${baseBranch}${RESET}`,
+  );
+
+  const commits = await getBranchCommits(baseBranch);
+
+  if (commits.length === 0) {
+    console.error(
+      `  ${RED}Error: No commits on ${branchName} compared to ${baseBranch}. Commit something first.${RESET}`,
+    );
+    process.exit(1);
+  }
+
+  console.log(
+    `  ${commits.length} commit${commits.length > 1 ? "s" : ""} on this branch`,
+  );
+
+  const pushStatus = await getBranchPushStatus();
+  if (!pushStatus.pushed) {
+    const target = pushStatus.upstream ?? `origin/${branchName}`;
+    const answer = await ask(
+      `  Branch is not pushed to ${CYAN}${target}${RESET}. Push now? [${GREEN}Y${RESET}/n] `,
+    );
+
+    if (answer.toLowerCase() === "n") {
+      console.log("  Aborted.");
+      return;
+    }
+
+    console.log(`  Pushing ${CYAN}${branchName}${RESET}...`);
+    try {
+      await pushCurrentBranch(branchName, pushStatus.upstream);
+      console.log(`  ${GREEN}Pushed ${branchName}.${RESET}`);
+    } catch (err) {
+      console.error(
+        `  ${RED}Push failed: ${err instanceof Error ? err.message : err}${RESET}`,
+      );
+      process.exit(1);
+    }
+  }
+
+  const diff = await getBranchDiff(baseBranch);
+  if (!diff) {
+    console.error(`  ${RED}Error: No diff from base branch.${RESET}`);
+    process.exit(1);
+  }
+
+  const MAX_DIFF_SIZE = 15000;
+  const truncatedDiff =
+    diff.length > MAX_DIFF_SIZE
+      ? diff.substring(0, MAX_DIFF_SIZE) + "\n... (truncated)"
+      : diff;
+
+  const repoRoot = await getRepoRoot();
+  const projectCtx = await collectProjectContext(repoRoot);
+
+  const userPrompt = buildPRPrompt({
+    readme: projectCtx.readme,
+    packageDescription: projectCtx.packageDescription,
+    structure: projectCtx.structure,
+    branchName,
+    baseBranch,
+    branchCommits: commits,
+    diff: truncatedDiff,
+  });
+
+  console.log("\n  Generating PR title...");
+
+  let title: string;
+  let body: string;
+  try {
+    const result = await generatePRMessage(config, PR_SYSTEM_PROMPT, userPrompt);
+    title = result.title;
+    body = result.body;
+  } catch (err) {
+    console.error(
+      `  ${RED}AI request failed: ${err instanceof Error ? err.message : err}${RESET}`,
+    );
+    process.exit(1);
+  }
+
+  console.log(`\n  ${BOLD}Generated PR:${RESET}`);
+  console.log(`    Title: ${GREEN}${title}${RESET}`);
+  if (body) {
+    console.log(
+      `    Body:  ${DIM}${body.replace(/\n/g, "\n           ")}${RESET}`,
+    );
+  }
+  console.log("");
+
+  const answer = await ask(`  Create this PR? [${GREEN}Y${RESET}/n/e] `);
+  const lower = answer.toLowerCase();
+
+  if (lower === "n") {
+    console.log("  Aborted.");
+    return;
+  }
+
+  if (lower === "e") {
+    const newTitle = await ask("  Title: ");
+    const newBody = await ask("  Body (optional): ");
+    if (!newTitle.trim()) {
+      console.log("  Aborted.");
+      return;
+    }
+    title = newTitle;
+    body = newBody;
+  }
+
+  console.log(`\n  Creating PR...`);
+
+  try {
+    const url = await createPR(platform, title, body, baseBranch, draft);
+    console.log(`  ${GREEN}${BOLD}✔ PR created!${RESET}`);
+    console.log(`    ${CYAN}${url}${RESET}`);
+  } catch (err) {
+    console.error(
+      `  ${RED}PR creation failed: ${err instanceof Error ? err.message : err}${RESET}`,
+    );
+    process.exit(1);
+  }
+}
+
 async function main() {
   if (args.includes("--help") || args.includes("-h")) {
     showHelp();
@@ -547,6 +662,12 @@ async function main() {
     return;
   }
 
+  if (subcommand === "pr") {
+    const draft = args.includes("--draft");
+    await handlePR(draft);
+    return;
+  }
+
   if (!subcommand) {
     await showMenu();
     return;

src/ai.ts

@@ -39,11 +39,10 @@ async function sleep(ms: number) {
   return new Promise((resolve) => setTimeout(resolve, ms));
 }
 
-export async function generateCommitMessage(
+export async function callAI(
   config: Config,
   systemPrompt: string,
   userPrompt: string,
-  retries = MAX_RETRIES,
 ): Promise<string> {
   const url = `${config.apiBase.replace(/\/$/, "")}/chat/completions`;
 
@@ -52,7 +51,7 @@ export async function generateCommitMessage(
     { role: "user", content: userPrompt },
   ];
 
-  for (let attempt = 1; attempt <= retries; attempt++) {
+  for (let attempt = 1; attempt <= MAX_RETRIES; attempt++) {
     try {
       const response = await fetch(url, {
         method: "POST",
@@ -70,7 +69,7 @@ export async function generateCommitMessage(
 
       if (!response.ok) {
         const text = await response.text();
-        if (response.status === 429 && attempt < retries) {
+        if (response.status === 429 && attempt < MAX_RETRIES) {
           await sleep(RETRY_DELAY * attempt);
           continue;
         }
@@ -89,7 +88,7 @@ export async function generateCommitMessage(
       const finishReason = data.choices?.[0]?.finish_reason;
 
       if (raw && raw.trim()) {
-        return cleanMessage(raw);
+        return raw;
       }
 
       if (finishReason === "length") {
@@ -102,22 +101,53 @@ export async function generateCommitMessage(
         throw new Error("Response blocked by content filter.");
       }
 
-      if (attempt < retries) {
+      if (attempt < MAX_RETRIES) {
         await sleep(RETRY_DELAY * attempt);
         continue;
       }
 
       throw new Error(
-        `Empty response from AI after ${retries} attempts. finish_reason: ${finishReason ?? "unknown"}`,
+        `Empty response from AI after ${MAX_RETRIES} attempts. finish_reason: ${finishReason ?? "unknown"}`,
       );
     } catch (err) {
-      if (attempt >= retries) throw err;
+      if (attempt >= MAX_RETRIES) throw err;
       if (err instanceof Error && err.message.startsWith("API error")) throw err;
       if (err instanceof Error && err.message.includes("max_tokens")) throw err;
-      if (err instanceof Error && err.message.includes("content filter")) throw err;
+      if (err instanceof Error && err.message.includes("content filter"))
+        throw err;
       await sleep(RETRY_DELAY * attempt);
     }
   }
 
-  throw new Error("Failed to generate commit message");
+  throw new Error("Failed to generate response");
+}
+
+export async function generateCommitMessage(
+  config: Config,
+  systemPrompt: string,
+  userPrompt: string,
+): Promise<string> {
+  const raw = await callAI(config, systemPrompt, userPrompt);
+  return cleanMessage(raw);
+}
+
+export async function generatePRMessage(
+  config: Config,
+  systemPrompt: string,
+  userPrompt: string,
+): Promise<{ title: string; body: string }> {
+  const raw = await callAI(config, systemPrompt, userPrompt);
+  const cleaned = cleanMessage(raw);
+
+  const lines = cleaned.split("\n");
+  const title = lines[0]?.trim() || "Update";
+  let bodyStart = 1;
+
+  while (bodyStart < lines.length && lines[bodyStart]?.trim() === "") {
+    bodyStart++;
+  }
+
+  const body = lines.slice(bodyStart).join("\n").trim();
+
+  return { title, body };
 }

src/menu.ts

@@ -0,0 +1,307 @@
+import { BOLD, GREEN, CYAN, DIM, RESET } from "./terminal";
+
+const UP = "\x1b[A";
+const DOWN = "\x1b[B";
+const ALT_UP = "\x1bOA";
+const ALT_DOWN = "\x1bOB";
+const SPACE = " ";
+const ENTER = "\r";
+const CTRL_C = "\x03";
+
+export interface Choice<T> {
+  label: string;
+  value: T;
+  description?: string;
+  selected?: boolean;
+}
+
+interface BasePromptOptions {
+  title: string;
+  subtitle?: string;
+  cancelMessage?: string;
+}
+
+interface SinglePromptOptions<T> extends BasePromptOptions {
+  items: Choice<T>[];
+}
+
+interface MultiPromptOptions<T> extends BasePromptOptions {
+  items: Choice<T>[];
+  selectAllLabel?: string;
+  doneLabel?: string;
+}
+
+function hideCursor() {
+  process.stdout.write("\x1b[?25l");
+}
+
+function showCursor() {
+  process.stdout.write("\x1b[?25h");
+}
+
+function moveUp(lines: number) {
+  if (lines > 0) process.stdout.write(`\x1b[${lines}A`);
+}
+
+function clearLine() {
+  process.stdout.write("\r\x1b[2K");
+}
+
+function visibleLength(value: string) {
+  return value.replace(/\x1b\[[0-9;]*m/g, "").length;
+}
+
+function padLabel(label: string, width: number) {
+  return label + " ".repeat(Math.max(1, width - visibleLength(label)));
+}
+
+function controls(mode: "single" | "multi") {
+  if (mode === "single") {
+    return `${DIM}↑/↓ navigate · enter/space select · ctrl+c cancel${RESET}`;
+  }
+  return `${DIM}↑/↓ navigate · space toggle · enter confirm · ctrl+c cancel${RESET}`;
+}
+
+function renderPrompt(lines: string[], previousLines: number) {
+  if (previousLines > 0) {
+    for (let i = 0; i < previousLines; i++) {
+      clearLine();
+      process.stdout.write("\n");
+    }
+    moveUp(previousLines);
+  }
+
+  for (const line of lines) {
+    process.stdout.write(`${line}\n`);
+  }
+  moveUp(lines.length);
+  return lines.length;
+}
+
+function clearPrompt(lines: number) {
+  for (let i = 0; i < lines; i++) {
+    clearLine();
+    process.stdout.write("\n");
+  }
+  moveUp(lines);
+}
+
+function normalizeKey(key: string, escapeBuf: string) {
+  if (key === UP || key === ALT_UP) return { action: "up", escapeBuf: "" };
+  if (key === DOWN || key === ALT_DOWN) return { action: "down", escapeBuf: "" };
+  if (key === SPACE) return { action: "space", escapeBuf: "" };
+  if (key === ENTER) return { action: "enter", escapeBuf: "" };
+  if (key === CTRL_C) return { action: "cancel", escapeBuf: "" };
+
+  if (key === "\x1b" || key.startsWith("\x1b[")) {
+    return { action: null, escapeBuf: key };
+  }
+
+  if (escapeBuf) {
+    const next = escapeBuf + key;
+    if (next === UP || next === ALT_UP) return { action: "up", escapeBuf: "" };
+    if (next === DOWN || next === ALT_DOWN) return { action: "down", escapeBuf: "" };
+    return {
+      action: null,
+      escapeBuf: /^[A-Za-z~]$/.test(key) || next.length > 8 ? "" : next,
+    };
+  }
+
+  return { action: null, escapeBuf: "" };
+}
+
+function createLines<T>(
+  options: BasePromptOptions & { items: Choice<T>[] },
+  mode: "single" | "multi",
+  cursor: number,
+) {
+  const labelWidth = Math.max(
+    ...options.items.map((item) => visibleLength(item.label)),
+    0,
+  ) + 2;
+
+  const lines = [
+    "",
+    `  ${BOLD}${options.title}${RESET}`,
+  ];
+
+  if (options.subtitle) lines.push(`  ${DIM}${options.subtitle}${RESET}`);
+  lines.push(`  ${controls(mode)}`, "");
+
+  for (let i = 0; i < options.items.length; i++) {
+    const item = options.items[i]!;
+    const active = i === cursor;
+    const pointer = active ? `${CYAN}❯${RESET}` : " ";
+    const marker = mode === "single"
+      ? active ? `${GREEN}●${RESET}` : `${DIM}○${RESET}`
+      : item.selected ? `${GREEN}◼${RESET}` : `${DIM}□${RESET}`;
+    const label = active ? `${BOLD}${item.label}${RESET}` : item.label;
+    const description = item.description
+      ? active ? item.description : `${DIM}${item.description}${RESET}`
+      : "";
+
+    lines.push(
+      `  ${pointer} ${marker} ${padLabel(label, labelWidth)}${description}`,
+    );
+  }
+
+  return lines;
+}
+
+function ensureTTY(title: string) {
+  if (process.stdin.isTTY !== true) {
+    throw new Error(`${title} requires a TTY.`);
+  }
+}
+
+export async function selectOne<T>(
+  options: SinglePromptOptions<T>,
+): Promise<T | null> {
+  ensureTTY(options.title);
+
+  let cursor = 0;
+  let renderedLines = 0;
+  let escapeBuf = "";
+  const wasRaw = process.stdin.isRaw;
+
+  if (wasRaw !== true) process.stdin.setRawMode(true);
+  process.stdin.resume();
+  hideCursor();
+
+  const render = () => {
+    renderedLines = renderPrompt(
+      createLines(options, "single", cursor),
+      renderedLines,
+    );
+  };
+
+  render();
+
+  return new Promise((resolve) => {
+    const finish = (value: T | null) => {
+      process.stdin.setRawMode(wasRaw === true);
+      process.stdin.pause();
+      process.stdin.removeListener("data", onData);
+      clearPrompt(renderedLines);
+      showCursor();
+      if (value === null && options.cancelMessage) {
+        process.stdout.write(`  ${options.cancelMessage}\n`);
+      }
+      resolve(value);
+    };
+
+    const onData = (data: Buffer) => {
+      const result = normalizeKey(data.toString(), escapeBuf);
+      escapeBuf = result.escapeBuf;
+
+      if (result.action === "cancel") return finish(null);
+      if (result.action === "up" && cursor > 0) {
+        cursor--;
+        render();
+      } else if (result.action === "down" && cursor < options.items.length - 1) {
+        cursor++;
+        render();
+      } else if (result.action === "space" || result.action === "enter") {
+        finish(options.items[cursor]!.value);
+      }
+    };
+
+    process.stdin.on("data", onData);
+  });
+}
+
+export async function selectMany<T>(
+  options: MultiPromptOptions<T>,
+): Promise<T[] | null> {
+  ensureTTY(options.title);
+
+  const items: Choice<T | null>[] = options.selectAllLabel
+    ? [
+        { label: options.selectAllLabel, value: null, selected: false },
+        ...options.items.map((item) => ({ ...item })),
+      ]
+    : options.items.map((item) => ({ ...item }));
+
+  let cursor = 0;
+  let renderedLines = 0;
+  let escapeBuf = "";
+  const wasRaw = process.stdin.isRaw;
+
+  if (wasRaw !== true) process.stdin.setRawMode(true);
+  process.stdin.resume();
+  hideCursor();
+
+  const syncSelectAll = () => {
+    if (!options.selectAllLabel) return;
+    items[0]!.selected = items.slice(1).every((item) => item.selected);
+  };
+
+  const toggle = (index: number) => {
+    const item = items[index]!;
+    item.selected = !item.selected;
+
+    if (options.selectAllLabel && index === 0) {
+      for (let i = 1; i < items.length; i++) {
+        items[i]!.selected = item.selected;
+      }
+    } else {
+      syncSelectAll();
+    }
+  };
+
+  const render = () => {
+    renderedLines = renderPrompt(
+      createLines(
+        {
+          title: options.title,
+          subtitle: options.subtitle,
+          items,
+        },
+        "multi",
+        cursor,
+      ),
+      renderedLines,
+    );
+  };
+
+  render();
+
+  return new Promise((resolve) => {
+    const finish = (value: T[] | null) => {
+      process.stdin.setRawMode(wasRaw === true);
+      process.stdin.pause();
+      process.stdin.removeListener("data", onData);
+      clearPrompt(renderedLines);
+      showCursor();
+      if (value === null && options.cancelMessage) {
+        process.stdout.write(`  ${options.cancelMessage}\n`);
+      }
+      resolve(value);
+    };
+
+    const onData = (data: Buffer) => {
+      const result = normalizeKey(data.toString(), escapeBuf);
+      escapeBuf = result.escapeBuf;
+
+      if (result.action === "cancel") return finish(null);
+      if (result.action === "up" && cursor > 0) {
+        cursor--;
+        render();
+      } else if (result.action === "down" && cursor < items.length - 1) {
+        cursor++;
+        render();
+      } else if (result.action === "space") {
+        toggle(cursor);
+        render();
+      } else if (result.action === "enter") {
+        finish(
+          items
+            .filter((item) => item.selected && item.value !== null)
+            .map((item) => item.value as T),
+        );
+      }
+    };
+
+    process.stdin.on("data", onData);
+  });
+}

src/pr.ts

@@ -0,0 +1,216 @@
+export type Platform = "github" | "gitea";
+
+export async function getDefaultBranch(): Promise<string> {
+  try {
+    const result =
+      await Bun.$`git symbolic-ref refs/remotes/origin/HEAD`.quiet().text();
+    return result.trim().replace("refs/remotes/origin/", "");
+  } catch {
+    try {
+      const branches = await Bun.$`git branch -r`.quiet().text();
+      for (const line of branches.split("\n")) {
+        const trimmed = line.trim();
+        if (trimmed === "origin/main" || trimmed === "origin/master") {
+          return trimmed.replace("origin/", "");
+        }
+      }
+    } catch {}
+    return "main";
+  }
+}
+
+export async function getBranchName(): Promise<string> {
+  const result =
+    await Bun.$`git rev-parse --abbrev-ref HEAD`.quiet().text();
+  return result.trim();
+}
+
+export async function getBranchPushStatus(): Promise<{
+  pushed: boolean;
+  upstream: string | null;
+}> {
+  try {
+    const upstream = (await Bun.$`git rev-parse --abbrev-ref --symbolic-full-name @{u}`.quiet().text()).trim();
+    const localHead = (await Bun.$`git rev-parse HEAD`.quiet().text()).trim();
+    const remoteHead = (await Bun.$`git rev-parse @{u}`.quiet().text()).trim();
+    return { pushed: localHead === remoteHead, upstream };
+  } catch {
+    return { pushed: false, upstream: null };
+  }
+}
+
+export async function pushCurrentBranch(branch: string, upstream: string | null): Promise<void> {
+  const args = upstream
+    ? ["push"]
+    : ["push", "-u", "origin", branch];
+
+  const proc = Bun.spawn(["git", ...args], {
+    stdout: "pipe",
+    stderr: "pipe",
+  });
+  const exitCode = await proc.exited;
+  const stdout = await new Response(proc.stdout).text();
+  const stderr = await new Response(proc.stderr).text();
+
+  if (exitCode !== 0) {
+    throw new Error(stderr.trim() || stdout.trim() || `git push failed (exit code ${exitCode})`);
+  }
+}
+
+export async function getBranchCommits(base: string): Promise<string[]> {
+  try {
+    const result =
+      await Bun.$`git log --oneline origin/${base}..HEAD`.quiet().text();
+    return result.trim().split("\n").filter(Boolean);
+  } catch {
+    try {
+      const result =
+        await Bun.$`git log --oneline ${base}..HEAD`.quiet().text();
+      return result.trim().split("\n").filter(Boolean);
+    } catch {
+      return [];
+    }
+  }
+}
+
+export async function getBranchDiff(base: string): Promise<string> {
+  try {
+    const result =
+      await Bun.$`git diff ${base}...HEAD`.quiet().text();
+    return result.trim();
+  } catch {
+    return "";
+  }
+}
+
+function parseRemoteHostname(url: string): string | null {
+  const hostname = url
+    .trim()
+    .toLowerCase()
+    .replace(/^(https?:\/\/|ssh:\/\/|git:\/\/)/, "")
+    .replace(/^[^@]+@/, "")
+    .split(/[:/]/)[0];
+  return hostname || null;
+}
+
+export async function detectPlatform(): Promise<Platform | null> {
+  try {
+    const url = await Bun.$`git remote get-url origin`.quiet().text();
+    const hostname = parseRemoteHostname(url);
+
+    if (!hostname) return null;
+
+    if (hostname === "github.com") return "github";
+    if (hostname.includes("gitea")) return "gitea";
+    return null;
+  } catch {
+    return null;
+  }
+}
+
+export async function getRemoteHostname(): Promise<string | null> {
+  try {
+    const url = await Bun.$`git remote get-url origin`.quiet().text();
+    return parseRemoteHostname(url);
+  } catch {
+    return null;
+  }
+}
+
+export function checkCLI(platform: Platform): string | null {
+  const bin = platform === "github" ? "gh" : "tea";
+  const path = Bun.which(bin);
+  if (!path) {
+    if (platform === "github") {
+      return "GitHub CLI (gh) not found. Install: brew install gh";
+    }
+    return "Gitea CLI (tea) not found. Install from: https://gitea.com/gitea/tea";
+  }
+  return null;
+}
+
+export async function checkAuth(platform: Platform): Promise<string | null> {
+  if (platform === "github") {
+    try {
+      await Bun.$`gh auth status`.quiet();
+      return null;
+    } catch {
+      return "Not authenticated with GitHub CLI. Run: gh auth login";
+    }
+  }
+
+  try {
+    const result = await Bun.$`tea logins list`.quiet().text();
+    if (result.trim()) return null;
+    return "Not authenticated with Gitea CLI. Run: tea login add";
+  } catch {
+    return "Not authenticated with Gitea CLI. Run: tea login add";
+  }
+}
+
+export async function createPR(
+  platform: Platform,
+  title: string,
+  body: string,
+  base: string,
+  draft: boolean,
+): Promise<string> {
+  if (platform === "github") {
+    const args = [
+      "pr",
+      "create",
+      "--title",
+      title,
+      "--body",
+      body,
+      "--base",
+      base,
+    ];
+    if (draft) args.push("--draft");
+
+    const proc = Bun.spawn(["gh", ...args], {
+      stdout: "pipe",
+      stderr: "pipe",
+    });
+    const exitCode = await proc.exited;
+    const stdout = await new Response(proc.stdout).text();
+    const stderr = await new Response(proc.stderr).text();
+
+    if (exitCode !== 0) {
+      throw new Error(
+        stderr.trim() || `gh pr create failed (exit code ${exitCode})`,
+      );
+    }
+
+    const match = stdout.match(/(https?:\/\/[^\s]+)/);
+    return match?.[1] ?? stdout.trim();
+  }
+
+  const args = [
+    "pulls",
+    "create",
+    "--title",
+    title,
+    "--description",
+    body,
+    "--base",
+    base,
+  ];
+
+  const proc = Bun.spawn(["tea", ...args], {
+    stdout: "pipe",
+    stderr: "pipe",
+  });
+  const exitCode = await proc.exited;
+  const stdout = await new Response(proc.stdout).text();
+  const stderr = await new Response(proc.stderr).text();
+
+  if (exitCode !== 0) {
+    throw new Error(
+      stderr.trim() || `tea pulls create failed (exit code ${exitCode})`,
+    );
+  }
+
+  const match = stdout.match(/(https?:\/\/[^\s]+)/);
+  return match?.[1] ?? stdout.trim();
+}

src/prompt.ts

@@ -1,4 +1,4 @@
-import type { ProjectContext } from "./types";
+import type { PRContext, ProjectContext } from "./types";
 
 export const SYSTEM_PROMPT = `You are an expert at writing concise, meaningful git commit messages following the Conventional Commits specification.
 
@@ -54,3 +54,65 @@ export function buildPrompt(context: ProjectContext): string {
 
   return parts.join("\n");
 }
+
+export const PR_SYSTEM_PROMPT = `You are an expert at writing clear, concise pull request titles and descriptions.
+
+Format:
+<pr title>
+<blank line>
+<pr body>
+
+Rules:
+1. Title must be under 72 characters, in imperative mood
+2. Follow the Conventional Commits style for the title (e.g., "feat(api): add user authentication")
+3. Body should be 2-3 sentences in plain text explaining WHAT was changed and WHY
+4. Be specific — avoid vague messages
+5. Match the language and style of recent commits if provided
+6. If the branch name hints at the type (e.g., "feat/..." or "fix/..."), reflect that in the title
+7. Output ONLY the PR text — no markdown, no code blocks, no prefixes`;
+
+export function buildPRPrompt(context: PRContext): string {
+  const parts: string[] = [];
+
+  if (
+    context.packageDescription ||
+    context.readme ||
+    context.structure
+  ) {
+    parts.push("## Project Context");
+    if (context.packageDescription) {
+      parts.push(`Description: ${context.packageDescription}`);
+    }
+    if (context.structure) {
+      parts.push(`Structure: ${context.structure}`);
+    }
+    if (context.readme) {
+      parts.push(`README:\n${context.readme}`);
+    }
+    parts.push("");
+  }
+
+  parts.push("## Branch Info");
+  parts.push(`Branch: ${context.branchName}`);
+  parts.push(`Target base: ${context.baseBranch}`);
+  parts.push("");
+
+  if (context.branchCommits.length > 0) {
+    parts.push("## Commits on This Branch");
+    for (const c of context.branchCommits) {
+      parts.push(c);
+    }
+    parts.push("");
+  }
+
+  parts.push("## Changes (diff from base)");
+  parts.push("```diff");
+  parts.push(context.diff);
+  parts.push("```");
+  parts.push("");
+  parts.push(
+    "Generate a pull request title and brief body for the above changes.",
+  );
+
+  return parts.join("\n");
+}

src/selector.ts

@@ -1,37 +1,6 @@
 import type { FileEntry } from "./types";
-import { BOLD, GREEN, YELLOW, CYAN, DIM, RESET } from "./terminal";
+import { BOLD, GREEN, YELLOW, RESET } from "./terminal";
-
+import { selectMany } from "./menu";
-const UP = "\x1b[A";
-const DOWN = "\x1b[B";
-const SPACE = " ";
-const ENTER = "\r";
-const CTRL_C = "\x03";
-
-function hideCursor() {
-  process.stdout.write("\x1b[?25l");
-}
-
-function showCursor() {
-  process.stdout.write("\x1b[?25h");
-}
-
-function moveUp(n: number) {
-  process.stdout.write(`\x1b[${n}A`);
-}
-
-function moveDown(n: number) {
-  process.stdout.write(`\x1b[${n}B`);
-}
-
-function clearLine() {
-  process.stdout.write("\x1b[2K\r");
-}
-
-interface SelectItem {
-  label: string;
-  path: string;
-  selected: boolean;
-}
 
 export async function selectFiles(
   stagedFiles: FileEntry[],
@@ -46,123 +15,27 @@ export async function selectFiles(
     }
   }
 
-  const items: SelectItem[] = [
+  if (process.stdin.isTTY !== true) return [];
-    { label: "Select all", path: "__all__", selected: false },
+
-    ...unstagedFiles.map((f) => ({
+  const selected = await selectMany({
-      label: `${f.path} (${f.label})`,
+    title: "Select files to stage",
-      path: f.path,
+    subtitle: `${unstagedFiles.length} unstaged file${unstagedFiles.length > 1 ? "s" : ""} available`,
-      selected: false,
+    selectAllLabel: "Select all",
+    cancelMessage: "Aborted.",
+    items: unstagedFiles.map((f) => ({
+      label: f.path,
+      value: f.path,
+      description: f.label,
     })),
-  ];
-
-  let cursor = 0;
-
-  process.stdout.write(`\n  ${BOLD}Select files to stage:${RESET}\n`);
-  process.stdout.write(`  ${DIM}↑/↓ navigate, space select, enter confirm${RESET}\n\n`);
-
-  const itemStartRow = 4 + (stagedFiles.length > 0 ? stagedFiles.length + 2 : 0);
-
-  function render() {
-    for (let i = 0; i < items.length; i++) {
-      process.stdout.write("\x1b[2K\r");
-      const item = items[i]!;
-      const isAll = i === 0;
-      const cursor_ = i === cursor ? `${CYAN}❯${RESET} ` : "  ";
-      const checkbox = item.selected ? `${GREEN}◉${RESET}` : `${DIM}○${RESET}`;
-
-      if (isAll) {
-        process.stdout.write(`${cursor_} ${checkbox} ${BOLD}${item.label}${RESET}\n`);
-      } else {
-        process.stdout.write(`${cursor_} ${checkbox} ${item.path.includes("(") ? item.label : `${item.label}`}\n`);
-      }
-    }
-    moveUp(items.length);
-  }
-
-  function toggleItem(index: number) {
-    const item = items[index]!;
-    item.selected = !item.selected;
-
-    if (index === 0) {
-      for (let i = 1; i < items.length; i++) {
-        items[i]!.selected = item.selected;
-      }
-    } else {
-      const allSelected = items.slice(1).every((it) => it.selected);
-      items[0]!.selected = allSelected;
-    }
-  }
-
-  return new Promise((resolve) => {
-    if (process.stdin.isTTY !== true) {
-      resolve([]);
-      return;
-    }
-
-    const wasRaw = process.stdin.isRaw;
-    if (wasRaw !== true) {
-      process.stdin.setRawMode(true);
-    }
-    process.stdin.resume();
-    hideCursor();
-
-    render();
-
-    const onData = (data: Buffer) => {
-      const key = data.toString();
-
-      if (key === CTRL_C) {
-        process.stdin.setRawMode(wasRaw === true);
-        process.stdin.pause();
-        process.stdin.removeListener("data", onData);
-        showCursor();
-        for (let i = 0; i < items.length; i++) {
-          process.stdout.write("\x1b[2K\n");
-        }
-        moveUp(items.length);
-        process.stdout.write(`\n  Aborted.\n`);
-        process.exit(1);
-      }
-
-      if (key === UP) {
-        if (cursor > 0) {
-          cursor--;
-          render();
-        }
-      } else if (key === DOWN) {
-        if (cursor < items.length - 1) {
-          cursor++;
-          render();
-        }
-      } else if (key === SPACE) {
-        toggleItem(cursor);
-        render();
-      } else if (key === ENTER) {
-        process.stdin.setRawMode(wasRaw === true);
-        process.stdin.pause();
-        process.stdin.removeListener("data", onData);
-
-        for (let i = 0; i < items.length; i++) {
-          process.stdout.write("\x1b[2K\n");
-        }
-        moveUp(items.length);
-
-        const selected = items
-          .slice(1)
-          .filter((it) => it.selected)
-          .map((it) => it.path);
-
-        if (selected.length > 0) {
-          process.stdout.write(
-            `  ${GREEN}Staged ${selected.length} file(s):${RESET} ${selected.join(", ")}\n`,
-          );
-        }
-
-        showCursor();
-        resolve(selected);
-      }
-    };
-
-    process.stdin.on("data", onData);
   });
+
+  if (selected === null) process.exit(1);
+
+  if (selected.length > 0) {
+    process.stdout.write(
+      `  ${GREEN}Staged ${selected.length} file(s):${RESET} ${selected.join(", ")}\n`,
+    );
+  }
+
+  return selected;
 }

src/types.ts

@@ -19,3 +19,13 @@ export interface ProjectContext {
   recentCommits: string[];
   diff: string;
 }
+
+export interface PRContext {
+  readme: string | null;
+  packageDescription: string | null;
+  structure: string | null;
+  branchName: string;
+  baseBranch: string;
+  branchCommits: string[];
+  diff: string;
+}