Merge dev → main

src/agents/definitions/contextSteps.ts

@@ -106,13 +106,16 @@ export async function fetchWorkItemStep(params: FetchContextParams): Promise<Con
 
 			const { jiraClient } = await import('../../jira/client.js');
 			const { trelloClient } = await import('../../trello/client.js');
+			const { linearClient } = await import('../../linear/client.js');
 
 			const results = await Promise.all(
 				limited.map(async (ref) => {
 					try {
 						let downloaded: { buffer: Buffer; mimeType: string } | null = null;
 						if (provider?.type === 'jira') {
 							downloaded = await jiraClient.downloadAttachment(ref.url);
+						} else if (provider?.type === 'linear') {
+							downloaded = await linearClient.downloadAttachment(ref.url);
 						} else {
 							downloaded = await trelloClient.downloadAttachment(ref.url);
 						}

src/agents/prompts/index.ts

@@ -189,12 +189,12 @@ export interface TaskPromptInput {
 	workItemId?: string;
 	prNumber?: number;
 	prBranch?: string;
-	// PM comment trigger fields
-	triggerCommentText?: string;
-	triggerCommentAuthor?: string;
-	// PR comment trigger fields
+	// Comment trigger fields (unified for PM and SCM comment-mention triggers)
 	triggerCommentBody?: string;
 	triggerCommentPath?: string;
+	triggerCommentAuthor?: string;
+	/** @deprecated Use triggerCommentBody. Kept as backward-compatible alias. */
+	triggerCommentText?: string;
 	// Allow extra fields for future extensibility
 	[key: string]: unknown;
 }
@@ -210,9 +210,9 @@ export function buildTaskPromptContext(input: TaskPromptInput): TaskPromptContex
 		workItemId: input.workItemId,
 		prNumber: input.prNumber,
 		prBranch: input.prBranch,
-		commentText: input.triggerCommentText,
+		commentText: input.triggerCommentBody ?? input.triggerCommentText,
 		commentAuthor: input.triggerCommentAuthor,
-		commentBody: input.triggerCommentBody,
+		commentBody: input.triggerCommentBody ?? input.triggerCommentText,
 		commentPath: input.triggerCommentPath,
 	};
 }

src/linear/client.ts

@@ -629,6 +629,23 @@ export const linearClient = {
 		};
 	},
 
+	/**
+	 * Downloads a Linear-hosted image (e.g. `uploads.linear.app/…`) and
+	 * returns its raw bytes and MIME type.
+	 *
+	 * Linear personal API keys are sent **bare** in the `Authorization` header
+	 * (no `Bearer` prefix). `Content-Type` is intentionally omitted here
+	 * because this is a GET download request, not a JSON API call.
+	 *
+	 * @param url - The attachment/inline image URL to download.
+	 * @returns `{ buffer, mimeType }` on success, `null` on any failure.
+	 */
+	async downloadAttachment(url: string): Promise<{ buffer: Buffer; mimeType: string } | null> {
+		const { apiKey } = getLinearCredentials();
+		const { downloadMedia } = await import('../pm/media.js');
+		return downloadMedia(url, { Authorization: apiKey });
+	},
+
 	// ===== Reactions =====
 
 	async createReaction(commentId: string, emoji: string): Promise<LinearReaction> {

src/pm/linear/adapter.ts

@@ -23,6 +23,7 @@ import {
 } from '../_shared/inline-checklist.js';
 import type { LinearConfig } from '../config.js';
 import type { ContainerId, LabelId } from '../ids.js';
+import { extractMarkdownImages } from '../media.js';
 import type {
 	Attachment,
 	Checklist,
@@ -57,6 +58,7 @@ export class LinearPMProvider implements PMProvider {
 
 	async getWorkItem(id: string): Promise<WorkItem> {
 		const issue = await linearClient.getIssue(id);
+		const inlineMedia = extractMarkdownImages(issue.description ?? '', 'description');
 		return {
 			id: issue.identifier || issue.id,
 			title: issue.title,
@@ -70,21 +72,26 @@ export class LinearPMProvider implements PMProvider {
 					color: l.color,
 				}),
 			),
+			inlineMedia: inlineMedia.length > 0 ? inlineMedia : undefined,
 		};
 	}
 
 	async getWorkItemComments(id: string): Promise<WorkItemComment[]> {
 		const comments = await linearClient.getIssueComments(id);
-		return comments.map((c) => ({
-			id: c.id,
-			date: c.createdAt,
-			text: c.body,
-			author: {
-				id: c.user?.id ?? '',
-				name: c.user?.displayName ?? c.user?.name ?? '',
-				username: c.user?.email ?? '',
-			},
-		}));
+		return comments.map((c) => {
+			const inlineMedia = extractMarkdownImages(c.body, 'comment');
+			return {
+				id: c.id,
+				date: c.createdAt,
+				text: c.body,
+				author: {
+					id: c.user?.id ?? '',
+					name: c.user?.displayName ?? c.user?.name ?? '',
+					username: c.user?.email ?? '',
+				},
+				inlineMedia: inlineMedia.length > 0 ? inlineMedia : undefined,
+			};
+		});
 	}
 
 	async updateWorkItem(

src/router/acknowledgments.ts

@@ -119,12 +119,15 @@ export async function deleteLinearAck(
 // for backward compatibility with pm/ integrations and router/trello.ts.
 // ---------------------------------------------------------------------------
 
+export type { JiraBotIdentity, TrelloBotIdentity } from './bot-identity-resolvers.js';
 export {
 	_resetJiraBotCache,
 	_resetLinearBotCache,
 	_resetTrelloBotCache,
 	resolveJiraBotAccountId,
+	resolveJiraBotIdentity,
 	resolveLinearBotUserId,
+	resolveTrelloBotIdentity,
 	resolveTrelloBotMemberId,
 } from './bot-identity-resolvers.js';
 

src/router/bot-identity-resolvers.ts

@@ -19,13 +19,18 @@ import {
 // JIRA bot identity
 // ---------------------------------------------------------------------------
 
-const jiraBotIdentityCache = new BotIdentityCache<string>('accountId');
+export interface JiraBotIdentity {
+	accountId: string;
+	displayName: string;
+}
+
+const jiraBotIdentityCache = new BotIdentityCache<JiraBotIdentity>('identity');
 
 /**
- * Resolve the JIRA account ID for the bot credentials linked to a project.
+ * Resolve the JIRA bot identity (accountId + displayName) for a project.
  * Cached per-project with 60s TTL. Returns null on any failure.
  */
-export async function resolveJiraBotAccountId(projectId: string): Promise<string | null> {
+export async function resolveJiraBotIdentity(projectId: string): Promise<JiraBotIdentity | null> {
 	return jiraBotIdentityCache.resolve(projectId, async () => {
 		const creds = await resolveJiraCredentials(projectId);
 		if (!creds) return null;
@@ -35,11 +40,21 @@ export async function resolveJiraBotAccountId(projectId: string): Promise<string
 		});
 		if (!response.ok) return null;
 
-		const data = (await response.json()) as { accountId?: string };
-		return data.accountId ?? null;
+		const data = (await response.json()) as { accountId?: string; displayName?: string };
+		if (!data.accountId) return null;
+		return { accountId: data.accountId, displayName: data.displayName ?? '' };
 	});
 }
 
+/**
+ * Resolve the JIRA account ID for the bot credentials linked to a project.
+ * Cached per-project with 60s TTL. Returns null on any failure.
+ */
+export async function resolveJiraBotAccountId(projectId: string): Promise<string | null> {
+	const identity = await resolveJiraBotIdentity(projectId);
+	return identity?.accountId ?? null;
+}
+
 /** @internal Visible for testing only */
 export function _resetJiraBotCache(): void {
 	jiraBotIdentityCache._reset();
@@ -49,13 +64,20 @@ export function _resetJiraBotCache(): void {
 // Trello bot identity
 // ---------------------------------------------------------------------------
 
-const trelloBotIdentityCache = new BotIdentityCache<string>('memberId');
+export interface TrelloBotIdentity {
+	id: string;
+	username: string;
+}
+
+const trelloBotIdentityCache = new BotIdentityCache<TrelloBotIdentity>('identity');
 
 /**
- * Resolve the Trello member ID for the bot credentials linked to a project.
+ * Resolve the Trello bot identity (id + username) for a project.
  * Cached per-project with 60s TTL. Returns null on any failure.
  */
-export async function resolveTrelloBotMemberId(projectId: string): Promise<string | null> {
+export async function resolveTrelloBotIdentity(
+	projectId: string,
+): Promise<TrelloBotIdentity | null> {
 	return trelloBotIdentityCache.resolve(projectId, async () => {
 		const creds = await resolveTrelloCredentials(projectId);
 		if (!creds) return null;
@@ -66,11 +88,21 @@ export async function resolveTrelloBotMemberId(projectId: string): Promise<strin
 		);
 		if (!response.ok) return null;
 
-		const data = (await response.json()) as { id?: string };
-		return data.id ?? null;
+		const data = (await response.json()) as { id?: string; username?: string };
+		if (!data.id) return null;
+		return { id: data.id, username: data.username ?? '' };
 	});
 }
 
+/**
+ * Resolve the Trello member ID for the bot credentials linked to a project.
+ * Cached per-project with 60s TTL. Returns null on any failure.
+ */
+export async function resolveTrelloBotMemberId(projectId: string): Promise<string | null> {
+	const identity = await resolveTrelloBotIdentity(projectId);
+	return identity?.id ?? null;
+}
+
 /** @internal Visible for testing only */
 export function _resetTrelloBotCache(): void {
 	trelloBotIdentityCache._reset();

src/triggers/github/check-suite-failure.ts

@@ -4,7 +4,7 @@ import { logger } from '../../utils/logging.js';
 import { parseRepoFullName } from '../../utils/repo.js';
 import { checkTriggerEnabled } from '../shared/trigger-check.js';
 import { type GitHubCheckSuitePayload, isGitHubCheckSuitePayload } from './types.js';
-import { parsePrNumberFromRef, resolveWorkItemId } from './utils.js';
+import { parsePrNumberFromRef, resolveWorkItemDisplayData, resolveWorkItemId } from './utils.js';
 
 /**
  * Resolve a PR number from a check_suite payload.
@@ -121,6 +121,7 @@ export class CheckSuiteFailureTrigger implements TriggerHandler {
 
 		// Resolve work item from DB
 		const workItemId = await resolveWorkItemId(ctx.project.id, prNumber);
+		const { workItemUrl, workItemTitle } = await resolveWorkItemDisplayData(workItemId);
 
 		// Get ALL check runs for this commit to verify they're all complete
 		const checkStatus = await githubClient.getCheckSuiteStatus(owner, repo, headSha);
@@ -205,6 +206,8 @@ export class CheckSuiteFailureTrigger implements TriggerHandler {
 			prUrl: prDetails.htmlUrl,
 			prTitle: prDetails.title,
 			workItemId,
+			workItemUrl,
+			workItemTitle,
 		};
 	}
 }

src/triggers/github/check-suite-success.ts

@@ -9,7 +9,12 @@ import {
 	releaseReviewDispatch,
 } from './review-dispatch-dedup.js';
 import { type GitHubCheckSuitePayload, isGitHubCheckSuitePayload } from './types.js';
-import { evaluateAuthorMode, parsePrNumberFromRef, resolveWorkItemId } from './utils.js';
+import {
+	evaluateAuthorMode,
+	parsePrNumberFromRef,
+	resolveWorkItemDisplayData,
+	resolveWorkItemId,
+} from './utils.js';
 
 const MAX_RETRIES = 12;
 const RETRY_DELAY_MS = 10_000;
@@ -156,6 +161,7 @@ export class CheckSuiteSuccessTrigger implements TriggerHandler {
 
 		// Resolve work item from DB
 		const workItemId = await resolveWorkItemId(ctx.project.id, prNumber);
+		const { workItemUrl, workItemTitle } = await resolveWorkItemDisplayData(workItemId);
 
 		// Skip if the reviewer persona's latest review already covers the current HEAD SHA
 		const reviews = await githubClient.getPRReviews(owner, repo, prNumber);
@@ -224,6 +230,8 @@ export class CheckSuiteSuccessTrigger implements TriggerHandler {
 			prUrl: prDetails.htmlUrl,
 			prTitle: prDetails.title,
 			workItemId,
+			workItemUrl,
+			workItemTitle,
 			waitForChecks: true,
 			onBlocked: () => releaseReviewDispatch(dedupKey),
 		};

src/triggers/github/pr-comment-mention.ts

@@ -5,7 +5,7 @@ import { logger } from '../../utils/logging.js';
 import { parseRepoFullName } from '../../utils/repo.js';
 import { checkTriggerEnabled } from '../shared/trigger-check.js';
 import { isGitHubIssueCommentPayload, isGitHubPRReviewCommentPayload } from './types.js';
-import { resolveWorkItemId } from './utils.js';
+import { resolveWorkItemDisplayData, resolveWorkItemId } from './utils.js';
 
 /**
  * Trigger that fires when someone @mentions the reviewer bot in a PR comment.
@@ -118,6 +118,7 @@ export class PRCommentMentionTrigger implements TriggerHandler {
 
 		// Resolve work item from DB
 		const workItemId = await resolveWorkItemId(ctx.project.id, prNumber);
+		const { workItemUrl, workItemTitle } = await resolveWorkItemDisplayData(workItemId);
 
 		logger.info('PR comment @mention detected, triggering respond-to-pr-comment agent', {
 			prNumber,
@@ -144,6 +145,8 @@ export class PRCommentMentionTrigger implements TriggerHandler {
 			prUrl,
 			prTitle,
 			workItemId,
+			workItemUrl,
+			workItemTitle,
 		};
 	}
 }

src/triggers/github/pr-review-submitted.ts

@@ -3,7 +3,7 @@ import type { TriggerContext, TriggerHandler, TriggerResult } from '../../types/
 import { logger } from '../../utils/logging.js';
 import { checkTriggerEnabled } from '../shared/trigger-check.js';
 import { type GitHubPullRequestReviewPayload, isGitHubPullRequestReviewPayload } from './types.js';
-import { resolveWorkItemId } from './utils.js';
+import { resolveWorkItemDisplayData, resolveWorkItemId } from './utils.js';
 
 export class PRReviewSubmittedTrigger implements TriggerHandler {
 	name = 'pr-review-submitted';
@@ -59,6 +59,7 @@ export class PRReviewSubmittedTrigger implements TriggerHandler {
 
 		// Resolve work item from DB
 		const workItemId = await resolveWorkItemId(ctx.project.id, prNumber);
+		const { workItemUrl, workItemTitle } = await resolveWorkItemDisplayData(workItemId);
 
 		logger.info('PR review submitted, triggering review agent', {
 			prNumber,
@@ -83,6 +84,8 @@ export class PRReviewSubmittedTrigger implements TriggerHandler {
 			prUrl: reviewPayload.pull_request.html_url,
 			prTitle: reviewPayload.pull_request.title,
 			workItemId,
+			workItemUrl,
+			workItemTitle,
 		};
 	}
 }