1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
const lazy = {};
ChromeUtils.defineESModuleGetters(lazy, {
DomainCache: "chrome://remote/content/cdp/domains/DomainCache.sys.mjs",
NetworkObserver:
"chrome://remote/content/cdp/observers/NetworkObserver.sys.mjs",
ParentProcessDomains:
"chrome://remote/content/cdp/domains/ParentProcessDomains.sys.mjs",
});
/**
* A session represents exactly one client WebSocket connection.
*
* Every new WebSocket connections is associated with one session that
* deals with dispatching incoming command requests to the right
* target, sending back responses, and propagating events originating
* from domains.
* Then, some subsequent Sessions may be created over a single WebSocket
* connection. In this case, the subsequent session will have an `id`
* being passed to their constructor and each packet of these sessions
* will have a `sessionId` attribute in order to filter the packets
* by session both on client and server side.
*/
export class Session {
/**
* @param {Connection} connection
* The connection used to communicate with the server.
* @param {Target} target
* The target to which this session communicates with.
* @param {number=} id
* If this session isn't the default one used for the HTTP endpoint we
* connected to, the session requires an id to distinguish it from the default
* one. This id is used to filter our request, responses and events between
* all active sessions. For now, this is only passed by `Target.attachToTarget()`.
*/
constructor(connection, target, id) {
this.connection = connection;
this.target = target;
this.id = id;
this.domains = new lazy.DomainCache(this, lazy.ParentProcessDomains);
}
destructor() {
if (
this.networkObserver &&
this.networkObserver.isActive(this.target.browser)
) {
this.networkObserver.dispose();
}
this.domains.clear();
}
execute(id, domain, command, params) {
return this.domains.execute(domain, command, params);
}
get networkObserver() {
if (!this._networkObserver) {
this._networkObserver = new lazy.NetworkObserver();
}
return this._networkObserver;
}
/**
* Domains event listener. Called when an event is fired
* by any Domain and has to be sent to the client.
*/
onEvent(eventName, params) {
this.connection.sendEvent(eventName, params, this.id);
}
toString() {
return `[object ${this.constructor.name} ${this.connection.id}]`;
}
}
|
