Page MenuHomec4science
Files F84039748

query-status.js
No OneTemporary
Actions

File Metadata

Created
Fri, Sep 20, 09:58

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);
return;
}
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 => {
if(this.status && this.status.canceled) return;
const {networkId, name} = d;
const state = initialState();
const {nodes} = state;
const queryName = name || state.query.queryName;
this.status = this.status? {...this.status, ...{nodes}} : state;
this.status.query = {...this.status.query, ...{queryName, networkId}};
this.publish(this.commands.shrine.fetchQuery, {networkId, timeoutSeconds: TIMEOUT_SECONDS, dataVersion: DEFAULT_VERSION})
});
this.subscribe(this.notifications.i2b2.exportQuery, () => {
this.publish(this.commands.shrine.exportResult, { ...{}, ...this.status });
})
this.subscribe(this.notifications.i2b2.clearQuery, () => {
this.status = {...initialState(), ...{canceled: true}};
})
this.subscribe(this.notifications.shrine.queryReceived, data => {
const {query, nodes, dataVersion = DEFAULT_VERSION, complete, query:{networkId}} = data;
const timeoutSeconds = TIMEOUT_SECONDS;
if(networkId !== this.status.query.networkId || this.status.canceled) return;
const updated = Number(new Date());
this.status = { ...this.status, ...{ query, nodes, updated } }
if (!complete) {
this.publish(this.commands.shrine.fetchQuery, {networkId, dataVersion, timeoutSeconds});
}
});
if (me.get(this).isDevEnv) {
//this.publish(this.notifications.i2b2.queryStarted, "started query");
this.publish(this.notifications.i2b2.networkIdReceived, {networkId: '2421519216383772161', name: "started query"});
}
}
}
const TIMEOUT_SECONDS = 15;
const DEFAULT_VERSION = -1;
const me = new WeakMap();
const initialState = (n) => ({ query: { networkId: null, queryName: null, updated: null, complete: false, canceled: false}, nodes: null });

Event Timeline

c4science · Help