Merge pull request #49 from meltwater/Major_Update

Feat: remove all logs that contain large payloads
meltwater · Jan 30, 2025 · 743da04 · 743da04
2 parents 95e23c0 + aae8870
commit 743da04
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 20 deletions.
diff --git a/lib/aws/dynamodb-document.js b/lib/aws/dynamodb-document.js
@@ -61,7 +61,6 @@ export class DynamodbDocumentClient {
 
       const res = await this._db.get(req).promise()
       const data = res.Item
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {
@@ -87,7 +86,6 @@ export class DynamodbDocumentClient {
 
       const res = await this._db.put(req).promise()
       const data = res.Attributes
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {
@@ -133,7 +131,6 @@ export class DynamodbDocumentClient {
         scannedCount: res.ScannedCount,
         lastEvaluatedKey: res.LastEvaluatedKey
       }
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {
@@ -158,7 +155,6 @@ export class DynamodbDocumentClient {
       }
 
       const data = await this._db.update(req).promise()
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {

diff --git a/lib/aws/eventbridge.js b/lib/aws/eventbridge.js
@@ -66,7 +66,7 @@ export class EventbridgeClient {
       method: 'putEvents'
     })
     try {
-      log.info({ data: events }, 'start')
+      log.info('start putEvents')
 
       const req = {
         Entries: events.map((event) => this._toEventRequest(event)),
@@ -78,7 +78,6 @@ export class EventbridgeClient {
       checkFailedEntries(res)
       const data = res.Entries.map(createEventResponse)
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {

diff --git a/lib/aws/lambda.js b/lib/aws/lambda.js
@@ -59,7 +59,6 @@ export class LambdaClient {
       checkFunctionError(res)
 
       const data = JSON.parse(res.Payload)
-      log.debug({ data, statusCode }, 'data')
       log.info({ statusCode }, 'end')
       return data
     } catch (err) {

diff --git a/lib/aws/s3.js b/lib/aws/s3.js
@@ -122,7 +122,6 @@ export class S3Client {
 
       const data = await this._s3.getObject(req).promise()
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {
@@ -149,7 +148,6 @@ export class S3Client {
       const res = await this.getObject(key, params)
       const data = parseResAsJson(res)
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {
@@ -174,7 +172,6 @@ export class S3Client {
 
       const data = await this._s3.listObjectVersions(params).promise()
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {
@@ -199,7 +196,6 @@ export class S3Client {
 
       const data = await this._s3.deleteObjects(params).promise()
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {

diff --git a/lib/aws/sns.js b/lib/aws/sns.js
@@ -82,7 +82,6 @@ export class SnsClient {
         sequenceNumber: res.SequenceNumber
       })
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {

diff --git a/lib/aws/sqs.js b/lib/aws/sqs.js
@@ -95,7 +95,6 @@ export class SqsClient {
         sequenceNumber: res.SequenceNumber
       })
 
-      log.debug({ data }, 'data')
       log.info('end')
       return data
     } catch (err) {

diff --git a/lib/wrapper/default-wrapper.js b/lib/wrapper/default-wrapper.js
@@ -16,11 +16,11 @@ export const createDefaultWrapper = (
   try {
     log.info('handle: start')
     const parsedEvent = parser(event, context)
-    log.info({ meta: parsedEvent }, 'handle: parse')
+    log.info('handle: parse')
     const data = await processor(parsedEvent, context)
-    log.debug({ data }, 'handle: data')
+    log.debug('handle: data')
     const serializedData = serializer(data, ctx)
-    log.debug({ data: serializedData }, 'handle: serialize')
+    log.debug('handle: serialize')
     log.info('handle: end')
     return serializedData
   } catch (err) {

diff --git a/lib/wrapper/json-wrapper.js b/lib/wrapper/json-wrapper.js
@@ -22,12 +22,12 @@ export const createApiJsonWrapper = (
   try {
     log.info('handle: start')
     const parsedEvent = parser(event, context)
-    log.info({ meta: parsedEvent }, 'handle: parse')
+    log.info('handle: parse')
     const data = await processor(parsedEvent, context)
-    log.debug({ data }, 'handle: data')
+    log.debug('handle: data')
     const serializedData = serializer(data, ctx)
     const { statusCode } = serializedData
-    log.debug({ data: serializedData, statusCode }, 'handle: serialize')
+    log.debug('handle: serialize')
     log.info({ statusCode }, 'handle: end')
     return serializedData
   } catch (err) {
@@ -44,7 +44,7 @@ export const createApiJsonWrapper = (
       ctx
     )
     const { statusCode } = serializedData
-    log.debug({ data: serializedData, statusCode }, 'handle: data')
+    log.debug('handle: data')
     log.info({ statusCode }, 'handle: end')
     return serializedData
   }