feat(opentelemetry-web): capture decodedBodySize / http.response_content_length

packages/opentelemetry-plugin-fetch/src/enums/AttributeNames.ts

@@ -28,4 +28,5 @@ export enum AttributeNames {
   HTTP_URL = 'http.url',
   HTTP_TARGET = 'http.target',
   HTTP_USER_AGENT = 'http.user_agent',
+  TRANSFER_SIZE = 'transferSize',
 }

packages/opentelemetry-plugin-fetch/test/fetch.test.ts

@@ -300,8 +300,12 @@ describe('fetch', () => {
         attributes[keys[7]] !== '',
         `attributes ${AttributeNames.HTTP_USER_AGENT} is not defined`
       );
+      assert.ok(
+        (attributes[keys[8]] as number) > 0,
+        `attributes ${AttributeNames.TRANSFER_SIZE} is <= 0`
+      );
 
-      assert.strictEqual(keys.length, 8, 'number of attributes is wrong');
+      assert.strictEqual(keys.length, 9, 'number of attributes is wrong');
     });
 
     it('span should have correct events', () => {

packages/opentelemetry-plugin-xml-http-request/test/xhr.test.ts

@@ -290,31 +290,35 @@ describe('xhr', () => {
             url,
             `attributes ${HttpAttribute.HTTP_URL} is wrong`
           );
+          assert.ok(
+            (attributes[keys[2]] as number) > 0,
+            'attributes transferSize <= 0'
+          );
           assert.strictEqual(
-            attributes[keys[2]],
+            attributes[keys[3]],
             200,
             `attributes ${HttpAttribute.HTTP_STATUS_CODE} is wrong`
           );
           assert.strictEqual(
-            attributes[keys[3]],
+            attributes[keys[4]],
             'OK',
             `attributes ${HttpAttribute.HTTP_STATUS_TEXT} is wrong`
           );
           assert.strictEqual(
-            attributes[keys[4]],
+            attributes[keys[5]],
             parseUrl(url).host,
             `attributes ${HttpAttribute.HTTP_HOST} is wrong`
           );
           assert.ok(
-            attributes[keys[5]] === 'http' || attributes[keys[5]] === 'https',
+            attributes[keys[6]] === 'http' || attributes[keys[6]] === 'https',
             `attributes ${HttpAttribute.HTTP_SCHEME} is wrong`
           );
           assert.ok(
-            attributes[keys[6]] !== '',
+            attributes[keys[7]] !== '',
             `attributes ${HttpAttribute.HTTP_USER_AGENT} is not defined`
           );
 
-          assert.strictEqual(keys.length, 7, 'number of attributes is wrong');
+          assert.strictEqual(keys.length, 8, 'number of attributes is wrong');
         });
 
         it('span should have correct events', () => {

packages/opentelemetry-web/src/enums/PerformanceTimingNames.ts

@@ -32,6 +32,7 @@ export enum PerformanceTimingNames {
   RESPONSE_END = 'responseEnd',
   RESPONSE_START = 'responseStart',
   SECURE_CONNECTION_START = 'secureConnectionStart',
+  TRANSFER_SIZE = 'transferSize',
   UNLOAD_EVENT_END = 'unloadEventEnd',
   UNLOAD_EVENT_START = 'unloadEventStart',
 }

packages/opentelemetry-web/src/types.ts

@@ -33,6 +33,7 @@ export type PerformanceEntries = {
   [PerformanceTimingNames.RESPONSE_END]?: number;
   [PerformanceTimingNames.RESPONSE_START]?: number;
   [PerformanceTimingNames.SECURE_CONNECTION_START]?: number;
+  [PerformanceTimingNames.TRANSFER_SIZE]?: number;
   [PerformanceTimingNames.UNLOAD_EVENT_END]?: number;
   [PerformanceTimingNames.UNLOAD_EVENT_START]?: number;
 };

packages/opentelemetry-web/src/utils.ts

@@ -81,6 +81,9 @@ export function addSpanNetworkEvents(
   addSpanNetworkEvent(span, PTN.REQUEST_START, resource);
   addSpanNetworkEvent(span, PTN.RESPONSE_START, resource);
   addSpanNetworkEvent(span, PTN.RESPONSE_END, resource);
+  if (resource.transferSize) {
+    span.setAttribute('transferSize', resource.transferSize);
+  }
 }
 
 /**

packages/opentelemetry-web/test/utils.test.ts

@@ -137,8 +137,10 @@ describe('utils', () => {
   describe('addSpanNetworkEvents', () => {
     it('should add all network events to span', () => {
       const addEventSpy = sinon.spy();
+      const setAttributeSpy = sinon.spy();
       const span = ({
         addEvent: addEventSpy,
+        setAttribute: setAttributeSpy,
       } as unknown) as tracing.Span;
       const entries = {
         [PTN.FETCH_START]: 123,
@@ -150,13 +152,15 @@ describe('utils', () => {
         [PTN.REQUEST_START]: 123,
         [PTN.RESPONSE_START]: 123,
         [PTN.RESPONSE_END]: 123,
+        [PTN.TRANSFER_SIZE]: 123,
       } as PerformanceEntries;
 
       assert.strictEqual(addEventSpy.callCount, 0);
 
       addSpanNetworkEvents(span, entries);
 
       assert.strictEqual(addEventSpy.callCount, 9);
+      assert.strictEqual(setAttributeSpy.callCount, 1);
     });
   });
   describe('addSpanNetworkEvent', () => {