Module
x/puppeteer/vendor/puppeteer-core/puppeteer/common/ChromeTargetManager.js
A port of puppeteer running on Deno
Very Popular
Latest
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808/// <reference types="./ChromeTargetManager.d.ts" />/** * Copyright 2022 Google Inc. All rights reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */var __classPrivateFieldSet = (this && this.__classPrivateFieldSet) || function (receiver, state, value, kind, f) { if (kind === "m") throw new TypeError("Private method is not writable"); if (kind === "a" && !f) { throw new TypeError("Private accessor was defined without a setter"); } if ( typeof state === "function" ? receiver !== state || !f : !state.has(receiver) ) { throw new TypeError( "Cannot write private member to an object whose class did not declare it", ); } return (kind === "a" ? f.call(receiver, value) : f ? f.value = value : state.set(receiver, value)), value; };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 _ChromeTargetManager_instances, _ChromeTargetManager_connection, _ChromeTargetManager_discoveredTargetsByTargetId, _ChromeTargetManager_attachedTargetsByTargetId, _ChromeTargetManager_attachedTargetsBySessionId, _ChromeTargetManager_ignoredTargets, _ChromeTargetManager_targetFilterCallback, _ChromeTargetManager_targetFactory, _ChromeTargetManager_targetInterceptors, _ChromeTargetManager_attachedToTargetListenersBySession, _ChromeTargetManager_detachedFromTargetListenersBySession, _ChromeTargetManager_initializeCallback, _ChromeTargetManager_initializePromise, _ChromeTargetManager_targetsIdsForInit, _ChromeTargetManager_storeExistingTargetsForInit, _ChromeTargetManager_setupAttachmentListeners, _ChromeTargetManager_removeAttachmentListeners, _ChromeTargetManager_onSessionDetached, _ChromeTargetManager_onTargetCreated, _ChromeTargetManager_onTargetDestroyed, _ChromeTargetManager_onTargetInfoChanged, _ChromeTargetManager_onAttachedToTarget, _ChromeTargetManager_finishInitializationIfReady, _ChromeTargetManager_onDetachedFromTarget;import { assert } from "../util/assert.js";import { Connection } from "./Connection.js";import { EventEmitter } from "./EventEmitter.js";import { debugError } from "./util.js";/** * ChromeTargetManager uses the CDP's auto-attach mechanism to intercept * new targets and allow the rest of Puppeteer to configure listeners while * the target is paused. * * @internal */export class ChromeTargetManager extends EventEmitter { constructor(connection, targetFactory, targetFilterCallback) { super(); _ChromeTargetManager_instances.add(this); _ChromeTargetManager_connection.set(this, void 0); /** * Keeps track of the following events: 'Target.targetCreated', * 'Target.targetDestroyed', 'Target.targetInfoChanged'. * * A target becomes discovered when 'Target.targetCreated' is received. * A target is removed from this map once 'Target.targetDestroyed' is * received. * * `targetFilterCallback` has no effect on this map. */ _ChromeTargetManager_discoveredTargetsByTargetId.set(this, new Map()); /** * A target is added to this map once ChromeTargetManager has created * a Target and attached at least once to it. */ _ChromeTargetManager_attachedTargetsByTargetId.set(this, new Map()); /** * Tracks which sessions attach to which target. */ _ChromeTargetManager_attachedTargetsBySessionId.set(this, new Map()); /** * If a target was filtered out by `targetFilterCallback`, we still receive * events about it from CDP, but we don't forward them to the rest of Puppeteer. */ _ChromeTargetManager_ignoredTargets.set(this, new Set()); _ChromeTargetManager_targetFilterCallback.set(this, void 0); _ChromeTargetManager_targetFactory.set(this, void 0); _ChromeTargetManager_targetInterceptors.set(this, new WeakMap()); _ChromeTargetManager_attachedToTargetListenersBySession.set( this, new WeakMap(), ); _ChromeTargetManager_detachedFromTargetListenersBySession.set( this, new WeakMap(), ); _ChromeTargetManager_initializeCallback.set(this, () => {}); _ChromeTargetManager_initializePromise.set( this, new Promise((resolve) => { __classPrivateFieldSet( this, _ChromeTargetManager_initializeCallback, resolve, "f", ); }), ); _ChromeTargetManager_targetsIdsForInit.set(this, new Set()); _ChromeTargetManager_storeExistingTargetsForInit.set(this, () => { for ( const [targetId, targetInfo] of __classPrivateFieldGet( this, _ChromeTargetManager_discoveredTargetsByTargetId, "f", ).entries() ) { if ( (!__classPrivateFieldGet( this, _ChromeTargetManager_targetFilterCallback, "f", ) || __classPrivateFieldGet( this, _ChromeTargetManager_targetFilterCallback, "f", ).call(this, targetInfo)) && targetInfo.type !== "browser" ) { __classPrivateFieldGet( this, _ChromeTargetManager_targetsIdsForInit, "f", ).add(targetId); } } }); _ChromeTargetManager_onSessionDetached.set(this, (session) => { __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_removeAttachmentListeners, ).call(this, session); __classPrivateFieldGet(this, _ChromeTargetManager_targetInterceptors, "f") .delete(session); }); _ChromeTargetManager_onTargetCreated.set(this, async (event) => { __classPrivateFieldGet( this, _ChromeTargetManager_discoveredTargetsByTargetId, "f", ).set(event.targetInfo.targetId, event.targetInfo); this.emit( "targetDiscovered", /* TargetManagerEmittedEvents.TargetDiscovered */ event.targetInfo, ); // The connection is already attached to the browser target implicitly, // therefore, no new CDPSession is created and we have special handling // here. if (event.targetInfo.type === "browser" && event.targetInfo.attached) { if ( __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).has(event.targetInfo.targetId) ) { return; } const target = __classPrivateFieldGet( this, _ChromeTargetManager_targetFactory, "f", ).call(this, event.targetInfo, undefined); __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).set(event.targetInfo.targetId, target); } if (event.targetInfo.type === "shared_worker") { // Special case (https://crbug.com/1338156): currently, shared_workers // don't get auto-attached. This should be removed once the auto-attach // works. await __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f") ._createSession(event.targetInfo, true); } }); _ChromeTargetManager_onTargetDestroyed.set(this, (event) => { const targetInfo = __classPrivateFieldGet( this, _ChromeTargetManager_discoveredTargetsByTargetId, "f", ).get(event.targetId); __classPrivateFieldGet( this, _ChromeTargetManager_discoveredTargetsByTargetId, "f", ).delete(event.targetId); __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_finishInitializationIfReady, ).call(this, event.targetId); if ( (targetInfo === null || targetInfo === void 0 ? void 0 : targetInfo.type) === "service_worker" && __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).has(event.targetId) ) { // Special case for service workers: report TargetGone event when // the worker is destroyed. const target = __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).get(event.targetId); this.emit( "targetGone", /* TargetManagerEmittedEvents.TargetGone */ target, ); __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).delete(event.targetId); } }); _ChromeTargetManager_onTargetInfoChanged.set(this, (event) => { __classPrivateFieldGet( this, _ChromeTargetManager_discoveredTargetsByTargetId, "f", ).set(event.targetInfo.targetId, event.targetInfo); if ( __classPrivateFieldGet(this, _ChromeTargetManager_ignoredTargets, "f") .has(event.targetInfo.targetId) || !__classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).has(event.targetInfo.targetId) || !event.targetInfo.attached ) { return; } const target = __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).get(event.targetInfo.targetId); this.emit( "targetChanged", /* TargetManagerEmittedEvents.TargetChanged */ { target: target, targetInfo: event.targetInfo, }, ); }); _ChromeTargetManager_onAttachedToTarget.set( this, async (parentSession, event) => { const targetInfo = event.targetInfo; const session = __classPrivateFieldGet( this, _ChromeTargetManager_connection, "f", ).session(event.sessionId); if (!session) { throw new Error(`Session ${event.sessionId} was not created.`); } const silentDetach = async () => { await session.send("Runtime.runIfWaitingForDebugger").catch( debugError, ); // We don't use `session.detach()` because that dispatches all commands on // the connection instead of the parent session. await parentSession .send("Target.detachFromTarget", { sessionId: session.id(), }) .catch(debugError); }; if ( !__classPrivateFieldGet(this, _ChromeTargetManager_connection, "f") .isAutoAttached(targetInfo.targetId) ) { return; } // Special case for service workers: being attached to service workers will // prevent them from ever being destroyed. Therefore, we silently detach // from service workers unless the connection was manually created via // `page.worker()`. To determine this, we use // `this.#connection.isAutoAttached(targetInfo.targetId)`. In the future, we // should determine if a target is auto-attached or not with the help of // CDP. if ( targetInfo.type === "service_worker" && __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f") .isAutoAttached(targetInfo.targetId) ) { __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_finishInitializationIfReady, ).call(this, targetInfo.targetId); await silentDetach(); if ( __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).has(targetInfo.targetId) ) { return; } const target = __classPrivateFieldGet( this, _ChromeTargetManager_targetFactory, "f", ).call(this, targetInfo); __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).set(targetInfo.targetId, target); this.emit( "targetAvailable", /* TargetManagerEmittedEvents.TargetAvailable */ target, ); return; } if ( __classPrivateFieldGet( this, _ChromeTargetManager_targetFilterCallback, "f", ) && !__classPrivateFieldGet( this, _ChromeTargetManager_targetFilterCallback, "f", ).call(this, targetInfo) ) { __classPrivateFieldGet(this, _ChromeTargetManager_ignoredTargets, "f") .add(targetInfo.targetId); __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_finishInitializationIfReady, ).call(this, targetInfo.targetId); await silentDetach(); return; } const existingTarget = __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).has(targetInfo.targetId); const target = existingTarget ? __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).get(targetInfo.targetId) : __classPrivateFieldGet( this, _ChromeTargetManager_targetFactory, "f", ).call(this, targetInfo, session); __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_setupAttachmentListeners, ).call(this, session); if (existingTarget) { __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsBySessionId, "f", ).set( session.id(), __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).get(targetInfo.targetId), ); } else { __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).set(targetInfo.targetId, target); __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsBySessionId, "f", ).set(session.id(), target); } for ( const interceptor of __classPrivateFieldGet( this, _ChromeTargetManager_targetInterceptors, "f", ).get(parentSession) || [] ) { if (!(parentSession instanceof Connection)) { // Sanity check: if parent session is not a connection, it should be // present in #attachedTargetsBySessionId. assert( __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsBySessionId, "f", ).has(parentSession.id()), ); } await interceptor( target, parentSession instanceof Connection ? null : __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsBySessionId, "f", ).get(parentSession.id()), ); } __classPrivateFieldGet( this, _ChromeTargetManager_targetsIdsForInit, "f", ).delete(target._targetId); if (!existingTarget) { this.emit( "targetAvailable", /* TargetManagerEmittedEvents.TargetAvailable */ target, ); } __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_finishInitializationIfReady, ).call(this); // TODO: the browser might be shutting down here. What do we do with the // error? await Promise.all([ session.send("Target.setAutoAttach", { waitForDebuggerOnStart: true, flatten: true, autoAttach: true, }), session.send("Runtime.runIfWaitingForDebugger"), ]).catch(debugError); }, ); _ChromeTargetManager_onDetachedFromTarget.set( this, (_parentSession, event) => { const target = __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsBySessionId, "f", ).get(event.sessionId); __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsBySessionId, "f", ).delete(event.sessionId); if (!target) { return; } __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ).delete(target._targetId); this.emit( "targetGone", /* TargetManagerEmittedEvents.TargetGone */ target, ); }, ); __classPrivateFieldSet( this, _ChromeTargetManager_connection, connection, "f", ); __classPrivateFieldSet( this, _ChromeTargetManager_targetFilterCallback, targetFilterCallback, "f", ); __classPrivateFieldSet( this, _ChromeTargetManager_targetFactory, targetFactory, "f", ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").on( "Target.targetCreated", __classPrivateFieldGet(this, _ChromeTargetManager_onTargetCreated, "f"), ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").on( "Target.targetDestroyed", __classPrivateFieldGet(this, _ChromeTargetManager_onTargetDestroyed, "f"), ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").on( "Target.targetInfoChanged", __classPrivateFieldGet( this, _ChromeTargetManager_onTargetInfoChanged, "f", ), ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").on( "sessiondetached", __classPrivateFieldGet(this, _ChromeTargetManager_onSessionDetached, "f"), ); __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_setupAttachmentListeners, ).call( this, __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f"), ); // TODO: remove `as any` once the protocol definitions are updated with the // next Chromium roll. __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f") .send("Target.setDiscoverTargets", { discover: true, filter: [{ type: "tab", exclude: true }, {}], }) .then( __classPrivateFieldGet( this, _ChromeTargetManager_storeExistingTargetsForInit, "f", ), ) .catch(debugError); } async initialize() { await __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f") .send("Target.setAutoAttach", { waitForDebuggerOnStart: true, flatten: true, autoAttach: true, }); __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_finishInitializationIfReady, ).call(this); await __classPrivateFieldGet( this, _ChromeTargetManager_initializePromise, "f", ); } dispose() { __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").off( "Target.targetCreated", __classPrivateFieldGet(this, _ChromeTargetManager_onTargetCreated, "f"), ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").off( "Target.targetDestroyed", __classPrivateFieldGet(this, _ChromeTargetManager_onTargetDestroyed, "f"), ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").off( "Target.targetInfoChanged", __classPrivateFieldGet( this, _ChromeTargetManager_onTargetInfoChanged, "f", ), ); __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f").off( "sessiondetached", __classPrivateFieldGet(this, _ChromeTargetManager_onSessionDetached, "f"), ); __classPrivateFieldGet( this, _ChromeTargetManager_instances, "m", _ChromeTargetManager_removeAttachmentListeners, ).call( this, __classPrivateFieldGet(this, _ChromeTargetManager_connection, "f"), ); } getAvailableTargets() { return __classPrivateFieldGet( this, _ChromeTargetManager_attachedTargetsByTargetId, "f", ); } addTargetInterceptor(session, interceptor) { const interceptors = __classPrivateFieldGet(this, _ChromeTargetManager_targetInterceptors, "f") .get(session) || []; interceptors.push(interceptor); __classPrivateFieldGet(this, _ChromeTargetManager_targetInterceptors, "f") .set(session, interceptors); } removeTargetInterceptor(client, interceptor) { const interceptors = __classPrivateFieldGet(this, _ChromeTargetManager_targetInterceptors, "f") .get(client) || []; __classPrivateFieldGet(this, _ChromeTargetManager_targetInterceptors, "f") .set( client, interceptors.filter((currentInterceptor) => { return currentInterceptor !== interceptor; }), ); }}_ChromeTargetManager_connection = new WeakMap(), _ChromeTargetManager_discoveredTargetsByTargetId = new WeakMap(), _ChromeTargetManager_attachedTargetsByTargetId = new WeakMap(), _ChromeTargetManager_attachedTargetsBySessionId = new WeakMap(), _ChromeTargetManager_ignoredTargets = new WeakMap(), _ChromeTargetManager_targetFilterCallback = new WeakMap(), _ChromeTargetManager_targetFactory = new WeakMap(), _ChromeTargetManager_targetInterceptors = new WeakMap(), _ChromeTargetManager_attachedToTargetListenersBySession = new WeakMap(), _ChromeTargetManager_detachedFromTargetListenersBySession = new WeakMap(), _ChromeTargetManager_initializeCallback = new WeakMap(), _ChromeTargetManager_initializePromise = new WeakMap(), _ChromeTargetManager_targetsIdsForInit = new WeakMap(), _ChromeTargetManager_storeExistingTargetsForInit = new WeakMap(), _ChromeTargetManager_onSessionDetached = new WeakMap(), _ChromeTargetManager_onTargetCreated = new WeakMap(), _ChromeTargetManager_onTargetDestroyed = new WeakMap(), _ChromeTargetManager_onTargetInfoChanged = new WeakMap(), _ChromeTargetManager_onAttachedToTarget = new WeakMap(), _ChromeTargetManager_onDetachedFromTarget = new WeakMap(), _ChromeTargetManager_instances = new WeakSet(), _ChromeTargetManager_setupAttachmentListeners = function _ChromeTargetManager_setupAttachmentListeners(session) { const listener = (event) => { return __classPrivateFieldGet( this, _ChromeTargetManager_onAttachedToTarget, "f", ).call(this, session, event); }; assert( !__classPrivateFieldGet( this, _ChromeTargetManager_attachedToTargetListenersBySession, "f", ).has(session), ); __classPrivateFieldGet( this, _ChromeTargetManager_attachedToTargetListenersBySession, "f", ).set(session, listener); session.on("Target.attachedToTarget", listener); const detachedListener = (event) => { return __classPrivateFieldGet( this, _ChromeTargetManager_onDetachedFromTarget, "f", ).call(this, session, event); }; assert( !__classPrivateFieldGet( this, _ChromeTargetManager_detachedFromTargetListenersBySession, "f", ).has(session), ); __classPrivateFieldGet( this, _ChromeTargetManager_detachedFromTargetListenersBySession, "f", ).set(session, detachedListener); session.on("Target.detachedFromTarget", detachedListener); }, _ChromeTargetManager_removeAttachmentListeners = function _ChromeTargetManager_removeAttachmentListeners(session) { if ( __classPrivateFieldGet( this, _ChromeTargetManager_attachedToTargetListenersBySession, "f", ).has(session) ) { session.off( "Target.attachedToTarget", __classPrivateFieldGet( this, _ChromeTargetManager_attachedToTargetListenersBySession, "f", ).get(session), ); __classPrivateFieldGet( this, _ChromeTargetManager_attachedToTargetListenersBySession, "f", ).delete(session); } if ( __classPrivateFieldGet( this, _ChromeTargetManager_detachedFromTargetListenersBySession, "f", ).has(session) ) { session.off( "Target.detachedFromTarget", __classPrivateFieldGet( this, _ChromeTargetManager_detachedFromTargetListenersBySession, "f", ).get(session), ); __classPrivateFieldGet( this, _ChromeTargetManager_detachedFromTargetListenersBySession, "f", ).delete(session); } }, _ChromeTargetManager_finishInitializationIfReady = function _ChromeTargetManager_finishInitializationIfReady(targetId) { targetId !== undefined && __classPrivateFieldGet( this, _ChromeTargetManager_targetsIdsForInit, "f", ).delete(targetId); if ( __classPrivateFieldGet( this, _ChromeTargetManager_targetsIdsForInit, "f", ).size === 0 ) { __classPrivateFieldGet( this, _ChromeTargetManager_initializeCallback, "f", ).call(this); } };//# sourceMappingURL=ChromeTargetManager.js.map