Merge pull request #101 from shrimalmadhur/feat-issues-add-slack-thread-issue-transport

feat(issues): add Slack thread issue transport

Author: shrimalmadhur

drizzle/0011_nice_slack_threads.sql

@@ -0,0 +1,5 @@
+ALTER TABLE `issues` ADD `slack_channel_id` text;
+ALTER TABLE `issues` ADD `slack_thread_ts` text;
+ALTER TABLE `issue_messages` ADD `slack_message_ts` text;
+CREATE INDEX `idx_issues_slack_thread` ON `issues` (`slack_channel_id`,`slack_thread_ts`);
+CREATE INDEX `idx_issue_messages_slack_message_ts` ON `issue_messages` (`slack_message_ts`);

drizzle/meta/_journal.json

@@ -78,6 +78,13 @@
       "when": 1774574276077,
       "tag": "0010_complex_doomsday",
       "breakpoints": true
+    },
+    {
+      "idx": 11,
+      "version": "6",
+      "when": 1774600000000,
+      "tag": "0011_nice_slack_threads",
+      "breakpoints": true
     }
   ]
-}
+}

scripts/issue-pipeline.ts

@@ -1,8 +1,12 @@
 import { loadEnv } from "./lib/load-env";
 loadEnv();
 
+import { db } from "../src/lib/db";
+import { issues } from "../src/lib/db/schema";
 import { runIssuePipeline } from "../src/lib/issues/pipeline";
 import { getIssuesTelegramConfig } from "../src/lib/issues/telegram-poller";
+import { getIssuesSlackConfig } from "../src/lib/issues/slack";
+import { eq } from "drizzle-orm";
 
 async function main() {
   const args = process.argv.slice(2);
@@ -13,14 +17,39 @@ async function main() {
   }
   const issueId = args[issueIdx + 1];
 
+  const [issue] = await db.select({
+    slackChannelId: issues.slackChannelId,
+    slackThreadTs: issues.slackThreadTs,
+  }).from(issues).where(eq(issues.id, issueId)).limit(1);
+
+  if (!issue) {
+    console.error(`Issue not found: ${issueId}`);
+    process.exit(1);
+  }
+
+  const useSlack = Boolean(issue.slackChannelId && issue.slackThreadTs);
+
+  if (useSlack) {
+    const slackConfig = await getIssuesSlackConfig();
+    if (!slackConfig) {
+      console.error("No Slack issues app configured. Set it up via Issues > Config in the UI.");
+      process.exit(1);
+    }
+
+    console.log(`Running pipeline for issue: ${issueId}`);
+    await runIssuePipeline(issueId, { kind: "slack", ...slackConfig });
+    console.log("Pipeline complete.");
+    return;
+  }
+
   const config = await getIssuesTelegramConfig();
   if (!config) {
     console.error("No Telegram issues bot configured. Set up via Issues > Config in the UI.");
     process.exit(1);
   }
 
   console.log(`Running pipeline for issue: ${issueId}`);
-  await runIssuePipeline(issueId, config);
+  await runIssuePipeline(issueId, { kind: "telegram", ...config });
   console.log("Pipeline complete.");
 }
 

src/__tests__/instrumentation.test.ts

@@ -12,6 +12,8 @@ describe("instrumentation register()", () => {
     // Reset the globalThis poller state so ensurePollerRunning is callable
     const g = globalThis as unknown as { _issuePoller?: { running: boolean; starting: boolean } };
     g._issuePoller = { running: false, starting: false };
+    const slack = globalThis as unknown as { _slackIssueSocket?: { running: boolean; starting: boolean } };
+    slack._slackIssueSocket = { running: false, starting: false };
   });
 
   afterEach(() => {
@@ -29,16 +31,18 @@ describe("instrumentation register()", () => {
     }
   });
 
-  test("calls ensurePollerRunning in bun runtime", async () => {
+  test("starts issue transports in bun runtime", async () => {
     // We're running under bun, so process.versions.bun is already set
     expect(process.versions.bun).toBeTruthy();
 
     const { register } = await import("../instrumentation");
     await register();
 
-    // ensurePollerRunning sets starting=true on the global state
+    // Both transport managers set starting=true on the global state
     const g = globalThis as unknown as { _issuePoller?: { running: boolean; starting: boolean } };
     expect(g._issuePoller!.starting).toBe(true);
+    const slack = globalThis as unknown as { _slackIssueSocket?: { running: boolean; starting: boolean } };
+    expect(slack._slackIssueSocket!.starting).toBe(true);
   });
 
   test("skips in non-bun runtime", async () => {
@@ -52,8 +56,10 @@ describe("instrumentation register()", () => {
     const { register } = await import("../instrumentation");
     await register();
 
-    // ensurePollerRunning should NOT have been called
+    // Transport managers should NOT have been called
     const g = globalThis as unknown as { _issuePoller?: { running: boolean; starting: boolean } };
     expect(g._issuePoller!.starting).toBe(false);
+    const slack = globalThis as unknown as { _slackIssueSocket?: { running: boolean; starting: boolean } };
+    expect(slack._slackIssueSocket!.starting).toBe(false);
   });
 });

src/app/(app)/issues/config/page.tsx

@@ -31,9 +31,18 @@ interface TelegramConfig {
   chatId: string | null;
 }
 
+interface SlackConfig {
+  configured: boolean;
+  enabled: boolean;
+  botToken: string | null;
+  appToken: string | null;
+  channelId: string | null;
+}
+
 export default function IssuesConfigPage() {
   const [repos, setRepos] = useState<Repository[]>([]);
   const [telegram, setTelegram] = useState<TelegramConfig | null>(null);
+  const [slack, setSlack] = useState<SlackConfig | null>(null);
   const [loading, setLoading] = useState(true);
   const [error, setError] = useState<string | null>(null);
   const [success, setSuccess] = useState<string | null>(null);
@@ -66,11 +75,17 @@ export default function IssuesConfigPage() {
   const [tgChatTitle, setTgChatTitle] = useState("");
   const [tgManualChatId, setTgManualChatId] = useState("");
 
+  const [slackBotToken, setSlackBotToken] = useState("");
+  const [slackAppToken, setSlackAppToken] = useState("");
+  const [slackChannelId, setSlackChannelId] = useState("");
+  const [savingSlack, setSavingSlack] = useState(false);
+
   async function fetchAll() {
     try {
-      const [repoRes, tgRes] = await Promise.all([
+      const [repoRes, tgRes, slackRes] = await Promise.all([
         fetch("/api/issues/projects"),
         fetch("/api/issues/telegram"),
+        fetch("/api/issues/slack"),
       ]);
       if (repoRes.ok) {
         const data = await repoRes.json();
@@ -80,6 +95,10 @@ export default function IssuesConfigPage() {
         const data = await tgRes.json();
         setTelegram(data);
       }
+      if (slackRes.ok) {
+        const data = await slackRes.json();
+        setSlack(data);
+      }
     } catch {
       setError("Could not connect to server");
     } finally {
@@ -285,6 +304,52 @@ export default function IssuesConfigPage() {
     }
   }
 
+  async function handleSaveSlack() {
+    setSavingSlack(true);
+    setError(null);
+    try {
+      const res = await fetch("/api/issues/slack", {
+        method: "POST",
+        headers: { "Content-Type": "application/json" },
+        body: JSON.stringify({
+          botToken: slackBotToken.trim(),
+          appToken: slackAppToken.trim(),
+          channelId: slackChannelId.trim() || undefined,
+          test: true,
+        }),
+      });
+      if (!res.ok) {
+        const data = await res.json();
+        showError(data.error || "Failed to save Slack config");
+        return;
+      }
+
+      setSlackBotToken("");
+      setSlackAppToken("");
+      setSlackChannelId("");
+      showSuccess("Slack app configured and tested");
+      await fetchAll();
+    } catch {
+      showError("Failed to save Slack config");
+    } finally {
+      setSavingSlack(false);
+    }
+  }
+
+  async function handleDeleteSlack() {
+    try {
+      const res = await fetch("/api/issues/slack", { method: "DELETE" });
+      if (!res.ok) {
+        showError("Failed to remove Slack config");
+        return;
+      }
+      showSuccess("Slack config removed");
+      await fetchAll();
+    } catch {
+      showError("Failed to remove Slack config");
+    }
+  }
+
   if (loading) {
     return (
       <div className="flex items-center justify-center h-full">
@@ -332,6 +397,100 @@ export default function IssuesConfigPage() {
           </div>
         )}
 
+        <section className="space-y-3">
+          <h2 className="text-[14px] font-mono font-bold text-accent uppercase tracking-widest">
+            &gt; Slack Issue App
+          </h2>
+          <p className="text-[13px] font-mono text-muted-foreground ml-4">
+            Uses Slack Socket Mode so issue creation and all follow-up replies stay inside the Slack thread.
+          </p>
+
+          {slack?.configured ? (
+            <div className="term-card p-4 space-y-2">
+              <div className="grid grid-cols-3 gap-4">
+                <div className="space-y-1">
+                  <div className="text-[12px] font-mono text-muted uppercase">bot token</div>
+                  <div className="text-[14px] font-mono text-foreground">{slack.botToken}</div>
+                </div>
+                <div className="space-y-1">
+                  <div className="text-[12px] font-mono text-muted uppercase">app token</div>
+                  <div className="text-[14px] font-mono text-foreground">{slack.appToken}</div>
+                </div>
+                <div className="space-y-1 text-right">
+                  <div className="text-[12px] font-mono text-muted uppercase">channel id</div>
+                  <div className="text-[14px] font-mono text-foreground">{slack.channelId || "any joined channel"}</div>
+                </div>
+              </div>
+              <div className="flex items-center justify-between pt-2 border-t border-border/40">
+                <span className="flex items-center gap-1.5 text-[12px] font-mono text-green">
+                  <span className="h-1.5 w-1.5 rounded-full bg-green" />
+                  configured
+                </span>
+                <button
+                  onClick={handleDeleteSlack}
+                  className="text-[12px] font-mono text-muted-foreground hover:text-red transition-colors"
+                >
+                  remove
+                </button>
+              </div>
+            </div>
+          ) : (
+            <div className="term-card p-4 space-y-3">
+              <div className="space-y-1">
+                <label className="text-[12px] font-mono text-muted uppercase tracking-wider">bot token</label>
+                <input
+                  type="password"
+                  value={slackBotToken}
+                  onChange={(e) => setSlackBotToken(e.target.value)}
+                  placeholder="xoxb-..."
+                  className="w-full border border-border bg-background px-3 py-2 text-[14px] font-mono text-foreground placeholder:text-muted/50 outline-none focus:border-accent"
+                />
+              </div>
+              <div className="space-y-1">
+                <label className="text-[12px] font-mono text-muted uppercase tracking-wider">app token</label>
+                <input
+                  type="password"
+                  value={slackAppToken}
+                  onChange={(e) => setSlackAppToken(e.target.value)}
+                  placeholder="xapp-..."
+                  className="w-full border border-border bg-background px-3 py-2 text-[14px] font-mono text-foreground placeholder:text-muted/50 outline-none focus:border-accent"
+                />
+                <p className="text-[12px] font-mono text-muted">
+                  Enable Socket Mode in your Slack app and use an app-level token with the <span className="text-foreground">connections:write</span> scope.
+                </p>
+              </div>
+              <div className="space-y-1">
+                <label className="text-[12px] font-mono text-muted uppercase tracking-wider">channel id (optional)</label>
+                <input
+                  type="text"
+                  value={slackChannelId}
+                  onChange={(e) => setSlackChannelId(e.target.value)}
+                  placeholder="C0123456789"
+                  className="w-full border border-border bg-background px-3 py-2 text-[14px] font-mono text-foreground placeholder:text-muted/50 outline-none focus:border-accent"
+                />
+                <p className="text-[12px] font-mono text-muted">
+                  Restrict issue creation to one Slack channel, or leave blank to accept mentions in any channel the bot has joined.
+                </p>
+              </div>
+              <div className="border border-border/50 bg-background/40 px-3 py-3 text-[12px] font-mono text-muted space-y-1">
+                <div>Required bot scopes: <span className="text-foreground">app_mentions:read</span>, <span className="text-foreground">channels:history</span>, <span className="text-foreground">groups:history</span>, <span className="text-foreground">chat:write</span></div>
+                <div>Usage: mention the bot with <span className="text-foreground">@bot repo-name: description</span>. All replies should stay in that Slack thread.</div>
+              </div>
+              <button
+                onClick={handleSaveSlack}
+                disabled={!slackBotToken.trim() || !slackAppToken.trim() || savingSlack}
+                className="flex items-center gap-1.5 border border-accent bg-accent/10 px-4 py-1.5 text-[13px] font-mono font-bold text-accent uppercase tracking-wider transition-all hover:bg-accent/20 disabled:opacity-40"
+              >
+                {savingSlack ? (
+                  <><Loader2 className="h-3 w-3 animate-spin" /> saving...</>
+                ) : (
+                  <><Send className="h-3 w-3" /> save &amp; test</>
+                )}
+              </button>
+            </div>
+          )}
+        </section>
+
         {/* Telegram Bot Config */}
         <section className="space-y-3">
           <h2 className="text-[14px] font-mono font-bold text-accent uppercase tracking-widest">

src/app/api/issues/route.ts

@@ -3,14 +3,16 @@ import { db } from "@/lib/db";
 import { issues, repositories } from "@/lib/db/schema";
 import { eq, desc, and, isNull, isNotNull, count, type SQL } from "drizzle-orm";
 import { ensurePollerRunning } from "@/lib/issues/poller-manager";
+import { ensureSlackIssuesSocketRunning } from "@/lib/issues/slack-socket";
 import { createIssueSchema } from "@/lib/validations/issue";
 import { withErrorHandler } from "@/lib/api/utils";
 
 export const runtime = "nodejs";
 
 export const GET = withErrorHandler(async (request: Request) => {
-  // Start the in-process Telegram poller on first access (lazy init)
+  // Start the in-process issue transports on first access (lazy init)
   ensurePollerRunning();
+  ensureSlackIssuesSocketRunning();
 
   const { searchParams } = new URL(request.url);
   const repositoryId = searchParams.get("repositoryId");