lib/Utils/FetchUtils.js

"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
    if (k2 === undefined) k2 = k;
    var desc = Object.getOwnPropertyDescriptor(m, k);
    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
      desc = { enumerable: true, get: function() { return m[k]; } };
    }
    Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
    if (k2 === undefined) k2 = k;
    o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
    Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
    o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
    if (mod && mod.__esModule) return mod;
    var result = {};
    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
    __setModuleDefault(result, mod);
    return result;
};
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
    return new (P || (P = Promise))(function (resolve, reject) {
        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.httpClientRetries = void 0;
const CommonUtils_1 = require("./CommonUtils");
const UtilModels_1 = require("./../models/UtilModels");
const httpc = __importStar(require("typed-rest-client/HttpClient"));
const FileUtils_1 = require("./FileUtils");
const httpClient = new httpc.HttpClient('MALT-GHACTION');
const CoreUtils = __importStar(require("./CoreUtils"));
const methodEnumToString = {
    [UtilModels_1.FetchCallType.get]: "get",
    [UtilModels_1.FetchCallType.post]: "post",
    [UtilModels_1.FetchCallType.put]: "put",
    [UtilModels_1.FetchCallType.delete]: "del",
    [UtilModels_1.FetchCallType.patch]: "patch"
};
// (note mohit): shift to the enum later.
function httpClientRetries(urlSuffix_1, header_1, method_1) {
    return __awaiter(this, arguments, void 0, function* (urlSuffix, header, method, retries = 1, data, isUploadCall = true, log = true) {
        let httpResponse;
        try {
            let correlationId = `gh-actions-${(0, CommonUtils_1.getUniqueId)()}`;
            header[UtilModels_1.correlationHeader] = correlationId; // even if we put console.debug its printing along with the logs, so lets just go ahead with the differentiation with azdo, so we can search the timeframe for azdo in correlationid and resource filter.
            if (method == UtilModels_1.FetchCallType.get) {
                httpResponse = yield httpClient.get(urlSuffix, header);
            }
            else if (method == UtilModels_1.FetchCallType.delete) {
                httpResponse = yield httpClient.del(urlSuffix, header);
            }
            else if (method == UtilModels_1.FetchCallType.post) {
                httpResponse = yield httpClient.post(urlSuffix, data, header);
            }
            else if (method == UtilModels_1.FetchCallType.put && isUploadCall) {
                let fileContent = (0, FileUtils_1.uploadFileData)(data);
                httpResponse = yield httpClient.request(methodEnumToString[method], urlSuffix, fileContent, header);
            }
            else {
                const githubBaseUrl = process.env.GITHUB_SERVER_URL;
                const repository = process.env.GITHUB_REPOSITORY;
                const runId = process.env.GITHUB_RUN_ID;
                const pipelineName = process.env.GITHUB_WORKFLOW || "Unknown Pipeline";
                const pipelineUri = `${githubBaseUrl}/${repository}/actions/runs/${runId}`;
                header['x-ms-pipeline-name'] = pipelineName; // setting these for patch calls.
                header['x-ms-pipeline-uri'] = pipelineUri;
                httpResponse = yield httpClient.request(methodEnumToString[method], urlSuffix, data, header);
            }
            if (httpResponse.message.statusCode != undefined && httpResponse.message.statusCode >= 300) {
                CoreUtils.debug(`correlation id : ${correlationId}`);
            }
            if (httpResponse.message.statusCode != undefined && [408, 429, 502, 503, 504].includes(httpResponse.message.statusCode)) {
                let err = yield (0, CommonUtils_1.getResultObj)(httpResponse);
                throw { message: (err && err.error && err.error.message) ? err.error.message : (0, CommonUtils_1.errorCorrection)(httpResponse) }; // throwing as message to catch it as err.message
            }
            return httpResponse;
        }
        catch (err) {
            if (retries) {
                let sleeptime = (5 - retries) * 1000 + Math.floor(Math.random() * 5001);
                if (log) {
                    console.log(`Failed to connect to ${urlSuffix} due to ${err.message}, retrying in ${sleeptime / 1000} seconds`);
                }
                yield (0, CommonUtils_1.sleep)(sleeptime);
                return yield httpClientRetries(urlSuffix, header, method, retries - 1, data);
            }
            else {
                throw new Error(`Operation did not succeed after 3 retries. Pipeline failed with error : ${err.message}`);
            }
        }
    });
}
exports.httpClientRetries = httpClientRetries;