feat(mcp): add create_issue tool for issue creation via MCP

Add new create_issue tool to the MCP server that allows AI agents to
create issues directly in PostgresAI. Supports title, description,
project_id, and labels parameters.

Author: claude

cli/lib/issues.ts

@@ -223,6 +223,91 @@ export async function fetchIssue(params: FetchIssueParams): Promise<IssueDetail
   }
 }
 
+export interface CreateIssueParams {
+  apiKey: string;
+  apiBaseUrl: string;
+  title: string;
+  description?: string;
+  projectId?: number;
+  labels?: string[];
+  debug?: boolean;
+}
+
+export interface CreatedIssue {
+  id: string;
+  title: string;
+  description: string | null;
+  created_at: string;
+  status: number;
+  project_id: number | null;
+  labels: string[] | null;
+}
+
+export async function createIssue(params: CreateIssueParams): Promise<CreatedIssue> {
+  const { apiKey, apiBaseUrl, title, description, projectId, labels, debug } = params;
+  if (!apiKey) {
+    throw new Error("API key is required");
+  }
+  if (!title) {
+    throw new Error("title is required");
+  }
+
+  const base = normalizeBaseUrl(apiBaseUrl);
+  const url = new URL(`${base}/rpc/issue_create`);
+
+  const bodyObj: Record<string, unknown> = {
+    title: title,
+  };
+  if (description) {
+    bodyObj.description = description;
+  }
+  if (projectId !== undefined) {
+    bodyObj.project_id = projectId;
+  }
+  if (labels && labels.length > 0) {
+    bodyObj.labels = labels;
+  }
+  const body = JSON.stringify(bodyObj);
+
+  const headers: Record<string, string> = {
+    "access-token": apiKey,
+    "Prefer": "return=representation",
+    "Content-Type": "application/json",
+  };
+
+  if (debug) {
+    const debugHeaders: Record<string, string> = { ...headers, "access-token": maskSecret(apiKey) };
+    console.log(`Debug: Resolved API base URL: ${base}`);
+    console.log(`Debug: POST URL: ${url.toString()}`);
+    console.log(`Debug: Auth scheme: access-token`);
+    console.log(`Debug: Request headers: ${JSON.stringify(debugHeaders)}`);
+    console.log(`Debug: Request body: ${body}`);
+  }
+
+  const response = await fetch(url.toString(), {
+    method: "POST",
+    headers,
+    body,
+  });
+
+  if (debug) {
+    console.log(`Debug: Response status: ${response.status}`);
+    console.log(`Debug: Response headers: ${JSON.stringify(Object.fromEntries(response.headers.entries()))}`);
+  }
+
+  const data = await response.text();
+
+  if (response.ok) {
+    try {
+      return JSON.parse(data) as CreatedIssue;
+    } catch {
+      throw new Error(`Failed to parse create issue response: ${data}`);
+    }
+  } else {
+    throw new Error(formatHttpError("Failed to create issue", response.status, data));
+  }
+}
+
 export interface CreateIssueCommentParams {
   apiKey: string;
   apiBaseUrl: string;

cli/lib/mcp-server.ts

@@ -1,6 +1,6 @@
 import pkg from "../package.json";
 import * as config from "./config";
-import { fetchIssues, fetchIssueComments, createIssueComment, fetchIssue } from "./issues";
+import { fetchIssues, fetchIssueComments, createIssueComment, fetchIssue, createIssue } from "./issues";
 import { resolveBaseUrls } from "./util";
 
 // MCP SDK imports - Bun handles these directly
@@ -71,6 +71,26 @@ export async function startMcpServer(rootOpts?: RootOptsLike, extra?: { debug?:
             additionalProperties: false,
           },
         },
+        {
+          name: "create_issue",
+          description: "Create a new issue in PostgresAI",
+          inputSchema: {
+            type: "object",
+            properties: {
+              title: { type: "string", description: "Issue title (required)" },
+              description: { type: "string", description: "Issue description (supports \\n as newline)" },
+              project_id: { type: "number", description: "Project ID to associate the issue with" },
+              labels: {
+                type: "array",
+                items: { type: "string" },
+                description: "Labels to apply to the issue",
+              },
+              debug: { type: "boolean", description: "Enable verbose debug logs" },
+            },
+            required: ["title"],
+            additionalProperties: false,
+          },
+        },
       ],
     };
   });
@@ -133,6 +153,20 @@ export async function startMcpServer(rootOpts?: RootOptsLike, extra?: { debug?:
         return { content: [{ type: "text", text: JSON.stringify(result, null, 2) }] };
       }
 
+      if (toolName === "create_issue") {
+        const rawTitle = String(args.title || "").trim();
+        if (!rawTitle) {
+          return { content: [{ type: "text", text: "title is required" }], isError: true };
+        }
+        const title = interpretEscapes(rawTitle);
+        const rawDescription = args.description ? String(args.description) : undefined;
+        const description = rawDescription ? interpretEscapes(rawDescription) : undefined;
+        const projectId = args.project_id !== undefined ? Number(args.project_id) : undefined;
+        const labels = Array.isArray(args.labels) ? args.labels.map(String) : undefined;
+        const result = await createIssue({ apiKey, apiBaseUrl, title, description, projectId, labels, debug });
+        return { content: [{ type: "text", text: JSON.stringify(result, null, 2) }] };
+      }
+
       throw new Error(`Unknown tool: ${toolName}`);
     } catch (err) {
       const message = err instanceof Error ? err.message : String(err);