New: filter sprints on export log. #65

Author: pustovitDmytro

src/Jira.js

@@ -45,6 +45,10 @@ export default class JIRA extends Api {
         }
 
         if (!sprint.includes('all') && sprint.includes('open')) jql.push('Sprint in openSprints()');
+        const sprintIds = sprint.filter(s => ![ 'open', 'all' ].includes(s));
+
+        if (sprintIds.length > 0) jql.push(`Sprint IN (${sprintIds.join(', ')})`);
+
         if (search) jql.push(`summary ~ "${search}"`);
         if (id) jql.push(`id IN (${formatJQLList(id)})`);
 
@@ -128,11 +132,26 @@ export default class JIRA extends Api {
             .map(d => format ? d.format(format) : d);
     }
 
+    async getSprintsForPeriod(start, end) {
+        const sprints = await this.getAllSprints();
+
+        return sprints.filter(s => {
+            if (s.state === 'active') return true;
+            if (s.state === 'closed') {
+                return dayjs(s.completeDate).isBetween(start, end);
+            }
+
+            return false;
+        });
+    }
+
     async exportLog([ start, end ], file = path.join(os.tmpdir(), `${uuid()}.json`)) {
+        const sprints = await this.getSprintsForPeriod(start, end);
         const allModifiedTasks = await this.list({
             from    : start,
             to      : end,
-            wasMine : true
+            wasMine : true,
+            sprint  : sprints.map(s => s.id)
         }, [ 'comments', 'worklogs', 'changelog' ]);
 
         const tasks = allModifiedTasks.filter(issue => this.isInDevelopmentForRange(issue, [ start, end ]));

src/api/JiraApi.js

@@ -1,7 +1,7 @@
 /* eslint-disable no-param-reassign */
 
 import { uniqueIdFilter } from 'myrmidon';
-import { dumpStatus, dumpTask, dumpTransition, dumpComment, dumpWorklog } from '../utils/dumpUtils';
+import { dumpStatus, dumpTask, dumpTransition, dumpComment, dumpWorklog, dumpSprint } from '../utils/dumpUtils';
 import dayjs from '../date';
 import Api from './AtlassianApi';
 
@@ -12,6 +12,34 @@ export default class JiraApi extends Api {
         return res.map(s => dumpStatus(s));
     }
 
+    async getAllSprints() {
+        const boards = await this.get('/rest/agile/1.0/board');
+        const sprints = [];
+
+        await Promise.all(boards.values.map(async board => {
+            sprints.push(...await this.getSprints(board));
+        }));
+
+        return sprints;
+    }
+
+    async getSprints(board, { startAt = 0, maxResults = 50, ...params } = {}) {
+        const { isLast, values } = await this.get(`/rest/agile/1.0/board/${board.id}/sprint`, { startAt, maxResults, ...params });
+        const nextStart = startAt + values.length;
+
+        if (!isLast) {
+            const next = await this.getSprints(board, {
+                ...params,
+                startAt : nextStart
+            });
+
+            return [ ...values.map(v => dumpSprint(v)), ...next ]
+                .filter((element, index, array) => uniqueIdFilter(element, index, array));
+        }
+
+        return values.map(v => dumpSprint(v));
+    }
+
     async getIssues(params, includes = []) {
         const extraParams = {};
 

src/utils/dumpUtils.js

@@ -63,6 +63,21 @@ export function dumpUser(user) {
     };
 }
 
+export function dumpSprint(s) {
+    return {
+        id    : s.id,
+        state : s.state, // closed, future, active
+        name  : s.name,
+        goal  : s.goal,
+
+        startDate    : s.startDate,
+        endDate      : s.endDate,
+        completeDate : s.completeDate
+
+    };
+}
+
+
 export function dumpStatus(s) {
     return {
         id   : s.id,