87d4e6e068
* add storage route * template out the routes and new raft storage overview * fetch raft config and add new server model * pngcrush the favicon * add view components and binary-file component * add form-save-buttons component * adjust rawRequest so that it can send a request body and returns the response on errors * hook up restore * rename binary-file to file-to-array-buffer * add ember-service-worker * use forked version of ember-service-worker for now * scope the service worker to a single endpoint * show both download buttons for now * add service worker download with a fallback to JS in-mem download * add remove peer functionality * lint go file * add storage-type to the cluster and node models * update edit for to take a cancel action * separate out a css table styles to be used by http-requests-table and on the raft-overview component * add raft-join adapter, model, component and use on the init page * fix styling and gate the menu item on the cluster using raft storage * style tweaks to the raft-join component * fix linting * add form-save-buttons component to storybook * add cancel functionality for backup uploads, and add a success message for successful uploads * add component tests * add filesize.js * add filesize and modified date to file-to-array-buffer * fix linting * fix server section showing in the cluster nav * don't use babel transforms in service worker lib because we don't want 2 copies of babel polyfill * add file-to-array-buffer to storybook * add comments and use removeObjectURL to raft-storage-overview * update alert-banner markdown * messaging change for upload alert banner * Update ui/app/templates/components/raft-storage-restore.hbs Co-Authored-By: Joshua Ogle <joshua@joshuaogle.com> * more comments * actually render the label if passed and update stories with knobs
105 lines
3.2 KiB
JavaScript
105 lines
3.2 KiB
JavaScript
import { inject as service } from '@ember/service';
|
|
import { alias, and, equal, gte, not, or } from '@ember/object/computed';
|
|
import { get, computed } from '@ember/object';
|
|
import DS from 'ember-data';
|
|
import { fragment } from 'ember-data-model-fragments/attributes';
|
|
const { hasMany, attr } = DS;
|
|
|
|
export default DS.Model.extend({
|
|
version: service(),
|
|
|
|
nodes: hasMany('nodes', { async: false }),
|
|
name: attr('string'),
|
|
status: attr('string'),
|
|
standby: attr('boolean'),
|
|
type: attr('string'),
|
|
|
|
needsInit: computed('nodes', 'nodes.@each.initialized', function() {
|
|
// needs init if no nodes are initialized
|
|
return this.get('nodes').isEvery('initialized', false);
|
|
}),
|
|
|
|
unsealed: computed('nodes', 'nodes.{[],@each.sealed}', function() {
|
|
// unsealed if there's at least one unsealed node
|
|
return !!this.get('nodes').findBy('sealed', false);
|
|
}),
|
|
|
|
sealed: not('unsealed'),
|
|
|
|
leaderNode: computed('nodes', 'nodes.[]', function() {
|
|
const nodes = this.get('nodes');
|
|
if (nodes.get('length') === 1) {
|
|
return nodes.get('firstObject');
|
|
} else {
|
|
return nodes.findBy('isLeader');
|
|
}
|
|
}),
|
|
|
|
sealThreshold: alias('leaderNode.sealThreshold'),
|
|
sealProgress: alias('leaderNode.progress'),
|
|
sealType: alias('leaderNode.type'),
|
|
storageType: alias('leaderNode.storageType'),
|
|
hasProgress: gte('sealProgress', 1),
|
|
usingRaft: equal('storageType', 'raft'),
|
|
|
|
//replication mode - will only ever be 'unsupported'
|
|
//otherwise the particular mode will have the relevant mode attr through replication-attributes
|
|
mode: attr('string'),
|
|
allReplicationDisabled: and('{dr,performance}.replicationDisabled'),
|
|
|
|
anyReplicationEnabled: or('{dr,performance}.replicationEnabled'),
|
|
|
|
stateDisplay(state) {
|
|
if (!state) {
|
|
return null;
|
|
}
|
|
const defaultDisp = 'Synced';
|
|
const displays = {
|
|
'stream-wals': 'Streaming',
|
|
'merkle-diff': 'Determining sync status',
|
|
'merkle-sync': 'Syncing',
|
|
};
|
|
|
|
return displays[state] || defaultDisp;
|
|
},
|
|
|
|
drStateDisplay: computed('dr.state', function() {
|
|
return this.stateDisplay(this.get('dr.state'));
|
|
}),
|
|
|
|
performanceStateDisplay: computed('performance.state', function() {
|
|
return this.stateDisplay(this.get('performance.state'));
|
|
}),
|
|
|
|
stateGlyph(state) {
|
|
const glyph = 'check-circled-outline';
|
|
|
|
const glyphs = {
|
|
'stream-wals': 'android-sync',
|
|
'merkle-diff': 'android-sync',
|
|
'merkle-sync': null,
|
|
};
|
|
|
|
return glyphs[state] || glyph;
|
|
},
|
|
|
|
drStateGlyph: computed('dr.state', function() {
|
|
return this.stateGlyph(this.get('dr.state'));
|
|
}),
|
|
|
|
performanceStateGlyph: computed('performance.state', function() {
|
|
return this.stateGlyph(this.get('performance.state'));
|
|
}),
|
|
|
|
dr: fragment('replication-attributes'),
|
|
performance: fragment('replication-attributes'),
|
|
// this service exposes what mode the UI is currently viewing
|
|
// replicationAttrs will then return the relevant `replication-attributes` fragment
|
|
rm: service('replication-mode'),
|
|
replicationMode: alias('rm.mode'),
|
|
replicationAttrs: computed('dr.mode', 'performance.mode', 'replicationMode', function() {
|
|
const replicationMode = this.get('replicationMode');
|
|
return replicationMode ? get(this, replicationMode) : null;
|
|
}),
|
|
});
|