feat(xen-api): transfer the trace context to json rpc calls

Author: fbeauchamp

packages/xen-api/package.json

@@ -31,6 +31,7 @@
     "node": ">=18"
   },
   "dependencies": {
+    "@opentelemetry/api": "^1.9.0",
     "@vates/coalesce-calls": "^0.1.0",
     "@vates/compose": "^2.1.0",
     "@vates/decorate-with": "^2.1.0",

packages/xen-api/transports/json-rpc.mjs

@@ -10,8 +10,10 @@ const tracer = trace.getTracer('xo:json-rpc')
 // https://github.com/xenserver/xenadmin/blob/0df39a9d83cd82713f32d24704852a0fd57b8a64/XenModel/XenAPI/Session.cs#L403-L433
 export default ({ dispatcher, url }) => {
   url = new URL('./jsonrpc', Object.assign(new URL('http://localhost'), url))
-
   return async function (method, args) {
+    const traceparent = trace.getActiveSpan()?._spanContext?.spanId
+    const tracestate = trace.getActiveSpan()?._spanContext?.traceState
+
       return tracer.startActiveSpan(`xo:json-rpc:${method}`, async (span) => {
         try{
           const res = await request(url, {
@@ -20,6 +22,8 @@ export default ({ dispatcher, url }) => {
             headers: {
               Accept: 'application/json',
               'Content-Type': 'application/json',
+              tracestate,
+              traceparent
             },
             method: 'POST',
           })

packages/xo-server/src/instrumentation.js

@@ -12,7 +12,7 @@ const { ZipkinExporter } = require('@opentelemetry/exporter-zipkin')
 // default) and application name to the Zipkin options.
 // You can also define your custom headers which will be added automatically.
 const options = {
-  url: 'http://10.1.5.158:9411/api/v2/spans',
+  url: 'http://10.1.8.81:9411/api/v2/spans',
 }
 const exporter = new ZipkinExporter(options)
 const sdk = new NodeSDK({