Function logCopySourceAccess

lib/utilities/serverAccessLogger.js:703–741

* Logs a REST.COPY.OBJECT_GET or REST.COPY.PART_GET entry for the source side of copy operations * @param {object} req - HTTP request object * @param {string} requestID - Request ID from the response * @param {string} operation - Operation name ('REST.COPY.OBJECT_GET' or 'REST.COPY.PART_GET') *

(req, requestID, operation, sourceBucket, sourceObject, objectSize)

 * @return {undefined}
 */
function logCopySourceAccess(req, requestID, operation, sourceBucket, sourceObject, objectSize) {
    if (!req.sourceServerAccessLog || !serverAccessLogger) {
        return;
    }

    const params = req.sourceServerAccessLog;
    const error = params.error;
    let httpCode = 200;
    let errorCode = undefined;

    if (error) {
        httpCode = error.code ? parseInt(error.code, 10) : 500;
        errorCode = error.message || 'InternalError';
    }

    // Copy over necessary fields from main serverAccessLog
    if (req.serverAccessLog) {
        params.authInfo = req.serverAccessLog.authInfo;
        params.startTime = req.serverAccessLog.startTime;
        params.startTimeUnixMS = req.serverAccessLog.startTimeUnixMS;
        params.startTurnAroundTime = req.serverAccessLog.startTurnAroundTime;
        params.onFinishEndTime = req.serverAccessLog.onFinishEndTime;
        params.analyticsAccountName = req.serverAccessLog.analyticsAccountName;
        params.analyticsUserName = req.serverAccessLog.analyticsUserName;
        params.analyticsAction = req.serverAccessLog.analyticsAction;
    }

    const logEntry = buildLogEntry(req, params, {
        operation,
        objectKey: sourceObject,
        objectSize,
        httpCode,
        errorCode,
        requestID,
        aclRequired: params.aclRequired,
    });

    serverAccessLogger.write(`${JSON.stringify(logEntry)}\n`);
}

module.exports = {
    logServerAccess,