align network module with BiDi spec

Bug: #765
Spec: https://w3c.github.io/webdriver-bidi/#module-network

Author: Thiago Perrotta

src/bidiMapper/domains/events/SubscriptionManager.spec.ts

@@ -451,8 +451,9 @@ describe('unroll events', () => {
   it('all Network events', () => {
     expect(unrollEvents([Network.AllEvents])).to.deep.equal([
       Network.EventNames.BeforeRequestSentEvent,
-      Network.EventNames.ResponseCompletedEvent,
       Network.EventNames.FetchErrorEvent,
+      Network.EventNames.ResponseStartedEvent,
+      Network.EventNames.ResponseCompletedEvent,
     ]);
   });
 

src/bidiMapper/domains/network/networkProcessor.ts

@@ -25,6 +25,7 @@ import Protocol from 'devtools-protocol';
 import {CdpClient} from '../../CdpConnection.js';
 import {IEventManager} from '../events/EventManager.js';
 import {DefaultMap} from '../../../utils/DefaultMap.js';
+import {Network} from '../../../protocol/protocol.js';
 
 import {NetworkRequest} from './networkRequest.js';
 
@@ -35,11 +36,11 @@ export class NetworkProcessor {
    * Map of request ID to NetworkRequest objects. Needed as long as information
    * about requests comes from different events.
    */
-  readonly #requestMap: DefaultMap<string, NetworkRequest>;
+  readonly #requestMap: DefaultMap<Network.Request, NetworkRequest>;
 
   private constructor(eventManager: IEventManager) {
     this.#eventManager = eventManager;
-    this.#requestMap = new DefaultMap<string, NetworkRequest>(
+    this.#requestMap = new DefaultMap(
       (requestId) => new NetworkRequest(requestId, this.#eventManager)
     );
   }
@@ -100,7 +101,7 @@ export class NetworkProcessor {
     return networkProcessor;
   }
 
-  #getOrCreateNetworkRequest(requestId: string): NetworkRequest {
+  #getOrCreateNetworkRequest(requestId: Network.Request): NetworkRequest {
     return this.#requestMap.get(requestId);
   }
 }

src/bidiMapper/domains/network/networkRequest.ts

@@ -20,7 +20,6 @@
  * @fileoverview `NetworkRequest` represents a single network request and keeps
  * track of all the related CDP events.
  */
-
 import Protocol from 'devtools-protocol';
 
 import {Deferred} from '../../../utils/deferred.js';
@@ -29,22 +28,19 @@ import {Network} from '../../../protocol/protocol.js';
 
 export class NetworkRequest {
   static #unknown = 'UNKNOWN';
-  requestId: string;
+
+  requestId: Network.Request;
   #eventManager: IEventManager;
-  #requestWillBeSentEvent: Protocol.Network.RequestWillBeSentEvent | undefined;
-  #requestWillBeSentExtraInfoEvent:
-    | Protocol.Network.RequestWillBeSentExtraInfoEvent
-    | undefined;
-  #responseReceivedEvent: Protocol.Network.ResponseReceivedEvent | undefined;
 
-  #responseReceivedExtraInfoEvent:
-    | Protocol.Network.ResponseReceivedExtraInfoEvent
-    | undefined;
+  #requestWillBeSentEvent?: Protocol.Network.RequestWillBeSentEvent;
+  #requestWillBeSentExtraInfoEvent?: Protocol.Network.RequestWillBeSentExtraInfoEvent;
+  #responseReceivedEvent?: Protocol.Network.ResponseReceivedEvent;
+  #responseReceivedExtraInfoEvent?: Protocol.Network.ResponseReceivedExtraInfoEvent;
 
   #beforeRequestSentDeferred: Deferred<void>;
   #responseReceivedDeferred: Deferred<void>;
 
-  constructor(requestId: string, eventManager: IEventManager) {
+  constructor(requestId: Network.Request, eventManager: IEventManager) {
     this.requestId = requestId;
     this.#eventManager = eventManager;
     this.#beforeRequestSentDeferred = new Deferred<void>();
@@ -63,6 +59,7 @@ export class NetworkRequest {
     if (this.#requestWillBeSentExtraInfoEvent !== undefined) {
       this.#beforeRequestSentDeferred.resolve();
     }
+
     this.#sendBeforeRequestEvent();
   }
 
@@ -73,6 +70,7 @@ export class NetworkRequest {
       // TODO: Handle redirect event, requestId is same for the redirect chain
       return;
     }
+
     this.#requestWillBeSentExtraInfoEvent = requestWillBeSentExtraInfoEvent;
     if (this.#requestWillBeSentEvent !== undefined) {
       this.#beforeRequestSentDeferred.resolve();
@@ -87,18 +85,21 @@ export class NetworkRequest {
       return;
     }
     this.#responseReceivedEvent = responseReceivedEvent;
+
     if (
       !responseReceivedEvent.hasExtraInfo &&
       !this.#beforeRequestSentDeferred.isFinished
     ) {
       this.#beforeRequestSentDeferred.resolve();
     }
+
     if (
       !responseReceivedEvent.hasExtraInfo ||
       this.#responseReceivedExtraInfoEvent !== undefined
     ) {
       this.#responseReceivedDeferred.resolve();
     }
+
     this.#sendResponseReceivedEvent();
   }
 
@@ -110,6 +111,7 @@ export class NetworkRequest {
       return;
     }
     this.#responseReceivedExtraInfoEvent = responseReceivedExtraInfoEvent;
+
     if (this.#responseReceivedEvent !== undefined) {
       this.#responseReceivedDeferred.resolve();
     }
@@ -161,7 +163,7 @@ export class NetworkRequest {
     };
   }
 
-  #getBaseEventParams(): Network.BaseEventParams {
+  #getBaseEventParams(): Network.BaseParameters {
     return {
       context: this.#requestWillBeSentEvent?.frameId ?? null,
       navigation: this.#requestWillBeSentEvent?.loaderId ?? null,
@@ -221,8 +223,6 @@ export class NetworkRequest {
         // TODO: implement.
         tlsStart: 0,
         // TODO: implement.
-        tlsEnd: 0,
-        // TODO: implement.
         requestStart: 0,
         // TODO: implement.
         responseStart: 0,
@@ -244,7 +244,7 @@ export class NetworkRequest {
   }
 
   static #getCookiesSameSite(
-    cdpSameSiteValue: string | undefined
+    cdpSameSiteValue?: string
   ): Network.Cookie['sameSite'] {
     switch (cdpSameSiteValue) {
       case 'Strict':
@@ -309,7 +309,6 @@ export class NetworkRequest {
           fromCache:
             this.#responseReceivedEvent.response.fromDiskCache ||
             this.#responseReceivedEvent.response.fromPrefetchCache,
-          // TODO: implement.
           headers: this.#getHeaders(
             this.#responseReceivedEvent.response.headers
           ),

src/protocol/protocol.ts

@@ -32,6 +32,7 @@ export interface EventResponse<MethodType, ParamsType> {
 export type BiDiCommand =
   | BrowsingContext.Command
   | CDP.Command
+  | Network.Command
   | Script.Command
   | Session.Command;
 
@@ -51,6 +52,7 @@ export namespace Message {
   export type CommandRequest = Pick<RawCommandRequest, 'id'> & BiDiCommand;
   export type CommandResponse = Pick<RawCommandRequest, 'id'> & ResultData;
 
+  export type EmptyCommand = never;
   export type EmptyParams = Record<string, never>;
   export type EmptyResult = {result: Record<string, never>};
 
@@ -60,6 +62,7 @@ export namespace Message {
     | BrowsingContext.Result
     | CDP.Result
     | ErrorResult
+    | Network.Result
     | Script.Result
     | Session.Result;
   // keep-sorted end
@@ -1018,9 +1021,14 @@ export namespace Log {
 }
 
 export namespace Network {
+  export type Command = Message.EmptyCommand;
+
+  export type Result = Message.EmptyResult;
+
   export type Event =
     | BeforeRequestSentEvent
     | ResponseCompletedEvent
+    | ResponseStartedEvent
     | FetchErrorEvent;
 
   export type BeforeRequestSentEvent = EventResponse<
@@ -1033,6 +1041,11 @@ export namespace Network {
     ResponseCompletedParams
   >;
 
+  export type ResponseStartedEvent = EventResponse<
+    EventNames.ResponseStartedEvent,
+    ResponseStartedParams
+  >;
+
   export type FetchErrorEvent = EventResponse<
     EventNames.FetchErrorEvent,
     FetchErrorParams
@@ -1068,12 +1081,13 @@ export namespace Network {
     connectStart: number;
     connectEnd: number;
     tlsStart: number;
-    tlsEnd: number;
     requestStart: number;
     responseStart: number;
     responseEnd: number;
   };
 
+  export type Request = string;
+
   export type RequestData = {
     request: string;
     url: string;
@@ -1085,8 +1099,8 @@ export namespace Network {
     timings: FetchTimingInfo;
   };
 
-  export type BaseEventParams = {
-    context: string | null;
+  export type BaseParameters = {
+    context: CommonDataTypes.BrowsingContext | null;
     navigation: BrowsingContext.Navigation | null;
     redirectCount: number;
     request: RequestData;
@@ -1119,24 +1133,29 @@ export namespace Network {
     content: ResponseContent;
   };
 
-  export type BeforeRequestSentParams = BaseEventParams & {
+  export type BeforeRequestSentParams = BaseParameters & {
     initiator: Initiator;
   };
 
-  export type ResponseCompletedParams = BaseEventParams & {
+  export type ResponseCompletedParams = BaseParameters & {
     response: ResponseData;
   };
 
-  export type FetchErrorParams = BaseEventParams & {
+  export type ResponseStartedParams = BaseParameters & {
+    response: ResponseData;
+  };
+
+  export type FetchErrorParams = BaseParameters & {
     errorText: string;
   };
 
   export const AllEvents = 'network';
 
   export enum EventNames {
     BeforeRequestSentEvent = 'network.beforeRequestSent',
-    ResponseCompletedEvent = 'network.responseCompleted',
     FetchErrorEvent = 'network.fetchError',
+    ResponseStartedEvent = 'network.responseStarted',
+    ResponseCompletedEvent = 'network.responseCompleted',
   }
 }
 

wpt-metadata/chromedriver/headless/webdriver/tests/bidi/network/response_started/response_started.py.ini

@@ -1,4 +1,5 @@
 [response_started.py]
+  expected: TIMEOUT
   [test_subscribe_status]
     expected: FAIL