mirror of
https://github.com/nasa/openmct.git
synced 2025-02-24 10:45:02 +00:00
Merge branch 'topic-conditionals' of https://github.com/nasa/openmct into topic-conditionals
This commit is contained in:
commit
f790c9bd39
@ -45,16 +45,32 @@
|
|||||||
{{ option.text }}
|
{{ option.text }}
|
||||||
</option>
|
</option>
|
||||||
</select>
|
</select>
|
||||||
<span v-for="(item, inputIndex) in inputCount"
|
<span v-if="!enumerations.length">
|
||||||
:key="inputIndex"
|
<span v-for="(item, inputIndex) in inputCount"
|
||||||
class="c-cdef__control__inputs"
|
:key="inputIndex"
|
||||||
>
|
class="c-cdef__control__inputs"
|
||||||
<input v-model="criterion.input[inputIndex]"
|
|
||||||
class="c-cdef__control__input"
|
|
||||||
:type="setInputType"
|
|
||||||
@blur="persist"
|
|
||||||
>
|
>
|
||||||
<span v-if="inputIndex < inputCount-1">and</span>
|
<input v-model="criterion.input[inputIndex]"
|
||||||
|
class="c-cdef__control__input"
|
||||||
|
:type="setInputType"
|
||||||
|
@blur="persist"
|
||||||
|
>
|
||||||
|
<span v-if="inputIndex < inputCount-1">and</span>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
<span v-else>
|
||||||
|
<span v-if="inputCount && criterion.operation"
|
||||||
|
class="c-cdef__control"
|
||||||
|
>
|
||||||
|
<select v-model="criterion.input[0]">
|
||||||
|
<option v-for="option in enumerations"
|
||||||
|
:key="option.string"
|
||||||
|
:value="option.value.toString()"
|
||||||
|
>
|
||||||
|
{{ option.string }}
|
||||||
|
</option>
|
||||||
|
</select>
|
||||||
|
</span>
|
||||||
</span>
|
</span>
|
||||||
</span>
|
</span>
|
||||||
</span>
|
</span>
|
||||||
@ -92,7 +108,8 @@ export default {
|
|||||||
operations: OPERATIONS,
|
operations: OPERATIONS,
|
||||||
inputCount: 0,
|
inputCount: 0,
|
||||||
rowLabel: '',
|
rowLabel: '',
|
||||||
operationFormat: ''
|
operationFormat: '',
|
||||||
|
enumerations: []
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
computed: {
|
computed: {
|
||||||
@ -123,11 +140,13 @@ export default {
|
|||||||
},
|
},
|
||||||
methods: {
|
methods: {
|
||||||
getOperationFormat() {
|
getOperationFormat() {
|
||||||
|
this.enumerations = [];
|
||||||
this.telemetryMetadata.valueMetadatas.forEach((value, index) => {
|
this.telemetryMetadata.valueMetadatas.forEach((value, index) => {
|
||||||
if (value.key === this.criterion.metadata) {
|
if (value.key === this.criterion.metadata) {
|
||||||
let valueMetadata = this.telemetryMetadataOptions[index];
|
let valueMetadata = this.telemetryMetadataOptions[index];
|
||||||
if (valueMetadata.enumerations !== undefined) {
|
if (valueMetadata.enumerations !== undefined) {
|
||||||
this.operationFormat = 'enum';
|
this.operationFormat = 'enum';
|
||||||
|
this.enumerations = valueMetadata.enumerations;
|
||||||
} else if (valueMetadata.hints.hasOwnProperty('range')) {
|
} else if (valueMetadata.hints.hasOwnProperty('range')) {
|
||||||
this.operationFormat = 'number';
|
this.operationFormat = 'number';
|
||||||
} else if (valueMetadata.hints.hasOwnProperty('domain')) {
|
} else if (valueMetadata.hints.hasOwnProperty('domain')) {
|
||||||
@ -164,7 +183,7 @@ export default {
|
|||||||
},
|
},
|
||||||
updateOperationInputVisibility(ev) {
|
updateOperationInputVisibility(ev) {
|
||||||
if (ev) {
|
if (ev) {
|
||||||
this.criterion.input = [];
|
this.criterion.input = this.enumerations.length ? [this.enumerations[0].value.toString()] : [];
|
||||||
this.inputCount = 0;
|
this.inputCount = 0;
|
||||||
}
|
}
|
||||||
for (let i = 0; i < this.filteredOps.length; i++) {
|
for (let i = 0; i < this.filteredOps.length; i++) {
|
||||||
|
@ -51,11 +51,15 @@ export default class TelemetryCriterion extends EventEmitter {
|
|||||||
|
|
||||||
initialize(obj) {
|
initialize(obj) {
|
||||||
this.telemetryObject = obj;
|
this.telemetryObject = obj;
|
||||||
|
this.telemetryMetaData = this.openmct.telemetry.getMetadata(obj).valueMetadatas;
|
||||||
this.telemetryObjectIdAsString = this.objectAPI.makeKeyString(this.telemetryObject.identifier);
|
this.telemetryObjectIdAsString = this.objectAPI.makeKeyString(this.telemetryObject.identifier);
|
||||||
this.emitEvent('criterionUpdated', this);
|
this.emitEvent('criterionUpdated', this);
|
||||||
}
|
}
|
||||||
|
|
||||||
handleSubscription(data) {
|
handleSubscription(data) {
|
||||||
|
if (data) {
|
||||||
|
data = this.createNormalizedDatum(data);
|
||||||
|
}
|
||||||
const datum = {
|
const datum = {
|
||||||
result: this.computeResult(data)
|
result: this.computeResult(data)
|
||||||
};
|
};
|
||||||
@ -69,6 +73,13 @@ export default class TelemetryCriterion extends EventEmitter {
|
|||||||
this.emitEvent('criterionResultUpdated', datum);
|
this.emitEvent('criterionResultUpdated', datum);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
createNormalizedDatum(telemetryDatum) {
|
||||||
|
return Object.values(this.telemetryMetaData).reduce((normalizedDatum, metadatum) => {
|
||||||
|
normalizedDatum[metadatum.key] = telemetryDatum[metadatum.source];
|
||||||
|
return normalizedDatum;
|
||||||
|
}, {});
|
||||||
|
}
|
||||||
|
|
||||||
findOperation(operation) {
|
findOperation(operation) {
|
||||||
for (let i=0, ii=OPERATIONS.length; i < ii; i++) {
|
for (let i=0, ii=OPERATIONS.length; i < ii; i++) {
|
||||||
if (operation === OPERATIONS[i].name) {
|
if (operation === OPERATIONS[i].name) {
|
||||||
|
@ -37,18 +37,25 @@ describe("The telemetry criterion", function () {
|
|||||||
type: "test-object",
|
type: "test-object",
|
||||||
name: "Test Object",
|
name: "Test Object",
|
||||||
telemetry: {
|
telemetry: {
|
||||||
values: [{
|
valueMetadatas: [{
|
||||||
key: "some-key",
|
key: "value",
|
||||||
name: "Some attribute",
|
name: "Value",
|
||||||
|
hints: {
|
||||||
|
range: 2
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{
|
||||||
|
key: "utc",
|
||||||
|
name: "Time",
|
||||||
|
format: "utc",
|
||||||
hints: {
|
hints: {
|
||||||
domain: 1
|
domain: 1
|
||||||
}
|
}
|
||||||
}, {
|
}, {
|
||||||
key: "some-other-key",
|
key: "testSource",
|
||||||
name: "Another attribute",
|
source: "value",
|
||||||
hints: {
|
name: "Test",
|
||||||
range: 1
|
format: "enum"
|
||||||
}
|
|
||||||
}]
|
}]
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
@ -60,7 +67,7 @@ describe("The telemetry criterion", function () {
|
|||||||
openmct.telemetry = jasmine.createSpyObj('telemetry', ['isTelemetryObject', "subscribe", "getMetadata"]);
|
openmct.telemetry = jasmine.createSpyObj('telemetry', ['isTelemetryObject', "subscribe", "getMetadata"]);
|
||||||
openmct.telemetry.isTelemetryObject.and.returnValue(true);
|
openmct.telemetry.isTelemetryObject.and.returnValue(true);
|
||||||
openmct.telemetry.subscribe.and.returnValue(function () {});
|
openmct.telemetry.subscribe.and.returnValue(function () {});
|
||||||
openmct.telemetry.getMetadata.and.returnValue(testTelemetryObject.telemetry.values);
|
openmct.telemetry.getMetadata.and.returnValue(testTelemetryObject.telemetry);
|
||||||
|
|
||||||
openmct.time = jasmine.createSpyObj('timeAPI',
|
openmct.time = jasmine.createSpyObj('timeAPI',
|
||||||
['timeSystem', 'bounds', 'getAllTimeSystems']
|
['timeSystem', 'bounds', 'getAllTimeSystems']
|
||||||
@ -101,11 +108,11 @@ describe("The telemetry criterion", function () {
|
|||||||
});
|
});
|
||||||
|
|
||||||
it("emits update event on new data from telemetry providers", function () {
|
it("emits update event on new data from telemetry providers", function () {
|
||||||
|
telemetryCriterion.initialize(testTelemetryObject);
|
||||||
spyOn(telemetryCriterion, 'emitEvent').and.callThrough();
|
spyOn(telemetryCriterion, 'emitEvent').and.callThrough();
|
||||||
telemetryCriterion.handleSubscription({
|
telemetryCriterion.handleSubscription({
|
||||||
key: 'some-key',
|
value: 'Hello',
|
||||||
source: 'testSource',
|
utc: 'Hi'
|
||||||
testSource: 'Hello'
|
|
||||||
});
|
});
|
||||||
expect(telemetryCriterion.emitEvent).toHaveBeenCalled();
|
expect(telemetryCriterion.emitEvent).toHaveBeenCalled();
|
||||||
expect(mockListener).toHaveBeenCalled();
|
expect(mockListener).toHaveBeenCalled();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user