/** * @license * Copyright 2022 Google Inc. * SPDX-License-Identifier: Apache-2.0 */ import mitt, {type Emitter} from '../../third_party/mitt/mitt.js'; import {disposeSymbol} from '../util/disposable.js'; /** * @public */ export type EventType = string | symbol; /** * @public */ export type Handler = (event: T) => void; /** * @public */ export interface CommonEventEmitter> { on(type: Key, handler: Handler): this; off( type: Key, handler?: Handler ): this; emit(type: Key, event: Events[Key]): boolean; once( type: Key, handler: Handler ): this; listenerCount(event: keyof Events): number; removeAllListeners(event?: keyof Events): this; } /** * @public */ export type EventsWithWildcard> = Events & { '*': Events[keyof Events]; }; /** * The EventEmitter class that many Puppeteer classes extend. * * @remarks * * This allows you to listen to events that Puppeteer classes fire and act * accordingly. Therefore you'll mostly use {@link EventEmitter.on | on} and * {@link EventEmitter.off | off} to bind * and unbind to event listeners. * * @public */ export class EventEmitter> implements CommonEventEmitter> { #emitter: Emitter> | EventEmitter; #handlers = new Map>>(); /** * If you pass an emitter, the returned emitter will wrap the passed emitter. * * @internal */ constructor( emitter: Emitter> | EventEmitter = mitt( new Map() ) ) { this.#emitter = emitter; } /** * Bind an event listener to fire when an event occurs. * @param type - the event type you'd like to listen to. Can be a string or symbol. * @param handler - the function to be called when the event occurs. * @returns `this` to enable you to chain method calls. */ on>( type: Key, handler: Handler[Key]> ): this { const handlers = this.#handlers.get(type); if (handlers === undefined) { this.#handlers.set(type, [handler]); } else { handlers.push(handler); } this.#emitter.on(type, handler); return this; } /** * Remove an event listener from firing. * @param type - the event type you'd like to stop listening to. * @param handler - the function that should be removed. * @returns `this` to enable you to chain method calls. */ off>( type: Key, handler?: Handler[Key]> ): this { const handlers = this.#handlers.get(type) ?? []; if (handler === undefined) { for (const handler of handlers) { this.#emitter.off(type, handler); } this.#handlers.delete(type); return this; } const index = handlers.lastIndexOf(handler); if (index > -1) { this.#emitter.off(type, ...handlers.splice(index, 1)); } return this; } /** * Emit an event and call any associated listeners. * * @param type - the event you'd like to emit * @param eventData - any data you'd like to emit with the event * @returns `true` if there are any listeners, `false` if there are not. */ emit>( type: Key, event: EventsWithWildcard[Key] ): boolean { this.#emitter.emit(type, event); return this.listenerCount(type) > 0; } /** * Like `on` but the listener will only be fired once and then it will be removed. * @param type - the event you'd like to listen to * @param handler - the handler function to run when the event occurs * @returns `this` to enable you to chain method calls. */ once>( type: Key, handler: Handler[Key]> ): this { const onceHandler: Handler[Key]> = eventData => { handler(eventData); this.off(type, onceHandler); }; return this.on(type, onceHandler); } /** * Gets the number of listeners for a given event. * * @param type - the event to get the listener count for * @returns the number of listeners bound to the given event */ listenerCount(type: keyof EventsWithWildcard): number { return this.#handlers.get(type)?.length || 0; } /** * Removes all listeners. If given an event argument, it will remove only * listeners for that event. * * @param type - the event to remove listeners for. * @returns `this` to enable you to chain method calls. */ removeAllListeners(type?: keyof EventsWithWildcard): this { if (type !== undefined) { return this.off(type); } this[disposeSymbol](); return this; } /** * @internal */ [disposeSymbol](): void { for (const [type, handlers] of this.#handlers) { for (const handler of handlers) { this.#emitter.off(type, handler); } } this.#handlers.clear(); } } /** * @internal */ export class EventSubscription< Target extends CommonEventEmitter>, Type extends EventType = EventType, Event = unknown, > { #target: Target; #type: Type; #handler: Handler; constructor(target: Target, type: Type, handler: Handler) { this.#target = target; this.#type = type; this.#handler = handler; this.#target.on(this.#type, this.#handler); } [disposeSymbol](): void { this.#target.off(this.#type, this.#handler); } }