/** * Copyright 2017 Google Inc. All rights reserved. * Modifications 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 * as childProcess from 'child_process'; import { debugError, helper } from '../helper'; import { Browser } from './Browser'; import { BrowserFetcher } from './BrowserFetcher'; import { Connection } from './Connection'; import { Viewport } from './Page'; import { PipeTransport } from './PipeTransport'; const DEFAULT_ARGS = [ ]; export class Launcher { private _projectRoot: string; private _preferredRevision: string; constructor(projectRoot: string, preferredRevision: string) { this._projectRoot = projectRoot; this._preferredRevision = preferredRevision; } defaultArgs(options: any = {}) { const { args = [], } = options; const webkitArguments = [...DEFAULT_ARGS]; webkitArguments.push(...args); return webkitArguments; } async launch(options: LauncherLaunchOptions = {}): Promise { const { ignoreDefaultArgs = false, args = [], dumpio = false, executablePath = null, env = process.env, handleSIGINT = true, handleSIGTERM = true, handleSIGHUP = true, defaultViewport = {width: 800, height: 600}, slowMo = 0 } = options; const webkitArguments = []; if (!ignoreDefaultArgs) webkitArguments.push(...this.defaultArgs(options)); else webkitArguments.push(...args); let webkitExecutable = executablePath; if (!executablePath) { const {missingText, executablePath} = this._resolveExecutablePath(); if (missingText) throw new Error(missingText); webkitExecutable = executablePath; } let stdio: ('ignore' | 'pipe')[] = ['pipe', 'pipe', 'pipe']; if (dumpio) stdio = ['ignore', 'pipe', 'pipe', 'pipe', 'pipe']; else stdio = ['ignore', 'ignore', 'ignore', 'pipe', 'pipe']; webkitArguments.push('--inspector-pipe'); // Headless options is only implemented on Mac at the moment. if (process.platform === 'darwin' && options.headless !== false) webkitArguments.push('--headless'); const webkitProcess = childProcess.spawn( webkitExecutable, webkitArguments, { // On non-windows platforms, `detached: true` makes child process a leader of a new // process group, making it possible to kill child process tree with `.kill(-pid)` command. // @see https://nodejs.org/api/child_process.html#child_process_options_detached detached: process.platform !== 'win32', env, stdio } ); if (!webkitProcess.pid) { let reject; const result = new Promise((f, r) => reject = r); webkitProcess.once('error', error => { reject(new Error('Failed to launch browser: ' + error)); }); return result as Promise; } if (dumpio) { webkitProcess.stderr.pipe(process.stderr); webkitProcess.stdout.pipe(process.stdout); } let webkitClosed = false; const waitForChromeToClose = new Promise((fulfill, reject) => { webkitProcess.once('exit', () => { webkitClosed = true; fulfill(); }); }); const listeners = [ helper.addEventListener(process, 'exit', killWebKit) ]; if (handleSIGINT) listeners.push(helper.addEventListener(process, 'SIGINT', () => { killWebKit(); process.exit(130); })); if (handleSIGTERM) listeners.push(helper.addEventListener(process, 'SIGTERM', gracefullyCloseWebkit)); if (handleSIGHUP) listeners.push(helper.addEventListener(process, 'SIGHUP', gracefullyCloseWebkit)); let connection: Connection | null = null; try { const transport = new PipeTransport(webkitProcess.stdio[3] as NodeJS.WritableStream, webkitProcess.stdio[4] as NodeJS.ReadableStream); connection = new Connection('', transport, slowMo); const browser = new Browser(connection, defaultViewport, webkitProcess, gracefullyCloseWebkit); await browser._waitForTarget(t => t.type() === 'page'); return browser; } catch (e) { killWebKit(); throw e; } function gracefullyCloseWebkit(): Promise { helper.removeEventListeners(listeners); if (connection) { // Attempt to close chrome gracefully connection.send('Browser.close').catch(error => { debugError(error); killWebKit(); }); } return waitForChromeToClose; } // This method has to be sync to be used as 'exit' event handler. function killWebKit() { helper.removeEventListeners(listeners); if (webkitProcess.pid && !webkitProcess.killed && !webkitClosed) { // Force kill chrome. try { if (process.platform === 'win32') childProcess.execSync(`taskkill /pid ${webkitProcess.pid} /T /F`); else process.kill(-webkitProcess.pid, 'SIGKILL'); } catch (e) { // the process might have already stopped } } } } executablePath(): string { return this._resolveExecutablePath().executablePath; } _resolveExecutablePath(): { executablePath: string; missingText: string | null; } { const browserFetcher = new BrowserFetcher(this._projectRoot); const revisionInfo = browserFetcher.revisionInfo(this._preferredRevision); const missingText = !revisionInfo.local ? `WebKit revision is not downloaded. Run "npm install" or "yarn install"` : null; return {executablePath: revisionInfo.executablePath, missingText}; } } export type LauncherLaunchOptions = { ignoreDefaultArgs?: boolean, args?: string[], executablePath?: string, handleSIGINT?: boolean, handleSIGTERM?: boolean, handleSIGHUP?: boolean, headless?: boolean, dumpio?: boolean, env?: {[key: string]: string} | undefined, defaultViewport?: Viewport | null, slowMo?: number, };