LineageOS/android_development
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Winscope: Introduce ProxyClient class

Browse Source 
Use new class to share device auth states, adb proxy
state and expose functions to talk to proxy.

This is the first step before adding new functionality to
winscope that will convert transaction traces to
layer traces. This functionality needs to be added in
DataInput.vue so this class will make it easier to read
the proxy state and use the proxy.

There should be no functional change in this cl.

Test: collect winscope traces via proxy
Bug: 200284593
Change-Id: Ic1f492ebec6c8dfd667d0828bb2d6779665b89c2
Merged-In: Ic1f492ebec6c8dfd667d0828bb2d6779665b89c2
(cherry picked from commit f89a0fbaa9)
This commit is contained in:
Vishnu Nair
2022-02-22 22:04:11 -08:00
parent b2c12811b0
commit fe1da96bfb
2 changed files with 268 additions and 204 deletions
Download Patch File Download Diff File Expand all files Collapse all files

256
tools/winscope/src/DataAdb.vue
View File

@@ -39,7 +39,7 @@
<md-icon class="md-accent">update</md-icon>
<span class="md-subheading">The version of Winscope ADB Connect proxy running on your machine is incopatibile with Winscope.</span>
<div class="md-body-2">
<p>Please update the proxy to version {{ WINSCOPE_PROXY_VERSION }}</p>
<p>Please update the proxy to version {{ proxyClient.VERSION }}</p>
<p>Run:</p>
<pre>python3 $ANDROID_BUILD_TOP/development/tools/winscope/adb_proxy/winscope_proxy.py</pre>
<p>Or get it from the AOSP repository.</p>
@@ -54,7 +54,7 @@
<span class="md-subheading">Proxy authorisation required</span>
<md-field>
<label>Enter Winscope proxy token</label>
<md-input v-model="adbStore.proxyKey"></md-input>
<md-input v-model="proxyClient.store.proxyKey"></md-input>
</md-field>
<div class="md-body-2">The proxy token is printed to console on proxy launch, copy and paste it above.</div>
<div class="md-layout">
@@ -62,9 +62,9 @@
</div>
</md-card-content>
<md-card-content v-if="status === STATES.DEVICES">
<div class="md-subheading">{{ Object.keys(devices).length > 0 ? "Connected devices:" : "No devices detected" }}</div>
<div class="md-subheading">{{ Object.keys(proxyClient.devices).length > 0 ? "Connected devices:" : "No devices detected" }}</div>
<md-list>
<md-list-item v-for="(device, id) in devices" :key="id" @click="selectDevice(id)" :disabled="!device.authorised">
<md-list-item v-for="(device, id) in proxyClient.devices" :key="id" @click="proxyClient.selectDevice(id)" :disabled="!device.authorised">
<md-icon>{{ device.authorised ? "smartphone" : "screen_lock_portrait" }}</md-icon>
<span class="md-list-item-text">{{ device.authorised ? device.model : "unauthorised" }} ({{ id }})</span>
</md-list-item>
@@ -76,7 +76,7 @@
<md-list>
<md-list-item>
<md-icon>smartphone</md-icon>
<span class="md-list-item-text">{{ devices[selectedDevice].model }} ({{ selectedDevice }})</span>
<span class="md-list-item-text">{{ proxyClient.devices[proxyClient.selectedDevice].model }} ({{ proxyClient.selectedDevice }})</span>
</md-list-item>
</md-list>
<md-button class="md-primary" @click="resetLastDevice">Change device</md-button>
@@ -84,12 +84,12 @@
<div class="trace-section">
<h3>Trace targets:</h3>
<div class="selection">
<md-checkbox class="md-primary" v-for="traceKey in Object.keys(DYNAMIC_TRACES)" :key="traceKey" v-model="adbStore[traceKey]">{{ DYNAMIC_TRACES[traceKey].name }}</md-checkbox>
<md-checkbox class="md-primary" v-for="traceKey in Object.keys(DYNAMIC_TRACES)" :key="traceKey" v-model="traceStore[traceKey]">{{ DYNAMIC_TRACES[traceKey].name }}</md-checkbox>
</div>
<div class="trace-config">
<h4>Surface Flinger config</h4>
<div class="selection">
<md-checkbox class="md-primary" v-for="config in TRACE_CONFIG['layers_trace']" :key="config" v-model="adbStore[config]">{{config}}</md-checkbox>
<md-checkbox class="md-primary" v-for="config in TRACE_CONFIG['layers_trace']" :key="config" v-model="traceStore[config]">{{config}}</md-checkbox>
<div class="selection">
<md-field class="config-selection" v-for="selectConfig in Object.keys(SF_SELECTED_CONFIG)" :key="selectConfig">
<md-select v-model="SF_SELECTED_CONFIG_VALUES[selectConfig]" :placeholder="selectConfig">
@@ -116,7 +116,7 @@
<div class="dump-section">
<h3>Dump targets:</h3>
<div class="selection">
<md-checkbox class="md-primary" v-for="dumpKey in Object.keys(DUMPS)" :key="dumpKey" v-model="adbStore[dumpKey]">{{DUMPS[dumpKey].name}}</md-checkbox>
<md-checkbox class="md-primary" v-for="dumpKey in Object.keys(DUMPS)" :key="dumpKey" v-model="traceStore[dumpKey]">{{DUMPS[dumpKey].name}}</md-checkbox>
</div>
<div class="md-layout">
<md-button class="md-primary dump-btn" @click="dumpState">Dump state</md-button>
@@ -145,36 +145,9 @@
</flat-card>
</template>
<script>
import {FILE_DECODERS, FILE_TYPES} from './decode.js';
import LocalStore from './localstore.js';
import FlatCard from './components/FlatCard.vue';
const STATES = {
ERROR: 0,
CONNECTING: 1,
NO_PROXY: 2,
INVALID_VERSION: 3,
UNAUTH: 4,
DEVICES: 5,
START_TRACE: 6,
END_TRACE: 7,
LOAD_DATA: 8,
};
const WINSCOPE_PROXY_VERSION = '0.8';
const WINSCOPE_PROXY_URL = 'http://localhost:5544';
const PROXY_ENDPOINTS = {
DEVICES: '/devices/',
START_TRACE: '/start/',
END_TRACE: '/end/',
CONFIG_TRACE: '/configtrace/',
SELECTED_WM_CONFIG_TRACE: '/selectedwmconfigtrace/',
SELECTED_SF_CONFIG_TRACE: '/selectedsfconfigtrace/',
DUMP: '/dump/',
FETCH: '/fetch/',
STATUS: '/status/',
CHECK_WAYLAND: '/checkwayland/',
};
import {proxyClient, ProxyState, ProxyEndpoint} from './proxyclient/ProxyClient.ts';
// trace options should be added in a nested category
const TRACES = {
@@ -259,32 +232,15 @@ const DUMPS = {
},
};
const proxyFileTypeAdapter = {
'window_trace': FILE_TYPES.WINDOW_MANAGER_TRACE,
'accessibility_trace': FILE_TYPES.ACCESSIBILITY_TRACE,
'layers_trace': FILE_TYPES.SURFACE_FLINGER_TRACE,
'wl_trace': FILE_TYPES.WAYLAND_TRACE,
'layers_dump': FILE_TYPES.SURFACE_FLINGER_DUMP,
'window_dump': FILE_TYPES.WINDOW_MANAGER_DUMP,
'wl_dump': FILE_TYPES.WAYLAND_DUMP,
'screen_recording': FILE_TYPES.SCREEN_RECORDING,
'transactions': FILE_TYPES.TRANSACTIONS_TRACE,
'transactions_legacy': FILE_TYPES.TRANSACTIONS_TRACE_LEGACY,
'proto_log': FILE_TYPES.PROTO_LOG,
'system_ui_trace': FILE_TYPES.SYSTEM_UI,
'launcher_trace': FILE_TYPES.LAUNCHER,
'ime_trace_clients': FILE_TYPES.IME_TRACE_CLIENTS,
'ime_trace_service': FILE_TYPES.IME_TRACE_SERVICE,
'ime_trace_managerservice': FILE_TYPES.IME_TRACE_MANAGERSERVICE,
};
const CONFIGS = Object.keys(TRACE_CONFIG).flatMap((file) => TRACE_CONFIG[file]);
export default {
name: 'dataadb',
data() {
return {
STATES,
proxyClient,
ProxyState,
STATES: ProxyState,
TRACES,
DYNAMIC_TRACES: TRACES['default'],
TRACE_CONFIG,
@@ -293,23 +249,14 @@ export default {
SF_SELECTED_CONFIG_VALUES: {},
WM_SELECTED_CONFIG_VALUES: {},
DUMPS,
FILE_DECODERS,
WINSCOPE_PROXY_VERSION,
status: STATES.CONNECTING,
status: ProxyState.CONNECTING,
dataFiles: [],
devices: {},
selectedDevice: '',
refresh_worker: null,
keep_alive_worker: null,
errorText: '',
loadProgress: 0,
adbStore: LocalStore(
'adb',
traceStore: LocalStore(
'trace',
Object.assign(
{
proxyKey: '',
lastDevice: '',
},
this.getAllTraceKeys(TRACES)
.concat(Object.keys(DUMPS))
.concat(CONFIGS)
@@ -319,6 +266,10 @@ export default {
),
),
downloadProxyUrl: 'https://android.googlesource.com/platform/development/+/master/tools/winscope/adb_proxy/winscope_proxy.py',
onStateChangeFn: (newState, errorText) => {
this.status = newState;
this.errorText = errorText;
},
};
},
props: ['store'],
@@ -326,30 +277,6 @@ export default {
'flat-card': FlatCard,
},
methods: {
getDevices() {
if (this.status !== STATES.DEVICES && this.status !== STATES.CONNECTING) {
clearInterval(this.refresh_worker);
this.refresh_worker = null;
return;
}
this.callProxy('GET', PROXY_ENDPOINTS.DEVICES, this, function(request, view) {
try {
view.devices = JSON.parse(request.responseText);
if (view.adbStore.lastDevice && view.devices[view.adbStore.lastDevice] && view.devices[view.adbStore.lastDevice].authorised) {
view.selectDevice(view.adbStore.lastDevice);
} else {
if (view.refresh_worker === null) {
view.refresh_worker = setInterval(view.getDevices, 1000);
}
view.status = STATES.DEVICES;
}
} catch (err) {
console.error(err);
view.errorText = request.responseText;
view.status = STATES.ERROR;
}
});
},
getAllTraceKeys(traces) {
let keys = [];
for (let dict_key in traces) {
@@ -361,15 +288,14 @@ export default {
},
setAvailableTraces() {
this.DYNAMIC_TRACES = this.TRACES['default'];
this.callProxy('GET', PROXY_ENDPOINTS.CHECK_WAYLAND, this, function(request, view) {
proxyClient.call('GET', ProxyEndpoint.CHECK_WAYLAND, this, function(request, view) {
try {
if(request.responseText == 'true') {
view.appendOptionalTraces('arc');
}
} catch(err) {
console.error(err);
view.errorText = request.responseText;
view.status = STATES.ERROR;
proxyClient.setState(ProxyState.ERROR, request.responseText);
}
});
},
@@ -379,12 +305,12 @@ export default {
}
},
keepAliveTrace() {
if (this.status !== STATES.END_TRACE) {
if (this.status !== ProxyState.END_TRACE) {
clearInterval(this.keep_alive_worker);
this.keep_alive_worker = null;
return;
}
this.callProxy('GET', `${PROXY_ENDPOINTS.STATUS}${this.deviceId()}/`, this, function(request, view) {
proxyClient.call('GET', `${ProxyEndpoint.STATUS}${proxyClient.deviceId()}/`, this, function(request, view) {
if (request.responseText !== 'True') {
view.endTrace();
} else if (view.keep_alive_worker === null) {
@@ -398,18 +324,17 @@ export default {
const requestedSelectedSfConfig = this.toSelectedSfTraceConfig();
const requestedSelectedWmConfig = this.toSelectedWmTraceConfig();
if (requested.length < 1) {
this.errorText = 'No targets selected';
this.status = STATES.ERROR;
proxyClient.setState(ProxyState.ERROR, 'No targets selected');
this.recordNewEvent("No targets selected");
return;
}
this.recordNewEvent("Start Trace");
this.callProxy('POST', `${PROXY_ENDPOINTS.CONFIG_TRACE}${this.deviceId()}/`, this, null, null, requestedConfig);
this.callProxy('POST', `${PROXY_ENDPOINTS.SELECTED_SF_CONFIG_TRACE}${this.deviceId()}/`, this, null, null, requestedSelectedSfConfig);
this.callProxy('POST', `${PROXY_ENDPOINTS.SELECTED_WM_CONFIG_TRACE}${this.deviceId()}/`, this, null, null, requestedSelectedWmConfig);
this.status = STATES.END_TRACE;
this.callProxy('POST', `${PROXY_ENDPOINTS.START_TRACE}${this.deviceId()}/`, this, function(request, view) {
proxyClient.call('POST', `${ProxyEndpoint.CONFIG_TRACE}${proxyClient.deviceId()}/`, this, null, null, requestedConfig);
proxyClient.call('POST', `${ProxyEndpoint.SELECTED_SF_CONFIG_TRACE}${proxyClient.deviceId()}/`, this, null, null, requestedSelectedSfConfig);
proxyClient.call('POST', `${ProxyEndpoint.SELECTED_WM_CONFIG_TRACE}${proxyClient.deviceId()}/`, this, null, null, requestedSelectedWmConfig);
proxyClient.setState(ProxyState.END_TRACE);
proxyClient.call('POST', `${ProxyEndpoint.START_TRACE}${proxyClient.deviceId()}/`, this, function(request, view) {
view.keepAliveTrace();
}, null, requested);
},
@@ -417,68 +342,31 @@ export default {
this.recordButtonClickedEvent("Dump State");
const requested = this.toDump();
if (requested.length < 1) {
this.errorText = 'No targets selected';
this.status = STATES.ERROR;
proxyClient.setState(ProxyState.ERROR, 'No targets selected');
this.recordNewEvent("No targets selected");
return;
}
this.status = STATES.LOAD_DATA;
this.callProxy('POST', `${PROXY_ENDPOINTS.DUMP}${this.deviceId()}/`, this, function(request, view) {
view.loadFile(requested, 0, "dump");
proxyClient.setState(ProxyState.LOAD_DATA);
proxyClient.call('POST', `${ProxyEndpoint.DUMP}${proxyClient.deviceId()}/`, this, function(request, view) {
proxyClient.loadFile(requested, 0, "dump", view);
}, null, requested);
},
endTrace() {
this.status = STATES.LOAD_DATA;
this.callProxy('POST', `${PROXY_ENDPOINTS.END_TRACE}${this.deviceId()}/`, this, function(request, view) {
view.loadFile(view.toTrace(), 0, "trace");
proxyClient.setState(ProxyState.LOAD_DATA);
proxyClient.call('POST', `${ProxyEndpoint.END_TRACE}${proxyClient.deviceId()}/`, this, function(request, view) {
proxyClient.loadFile(view.toTrace(), 0, "trace", view);
});
this.recordNewEvent("Ended Trace");
},
loadFile(files, idx, traceType) {
this.callProxy('GET', `${PROXY_ENDPOINTS.FETCH}${this.deviceId()}/${files[idx]}/`, this, (request, view) => {
try {
const enc = new TextDecoder('utf-8');
const resp = enc.decode(request.response);
const filesByType = JSON.parse(resp);
for (const filetype in filesByType) {
if (filesByType.hasOwnProperty(filetype)) {
const files = filesByType[filetype];
const fileDecoder = FILE_DECODERS[proxyFileTypeAdapter[filetype]];
for (const encodedFileBuffer of files) {
const buffer = Uint8Array.from(atob(encodedFileBuffer), (c) => c.charCodeAt(0));
const data = fileDecoder.decoder(buffer, fileDecoder.decoderParams, fileDecoder.name, view.store);
view.dataFiles.push(data);
view.loadProgress = 100 * (idx + 1) / files.length; // TODO: Update this
}
}
}
if (idx < files.length - 1) {
view.loadFile(files, idx + 1, traceType);
} else {
const currentDate = new Date().toISOString();
view.$emit('dataReady',
`winscope-${traceType}-${currentDate}`,
view.dataFiles);
}
} catch (err) {
console.error(err);
view.errorText = err;
view.status = STATES.ERROR;
}
}, 'arraybuffer');
},
toTrace() {
return Object.keys(this.DYNAMIC_TRACES)
.filter((traceKey) => this.adbStore[traceKey]);
.filter((traceKey) => this.traceStore[traceKey]);
},
toTraceConfig() {
return Object.keys(TRACE_CONFIG)
.filter((file) => this.adbStore[file])
.filter((file) => this.traceStore[file])
.flatMap((file) => TRACE_CONFIG[file])
.filter((config) => this.adbStore[config]);
.filter((config) => this.traceStore[config]);
},
toSelectedSfTraceConfig() {
const requestedSelectedConfig = {};
@@ -500,77 +388,37 @@ export default {
},
toDump() {
return Object.keys(DUMPS)
.filter((dumpKey) => this.adbStore[dumpKey]);
},
selectDevice(device_id) {
this.selectedDevice = device_id;
this.adbStore.lastDevice = device_id;
this.status = STATES.START_TRACE;
},
deviceId() {
return this.selectedDevice;
.filter((dumpKey) => this.traceStore[dumpKey]);
},
restart() {
this.recordButtonClickedEvent("Connect / Retry");
this.status = STATES.CONNECTING;
proxyClient.setState(ProxyState.CONNECTING);
},
resetLastDevice() {
this.recordButtonClickedEvent("Change Device");
this.adbStore.lastDevice = '';
this.proxyClient.resetLastDevice();
this.restart();
},
callProxy(method, path, view, onSuccess, type, jsonRequest) {
const request = new XMLHttpRequest();
var view = this;
request.onreadystatechange = function() {
if (this.readyState !== 4) {
return;
}
if (this.status === 0) {
view.status = STATES.NO_PROXY;
} else if (this.status === 200) {
if (this.getResponseHeader('Winscope-Proxy-Version') !== WINSCOPE_PROXY_VERSION) {
view.status = STATES.INVALID_VERSION;
} else if (onSuccess) {
onSuccess(this, view);
}
} else if (this.status === 403) {
view.status = STATES.UNAUTH;
} else {
if (this.responseType === 'text' || !this.responseType) {
view.errorText = this.responseText;
} else if (this.responseType === 'arraybuffer') {
view.errorText = String.fromCharCode.apply(null, new Uint8Array(this.response));
}
view.status = STATES.ERROR;
}
};
request.responseType = type || '';
request.open(method, WINSCOPE_PROXY_URL + path);
request.setRequestHeader('Winscope-Token', this.adbStore.proxyKey);
if (jsonRequest) {
const json = JSON.stringify(jsonRequest);
request.setRequestHeader('Content-Type', 'application/json;charset=UTF-8');
request.send(json);
} else {
request.send();
}
},
},
created() {
proxyClient.setState(ProxyState.CONNECTING);
this.proxyClient.onStateChange(this.onStateChangeFn);
const urlParams = new URLSearchParams(window.location.search);
if (urlParams.has('token')) {
this.adbStore.proxyKey = urlParams.get('token');
this.proxyClient.proxyKey = urlParams.get('token');
}
this.getDevices();
this.proxyClient.getDevices();
},
beforeDestroy() {
this.proxyClient.removeOnStateChange(this.onStateChangeFn);
},
watch: {
status: {
handler(st) {
if (st == STATES.CONNECTING) {
this.getDevices();
if (st == ProxyState.CONNECTING) {
this.proxyClient.getDevices();
}
if (st == STATES.START_TRACE) {
if (st == ProxyState.START_TRACE) {
this.setAvailableTraces();
}
},

216
tools/winscope/src/proxyclient/ProxyClient.ts Normal file
View File

@@ -0,0 +1,216 @@
/*
* Copyright 2022, The Android Open Source Project
*
* Licensed 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 LocalStore from '../localstore.js';
import {FILE_DECODERS, FILE_TYPES} from '../decode.js';
export enum ProxyState {
ERROR = 0,
CONNECTING = 1,
NO_PROXY = 2,
INVALID_VERSION = 3,
UNAUTH = 4,
DEVICES = 5,
START_TRACE = 6,
END_TRACE = 7,
LOAD_DATA = 8,
};
export enum ProxyEndpoint {
DEVICES = '/devices/',
START_TRACE = '/start/',
END_TRACE = '/end/',
CONFIG_TRACE = '/configtrace/',
SELECTED_WM_CONFIG_TRACE = '/selectedwmconfigtrace/',
SELECTED_SF_CONFIG_TRACE = '/selectedsfconfigtrace/',
DUMP = '/dump/',
FETCH = '/fetch/',
STATUS = '/status/',
CHECK_WAYLAND = '/checkwayland/',
};
const proxyFileTypeAdapter = {
'window_trace': FILE_TYPES.WINDOW_MANAGER_TRACE,
'accessibility_trace': FILE_TYPES.ACCESSIBILITY_TRACE,
'layers_trace': FILE_TYPES.SURFACE_FLINGER_TRACE,
'wl_trace': FILE_TYPES.WAYLAND_TRACE,
'layers_dump': FILE_TYPES.SURFACE_FLINGER_DUMP,
'window_dump': FILE_TYPES.WINDOW_MANAGER_DUMP,
'wl_dump': FILE_TYPES.WAYLAND_DUMP,
'screen_recording': FILE_TYPES.SCREEN_RECORDING,
'transactions': FILE_TYPES.TRANSACTIONS_TRACE,
'transactions_legacy': FILE_TYPES.TRANSACTIONS_TRACE_LEGACY,
'proto_log': FILE_TYPES.PROTO_LOG,
'system_ui_trace': FILE_TYPES.SYSTEM_UI,
'launcher_trace': FILE_TYPES.LAUNCHER,
'ime_trace_clients': FILE_TYPES.IME_TRACE_CLIENTS,
'ime_trace_service': FILE_TYPES.IME_TRACE_SERVICE,
'ime_trace_managerservice': FILE_TYPES.IME_TRACE_MANAGERSERVICE,
};
class ProxyClient {
readonly WINSCOPE_PROXY_URL = 'http://localhost:5544';
readonly VERSION = '0.8';
store:LocalStore = LocalStore('adb', {
proxyKey: '',
lastDevice: ''});
state:ProxyState = ProxyState.CONNECTING;
stateChangeListeners:{(param:ProxyState, errorText:String): void;}[] = [];
refresh_worker: NodeJS.Timer = null;
devices = {};
selectedDevice = ""
errorText:String = ""
call(method, path, view, onSuccess, type = null, jsonRequest = null) {
const request = new XMLHttpRequest();
let client = this;
request.onreadystatechange = function() {
if (this.readyState !== 4) {
return;
}
if (this.status === 0) {
client.setState(ProxyState.NO_PROXY);
} else if (this.status === 200) {
if (this.getResponseHeader('Winscope-Proxy-Version') !== client.VERSION) {
client.setState(ProxyState.INVALID_VERSION);
} else if (onSuccess) {
onSuccess(this, view);
}
} else if (this.status === 403) {
client.setState(ProxyState.UNAUTH);
} else {
if (this.responseType === 'text' || !this.responseType) {
client.errorText = this.responseText;
} else if (this.responseType === 'arraybuffer') {
client.errorText = String.fromCharCode.apply(null, new Uint8Array(this.response));
}
client.setState(ProxyState.ERROR);
}
};
request.responseType = type || "";
request.open(method, client.WINSCOPE_PROXY_URL + path);
request.setRequestHeader('Winscope-Token', client.store.proxyKey);
if (jsonRequest) {
const json = JSON.stringify(jsonRequest);
request.setRequestHeader('Content-Type', 'application/json;charset=UTF-8');
request.send(json);
} else {
request.send();
}
}
setState(state:ProxyState, errorText:String = "") {
this.state = state;
this.errorText = errorText;
for (let listener of this.stateChangeListeners) {
listener(state, errorText);
}
}
onStateChange(fn: (state:ProxyState, errorText:String) => void) {
this.removeOnStateChange(fn);
this.stateChangeListeners.push(fn);
}
removeOnStateChange(removeFn: (state:ProxyState, errorText:String) => void) {
this.stateChangeListeners = this.stateChangeListeners.filter(fn => fn !== removeFn);
}
getDevices() {
if (this.state !== ProxyState.DEVICES && this.state !== ProxyState.CONNECTING) {
clearInterval(this.refresh_worker);
this.refresh_worker = null;
return;
}
let client = this;
this.call('GET', ProxyEndpoint.DEVICES, this, function(request, view) {
try {
client.devices = JSON.parse(request.responseText);
if (client.store.lastDevice && client.devices[client.store.lastDevice] &&
client.devices[client.store.lastDevice].authorised) {
client.selectDevice(client.store.lastDevice);
} else {
if (client.refresh_worker === null) {
client.refresh_worker = setInterval(client.getDevices, 1000);
}
client.setState(ProxyState.DEVICES);
}
} catch (err) {
console.error(err);
client.errorText = request.responseText;
client.setState(ProxyState.ERROR);
}
});
}
selectDevice(device_id) {
this.selectedDevice = device_id;
this.store.lastDevice = device_id;
this.setState(ProxyState.START_TRACE);
}
deviceId() {
return this.selectedDevice;
}
resetLastDevice() {
this.store.lastDevice = '';
}
loadFile(files, idx, traceType, view) {
let client = this;
this.call('GET', `${ProxyEndpoint.FETCH}${proxyClient.deviceId()}/${files[idx]}/`, view,
(request, view) => {
try {
const enc = new TextDecoder('utf-8');
const resp = enc.decode(request.response);
const filesByType = JSON.parse(resp);
for (const filetype in filesByType) {
if (filesByType.hasOwnProperty(filetype)) {
const files = filesByType[filetype];
const fileDecoder = FILE_DECODERS[proxyFileTypeAdapter[filetype]];
for (const encodedFileBuffer of files) {
const buffer = Uint8Array.from(atob(encodedFileBuffer), (c) => c.charCodeAt(0));
const data = fileDecoder.decoder(buffer, fileDecoder.decoderParams,
fileDecoder.name, view.store);
view.dataFiles.push(data);
view.loadProgress = 100 * (idx + 1) / files.length; // TODO: Update this
}
}
}
if (idx < files.length - 1) {
client.loadFile(files, idx + 1, traceType, view);
} else {
const currentDate = new Date().toISOString();
view.$emit('dataReady',
`winscope-${traceType}-${currentDate}`,
view.dataFiles);
}
} catch (err) {
console.error(err);
client.setState(ProxyState.ERROR, err);
}
}, 'arraybuffer');
}
}
export const proxyClient = new ProxyClient();