blob: 92ec440c3cd808595c2508b9daca351cd6f98e8a (
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
// Copyright 2018 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
Audits2.ProtocolService = class extends Common.Object {
constructor() {
super();
/** @type {?Protocol.Connection} */
this._rawConnection = null;
/** @type {?Services.ServiceManager.Service} */
this._backend = null;
/** @type {?Promise} */
this._backendPromise = null;
/** @type {?function(string)} */
this._status = null;
}
/**
* @return {!Promise<undefined>}
*/
attach() {
return SDK.interceptMainConnection(this._dispatchProtocolMessage.bind(this)).then(rawConnection => {
this._rawConnection = rawConnection;
});
}
/**
* @param {string} auditURL
* @param {!Array<string>} categoryIDs
* @param {!Object} flags
* @return {!Promise<!ReportRenderer.RunnerResult>}
*/
startLighthouse(auditURL, categoryIDs, flags) {
return this._send('start', {url: auditURL, categoryIDs, flags});
}
/**
* @return {!Promise<!Object|undefined>}
*/
detach() {
return Promise.resolve().then(() => this._send('stop')).then(() => this._backend.dispose()).then(() => {
delete this._backend;
delete this._backendPromise;
return this._rawConnection.disconnect();
});
}
/**
* @param {function (string): undefined} callback
*/
registerStatusCallback(callback) {
this._status = callback;
}
/**
* @param {!Object|string} message
*/
_dispatchProtocolMessage(message) {
this._send('dispatchProtocolMessage', {message: message});
}
_initWorker() {
this._backendPromise =
Services.serviceManager.createAppService('audits2_worker', 'Audits2Service').then(backend => {
if (this._backend)
return;
this._backend = backend;
this._backend.on('statusUpdate', result => this._status(result.message));
this._backend.on('sendProtocolMessage', result => this._sendProtocolMessage(result.message));
});
}
/**
* @param {string} message
*/
_sendProtocolMessage(message) {
this._rawConnection.sendRawMessage(message);
}
/**
* @param {string} method
* @param {!Object=} params
* @return {!Promise<!ReportRenderer.RunnerResult>}
*/
_send(method, params) {
if (!this._backendPromise)
this._initWorker();
return this._backendPromise.then(_ => this._backend.send(method, params));
}
};
|
