FM / pm-clients

/home/techb158/balavpn.abdallabala.com/src/integrations/pm-clients/

/home/techb158/balavpn.abdallabala.com/src/integrations/pm-clients

Name	Size	Mode	Actions
asana-client.js	2263	0644	edit dl rm
http-client.js	2417	0644	edit dl rm
index.js	1892	0644	edit dl rm
jira-client.js	3091	0644	edit dl rm
planner-client.js	2765	0644	edit dl rm
trello-client.js	7795	0644	edit dl rm

Edit: /home/techb158/balavpn.abdallabala.com/src/integrations/pm-clients/asana-client.js (2263B)

const { fetchJson, buildRiskDescription } = require("./http-client");

class AsanaClient {
  constructor(options = {}) {
    this.accessToken = options.accessToken;
    this.projectGid = options.projectGid;
    this.fetchImpl = options.fetchImpl;
    if (!this.accessToken) {
      throw new Error("Asana live sync requires accessToken.");
    }
  }

headers() {
    return { "Authorization": `Bearer ${this.accessToken}`, "Accept": "application/json", "Content-Type": "application/json" };
  }

async testConnection() {
    const result = await fetchJson("https://app.asana.com/api/1.0/users/me", { headers: this.headers() }, this.fetchImpl);
    const user = result.data || result;
    return { ok: true, provider: "ASANA", account: user.name || user.email || user.gid };
  }

async createRiskWorkItem(risk, mitigations = [], integration = {}) {
    const projectGid = integration.externalProjectKey || this.projectGid;
    if (!projectGid) {
      throw new Error("Asana live sync requires externalProjectKey or credentials.projectGid.");
    }
    const result = await fetchJson("https://app.asana.com/api/1.0/tasks", {
      method: "POST",
      headers: this.headers(),
      body: JSON.stringify({ data: { name: `[COSMIC Risk] ${risk.title}`, notes: buildRiskDescription(risk, mitigations), projects: [projectGid] } })
    }, this.fetchImpl);
    const task = result.data || result;
    return { externalId: task.gid, externalKey: task.gid, externalUrl: task.permalink_url || "", externalStatus: "Created" };
  }

async discoverResources() { return []; }

async updateRiskWorkItem(mapping, risk, mitigations = []) {
    const result = await fetchJson(`https://app.asana.com/api/1.0/tasks/${encodeURIComponent(mapping.externalItemId)}`, {
      method: "PUT",
      headers: this.headers(),
      body: JSON.stringify({ data: { name: `[COSMIC Risk] ${risk.title}`, notes: buildRiskDescription(risk, mitigations) } })
    }, this.fetchImpl);
    const task = result.data || result;
    return {
      externalId: task.gid || mapping.externalItemId,
      externalKey: task.gid || mapping.externalItemKey,
      externalUrl: task.permalink_url || mapping.externalUrl,
      externalStatus: "Updated"
    };
  }
}

module.exports = { AsanaClient };

const { fetchJson, buildRiskDescription } = require("./http-client"); class AsanaClient { constructor(options = {}) { this.accessToken = options.accessToken; this.projectGid = options.projectGid; this.fetchImpl = options.fetchImpl; if (!this.accessToken) { throw new Error("Asana live sync requires accessToken."); } } headers() { return { "Authorization": `Bearer ${this.accessToken}`, "Accept": "application/json", "Content-Type": "application/json" }; } async testConnection() { const result = await fetchJson("https://app.asana.com/api/1.0/users/me", { headers: this.headers() }, this.fetchImpl); const user = result.data || result; return { ok: true, provider: "ASANA", account: user.name || user.email || user.gid }; } async createRiskWorkItem(risk, mitigations = [], integration = {}) { const projectGid = integration.externalProjectKey || this.projectGid; if (!projectGid) { throw new Error("Asana live sync requires externalProjectKey or credentials.projectGid."); } const result = await fetchJson("https://app.asana.com/api/1.0/tasks", { method: "POST", headers: this.headers(), body: JSON.stringify({ data: { name: `[COSMIC Risk] ${risk.title}`, notes: buildRiskDescription(risk, mitigations), projects: [projectGid] } }) }, this.fetchImpl); const task = result.data || result; return { externalId: task.gid, externalKey: task.gid, externalUrl: task.permalink_url || "", externalStatus: "Created" }; } async discoverResources() { return []; } async updateRiskWorkItem(mapping, risk, mitigations = []) { const result = await fetchJson(`https://app.asana.com/api/1.0/tasks/${encodeURIComponent(mapping.externalItemId)}`, { method: "PUT", headers: this.headers(), body: JSON.stringify({ data: { name: `[COSMIC Risk] ${risk.title}`, notes: buildRiskDescription(risk, mitigations) } }) }, this.fetchImpl); const task = result.data || result; return { externalId: task.gid || mapping.externalItemId, externalKey: task.gid || mapping.externalItemKey, externalUrl: task.permalink_url || mapping.externalUrl, externalStatus: "Updated" }; } } module.exports = { AsanaClient };