/** * Copyright 2019 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 { helper } from '../helper'; import * as js from '../javascript'; import { FFSession } from './ffConnection'; import { Protocol } from './protocol'; export class FFExecutionContext implements js.ExecutionContextDelegate { _session: FFSession; _executionContextId: string; constructor(session: FFSession, executionContextId: string) { this._session = session; this._executionContextId = executionContextId; } async rawEvaluate(expression: string): Promise { const payload = await this._session.send('Runtime.evaluate', { expression: js.ensureSourceUrl(expression), returnByValue: false, executionContextId: this._executionContextId, }).catch(rewriteError); checkException(payload.exceptionDetails); return payload.result!; } async evaluate(context: js.ExecutionContext, returnByValue: boolean, pageFunction: Function | string, ...args: any[]): Promise { if (helper.isString(pageFunction)) { return this._callOnUtilityScript(context, `evaluate`, [ { value: pageFunction }, ], returnByValue, () => {}); } if (typeof pageFunction !== 'function') throw new Error(`Expected to get |string| or |function| as the first argument, but got "${pageFunction}" instead.`); const { functionText, values, handles, dispose } = await js.prepareFunctionCall(pageFunction, context, args, (value: any) => { if (Object.is(value, -0)) return { handle: { unserializableValue: '-0' } }; if (Object.is(value, Infinity)) return { handle: { unserializableValue: 'Infinity' } }; if (Object.is(value, -Infinity)) return { handle: { unserializableValue: '-Infinity' } }; if (Object.is(value, NaN)) return { handle: { unserializableValue: 'NaN' } }; if (value && (value instanceof js.JSHandle)) return { handle: this._toCallArgument(value._remoteObject) }; return { value }; }); return this._callOnUtilityScript(context, `callFunction`, [ { value: functionText }, ...values.map(value => ({ value })), ...handles, ], returnByValue, dispose); } private async _callOnUtilityScript(context: js.ExecutionContext, method: string, args: Protocol.Runtime.CallFunctionArgument[], returnByValue: boolean, dispose: () => void) { try { const utilityScript = await context.utilityScript(); const payload = await this._session.send('Runtime.callFunction', { functionDeclaration: `(utilityScript, ...args) => utilityScript.${method}(...args)`, args: [ { objectId: utilityScript._remoteObject.objectId, value: undefined }, { value: returnByValue }, ...args ], returnByValue, executionContextId: this._executionContextId }).catch(rewriteError); checkException(payload.exceptionDetails); if (returnByValue) return deserializeValue(payload.result!); return context.createHandle(payload.result); } finally { dispose(); } } async getProperties(handle: js.JSHandle): Promise> { const objectId = handle._remoteObject.objectId; if (!objectId) return new Map(); const response = await this._session.send('Runtime.getObjectProperties', { executionContextId: this._executionContextId, objectId, }); const result = new Map(); for (const property of response.properties) result.set(property.name, handle._context.createHandle(property.value)); return result; } async releaseHandle(handle: js.JSHandle): Promise { if (!handle._remoteObject.objectId) return; await this._session.send('Runtime.disposeObject', { executionContextId: this._executionContextId, objectId: handle._remoteObject.objectId, }).catch(error => {}); } async handleJSONValue(handle: js.JSHandle): Promise { const payload = handle._remoteObject; if (!payload.objectId) return deserializeValue(payload as Protocol.Runtime.RemoteObject); const simpleValue = await this._session.send('Runtime.callFunction', { executionContextId: this._executionContextId, returnByValue: true, functionDeclaration: ((e: any) => e).toString() + js.generateSourceUrl(), args: [this._toCallArgument(payload)], }); return deserializeValue(simpleValue.result!); } handleToString(handle: js.JSHandle, includeType: boolean): string { const payload = handle._remoteObject; if (payload.objectId) return 'JSHandle@' + (payload.subtype || payload.type); return (includeType ? 'JSHandle:' : '') + deserializeValue(payload as Protocol.Runtime.RemoteObject); } private _toCallArgument(payload: any): any { return { value: payload.value, unserializableValue: payload.unserializableValue, objectId: payload.objectId }; } } function checkException(exceptionDetails?: Protocol.Runtime.ExceptionDetails) { if (!exceptionDetails) return; if (exceptionDetails.value) throw new Error('Evaluation failed: ' + JSON.stringify(exceptionDetails.value)); else throw new Error('Evaluation failed: ' + exceptionDetails.text + '\n' + exceptionDetails.stack); } export function deserializeValue({unserializableValue, value}: Protocol.Runtime.RemoteObject) { if (unserializableValue === 'Infinity') return Infinity; if (unserializableValue === '-Infinity') return -Infinity; if (unserializableValue === '-0') return -0; if (unserializableValue === 'NaN') return NaN; return value; } function rewriteError(error: Error): (Protocol.Runtime.evaluateReturnValue | Protocol.Runtime.callFunctionReturnValue) { if (error.message.includes('cyclic object value') || error.message.includes('Object is not serializable')) return {result: {type: 'undefined', value: undefined}}; if (error.message.includes('Failed to find execution context with id') || error.message.includes('Execution context was destroyed!')) throw new Error('Execution context was destroyed, most likely because of a navigation.'); if (error instanceof TypeError && error.message.startsWith('Converting circular structure to JSON')) error.message += ' Are you passing a nested JSHandle?'; throw error; }