Function makeRequest

tests/functional/raw-node/utils/makeRequest.js:75–154

makeRequest - utility function to generate a request * @param {object} params - params for making request * @param {string} params.hostname - request hostname * @param {number} [params.port] - request port * @param {string} params.method - request method * @param {object} [params.queryObj] - qu

(params, callback)

 * @return {undefined} - and call callback
 */
function makeRequest(params, callback) {
    const { hostname, port, method, queryObj, headers, path,
            authCredentials, requestBody, jsonResponse,
            urlForSignature } = params;
    const options = {
        hostname,
        port,
        method,
        headers,
        path: path || '/',
        rejectUnauthorized: false,
    };
    const qs = querystring.stringify(queryObj);

    if (params.GCP && authCredentials) {
        const bucketMatch = options.path.match(/^\/([^\/]+)/);
        const bucketName = bucketMatch ? bucketMatch[1] : undefined;
        const gcpPath = queryObj ? `${options.path}?${qs}` : options.path;
        const requestForSigning = {
            method,
            headers: options.headers || {},
            url: gcpPath,
            path: options.path,
            endpoint: { host: hostname },
            bucketName,
            query: queryObj || {},
        };
        signGcpRequest(requestForSigning, authCredentials, new Date());
        Object.assign(options.headers, {
            Authorization: requestForSigning.headers.Authorization,
            Date: requestForSigning.headers['x-goog-date'],
        });
    }

    const req = transport.request(options, res => {
        const body = [];
        res.on('data', chunk => {
            body.push(chunk);
        });
        res.on('error', err => {
            process.stdout.write('err receiving response');
            return callback(err);
        });
        res.on('end', () => {
            const total = body.join('');
            const data = {
                headers: res.headers,
                statusCode: res.statusCode,
                body: total,
            };
            const err = _parseError(total, res.statusCode, jsonResponse);
            if (err) {
                err.statusCode = res.statusCode;
            }
            return callback(err, data);
        });
    });
    req.on('error', err => {