Homec4science
Diffusion SHRINE MedCo Fork (release/1.22.2.4) Browse

shrine-medco/apps/dashboard-app/src/main/js/src/app/diagnostic/diagnostic.model.js
f65b498e1100release/1.22.2.4

Last Change
Raw File

diagnostic.model.js
View Options

(function (){
'use strict';
// -- angular module -- //
angular.module('shrine-tools')
.factory('DiagnosticModel', DiagnosticModel);
DiagnosticModel.$inject = ['$http', '$q', 'UrlGetter', '$location'];
function DiagnosticModel (h, q, urlGetter, $location) {
var toDashboard = {url:''};
var cache = {};
// used solely for remote dashboard persistence
var m = {};
m.remoteSiteStatuses = [];
m.siteAlias = '';
// -- private const -- //
var Config = {
AdapterEndpoint: 'admin/status/adapter',
ConfigEndpoint: 'admin/status/config',
HubEndpoint: 'admin/status/hub',
I2B2Endpoint: 'admin/status/i2b2',
KeystoreEndpoint: 'admin/status/keystore',
OptionsEndpoint: 'admin/status/optionalParts',
ProblemEndpoint: 'admin/status/problems',
QepEndpoint: 'admin/status/qep',
SummaryEndpoint: 'admin/status/summary'
};
// -- public -- //
return {
getAdapter: getJsonMaker(Config.AdapterEndpoint, 'adapter'),
getConfig: getJsonMaker(Config.ConfigEndpoint, 'config', parseConfig),
getHub: getJsonMaker(Config.HubEndpoint, 'hub'),
getI2B2: getJsonMaker(Config.I2B2Endpoint, 'i2b2'),
getKeystore: getJsonMaker(Config.KeystoreEndpoint, 'keystore', storeRemoteSites),
getOptionalParts: getJsonMaker(Config.OptionsEndpoint, 'optionalParts'),
getProblems: getProblemsMaker(),
getQep: getJsonMaker(Config.QepEndpoint, 'qep'),
getSummary: getJsonMaker(Config.SummaryEndpoint, 'summary'),
safeLogout: safeLogout,
clearCache: clearCache,
map: map,
formatDate: formatDate,
cache: cache,
toDashboard: toDashboard,
m: m
};
function map(func, list) {
var result = [];
for(var i = 0; i < list.length; i++) {
result.push(func(list[i]))
}
return result;
}
function formatDate(dateObject) {
return [dateObject.getUTCFullYear(), "-",
pad2(dateObject.getUTCMonth()), "-",
pad2(dateObject.getUTCDate()), " ",
pad2(dateObject.getUTCHours()), ":",
pad2(dateObject.getUTCMinutes()), ":",
pad2(dateObject.getUTCSeconds())].join("");
}
function pad2(stringLikeThing) {
// Does javascript provide a string format thing? Would love to write %02d here.
var stringed = "" + stringLikeThing;
if (stringed.length > 2) {
return stringed;
}
return ("00" + stringed).slice(-2);
}
/**
* Clears the current remote dashboard before logging out.
*/
function safeLogout() {
clearCache();
toDashboard.url = '';
m.siteAlias = '';
$location.path('/login');
}
function clearCache() {
for (var member in cache) {
if(cache.hasOwnProperty(member)) delete cache[member];
}
}
/**
* Method for Handling a failed rest call.
* @param failedResult
* @returns {*}
*/
function onFail(failedResult) {
return q.reject(failedResult);
}
/***
* Method for handling a successful rest call. Simply caches it and returns it.
* @param result
* @param cacheKey
* @returns {*}
*/
function parseJsonResult(result, cacheKey) {
cache[cacheKey] = result.data;
return result.data;
}
/**
* Still cache and return the result, however, save the RemoteSites outside of the cache,
* as we don't want these values to change between cache resets (which occur when switching sites)
* @param result
* @param cacheKey
*/
function storeRemoteSites(result, cacheKey) {
cache[cacheKey] = result.data;
if (m.remoteSiteStatuses.length == 0) {
m.remoteSiteStatuses = result.data.remoteSiteStatuses;
}
return result.data
}
/**
* Parses the json config map and turns it into a nested json object
* @param json the flat config map
* @param cacheKey a unique identifier for the function
*/
function parseConfig (json, cacheKey) {
var configMap = json.data.configMap;
var processed = preProcessJson(configMap);
cache[cacheKey] = processed;
return processed;
}
// IE11 doesn't support string includes
// This only searchers for characters, not arbitrary strings
function stringIncludes(haystack, needle) {
var arr = haystack.split("");
for (var i = 0; i < arr.length; i++) {
if (arr[i] == needle) {
return true;
}
}
return false;
}
// "explodes" and merges the flag config map.
// e.g., {"key.foo": 10, "key.baz": 5} -> {"key": {"foo": 10, "baz": 5}}
function preProcessJson (object) {
var result = {};
for (var key in object) {
if (object.hasOwnProperty(key)) {
if (!stringIncludes(key, ".")) {
result[key] = object[key]
} else {
var split = key.split(".");
var prev = result;
for (var i = 0; i < split.length; i++) {
var cur = split[i];
if (!(cur in prev)) {
prev[cur] = {}
}
if (i == split.length - 1) {
prev[cur] = object[key];
} else {
prev = prev[cur]
}
}
}
}
}
return result;
}
/**
* There's a lot going on here. Essentially, this is a function factory that allows one to
* define backend calls just through the path. It also implements a simple caching
* strategy.
* Essentially the get function only needs to be called once, and from then on it will spit
* back a cached promise. This lets you write the code and not care whether it's cached or
* not, but also get the caching performance anyways. For this function to work, the
* resolver function has to take in the http response and the cache key to set, and make
* sure that it caches what it returns (see parseJsonResult or parseConfig).
* @param endpoint
* @param cacheKey
* @param resolverDefault
* @returns {Function}
*/
function getJsonMaker(endpoint, cacheKey, resolverDefault) {
var resolver = (typeof resolverDefault !== 'undefined')?
function (response) { return resolverDefault(response, cacheKey) }:
function (response) { return parseJsonResult(response, cacheKey) };
return function() {
var cachedValue = cache[cacheKey];
if (cachedValue === undefined) {
var url = urlGetter(endpoint, undefined, toDashboard.url);
return h.get(url)
.then(resolver, onFail)
} else {
return q(function(resolver) { resolver(cachedValue)});
}
}
}
function getProblemsMaker() {
// Caches the last offset and page size to hold onto it between different views
var prevOffset = 0;
var prevN = 20;
/**
* ProblemEndpoint: 'admin/status/problems',
* @returns {*}
*/
return function(offset, n, epoch) {
if (offset != null) {
prevOffset = offset;
} else {
offset = prevOffset;
}
if (n != null) {
prevN = n;
} else {
n = prevN;
}
var epochString = epoch && isFinite(epoch) ? '&epoch=' + epoch : '';
var url = urlGetter(
Config.ProblemEndpoint + '?offset=' + offset + '&n=' + n + epochString,
undefined,
toDashboard.url
);
return h.get(url)
.then(parseJsonResult, onFail);
}
}
}
})();
c4science · Help