Abstract the passing of extracted header span links to startSpan (#4918)

* updating span links

* correcting field name

* fixing links to _links

Author: mhlidd

packages/datadog-plugin-amqplib/src/consumer.js

@@ -26,8 +26,7 @@ class AmqplibConsumerPlugin extends ConsumerPlugin {
         'amqp.consumerTag': fields.consumerTag,
         'amqp.source': fields.source,
         'amqp.destination': fields.destination
-      },
-      extractedLinks: childOf?._links
+      }
     })
 
     if (

packages/datadog-plugin-aws-sdk/src/services/kinesis.js

@@ -42,8 +42,7 @@ class Kinesis extends BaseAwsSdkPlugin {
               {},
               this.requestTags.get(request) || {},
               { 'span.kind': 'server' }
-            ),
-            extractedLinks: responseExtraction.maybeChildOf._links
+            )
           }
           span = plugin.tracer.startSpan('aws.response', options)
           this.enter(span, store)

packages/datadog-plugin-aws-sdk/src/services/sqs.js

@@ -33,8 +33,7 @@ class Sqs extends BaseAwsSdkPlugin {
             {},
             this.requestTags.get(request) || {},
             { 'span.kind': 'server' }
-          ),
-          extractedLinks: contextExtraction.datadogContext._links
+          )
         }
         parsedMessageAttributes = contextExtraction.parsedAttributes
         span = plugin.tracer.startSpan('aws.response', options)

packages/datadog-plugin-google-cloud-pubsub/src/consumer.js

@@ -22,8 +22,7 @@ class GoogleCloudPubsubConsumerPlugin extends ConsumerPlugin {
       },
       metrics: {
         'pubsub.ack': 0
-      },
-      extractedLinks: childOf?._links
+      }
     })
     if (this.config.dsmEnabled && message?.attributes) {
       const payloadSize = getMessageSize(message)

packages/datadog-plugin-grpc/src/server.js

@@ -48,8 +48,7 @@ class GrpcServerPlugin extends ServerPlugin {
       },
       metrics: {
         'grpc.status.code': 0
-      },
-      extractedLinks: childOf?._links
+      }
     })
 
     addMetadataTags(span, metadata, metadataFilter, 'request')

packages/datadog-plugin-jest/src/index.js

@@ -219,8 +219,7 @@ class JestPlugin extends CiPlugin {
           [COMPONENT]: this.constructor.id,
           ...this.testEnvironmentMetadata,
           ...testSuiteMetadata
-        },
-        extractedLinks: testSessionSpanContext?._links
+        }
       })
       this.telemetry.ciVisEvent(TELEMETRY_EVENT_CREATED, 'suite')
       if (_ddTestCodeCoverageEnabled) {

packages/datadog-plugin-kafkajs/src/consumer.js

@@ -76,8 +76,7 @@ class KafkajsConsumerPlugin extends ConsumerPlugin {
       },
       metrics: {
         'kafka.partition': partition
-      },
-      extractedLinks: childOf?._links
+      }
     })
     if (this.config.dsmEnabled && message?.headers) {
       const payloadSize = getMessageSize(message)

packages/datadog-plugin-moleculer/src/server.js

@@ -18,8 +18,7 @@ class MoleculerServerPlugin extends ServerPlugin {
       meta: {
         'resource.name': action.name,
         ...moleculerTags(broker, ctx, this.config)
-      },
-      extractedLinks: followsFrom?._links
+      }
     })
   }
 }

packages/datadog-plugin-rhea/src/consumer.js

@@ -28,8 +28,7 @@ class RheaConsumerPlugin extends ConsumerPlugin {
         component: 'rhea',
         'amqp.link.source.address': name,
         'amqp.link.role': 'receiver'
-      },
-      extractedLinks: childOf?._links
+      }
     })
 
     if (

packages/datadog-plugin-vitest/src/index.js

@@ -191,8 +191,7 @@ class VitestPlugin extends CiPlugin {
           [COMPONENT]: this.constructor.id,
           ...this.testEnvironmentMetadata,
           ...testSuiteMetadata
-        },
-        extractedLinks: testSessionSpanContext?._links
+        }
       })
       this.telemetry.ciVisEvent(TELEMETRY_EVENT_CREATED, 'suite')
       const store = storage.getStore()

packages/dd-trace/src/plugins/tracing.js

@@ -101,7 +101,7 @@ class TracingPlugin extends Plugin {
     }
   }
 
-  startSpan (name, { childOf, kind, meta, metrics, service, resource, type, extractedLinks } = {}, enter = true) {
+  startSpan (name, { childOf, kind, meta, metrics, service, resource, type } = {}, enter = true) {
     const store = storage.getStore()
     if (store && childOf === undefined) {
       childOf = store.span
@@ -119,7 +119,7 @@ class TracingPlugin extends Plugin {
         ...metrics
       },
       integrationName: type,
-      links: extractedLinks
+      links: childOf?._links
     })
 
     analyticsSampler.sample(span, this.config.measured)

packages/dd-trace/src/plugins/util/web.js

@@ -267,7 +267,7 @@ const web = {
       }
     }
 
-    const span = tracer.startSpan(name, { childOf, extractedLinks: childOf?.links })
+    const span = tracer.startSpan(name, { childOf, links: childOf?._links })
 
     return span
   },