Page MenuHomec4science
Files F66605578

query-status.js
No OneTemporary
Actions

File Metadata

Created
Tue, Jun 11, 18:41

query-status.js
View Options

import { customElement, observable} from 'aurelia-framework';
import { QueryStatusModel } from 'services/query-status.model';
import { PubSub } from 'services/pub-sub';
@customElement('query-status')
export class QueryStatus extends PubSub {
@observable status
static inject = [QueryStatusModel];
constructor(queryStatus, ...rest) {
super(...rest);
me.set(this, {
isDevEnv: document.location.href.includes('http://localhost:8000/'),
exportAvailable: false
});
}
statusChanged(newValue, oldValue) {
if(!newValue.nodes || !newValue.nodes.length) {
me.get(this).exportAvailable = false;
this.publish(this.notifications.shrine.queryUnavailable);
}
else {
me.get(this).exportAvailable = true;
this.publish(this.notifications.shrine.queryAvailable);
}
}
attached() {
// -- subscribers -- //
this.subscribe(this.notifications.i2b2.queryStarted, (n) => {
this.status = initialState();
this.status.query.queryName = n;
});
this.subscribe(this.notifications.i2b2.networkIdReceived, d => {
const networkId = d.networkId;
const state = initialState();
const nodes = state.nodes;
state.query.queryName = d.name || state.query.queryName;
this.status = this.status? {...this.status, ...{nodes}} : state;
this.publish(this.commands.shrine.fetchQuery, {networkId, timeoutSeconds, dataVersion: defaultVersion})
});
this.subscribe(this.notifications.i2b2.exportQuery, () => {
this.publish(this.commands.shrine.exportResult, { ...{}, ...this.status });
})
this.subscribe(this.notifications.shrine.queryReceived, data => {
const query = data.query;
const nodes = data.nodes;
const dataVersion= data.dataVersion;
const updated = Number(new Date());
const complete = data.query.complete;
const id = data.query.networkId;
this.status = { ...this.status, ...{ query, nodes, updated } }
if (!complete) {
window.setTimeout(() => this.publish(this.commands.shrine.fetchQuery, {id, dataVersion, timeoutSeconds}), 5000);
}
});
if (me.get(this).isDevEnv) {
this.publish(this.notifications.i2b2.queryStarted, "started query");
this.publish(this.notifications.i2b2.networkIdReceived, 1);
}
}
}
const timeoutSeconds = 15;
const defaultVersion = -1;
const me = new WeakMap();
const initialState = (n) => ({ query: { queryName: null, updated: null, complete: false }, nodes: null });

Event Timeline

c4science · Help