Merge pull request #2 from insurify/add_target_project

Find correct project in asana-github integration action

Author: iamalisajid

README.md

@@ -22,18 +22,22 @@ This action integrates asana with github.
 
 **Optional** If any comment is provided, the action will add a comment to the specified asana task with the text & pull request link.
 
-### `target-section`
+### `targets`
 
-**Optional** Add/Move the task to the provided section i.e `merged`, `review`.
+**Optional** JSON array of objects having project and section where to move current task. Move task only if it exists in target project. e.g 
+```yaml
+targets: '[{"project": "Backlog", "section": "Development Done"}, {"project": "Current Sprint", "section": "In Review"}]'
+```
+if you don't want to move task omit `targets`.
 
 
 ## Example usage
 
 ```yaml
-uses: https://github.com/insurify/github-actions@master
+uses: https://github.com/insurify/github-actions@v2.0.0
 with:
   asana-pat: 'Your PAT'
-  target-section: 'In Review'
   task-comment: 'View Pull Request Here: '
   trigger-phrase: 'Asana Task:'
+  targets: '[{"project": "Backlog", "section": "Development Done"}, {"project": "Current Sprint", "section": "In Review"}]'
 ```

action.yml

@@ -7,8 +7,8 @@ inputs:
   task-comment:
     description: 'Provide text, which will add a comment with the pull request link to the asana task.'
     required: false
-  target-section:
-    description: 'Provide the name of an Asana projects section or column where you want to move the task.'
+  targets:
+    description: 'JSON array of objects having project and section where to move current task. Move task only if it exists in target project.'
     required: false
   trigger-phrase:
     description: 'Prefix before the task i.e ASANA TASK: https://app.asana.com/1/2/3'

index.js

@@ -4,30 +4,34 @@ const asana = require('asana');
 
 async function asanaOperations(
   asanaPAT,
-  projectId,
+  targets,
   taskId,
-  sectionName,
   taskComment
 ) {
   try {
     const client = asana.Client.create({
       defaultHeaders: { 'asana-enable': 'new-sections,string_ids' },
       logAsanaChangeWarnings: false
     }).useAccessToken(asanaPAT);
-    if (sectionName) {
-      let project = await client.sections.findByProject(projectId);
-      if (project) {
-        let requiredSection = project.find(data => data.name === sectionName);
-        if (requiredSection) {
-          await client.sections.addTask(requiredSection.gid, { task: taskId });
-          core.info('Moved to: ' + requiredSection.name);
+
+    const task = await client.tasks.findById(taskId);
+    
+    targets.forEach(async target => {
+      let targetProject = task.projects.find(project => project.name === target.project);
+      if (targetProject) {
+        let targetSection = await client.sections.findByProject(targetProject.gid)
+          .then(sections => sections.find(section => section.name === target.section));
+        if (targetSection) {
+          await client.sections.addTask(targetSection.gid, { task: taskId });
+          core.info(`Moved to: ${target.project}/${target.section}`);
         } else {
-          core.error('Asana section ' + sectionName + ' not found.');
+          core.error(`Asana section ${target.section} not found.`);
         }
       } else {
-        core.error('Asana project with id ' + projectId + ' not found.');
+        core.info(`This task does not exist in "${target.project}" project`);
       }
-    }
+    });
+
     if (taskComment) {
       await client.tasks.addComment(taskId, {
         text: taskComment
@@ -41,7 +45,7 @@ async function asanaOperations(
 
 try {
   const ASANA_PAT = core.getInput('asana-pat'),
-    SECTION_NAME = core.getInput('target-section'),
+    TARGETS = core.getInput('targets'),
     TRIGGER_PHRASE = core.getInput('trigger-phrase'),
     TASK_COMMENT = core.getInput('task-comment'),
     PULL_REQUEST = github.context.payload.pull_request,
@@ -50,21 +54,21 @@ try {
       'g'
     );
   let taskComment = null,
+    targets = TARGETS? JSON.parse(TARGETS) : [],
     parseAsanaURL = null;
 
   if (!ASANA_PAT){
-    throw({message: "ASANA PAT Not Found!"});
+    throw({message: 'ASANA PAT Not Found!'});
   }
   if (TASK_COMMENT) {
     taskComment = `${TASK_COMMENT} ${PULL_REQUEST.html_url}`;
   }
   while ((parseAsanaURL = REGEX.exec(PULL_REQUEST.body)) !== null) {
-    let projectId = parseAsanaURL.groups.project,
-      taskId = parseAsanaURL.groups.task;
-    if (projectId && taskId) {
-      asanaOperations(ASANA_PAT, projectId, taskId, SECTION_NAME, taskComment);
+    let taskId = parseAsanaURL.groups.task;
+    if (taskId) {
+      asanaOperations(ASANA_PAT, targets, taskId, taskComment);
     } else {
-      core.info('Invalid Asana task URL after the trigger phrase' + TRIGGER_PHRASE);
+      core.info(`Invalid Asana task URL after the trigger phrase ${TRIGGER_PHRASE}`);
     }
   }
 } catch (error) {