@@ -203,7 +203,7 @@ export function readTraceFromAppSyncEvent(event: any): TraceContext | undefined
203
203
}
204
204
205
205
export function readTraceFromSQSEvent ( event : SQSEvent ) : TraceContext | undefined {
206
- if ( event . Records && event . Records [ 0 ] ?. messageAttributes ?. _datadog ?. stringValue ) {
206
+ if ( event . Records ?. [ 0 ] ?. messageAttributes ?. _datadog ?. stringValue ) {
207
207
const traceHeaders = event . Records [ 0 ] . messageAttributes . _datadog . stringValue ;
208
208
209
209
try {
@@ -238,7 +238,7 @@ export function readTraceFromSQSEvent(event: SQSEvent): TraceContext | undefined
238
238
}
239
239
240
240
export function readTraceFromSNSSQSEvent ( event : SQSEvent ) : TraceContext | undefined {
241
- if ( event ?. Records [ 0 ] ?. body ) {
241
+ if ( event ?. Records ?. [ 0 ] ?. body ) {
242
242
try {
243
243
const parsedBody = JSON . parse ( event . Records [ 0 ] . body ) as SNSMessage ;
244
244
if (
@@ -275,7 +275,7 @@ export function readTraceFromSNSSQSEvent(event: SQSEvent): TraceContext | undefi
275
275
}
276
276
277
277
export function readTraceFromKinesisEvent ( event : KinesisStreamEvent ) : TraceContext | undefined {
278
- if ( event ?. Records [ 0 ] ?. kinesis ?. data ) {
278
+ if ( event ?. Records ?. [ 0 ] ?. kinesis ?. data ) {
279
279
try {
280
280
const parsedBody = JSON . parse ( Buffer . from ( event . Records [ 0 ] . kinesis . data , "base64" ) . toString ( "ascii" ) ) as any ;
281
281
if ( parsedBody && parsedBody . _datadog ) {
@@ -338,7 +338,7 @@ export function readTraceFromEventbridgeEvent(event: EventBridgeEvent<any, any>)
338
338
}
339
339
340
340
export function readTraceFromSNSEvent ( event : SNSEvent ) : TraceContext | undefined {
341
- if ( event ?. Records && event ?. Records [ 0 ] ?. Sns ?. MessageAttributes ?. _datadog . Value ) {
341
+ if ( event ?. Records ?. [ 0 ] ?. Sns ?. MessageAttributes ?. _datadog . Value ) {
342
342
try {
343
343
const traceData = JSON . parse ( event . Records [ 0 ] . Sns . MessageAttributes . _datadog . Value ) ;
344
344
const traceID = traceData [ traceIDHeader ] ;
0 commit comments