123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230
/// <reference types="./NetworkEventManager.d.ts" />var __classPrivateFieldGet = (this && this.__classPrivateFieldGet) ||  function (receiver, state, kind, f) {    if (kind === "a" && !f) {      throw new TypeError("Private accessor was defined without a getter");    }    if (      typeof state === "function"        ? receiver !== state || !f        : !state.has(receiver)    ) {      throw new TypeError(        "Cannot read private member from an object whose class did not declare it",      );    }    return kind === "m"      ? f      : kind === "a"      ? f.call(receiver)      : f      ? f.value      : state.get(receiver);  };var _NetworkEventManager_requestWillBeSentMap,  _NetworkEventManager_requestPausedMap,  _NetworkEventManager_httpRequestsMap,  _NetworkEventManager_responseReceivedExtraInfoMap,  _NetworkEventManager_queuedRedirectInfoMap,  _NetworkEventManager_queuedEventGroupMap;/** * Helper class to track network events by request ID * * @internal */export class NetworkEventManager {  constructor() {    /**     * There are four possible orders of events:     * A. `_onRequestWillBeSent`     * B. `_onRequestWillBeSent`, `_onRequestPaused`     * C. `_onRequestPaused`, `_onRequestWillBeSent`     * D. `_onRequestPaused`, `_onRequestWillBeSent`, `_onRequestPaused`,     * `_onRequestWillBeSent`, `_onRequestPaused`, `_onRequestPaused`     * (see crbug.com/1196004)     *     * For `_onRequest` we need the event from `_onRequestWillBeSent` and     * optionally the `interceptionId` from `_onRequestPaused`.     *     * If request interception is disabled, call `_onRequest` once per call to     * `_onRequestWillBeSent`.     * If request interception is enabled, call `_onRequest` once per call to     * `_onRequestPaused` (once per `interceptionId`).     *     * Events are stored to allow for subsequent events to call `_onRequest`.     *     * Note that (chains of) redirect requests have the same `requestId` (!) as     * the original request. We have to anticipate series of events like these:     * A. `_onRequestWillBeSent`,     * `_onRequestWillBeSent`, ...     * B. `_onRequestWillBeSent`, `_onRequestPaused`,     * `_onRequestWillBeSent`, `_onRequestPaused`, ...     * C. `_onRequestWillBeSent`, `_onRequestPaused`,     * `_onRequestPaused`, `_onRequestWillBeSent`, ...     * D. `_onRequestPaused`, `_onRequestWillBeSent`,     * `_onRequestPaused`, `_onRequestWillBeSent`, `_onRequestPaused`,     * `_onRequestWillBeSent`, `_onRequestPaused`, `_onRequestPaused`, ...     * (see crbug.com/1196004)     */    _NetworkEventManager_requestWillBeSentMap.set(this, new Map());    _NetworkEventManager_requestPausedMap.set(this, new Map());    _NetworkEventManager_httpRequestsMap.set(this, new Map());    /*         * The below maps are used to reconcile Network.responseReceivedExtraInfo         * events with their corresponding request. Each response and redirect         * response gets an ExtraInfo event, and we don't know which will come first.         * This means that we have to store a Response or an ExtraInfo for each         * response, and emit the event when we get both of them. In addition, to         * handle redirects, we have to make them Arrays to represent the chain of         * events.         */    _NetworkEventManager_responseReceivedExtraInfoMap.set(this, new Map());    _NetworkEventManager_queuedRedirectInfoMap.set(this, new Map());    _NetworkEventManager_queuedEventGroupMap.set(this, new Map());  }  forget(networkRequestId) {    __classPrivateFieldGet(this, _NetworkEventManager_requestWillBeSentMap, "f")      .delete(networkRequestId);    __classPrivateFieldGet(this, _NetworkEventManager_requestPausedMap, "f")      .delete(networkRequestId);    __classPrivateFieldGet(this, _NetworkEventManager_queuedEventGroupMap, "f")      .delete(networkRequestId);    __classPrivateFieldGet(      this,      _NetworkEventManager_queuedRedirectInfoMap,      "f",    ).delete(networkRequestId);    __classPrivateFieldGet(      this,      _NetworkEventManager_responseReceivedExtraInfoMap,      "f",    ).delete(networkRequestId);  }  responseExtraInfo(networkRequestId) {    if (      !__classPrivateFieldGet(        this,        _NetworkEventManager_responseReceivedExtraInfoMap,        "f",      ).has(networkRequestId)    ) {      __classPrivateFieldGet(        this,        _NetworkEventManager_responseReceivedExtraInfoMap,        "f",      ).set(networkRequestId, []);    }    return __classPrivateFieldGet(      this,      _NetworkEventManager_responseReceivedExtraInfoMap,      "f",    ).get(networkRequestId);  }  queuedRedirectInfo(fetchRequestId) {    if (      !__classPrivateFieldGet(        this,        _NetworkEventManager_queuedRedirectInfoMap,        "f",      ).has(fetchRequestId)    ) {      __classPrivateFieldGet(        this,        _NetworkEventManager_queuedRedirectInfoMap,        "f",      ).set(fetchRequestId, []);    }    return __classPrivateFieldGet(      this,      _NetworkEventManager_queuedRedirectInfoMap,      "f",    ).get(fetchRequestId);  }  queueRedirectInfo(fetchRequestId, redirectInfo) {    this.queuedRedirectInfo(fetchRequestId).push(redirectInfo);  }  takeQueuedRedirectInfo(fetchRequestId) {    return this.queuedRedirectInfo(fetchRequestId).shift();  }  numRequestsInProgress() {    return [      ...__classPrivateFieldGet(        this,        _NetworkEventManager_httpRequestsMap,        "f",      ),    ].filter(([, request]) => {      return !request.response();    }).length;  }  storeRequestWillBeSent(networkRequestId, event) {    __classPrivateFieldGet(this, _NetworkEventManager_requestWillBeSentMap, "f")      .set(networkRequestId, event);  }  getRequestWillBeSent(networkRequestId) {    return __classPrivateFieldGet(      this,      _NetworkEventManager_requestWillBeSentMap,      "f",    ).get(networkRequestId);  }  forgetRequestWillBeSent(networkRequestId) {    __classPrivateFieldGet(this, _NetworkEventManager_requestWillBeSentMap, "f")      .delete(networkRequestId);  }  getRequestPaused(networkRequestId) {    return __classPrivateFieldGet(      this,      _NetworkEventManager_requestPausedMap,      "f",    ).get(networkRequestId);  }  forgetRequestPaused(networkRequestId) {    __classPrivateFieldGet(this, _NetworkEventManager_requestPausedMap, "f")      .delete(networkRequestId);  }  storeRequestPaused(networkRequestId, event) {    __classPrivateFieldGet(this, _NetworkEventManager_requestPausedMap, "f")      .set(networkRequestId, event);  }  getRequest(networkRequestId) {    return __classPrivateFieldGet(      this,      _NetworkEventManager_httpRequestsMap,      "f",    ).get(networkRequestId);  }  storeRequest(networkRequestId, request) {    __classPrivateFieldGet(this, _NetworkEventManager_httpRequestsMap, "f").set(      networkRequestId,      request,    );  }  forgetRequest(networkRequestId) {    __classPrivateFieldGet(this, _NetworkEventManager_httpRequestsMap, "f")      .delete(networkRequestId);  }  getQueuedEventGroup(networkRequestId) {    return __classPrivateFieldGet(      this,      _NetworkEventManager_queuedEventGroupMap,      "f",    ).get(networkRequestId);  }  queueEventGroup(networkRequestId, event) {    __classPrivateFieldGet(this, _NetworkEventManager_queuedEventGroupMap, "f")      .set(networkRequestId, event);  }  forgetQueuedEventGroup(networkRequestId) {    __classPrivateFieldGet(this, _NetworkEventManager_queuedEventGroupMap, "f")      .delete(networkRequestId);  }}_NetworkEventManager_requestWillBeSentMap = new WeakMap(),  _NetworkEventManager_requestPausedMap = new WeakMap(),  _NetworkEventManager_httpRequestsMap = new WeakMap(),  _NetworkEventManager_responseReceivedExtraInfoMap = new WeakMap(),  _NetworkEventManager_queuedRedirectInfoMap = new WeakMap(),  _NetworkEventManager_queuedEventGroupMap = new WeakMap();//# sourceMappingURL=NetworkEventManager.js.map