From a045555f767582b7cd51e6316a9c180a96cf0188 Mon Sep 17 00:00:00 2001 From: Anton Martinovic Date: Wed, 24 Jan 2024 23:20:56 +0100 Subject: [PATCH] #175 Fixed a bug that caused to exit the index method too early without all issues, merge requests, and versions being persisted and thus logging a wrong number of persisted/omitted issues. --- lib/indexers/its/JiraITSIndexer.ts | 3 +-- lib/paginator.ts | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/lib/indexers/its/JiraITSIndexer.ts b/lib/indexers/its/JiraITSIndexer.ts index f720b6e7..80bfd1ac 100644 --- a/lib/indexers/its/JiraITSIndexer.ts +++ b/lib/indexers/its/JiraITSIndexer.ts @@ -199,8 +199,7 @@ class JiraITSIndexer { .then(() => this.reporter.finishMilestone()); }), ]).then((resp) => { - log('Persisted %d new issues (%d already present)', persistCount, omitCount); - log(resp); + return Promise.all(resp.flat()).then(() => log('Persisted %d new issues (%d already present)', persistCount, omitCount)); }); } diff --git a/lib/paginator.ts b/lib/paginator.ts index 00442ff4..c137785a 100755 --- a/lib/paginator.ts +++ b/lib/paginator.ts @@ -109,7 +109,7 @@ Paginator.prototype.$depaginate = function (perPage: number, countHolder: { coun } if (stop !== false && processed < countHolder.count && !this.its) { return this.$depaginate(perPage, countHolder, page + 1, processed); - } else if (stop !== false && this.its) { + } else if (stop !== false && processed < countHolder.count && this.its) { i++; return this.$depaginate(perPage, countHolder, this.defaultPageSize * i, processed, i); }