✨[RUM-5090] Collect resource protocol

packages/rum-core/src/browser/performanceObservable.ts

@@ -59,6 +59,7 @@ export interface RumPerformanceResourceTiming {
   decodedBodySize: number
   encodedBodySize: number
   transferSize: number
+  nextHopProtocol?: string
   renderBlockingStatus?: string
   traceId?: string
   toJSON(): Omit<PerformanceEntry, 'toJSON'>

packages/rum-core/src/domain/resource/resourceCollection.spec.ts

@@ -79,6 +79,7 @@ describe('resourceCollection', () => {
         download: jasmine.any(Object),
         first_byte: jasmine.any(Object),
         status_code: 200,
+        protocol: 'HTTP/1.0',
         render_blocking_status: 'blocking',
       },
       type: RumEventType.RESOURCE,
@@ -116,6 +117,7 @@ describe('resourceCollection', () => {
         duration: (100 * 1e6) as ServerDuration,
         method: 'GET',
         status_code: 200,
+        protocol: undefined,
         type: ResourceType.XHR,
         url: 'https://resource.com/valid',
       },
@@ -229,6 +231,7 @@ describe('resourceCollection', () => {
         duration: (100 * 1e6) as ServerDuration,
         method: 'GET',
         status_code: 200,
+        protocol: undefined,
         type: ResourceType.FETCH,
         url: 'https://resource.com/valid',
       },

packages/rum-core/src/domain/resource/resourceCollection.ts

@@ -30,6 +30,7 @@ import {
   computeResourceEntryDuration,
   computeResourceEntryType,
   computeResourceEntrySize,
+  computeResourceEntryProtocol,
   isResourceEntryRequestType,
   isLongDataUrl,
   sanitizeDataUrl,
@@ -104,6 +105,7 @@ function processRequest(
         duration,
         method: request.method,
         status_code: request.status,
+        protocol: matchingTiming && computeResourceEntryProtocol(matchingTiming),
         url: isLongDataUrl(request.url) ? sanitizeDataUrl(request.url) : request.url,
       },
       type: RumEventType.RESOURCE as const,
@@ -152,6 +154,7 @@ function processResourceEntry(
         type,
         url: entry.name,
         status_code: discardZeroStatus(entry.responseStatus),
+        protocol: computeResourceEntryProtocol(entry),
       },
       type: RumEventType.RESOURCE as const,
       _dd: {

packages/rum-core/src/domain/resource/resourceUtils.ts

@@ -177,6 +177,15 @@ function formatTiming(origin: RelativeTime, start: RelativeTime, end: RelativeTi
   }
 }
 
+/**
+ * The 'nextHopProtocol' is an empty string for cross-origin resources without CORS headers,
+ * meaning the protocol is unknown, and we shouldn't report it.
+ * https://developer.mozilla.org/en-US/docs/Web/API/PerformanceResourceTiming/nextHopProtocol#cross-origin_resources
+ */
+export function computeResourceEntryProtocol(entry: RumPerformanceResourceTiming) {
+  return entry.nextHopProtocol === '' ? undefined : entry.nextHopProtocol
+}
+
 export function computeResourceEntrySize(entry: RumPerformanceResourceTiming) {
   // Make sure a request actually occurred
   if (entry.startTime < entry.responseStart) {

packages/rum-core/src/rawRumEvent.types.ts

@@ -48,6 +48,7 @@ export interface RawRumResourceEvent {
     ssl?: ResourceEntryDetailsElement
     first_byte?: ResourceEntryDetailsElement
     download?: ResourceEntryDetailsElement
+    protocol?: string
   }
   _dd: {
     trace_id?: string

packages/rum-core/src/rumEvent.types.ts

@@ -702,6 +702,10 @@ export type RumResourceEvent = CommonProperties &
         readonly start: number
         [k: string]: unknown
       }
+      /**
+       * Network protocol used to fetch the resource (e.g., 'http/1.1', 'h2')
+       */
+      readonly protocol?: string
       /**
        * The provider for this resource
        */

packages/rum-core/test/fixtures.ts

@@ -259,6 +259,7 @@ export function createPerformanceEntry<T extends RumPerformanceEntryType>(
           secureConnectionStart: 200 as RelativeTime,
           startTime: 200 as RelativeTime,
           responseStatus: 200,
+          nextHopProtocol: 'HTTP/1.0',
         },
         overrides
       ) as EntryTypeToReturnType[T]