| /* Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you 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 { Router, Message } from '@weex-cli/linker' |
| import MemoryFile from '../MemoryFile' |
| import { Config } from '../ConfigResolver' |
| import { Device } from '../managers/DeviceManager' |
| import utils from '../utils' |
| |
| import * as DEBUG from 'debug' |
| const debug = DEBUG('Handler:Proxy.Native') |
| |
| const debuggerRouter = Router.get(`debugger-${Config.get('channelId')}`) |
| let environmentMap = Config.get(`debugger-${Config.get('channelId')}`) |
| let vmIndex = 0 |
| let jsserviceIndex = 0 |
| |
| let heartbeatTimer |
| const sendHeartbeat = () => { |
| heartbeatTimer && clearTimeout(heartbeatTimer) |
| heartbeatTimer = setTimeout(() => { |
| debuggerRouter.pushMessage('proxy.native', 'ping') |
| debug('ping-pong') |
| sendHeartbeat() |
| }, Config.get('heartbeatTime') || 30000) |
| } |
| |
| debuggerRouter |
| .registerHandler(async (message: Message) => { |
| const payload = message.payload |
| const method = payload.method |
| const device = Device.getDevice(message.channelId) |
| if (method === 'WxDebug.initJSRuntime') { |
| if (!environmentMap[message.channelId]) { |
| environmentMap[message.channelId] = {} |
| } |
| environmentMap[message.channelId]['jsframework'] = new MemoryFile( |
| 'js-framework.js', |
| payload.params.source, |
| ).getUrl() |
| if (device && device.logLevel) { |
| payload.params.env.WXEnvironment.logLevel = device.logLevel |
| } |
| environmentMap[message.channelId]['isLayoutAndSandbox'] = payload.params.isLayoutAndSandbox |
| environmentMap[message.channelId]['environment'] = payload.params.env |
| environmentMap[message.channelId]['device'] = device |
| } else if (method === 'WxDebug.callJS' && payload.params.method === 'createInstance') { |
| const code = payload.params.args[1] |
| let bundleUrl = payload.params.args[2].bundleUrl |
| let env = { |
| environment: environmentMap[message.channelId]['environment'], |
| device: environmentMap[message.channelId]['device'], |
| isLayoutAndSandbox: environmentMap[message.channelId]['isLayoutAndSandbox'], |
| } |
| if (/^(https?|taobao|qap):\/\/(.*your_current_ip):(\d+)\//i.test(bundleUrl)) { |
| bundleUrl = bundleUrl.replace(/^(https?|taobao|qap):\/\/(.*your_current_ip):(\d+)\//i, 'file://') |
| } |
| env['sourceUrl'] = new MemoryFile( |
| bundleUrl, |
| utils.wrapper.bundleWrapper(code, utils.wrapper.transformUrlToLocalUrl(bundleUrl)), |
| ).getUrl() |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['jsframework'] |
| ) { |
| env['jsframework'] = environmentMap[message.channelId]['polify']['jsframework'] |
| } else { |
| env['jsframework'] = environmentMap[message.channelId]['jsframework'] |
| } |
| environmentMap[message.channelId]['workerjs'] = payload.params.workerjs = new MemoryFile( |
| `VM_${vmIndex++}`, |
| utils.wrapper.generateWorkerEntry(env), |
| ).getUrl() |
| if (environmentMap[message.channelId]['polify'] && environmentMap[message.channelId]['polify']['workerjs']) { |
| env['workerjs'] = environmentMap[message.channelId]['polify']['workerjs'] |
| } else { |
| env['workerjs'] = environmentMap[message.channelId]['workerjs'] |
| } |
| payload.params.workerjs = env['workerjs'] |
| if ( |
| environmentMap[message.channelId]['polify'] && |
| Array.isArray(environmentMap[message.channelId]['polify']['jsservice']) && |
| environmentMap[message.channelId]['polify']['jsservice'].length > 0 |
| ) { |
| payload.params.jsservice = environmentMap[message.channelId]['polify']['jsservice'] |
| } else { |
| payload.params.jsservice = environmentMap[message.channelId]['jsservice'] |
| } |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['sourcejs'] |
| ) { |
| bundleUrl = payload.params.sourceUrl = environmentMap[message.channelId]['polify']['sourcejs'] |
| } else { |
| bundleUrl = payload.params.sourceUrl = env['sourceUrl'] |
| } |
| await debuggerRouter.pushMessageByChannelId('page.debugger', message.channelId, { |
| method: 'WxDebug.bundleRendered', |
| params: { |
| bundleUrl: bundleUrl, |
| env: { |
| jsframework: environmentMap[message.channelId]['jsframework'], |
| jsservice: payload.params.jsservice, |
| workerjs: payload.params.workerjs, |
| sourcejs: payload.params.sourceUrl, |
| }, |
| isSandbox: false, |
| }, |
| }) |
| } else if (method === 'WxDebug.callJS' && payload.params.method === 'destroyInstance') { |
| Config.set('ACTIVE_INSTANCEID', '') |
| } else if (method === 'WxDebug.callJS' && payload.params.method === 'createInstanceContext') { |
| const options = payload.params.args[1] |
| const dependenceCode = payload.params.args[3] |
| let env = { |
| environment: environmentMap[message.channelId]['environment'], |
| device: environmentMap[message.channelId]['device'], |
| isLayoutAndSandbox: environmentMap[message.channelId]['isLayoutAndSandbox'], |
| } |
| let bundleUrl = options.bundleUrl |
| if (/^(https?|taobao|qap):\/\/(.*your_current_ip):(\d+)\//i.test(bundleUrl)) { |
| bundleUrl = '/source/' + bundleUrl.replace(/^(https?|taobao|qap):\/\/(.*your_current_ip):(\d+)\//i, 'file://') |
| } else if (/^file:\/\//.test(bundleUrl)) { |
| bundleUrl = '/source/' + bundleUrl |
| } else { |
| bundleUrl = '/source/' + bundleUrl |
| } |
| Config.set('ACTIVE_INSTANCEID', payload.params.args[0]) |
| if (dependenceCode) { |
| environmentMap[message.channelId]['dependencejs'] = new MemoryFile(`dependencejs.js`, dependenceCode).getUrl() |
| if ( |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['dependencejs'] |
| ) { |
| payload.params.dependencejs = environmentMap[message.channelId]['polify']['dependencejs'] |
| } else { |
| payload.params.dependencejs = environmentMap[message.channelId]['dependencejs'] |
| } |
| } |
| |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['jsservice'] |
| ) { |
| payload.params.jsservice = environmentMap[message.channelId]['polify']['jsservice'] |
| } else { |
| payload.params.jsservice = environmentMap[message.channelId]['jsservice'] |
| } |
| |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['jsframework'] |
| ) { |
| env['jsframework'] = environmentMap[message.channelId]['polify']['jsframework'] |
| } else { |
| env['jsframework'] = environmentMap[message.channelId]['jsframework'] |
| } |
| |
| env['isLayoutAndSandbox'] = environmentMap[message.channelId]['isLayoutAndSandbox'] |
| environmentMap[message.channelId]['workerjs'] = payload.params.workerjs = new MemoryFile( |
| `VM_${vmIndex++}`, |
| utils.wrapper.generateSandboxWorkerEntry(env), |
| ).getUrl() |
| |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['workerjs'] |
| ) { |
| payload.params.workerjs = environmentMap[message.channelId]['polify']['workerjs'] |
| } else { |
| payload.params.workerjs = environmentMap[message.channelId]['workerjs'] |
| } |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['sourcejs'] |
| ) { |
| bundleUrl = environmentMap[message.channelId]['polify']['sourcejs'] |
| } else if (environmentMap[message.channelId]['sourcejs']) { |
| bundleUrl = environmentMap[message.channelId]['sourcejs'] |
| } |
| await debuggerRouter.pushMessageByChannelId('page.debugger', message.channelId, { |
| method: 'WxDebug.bundleRendered', |
| params: { |
| bundleUrl: bundleUrl, |
| env: { |
| jsframework: env['jsframework'], |
| jsservice: payload.params.jsservice, |
| workerjs: payload.params.workerjs, |
| dependencejs: payload.params.dependencejs, |
| sourcejs: bundleUrl, |
| }, |
| isSandbox: true, |
| }, |
| }) |
| } else if (method === 'WxDebug.callJS' && payload.params.method === 'importScript') { |
| const code = payload.params.args[1] |
| let bundleUrl = payload.params.args[2] && payload.params.args[2].bundleUrl |
| bundleUrl = bundleUrl.replace(/\?random=(-)?\d+/i, '') |
| if ( |
| environmentMap[message.channelId] && |
| environmentMap[message.channelId]['polify'] && |
| environmentMap[message.channelId]['polify']['sourcejs'] |
| ) { |
| payload.params.sourceUrl = environmentMap[message.channelId]['polify']['sourcejs'] |
| } else { |
| environmentMap[message.channelId]['sourcejs'] = payload.params.sourceUrl = new MemoryFile( |
| bundleUrl, |
| code, |
| ).getUrl() |
| } |
| } else if (method === 'WxDebug.importScript') { |
| const url = new MemoryFile(`jsservice_${jsserviceIndex++}.js`, payload.params.source).getUrl() |
| if (!environmentMap[message.channelId]['jsservice']) { |
| environmentMap[message.channelId]['jsservice'] = [] |
| } |
| if (environmentMap[message.channelId]['jsservice'].indexOf(url) === -1) { |
| environmentMap[message.channelId]['jsservice'].push(url) |
| } |
| } else if (method === 'syncReturn') { |
| message.payload = { |
| error: payload.error, |
| ret: payload.params && payload.params.ret, |
| } |
| message.to('sync.native') |
| return |
| } else if (method === 'WxDebug.sendTracingData') { |
| message.to('page.debugger') |
| return |
| } else if (method === 'WxDebug.sendSummaryInfo') { |
| message.to('page.debugger') |
| return |
| } else if (method === 'WxDebug.sendPerformanceData') { |
| message.to('page.debugger') |
| return |
| } |
| message.to('runtime.worker') |
| }) |
| .at('proxy.native') |
| .when('payload.method&&payload.method.split(".")[0]==="WxDebug"') |
| |
| debuggerRouter |
| .registerHandler(function(message) { |
| const payload = message.payload |
| const device = Device.getDevice(message.channelId) |
| if (payload.method === 'Page.screencastFrame') { |
| payload.params.sessionId = 1 |
| if (device && device.platform === 'android') { |
| payload.params.metadata.pageScaleFactor = 0.999 |
| } |
| } else if (payload.method === 'Console.messageAdded') { |
| // issue: https://github.com/weexteam/weex-toolkit/issues/408 |
| // TODO: make it can be control by user |
| if (device && device.remoteDebug) { |
| message.discard() |
| } else { |
| message.payload = { |
| method: 'Runtime.consoleAPICalled', |
| params: { |
| type: payload.params.message.level, |
| args: |
| [ |
| { |
| type: 'string', |
| value: payload.params.message.text, |
| }, |
| ] || [], |
| executionContextId: 1, |
| // "stackTrace": payload.params.message.stackTrace |
| }, |
| } |
| } |
| } else if (payload.result && payload.result.method === 'WxDebug.syncReturn') { |
| message.payload = { |
| id: payload.result.params && payload.result.id && payload.result.params.syncId, |
| error: payload.error, |
| ret: payload.result.params && payload.result.params.ret, |
| } |
| message.to('sync.native') |
| return |
| } else if (payload.result && payload.id === undefined) { |
| message.discard() |
| } |
| message.to('proxy.inspector') |
| }) |
| .at('proxy.native') |
| .when('!payload.method||(payload.method.split(".")[0]!=="WxDebug")') |
| |
| debuggerRouter |
| .registerHandler(async () => { |
| sendHeartbeat() |
| }) |
| .at('proxy.native') |
