Skip to content

Commit 99b9108

Browse files
DarkIsDudeDarkIsDude
committed
🎨 Code formatting improvements
Issue: CLDSRV-823
1 parent 051a2d8 commit 99b9108

2 files changed

Lines changed: 39 additions & 77 deletions

File tree

‎lib/api/bucketGet.js‎

Lines changed: 26 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,9 @@ const escapeForXml = s3middleware.escapeForXml;
88
const { pushMetric } = require('../utapi/utilities');
99
const versionIdUtils = versioning.VersionID;
1010
const monitoring = require('../utilities/monitoringHandler');
11-
const { generateToken, decryptToken }
12-
= require('../api/apiUtils/object/continueToken');
11+
const { generateToken, decryptToken } = require('../api/apiUtils/object/continueToken');
1312

14-
// do not url encode the continuation tokens
15-
const skipUrlEncoding = new Set([
16-
'ContinuationToken',
17-
'NextContinuationToken',
18-
]);
13+
const xmlParamsToSkipUrlEncoding = new Set(['ContinuationToken', 'NextContinuationToken']);
1914

2015
/* Sample XML response for GET bucket objects V2:
2116
<ListBucketResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/">
@@ -122,17 +117,16 @@ function processVersions(bucketName, listParams, list) {
122117
{ tag: 'IsTruncated', value: isTruncated },
123118
];
124119

125-
const escapeXmlFn = listParams.encoding === 'url' ?
126-
querystring.escape : escapeForXml;
120+
const escapeXmlFn = listParams.encoding === 'url' ? querystring.escape : escapeForXml;
127121
xmlParams.forEach(p => {
128122
if (p.value) {
129123
const val = p.tag !== 'NextVersionIdMarker' || p.value === 'null' ?
130-
p.value : versionIdUtils.encode(p.value);
124+
p.value :
125+
versionIdUtils.encode(p.value);
131126
xml.push(`<${p.tag}>${escapeXmlFn(val)}</${p.tag}>`);
132127
}
133128
});
134-
let lastKey = listParams.keyMarker ?
135-
escapeXmlFn(listParams.keyMarker) : undefined;
129+
let lastKey = listParams.keyMarker ? escapeXmlFn(listParams.keyMarker) : undefined;
136130
list.Versions.forEach(item => {
137131
const v = item.value;
138132
const objectKey = escapeXmlFn(item.key);
@@ -143,7 +137,8 @@ function processVersions(bucketName, listParams, list) {
143137
`<Key>${objectKey}</Key>`,
144138
'<VersionId>',
145139
(v.IsNull || v.VersionId === undefined) ?
146-
'null' : versionIdUtils.encode(v.VersionId),
140+
'null'
141+
: versionIdUtils.encode(v.VersionId),
147142
'</VersionId>',
148143
`<IsLatest>${isLatest}</IsLatest>`,
149144
`<LastModified>${v.LastModified}</LastModified>`,
@@ -182,31 +177,19 @@ function processMasterVersions(bucketName, listParams, list) {
182177
];
183178

184179
if (listParams.v2) {
185-
xmlParams.push(
186-
{ tag: 'StartAfter', value: listParams.startAfter || '' });
187-
xmlParams.push(
188-
{ tag: 'FetchOwner', value: `${listParams.fetchOwner}` });
189-
xmlParams.push({
190-
tag: 'ContinuationToken',
191-
value: generateToken(listParams.continuationToken) || '',
192-
});
193-
xmlParams.push({
194-
tag: 'NextContinuationToken',
195-
value: generateToken(list.NextContinuationToken),
196-
});
197-
xmlParams.push({
198-
tag: 'KeyCount',
199-
value: list.Contents ? list.Contents.length : 0,
200-
});
180+
xmlParams.push({ tag: 'StartAfter', value: listParams.startAfter || '' });
181+
xmlParams.push({ tag: 'FetchOwner', value: `${listParams.fetchOwner}` });
182+
xmlParams.push({ tag: 'ContinuationToken', value: generateToken(listParams.continuationToken) || '', });
183+
xmlParams.push({ tag: 'NextContinuationToken', value: generateToken(list.NextContinuationToken), });
184+
xmlParams.push({ tag: 'KeyCount', value: list.Contents ? list.Contents.length : 0, });
201185
} else {
202186
xmlParams.push({ tag: 'Marker', value: listParams.marker || '' });
203187
xmlParams.push({ tag: 'NextMarker', value: list.NextMarker });
204188
}
205189

206-
const escapeXmlFn = listParams.encoding === 'url' ?
207-
querystring.escape : escapeForXml;
190+
const escapeXmlFn = listParams.encoding === 'url' ? querystring.escape : escapeForXml;
208191
xmlParams.forEach(p => {
209-
if (p.value && skipUrlEncoding.has(p.tag)) {
192+
if (p.value && xmlParamsToSkipUrlEncoding.has(p.tag)) {
210193
xml.push(`<${p.tag}>${p.value}</${p.tag}>`);
211194
} else if (p.value || p.tag === 'KeyCount' || p.tag === 'MaxKeys') {
212195
xml.push(`<${p.tag}>${escapeXmlFn(p.value)}</${p.tag}>`);
@@ -246,10 +229,10 @@ function processMasterVersions(bucketName, listParams, list) {
246229
);
247230
});
248231
list.CommonPrefixes.forEach(item => {
249-
const val = escapeXmlFn(item);
250-
xml.push(`<CommonPrefixes><Prefix>${val}</Prefix></CommonPrefixes>`);
232+
xml.push(`<CommonPrefixes><Prefix>${escapeXmlFn(item)}</Prefix></CommonPrefixes>`);
251233
});
252234
xml.push('</ListBucketResult>');
235+
253236
return xml.join('');
254237
}
255238

@@ -298,17 +281,13 @@ function bucketGet(authInfo, request, log, callback) {
298281
'List Type specified in Request'));
299282
}
300283
if (v2) {
301-
log.addDefaultFields({
302-
action: 'ListObjectsV2',
303-
});
284+
log.addDefaultFields({ action: 'ListObjectsV2', });
304285
if (request.serverAccessLog) {
305286
// eslint-disable-next-line no-param-reassign
306287
request.serverAccessLog.analyticsAction = 'ListObjectsV2';
307288
}
308289
} else if (params.versions !== undefined) {
309-
log.addDefaultFields({
310-
action: 'ListObjectVersions',
311-
});
290+
log.addDefaultFields({ action: 'ListObjectVersions', });
312291
if (request.serverAccessLog) {
313292
// eslint-disable-next-line no-param-reassign
314293
request.serverAccessLog.analyticsAction = 'ListObjectVersions';
@@ -317,16 +296,14 @@ function bucketGet(authInfo, request, log, callback) {
317296
log.debug('processing request', { method: 'bucketGet' });
318297
const encoding = params['encoding-type'];
319298
if (encoding !== undefined && encoding !== 'url') {
320-
monitoring.promMetrics(
321-
'GET', bucketName, 400, 'listBucket');
299+
monitoring.promMetrics('GET', bucketName, 400, 'listBucket');
322300
return callback(errorInstances.InvalidArgument.customizeDescription('Invalid ' +
323301
'Encoding Method specified in Request'));
324302
}
325-
const requestMaxKeys = params['max-keys'] ?
326-
Number.parseInt(params['max-keys'], 10) : 1000;
303+
304+
const requestMaxKeys = params['max-keys'] ? Number.parseInt(params['max-keys'], 10) : 1000;
327305
if (Number.isNaN(requestMaxKeys) || requestMaxKeys < 0) {
328-
monitoring.promMetrics(
329-
'GET', bucketName, 400, 'listBucket');
306+
monitoring.promMetrics('GET', bucketName, 400, 'listBucket');
330307
return callback(errors.InvalidArgument);
331308
}
332309
// AWS only returns 1000 keys even if max keys are greater.
@@ -353,8 +330,7 @@ function bucketGet(authInfo, request, log, callback) {
353330
if (v2) {
354331
listParams.v2 = true;
355332
listParams.startAfter = params['start-after'];
356-
listParams.continuationToken =
357-
decryptToken(params['continuation-token']);
333+
listParams.continuationToken = decryptToken(params['continuation-token']);
358334
listParams.fetchOwner = params['fetch-owner'] === 'true';
359335
} else {
360336
listParams.marker = params.marker;
@@ -374,7 +350,8 @@ function bucketGet(authInfo, request, log, callback) {
374350
delete listParams.marker;
375351
listParams.keyMarker = params['key-marker'];
376352
listParams.versionIdMarker = params['version-id-marker'] ?
377-
versionIdUtils.decode(params['version-id-marker']) : undefined;
353+
versionIdUtils.decode(params['version-id-marker']) :
354+
undefined;
378355
}
379356

380357
if (!requestMaxKeys) {

‎lib/api/objectGetLegalHold.js‎

Lines changed: 13 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -25,16 +25,12 @@ function objectGetLegalHold(authInfo, request, log, callback) {
2525

2626
const decodedVidResult = decodeVersionId(query);
2727
if (decodedVidResult instanceof Error) {
28-
log.trace('invalid versionId query', {
29-
versionId: query.versionId,
30-
error: decodedVidResult,
31-
});
28+
log.trace('invalid versionId query', { versionId: query.versionId, error: decodedVidResult });
3229
return process.nextTick(() => callback(decodedVidResult));
3330
}
3431
const versionId = decodedVidResult;
3532

36-
// FIXME pass 'getDeleteMarker: true' option to set
37-
// 'x-amz-delete-marker' header (see S3C-7592)
33+
// FIXME pass 'getDeleteMarker: true' option to set 'x-amz-delete-marker' header (see S3C-7592)
3834
const metadataValParams = {
3935
authInfo,
4036
bucketName,
@@ -48,34 +44,26 @@ function objectGetLegalHold(authInfo, request, log, callback) {
4844
next => standardMetadataValidateBucketAndObj(metadataValParams, request.actionImplicitDenies, log,
4945
(err, bucket, objectMD) => {
5046
if (err) {
51-
log.trace('request authorization failed',
52-
{ method: 'objectGetLegalHold', error: err });
47+
log.trace('request authorization failed', { method: 'objectGetLegalHold', error: err });
5348
return next(err);
5449
}
5550
if (!objectMD) {
56-
const err = versionId ? errors.NoSuchVersion :
57-
errors.NoSuchKey;
58-
log.trace('error no object metadata found',
59-
{ method: 'objectGetLegalHold', error: err });
51+
const err = versionId ? errors.NoSuchVersion : errors.NoSuchKey;
52+
log.trace('error no object metadata found', { method: 'objectGetLegalHold', error: err });
6053
return next(err, bucket);
6154
}
6255
if (objectMD.isDeleteMarker) {
6356
if (versionId) {
64-
log.trace('requested version is delete marker',
65-
{ method: 'objectGetLegalHold' });
66-
// FIXME we should return a `x-amz-delete-marker: true` header,
67-
// see S3C-7592
57+
log.trace('requested version is delete marker', { method: 'objectGetLegalHold' });
58+
// FIXME we should return a `x-amz-delete-marker: true` header, see S3C-7592
6859
return next(errors.MethodNotAllowed);
6960
}
70-
log.trace('most recent version is delete marker',
71-
{ method: 'objectGetLegalHold' });
72-
// FIXME we should return a `x-amz-delete-marker: true` header,
73-
// see S3C-7592
61+
log.trace('most recent version is delete marker', { method: 'objectGetLegalHold' });
62+
// FIXME we should return a `x-amz-delete-marker: true` header, see S3C-7592
7463
return next(errors.NoSuchKey);
7564
}
7665
if (!bucket.isObjectLockEnabled()) {
77-
log.trace('object lock not enabled on bucket',
78-
{ method: 'objectGetRetention' });
66+
log.trace('object lock not enabled on bucket', { method: 'objectGetRetention' });
7967
return next(errorInstances.InvalidRequest.customizeDescription(
8068
'Bucket is missing Object Lock Configuration'));
8169
}
@@ -90,11 +78,9 @@ function objectGetLegalHold(authInfo, request, log, callback) {
9078
return next(null, bucket, xml, objectMD);
9179
},
9280
], (err, bucket, xml, objectMD) => {
93-
const additionalResHeaders = collectCorsHeaders(request.headers.origin,
94-
request.method, bucket);
81+
const additionalResHeaders = collectCorsHeaders(request.headers.origin, request.method, bucket);
9582
if (err) {
96-
log.trace('error processing request', { error: err,
97-
method: 'objectGetLegalHold' });
83+
log.trace('error processing request', { error: err, method: 'objectGetLegalHold' });
9884
} else {
9985
pushMetric('getObjectLegalHold', log, {
10086
authInfo,
@@ -104,8 +90,7 @@ function objectGetLegalHold(authInfo, request, log, callback) {
10490
location: objectMD ? objectMD.dataStoreName : undefined,
10591
});
10692
const verCfg = bucket.getVersioningConfiguration();
107-
additionalResHeaders['x-amz-version-id'] =
108-
getVersionIdResHeader(verCfg, objectMD);
93+
additionalResHeaders['x-amz-version-id'] = getVersionIdResHeader(verCfg, objectMD);
10994
}
11095
return callback(err, xml, additionalResHeaders);
11196
});

0 commit comments

Comments
 (0)