feat: implement Jira integration for PR handling

.env.example

@@ -7,3 +7,6 @@ LOG_LEVEL=debug
 
 # Go to https://smee.io/new set this to the URL that you are redirected to.
 WEBHOOK_PROXY_URL=
+
+JIRA_BASE_URL=
+JIRA_API_TOKEN=

src/handleJira.ts

@@ -0,0 +1,135 @@
+import { Context } from 'probot';
+
+interface HandleJiraArg {
+	context: Context;
+	boardName: string;
+	pr: {
+		number: number;
+		title: string;
+		body: string | null;
+		html_url: string;
+		labels: string[];
+		user?: {
+			login?: string;
+		} | null;
+	};
+	requestedBy: string;
+	commentId: number;
+}
+
+const getEnv = (name: string): string => {
+	const value = process.env[name];
+
+	if (!value?.trim()) {
+		throw new Error(`Missing required env var: ${name}`);
+	}
+
+	return value.trim();
+};
+
+export const handleJira = async ({ context, boardName, pr, requestedBy, commentId }: HandleJiraArg): Promise<string> => {
+	const jiraBaseUrl = getEnv('JIRA_BASE_URL').replace(/\/$/, '');
+	const jiraApiToken = getEnv('JIRA_API_TOKEN');
+	const hasCommunityLabel = pr.labels.some((label) => label.toLowerCase() === 'community');
+
+	const payload = {
+		fields: {
+			project: {
+				key: boardName,
+			},
+			summary: `[PR #${pr.number}] ${pr.title}`,
+			issuetype: {
+				name: 'Task',
+			},
+			...(hasCommunityLabel ? { labels: ['community'] } : {}),
+			description: {
+				type: 'doc',
+				version: 1,
+				content: [
+					{
+						type: 'paragraph',
+						content: [
+							{
+								type: 'text',
+								text: 'Task automatically created by dionisio-bot.',
+							},
+						],
+					},
+					{
+						type: 'paragraph',
+						content: [
+							{
+								type: 'text',
+								text: `PR: ${pr.html_url}`,
+							},
+						],
+					},
+					{
+						type: 'paragraph',
+						content: [
+							{
+								type: 'text',
+								text: `PR description: ${pr.body?.trim() || 'no description'}`,
+							},
+						],
+					},
+					{
+						type: 'paragraph',
+						content: [
+							{
+								type: 'text',
+								text: `PR author: ${pr.user?.login ?? 'unknown'}`,
+							},
+						],
+					},
+					{
+						type: 'paragraph',
+						content: [
+							{
+								type: 'text',
+								text: `Requested by: ${requestedBy}`,
+							},
+						],
+					},
+				],
+			},
+		},
+	};
+
+	const response = await fetch(`${jiraBaseUrl}/rest/api/3/issue`, {
+		method: 'POST',
+		headers: {
+			'Authorization': `Basic ${jiraApiToken}`,
+			'Accept': 'application/json',
+			'Content-Type': 'application/json',
+		},
+		body: JSON.stringify(payload),
+	});
+
+	if (!response.ok) {
+		const body = await response.text();
+		throw new Error(`Jira request failed (${response.status}): ${body}`);
+	}
+	const task = (await response.json()) as { key?: string };
+
+	await context.octokit.issues.update({
+		...context.issue(),
+		body: `${pr.body?.trim() || 'no description'} \n\n Task: [${task.key}]`,
+	});
+
+	const data = (await response.json()) as { key?: string };
+	const issueKey = data.key;
+
+	if (!issueKey) {
+		throw new Error('Jira response did not return issue key');
+	}
+
+	const issueUrl = `${jiraBaseUrl}/browse/${issueKey}`;
+
+	await context.octokit.reactions.createForIssueComment({
+		...context.issue(),
+		comment_id: commentId,
+		content: '+1',
+	});
+	return issueUrl;
+};

src/index.ts

@@ -5,6 +5,7 @@ import { handleBackport } from './handleBackport';
 import { run } from './Queue';
 import { consoleProps } from './createPullRequest';
 import { handleRebase } from './handleRebase';
+import { handleJira } from './handleJira';
 
 export = (app: Probot) => {
 	app.log.useLevelLabels = false;
@@ -214,6 +215,55 @@ export = (app: Probot) => {
 				);
 			}
 		}
+
+		if (command === 'jira' && args?.trim()) {
+			const boardName = args.trim().replace(/^["']|["']$/g, '');
+
+			await context.octokit.reactions.createForIssueComment({
+				...context.issue(),
+				comment_id: comment.id,
+				content: 'eyes',
+			});
+
+			try {
+				await handleJira({
+					context,
+					boardName,
+					pr: {
+						number: pr.data.number,
+						title: pr.data.title,
+						body: pr.data.body,
+						html_url: pr.data.html_url,
+						labels: pr.data.labels.map((label) => label.name),
+						user: pr.data.user,
+					},
+					requestedBy: comment.user.login,
+					commentId: comment.id,
+				});
+
+				await context.octokit.reactions.createForIssueComment({
+					...context.issue(),
+					comment_id: comment.id,
+					content: '+1',
+				});
+			} catch (e) {
+				await context.octokit.reactions.createForIssueComment({
+					...context.issue(),
+					comment_id: comment.id,
+					content: '-1',
+				});
+				console.log('handleJira->', e);
+			}
+		}
+
+		if (command === 'jira' && !args?.trim()) {
+			// reacts with thinking face
+			await context.octokit.reactions.createForIssueComment({
+				...context.issue(),
+				comment_id: comment.id,
+				content: 'confused',
+			});
+		}
 	});
 
 	app.on(['check_suite.requested'], async function check(context) {