CR-13431 add CF_API_RETRIES

Author: vadim-kharin-codefresh

config/index.js

@@ -109,6 +109,7 @@ class Config {
                 branchNormalized: process.env.CF_BRANCH_TAG_NORMALIZED,
                 storageIntegration: process.env.CF_STORAGE_INTEGRATION,
                 logLevel: logLevelsMap[process.env.REPORT_LOGGING_LEVEL] || INFO,
+                retriesForCodefreshAPI: Number(process.env.CF_API_RETRIES) || 0,
                 sourceReportFolderName: (allureDir || 'allure-results').trim(),
                 reportDir: ((reportDir || '').trim()) || undefined,
                 reportPath: ((reportPath || '').trim()).replace(/\/$/, ''),

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "cf-docker-test-reporting",
-	"version": "1.0.4",
+	"version": "1.0.5",
 	"description": "Generate test report",
 	"repository": {
 		"type": "git",

src/api/index.js

@@ -1,6 +1,24 @@
 const rp = require('request-promise');
 
 class CodefreshAPI {
+
+    static async sendRequest(config, opts) {
+        if (config.env.retriesForCodefreshAPI) {
+            let error;
+            for (let i = 0; i < config.env.retriesForCodefreshAPI; i += 1) {
+                try {
+                    // eslint-disable-next-line no-await-in-loop
+                    const result = await rp(opts);
+                    return result;
+                } catch (e) {
+                    error = e;
+                }
+            }
+            throw error;
+        }
+        return rp(opts);
+    }
+
     static async createAnnotation({ config, value }) {
         // this query use proxy ability to replace :account_id to currentAccountID
         // this ability use because we don`t know accountId
@@ -19,7 +37,7 @@ class CodefreshAPI {
             json: true,
         };
 
-        return rp(createAnnotationOpts);
+        return this.sendRequest(config, createAnnotationOpts);
     }
 
     static async getProcessById({ id, config }) {
@@ -33,7 +51,7 @@ class CodefreshAPI {
         let process;
 
         try {
-            const processRes = await rp(opts);
+            const processRes = await this.sendRequest(config, opts);
             process = JSON.parse(processRes);
         } catch (e) {
             throw new Error('Error during getting process info');

src/storageConfig/StorageConfigProvider.js

@@ -1,9 +1,9 @@
 const _ = require('lodash');
-const rp = require('request-promise');
 const VariableResolver = require('../ variableResolver/VariableResolver');
 const storageTypesMap = require('./types');
 const storageTypes = require('./storageTypes');
 const fs = require('fs');
+const CodefreshAPI = require('../api');
 
 class StorageConfigProvider {
     constructor({ config }) {
@@ -29,7 +29,7 @@ class StorageConfigProvider {
         };
 
         try {
-            return await rp(opts);
+            return await CodefreshAPI.sendRequest(config, opts);
         } catch (e) {
             const infoErrMsg = `Can't get storage integration: ${this.integrationName}`;
             if (config.env.logLevel === config.logLevels.DEBUG) {