2021-02-16 13:31:24 +05:30
|
|
|
// Licensed to the Software Freedom Conservancy (SFC) under one
|
|
|
|
|
// or more contributor license agreements. See the NOTICE file
|
|
|
|
|
// distributed with this work for additional information
|
|
|
|
|
// regarding copyright ownership. The SFC 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.
|
|
|
|
|
|
2023-10-11 06:54:01 -04:00
|
|
|
const logging = require('../lib/logging')
|
|
|
|
|
|
2023-02-08 17:11:09 +05:30
|
|
|
const RESPONSE_TIMEOUT = 1000 * 30
|
2024-03-08 12:13:00 +00:00
|
|
|
|
2020-07-16 18:34:04 +05:30
|
|
|
class CDPConnection {
|
|
|
|
|
constructor(wsConnection) {
|
2020-08-03 17:56:31 +03:00
|
|
|
this._wsConnection = wsConnection
|
2021-11-03 03:50:03 +05:30
|
|
|
this.cmd_id = 0
|
2022-06-02 23:41:17 +05:30
|
|
|
this.targetID = null
|
2021-11-03 03:50:03 +05:30
|
|
|
this.sessionId = null
|
2020-07-16 18:34:04 +05:30
|
|
|
}
|
|
|
|
|
|
2021-11-03 17:47:08 +05:30
|
|
|
execute(method, params, callback) {
|
2021-11-03 03:50:03 +05:30
|
|
|
let message = {
|
2020-07-16 18:34:04 +05:30
|
|
|
method,
|
2021-11-03 03:50:03 +05:30
|
|
|
id: this.cmd_id++,
|
|
|
|
|
}
|
|
|
|
|
if (this.sessionId) {
|
|
|
|
|
message['sessionId'] = this.sessionId
|
2020-08-03 17:56:31 +03:00
|
|
|
}
|
2020-07-16 18:34:04 +05:30
|
|
|
|
2020-10-20 12:15:20 +03:00
|
|
|
const mergedMessage = Object.assign({ params: params }, message)
|
2020-09-30 18:13:53 +05:30
|
|
|
this._wsConnection.send(JSON.stringify(mergedMessage), callback)
|
|
|
|
|
}
|
2023-02-08 17:11:09 +05:30
|
|
|
|
|
|
|
|
async send(method, params) {
|
|
|
|
|
let cdp_id = this.cmd_id++
|
|
|
|
|
let message = {
|
|
|
|
|
method,
|
|
|
|
|
id: cdp_id,
|
|
|
|
|
}
|
|
|
|
|
if (this.sessionId) {
|
|
|
|
|
message['sessionId'] = this.sessionId
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const mergedMessage = Object.assign({ params: params }, message)
|
|
|
|
|
this._wsConnection.send(JSON.stringify(mergedMessage))
|
|
|
|
|
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
const timeoutId = setTimeout(() => {
|
|
|
|
|
reject(new Error(`Request with id ${cdp_id} timed out`))
|
|
|
|
|
handler.off('message', listener)
|
|
|
|
|
}, RESPONSE_TIMEOUT)
|
|
|
|
|
|
|
|
|
|
const listener = (data) => {
|
|
|
|
|
try {
|
|
|
|
|
const payload = JSON.parse(data.toString())
|
|
|
|
|
if (payload.id === cdp_id) {
|
|
|
|
|
clearTimeout(timeoutId)
|
|
|
|
|
handler.off('message', listener)
|
|
|
|
|
resolve(payload)
|
|
|
|
|
}
|
|
|
|
|
} catch (err) {
|
2024-02-07 16:07:24 +00:00
|
|
|
logging.getLogger(logging.Type.BROWSER).severe(`Failed parse message: ${err.message}`)
|
2023-02-08 17:11:09 +05:30
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const handler = this._wsConnection.on('message', listener)
|
|
|
|
|
})
|
|
|
|
|
}
|
2020-07-16 18:34:04 +05:30
|
|
|
}
|
|
|
|
|
|
2020-08-03 17:56:31 +03:00
|
|
|
exports.CdpConnection = CDPConnection
|
