blob: ee6353983bc8ecedac2ae19b7347f9e4ee2fb803 (
plain)
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
|
/* 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, {
CDPConnection: "chrome://remote/content/cdp/CDPConnection.sys.mjs",
generateUUID: "chrome://remote/content/shared/UUID.sys.mjs",
WebSocketHandshake:
"chrome://remote/content/server/WebSocketHandshake.sys.mjs",
});
/**
* Base class for all the targets.
*/
export class Target {
/**
* @param {TargetList} targetList
* @param {Class} sessionClass
*/
constructor(targetList, sessionClass) {
// Save a reference to TargetList instance in order to expose it to:
// domains/parent/Target.sys.mjs
this.targetList = targetList;
// When a new connection is made to this target,
// we will instantiate a new session based on this given class.
// The session class is specific to each target's kind and is passed
// by the inheriting class.
this.sessionClass = sessionClass;
// There can be more than one connection if multiple clients connect to the remote agent.
this.connections = new Set();
this.id = lazy.generateUUID();
}
/**
* Close all active connections made to this target.
*/
destructor() {
for (const conn of this.connections) {
conn.close();
}
}
// nsIHttpRequestHandler
async handle(request, response) {
const webSocket = await lazy.WebSocketHandshake.upgrade(request, response);
const conn = new lazy.CDPConnection(webSocket, response._connection);
const session = new this.sessionClass(conn, this);
conn.registerSession(session);
this.connections.add(conn);
}
// XPCOM
get QueryInterface() {
return ChromeUtils.generateQI(["nsIHttpRequestHandler"]);
}
}
|
