/home/techb158/cosmic-risk.abdallabala.com/src/integrations/pm-clients
Edit: /home/techb158/cosmic-risk.abdallabala.com/src/integrations/pm-clients/jira-client.js (4361B)
const { fetchJson, buildRiskDescription, jiraDoc } = require("./http-client");
class JiraClient {
constructor(options = {}) {
this.accessToken = options.accessToken;
this.apiEmail = options.apiEmail;
this.apiToken = options.apiToken;
this.baseUrl = (options.baseUrl || "").replace(/\/$/, "");
this.cloudId = options.cloudId;
this.projectKey = options.projectKey;
this.fetchImpl = options.fetchImpl;
if (!this.accessToken && !(this.apiEmail && this.apiToken && this.baseUrl)) {
throw new Error("Jira live sync requires either accessToken + cloudId, or apiEmail + apiToken + baseUrl.");
}
}
apiBase() {
if (this.accessToken) {
if (!this.cloudId) throw new Error("Jira OAuth live sync requires cloudId.");
return `https://api.atlassian.com/ex/jira/${encodeURIComponent(this.cloudId)}/rest/api/3`;
}
return `${this.baseUrl}/rest/api/3`;
}
headers() {
const authorization = this.accessToken
? `Bearer ${this.accessToken}`
: `Basic ${Buffer.from(`${this.apiEmail}:${this.apiToken}`).toString("base64")}`;
return { "Authorization": authorization, "Accept": "application/json", "Content-Type": "application/json" };
}
async testConnection() {
const user = await fetchJson(`${this.apiBase()}/myself`, { headers: this.headers() }, this.fetchImpl);
return { ok: true, provider: "JIRA", account: user.displayName || user.emailAddress || user.accountId };
}
async createRiskWorkItem(risk, mitigations = [], integration = {}) {
const projectKey = integration.externalProjectKey || this.projectKey;
if (!projectKey) {
throw new Error("Jira live sync requires externalProjectKey or credentials.projectKey.");
}
const issue = await fetchJson(`${this.apiBase()}/issue`, {
method: "POST",
headers: this.headers(),
body: JSON.stringify({
fields: {
project: { key: projectKey },
summary: `[COSMIC Risk] ${risk.title}`,
description: jiraDoc(buildRiskDescription(risk, mitigations)),
issuetype: { name: "Task" },
labels: ["cosmic-ai-risk", String(risk.dimension || "risk").toLowerCase().replace(/\s+/g, "-")]
}
})
}, this.fetchImpl);
return {
externalId: issue.id,
externalKey: issue.key,
externalUrl: this.baseUrl && issue.key ? `${this.baseUrl}/browse/${issue.key}` : "",
externalStatus: "Created"
};
}
async fetchWorkItems(options = {}) {
const projectKey = options.projectKey || this.projectKey;
if (!projectKey) {
throw new Error("Jira fetchWorkItems requires externalProjectKey or credentials.projectKey.");
}
const maxResults = options.maxResults || 100;
const result = await fetchJson(`${this.apiBase()}/search?jql=project%3D${encodeURIComponent(projectKey)}&maxResults=${maxResults}&fields=summary,description,status,duedate,assignee,labels,created,updated`, { headers: this.headers() }, this.fetchImpl);
const issues = result.issues || [];
return issues.map(issue => ({
id: issue.id,
key: issue.key,
title: issue.fields?.summary || "",
description: issue.fields?.description || "",
status: issue.fields?.status?.name || "",
statusCategory: issue.fields?.status?.statusCategory?.name || "",
dueDate: issue.fields?.duedate || null,
assignee: issue.fields?.assignee ? { id: issue.fields.assignee.accountId, displayName: issue.fields.assignee.displayName, email: issue.fields.assignee.emailAddress } : null,
labels: issue.fields?.labels || [],
externalUrl: this.baseUrl ? `${this.baseUrl}/browse/${issue.key}` : "",
raw: issue
}));
}
async discoverResources() { return []; }
async updateRiskWorkItem(mapping, risk, mitigations = []) {
const key = mapping.externalItemKey || mapping.externalItemId;
await fetchJson(`${this.apiBase()}/issue/${encodeURIComponent(key)}`, {
method: "PUT",
headers: this.headers(),
body: JSON.stringify({ fields: { summary: `[COSMIC Risk] ${risk.title}`, description: jiraDoc(buildRiskDescription(risk, mitigations)) } })
}, this.fetchImpl);
return { externalId: mapping.externalItemId, externalKey: key, externalUrl: mapping.externalUrl, externalStatus: "Updated" };
}
}
module.exports = { JiraClient };