/** * Copyright (c) Microsoft Corporation. * * 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. */ import debug from 'debug'; import * as playwright from 'playwright'; import { logUnhandledError } from './log.js'; import { Tab } from './tab.js'; import { EnvironmentIntrospector } from './environmentIntrospection.js'; import type { Tool } from './tools/tool.js'; import type { FullConfig } from './config.js'; import type { BrowserContextFactory } from './browserContextFactory.js'; const testDebug = debug('pw:mcp:test'); export class Context { readonly tools: Tool[]; readonly config: FullConfig; private _browserContextPromise: Promise<{ browserContext: playwright.BrowserContext, close: () => Promise }> | undefined; private _browserContextFactory: BrowserContextFactory; private _tabs: Tab[] = []; private _currentTab: Tab | undefined; clientVersion: { name: string; version: string; } | undefined; private _videoRecordingConfig: { dir: string; size?: { width: number; height: number } } | undefined; private _videoBaseFilename: string | undefined; private _activePagesWithVideos: Set = new Set(); private _environmentIntrospector: EnvironmentIntrospector; private static _allContexts: Set = new Set(); private _closeBrowserContextPromise: Promise | undefined; // Session isolation properties readonly sessionId: string; private _sessionStartTime: number; constructor(tools: Tool[], config: FullConfig, browserContextFactory: BrowserContextFactory, environmentIntrospector?: EnvironmentIntrospector) { this.tools = tools; this.config = config; this._browserContextFactory = browserContextFactory; this._environmentIntrospector = environmentIntrospector || new EnvironmentIntrospector(); // Generate unique session ID this._sessionStartTime = Date.now(); this.sessionId = this._generateSessionId(); testDebug(`create context with sessionId: ${this.sessionId}`); Context._allContexts.add(this); } static async disposeAll() { await Promise.all([...Context._allContexts].map(context => context.dispose())); } private _generateSessionId(): string { // Create a base session ID from timestamp and random const baseId = `${this._sessionStartTime}-${Math.random().toString(36).substr(2, 9)}`; // If we have client version info, incorporate it if (this.clientVersion) { const clientInfo = `${this.clientVersion.name || 'unknown'}-${this.clientVersion.version || 'unknown'}`; return `${clientInfo}-${baseId}`; } return baseId; } updateSessionIdWithClientInfo() { if (this.clientVersion) { const newSessionId = this._generateSessionId(); testDebug(`updating sessionId from ${this.sessionId} to ${newSessionId}`); // Note: sessionId is readonly, but we can update it during initialization (this as any).sessionId = newSessionId; } } tabs(): Tab[] { return this._tabs; } currentTab(): Tab | undefined { return this._currentTab; } currentTabOrDie(): Tab { if (!this._currentTab) throw new Error('No open pages available. Use the "browser_navigate" tool to navigate to a page first.'); return this._currentTab; } async newTab(): Promise { const { browserContext } = await this._ensureBrowserContext(); const page = await browserContext.newPage(); this._currentTab = this._tabs.find(t => t.page === page)!; return this._currentTab; } async selectTab(index: number) { const tab = this._tabs[index]; if (!tab) throw new Error(`Tab ${index} not found`); await tab.page.bringToFront(); this._currentTab = tab; return tab; } async ensureTab(): Promise { const { browserContext } = await this._ensureBrowserContext(); if (!this._currentTab) await browserContext.newPage(); return this._currentTab!; } async listTabsMarkdown(force: boolean = false): Promise { if (this._tabs.length === 1 && !force) return []; if (!this._tabs.length) { return [ '### No open tabs', 'Use the "browser_navigate" tool to navigate to a page first.', '', ]; } const lines: string[] = ['### Open tabs']; for (let i = 0; i < this._tabs.length; i++) { const tab = this._tabs[i]; const title = await tab.title(); const url = tab.page.url(); const current = tab === this._currentTab ? ' (current)' : ''; lines.push(`- ${i}:${current} [${title}] (${url})`); } lines.push(''); return lines; } async closeTab(index: number | undefined): Promise { const tab = index === undefined ? this._currentTab : this._tabs[index]; if (!tab) throw new Error(`Tab ${index} not found`); const url = tab.page.url(); await tab.page.close(); return url; } private _onPageCreated(page: playwright.Page) { const tab = new Tab(this, page, tab => this._onPageClosed(tab)); this._tabs.push(tab); if (!this._currentTab) this._currentTab = tab; // Track pages with video recording if (this._videoRecordingConfig && page.video()) this._activePagesWithVideos.add(page); } private _onPageClosed(tab: Tab) { const index = this._tabs.indexOf(tab); if (index === -1) return; this._tabs.splice(index, 1); if (this._currentTab === tab) this._currentTab = this._tabs[Math.min(index, this._tabs.length - 1)]; if (!this._tabs.length) void this.closeBrowserContext(); } async closeBrowserContext() { if (!this._closeBrowserContextPromise) this._closeBrowserContextPromise = this._closeBrowserContextImpl().catch(logUnhandledError); await this._closeBrowserContextPromise; this._closeBrowserContextPromise = undefined; } private async _closeBrowserContextImpl() { if (!this._browserContextPromise) return; testDebug('close context'); const promise = this._browserContextPromise; this._browserContextPromise = undefined; await promise.then(async ({ browserContext, close }) => { if (this.config.saveTrace) await browserContext.tracing.stop(); await close(); }); } async dispose() { await this.closeBrowserContext(); Context._allContexts.delete(this); } private async _setupRequestInterception(context: playwright.BrowserContext) { if (this.config.network?.allowedOrigins?.length) { await context.route('**', route => route.abort('blockedbyclient')); for (const origin of this.config.network.allowedOrigins) await context.route(`*://${origin}/**`, route => route.continue()); } if (this.config.network?.blockedOrigins?.length) { for (const origin of this.config.network.blockedOrigins) await context.route(`*://${origin}/**`, route => route.abort('blockedbyclient')); } } private _ensureBrowserContext() { if (!this._browserContextPromise) { this._browserContextPromise = this._setupBrowserContext(); this._browserContextPromise.catch(() => { this._browserContextPromise = undefined; }); } return this._browserContextPromise; } private async _setupBrowserContext(): Promise<{ browserContext: playwright.BrowserContext, close: () => Promise }> { if (this._closeBrowserContextPromise) throw new Error('Another browser context is being closed.'); let result: { browserContext: playwright.BrowserContext, close: () => Promise }; if (this._videoRecordingConfig) { // Create a new browser context with video recording enabled result = await this._createVideoEnabledContext(); } else { // Use session-aware browser context factory result = await this._createSessionIsolatedContext(); } const { browserContext } = result; await this._setupRequestInterception(browserContext); for (const page of browserContext.pages()) this._onPageCreated(page); browserContext.on('page', page => this._onPageCreated(page)); if (this.config.saveTrace) { await browserContext.tracing.start({ name: 'trace', screenshots: false, snapshots: true, sources: false, }); } return result; } private async _createVideoEnabledContext(): Promise<{ browserContext: playwright.BrowserContext, close: () => Promise }> { // For video recording, we need to create an isolated context const browserType = playwright[this.config.browser.browserName]; // Get environment-specific browser options const envOptions = this._environmentIntrospector.getRecommendedBrowserOptions(); const browser = await browserType.launch({ ...this.config.browser.launchOptions, ...envOptions, // Include environment-detected options handleSIGINT: false, handleSIGTERM: false, }); // Use environment-specific video directory if available const videoConfig = envOptions.recordVideo ? { ...this._videoRecordingConfig, dir: envOptions.recordVideo.dir } : this._videoRecordingConfig; const contextOptions = { ...this.config.browser.contextOptions, recordVideo: videoConfig, // Force isolated session for video recording with session-specific storage storageState: undefined, // Always start fresh for video recording }; const browserContext = await browser.newContext(contextOptions); return { browserContext, close: async () => { await browserContext.close(); await browser.close(); } }; } private async _createSessionIsolatedContext(): Promise<{ browserContext: playwright.BrowserContext, close: () => Promise }> { // Always create isolated browser contexts for each MCP client // This ensures complete session isolation between different clients const browserType = playwright[this.config.browser.browserName]; // Get environment-specific browser options const envOptions = this._environmentIntrospector.getRecommendedBrowserOptions(); const browser = await browserType.launch({ ...this.config.browser.launchOptions, ...envOptions, // Include environment-detected options handleSIGINT: false, handleSIGTERM: false, }); // Create isolated context options with session-specific storage const contextOptions = { ...this.config.browser.contextOptions, // Each session gets its own isolated storage - no shared state storageState: undefined, }; const browserContext = await browser.newContext(contextOptions); testDebug(`created isolated browser context for session: ${this.sessionId}`); return { browserContext, close: async () => { testDebug(`closing isolated browser context for session: ${this.sessionId}`); await browserContext.close(); await browser.close(); } }; } setVideoRecording(config: { dir: string; size?: { width: number; height: number } }, baseFilename: string) { this._videoRecordingConfig = config; this._videoBaseFilename = baseFilename; // Force recreation of browser context to include video recording if (this._browserContextPromise) { void this.closeBrowserContext().then(() => { // The next call to _ensureBrowserContext will create a new context with video recording }); } } getVideoRecordingInfo() { return { enabled: !!this._videoRecordingConfig, config: this._videoRecordingConfig, baseFilename: this._videoBaseFilename, activeRecordings: this._activePagesWithVideos.size, }; } updateEnvironmentRoots(roots: { uri: string; name?: string }[]) { this._environmentIntrospector.updateRoots(roots); // Log environment change const summary = this._environmentIntrospector.getEnvironmentSummary(); testDebug(`environment updated for session ${this.sessionId}: ${summary}`); // If we have an active browser context, we might want to recreate it // For now, we'll just log the change - full recreation would close existing tabs if (this._browserContextPromise) testDebug(`browser context exists - environment changes will apply to new contexts`); } getEnvironmentIntrospector(): EnvironmentIntrospector { return this._environmentIntrospector; } async updateBrowserConfig(changes: { headless?: boolean; viewport?: { width: number; height: number }; userAgent?: string; }): Promise { const currentConfig = { ...this.config }; // Update the configuration if (changes.headless !== undefined) { currentConfig.browser.launchOptions.headless = changes.headless; } if (changes.viewport) { currentConfig.browser.contextOptions.viewport = changes.viewport; } if (changes.userAgent) { currentConfig.browser.contextOptions.userAgent = changes.userAgent; } // Store the modified config (this as any).config = currentConfig; // Close the current browser context to force recreation with new settings await this.closeBrowserContext(); // Clear tabs since they're attached to the old context this._tabs = []; this._currentTab = undefined; testDebug(`browser config updated for session ${this.sessionId}: headless=${currentConfig.browser.launchOptions.headless}, viewport=${JSON.stringify(currentConfig.browser.contextOptions.viewport)}`); } async stopVideoRecording(): Promise { if (!this._videoRecordingConfig) return []; const videoPaths: string[] = []; // Close all pages to save videos for (const page of this._activePagesWithVideos) { try { if (!page.isClosed()) { await page.close(); const video = page.video(); if (video) { const videoPath = await video.path(); videoPaths.push(videoPath); } } } catch (error) { testDebug('Error closing page for video recording:', error); } } this._activePagesWithVideos.clear(); this._videoRecordingConfig = undefined; this._videoBaseFilename = undefined; return videoPaths; } }