Function respondWithData

lib/routes/veeam/utils.js:129–170

* Generic function to respond to user with data using streams * * @param {object} request - incoming request * @param {object} response - response object * @param {object} log - logging object * @param {BucketInfo} bucket - bucket info * @param {string} data - data to send * @param {date} [la

(request, response, log, bucket, data, lastModified)

 * @returns {Promise<void>} -
 */
async function respondWithData(request, response, log, bucket, data, lastModified) {
    const dataBuffer = Buffer.from(data);
    const responseMetaHeaders = getResponseHeader(request, bucket, dataBuffer, lastModified, log);

    if (responseMetaHeaders && typeof responseMetaHeaders === 'object') {
        Object.keys(responseMetaHeaders).forEach(key => {
            if (responseMetaHeaders[key] !== undefined) {
                try {
                    response.setHeader(key, responseMetaHeaders[key]);
                } catch (e) {
                    log.debug('header can not be added ' +
                        'to the response', {
                        header: responseMetaHeaders[key],
                        error: e.stack, method: 'routeVeeam/respondWithData'
                    });
                }
            }
        });
    }

    response.writeHead(200);

    let contentLength = 0;
    if (responseMetaHeaders && responseMetaHeaders['Content-Length']) {
        contentLength = responseMetaHeaders['Content-Length'];
    }
    log.end().addDefaultFields({ contentLength });

    try {
        // Use a single-element array so the Buffer is sent as one chunk rather
        // than being iterated byte-by-byte by Readable.from.
        await pipeline(Readable.from([dataBuffer]), response);
        log.end().info('responded with streamed content', {
            httpCode: response.statusCode,
        });
    } catch (err) {
        log.end().error('error streaming response', {
            httpCode: response.statusCode,
            error: err.message,
        });
    }
}

const validPath = '.system-d26a9498-cb7c-4a87-a44a-8ae204f5ba6c/';