mirror of
https://github.com/nasa/openmct.git
synced 2025-05-31 22:50:49 +00:00
more debug just in case
This commit is contained in:
parent
4bbbd17b61
commit
38316bd2f5
@ -75,7 +75,7 @@ export default class TelemetryCollection extends EventEmitter {
|
|||||||
this.modeChanged = false;
|
this.modeChanged = false;
|
||||||
|
|
||||||
console.debug(
|
console.debug(
|
||||||
`🫙 Created telemetry for ${this.domainObject.name} with bounds ${options.start} and ${options.end}`
|
`🫙 Created telemetry for ${this.domainObject.name} with bounds ${new Date(options.start).toISOString()} and ${new Date(options.end).toISOString()}`
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -98,7 +98,7 @@ export default class TelemetryCollection extends EventEmitter {
|
|||||||
this.lastBounds.end = this.options.end;
|
this.lastBounds.end = this.options.end;
|
||||||
}
|
}
|
||||||
console.debug(
|
console.debug(
|
||||||
`🫙 Bounds for collection are start ${this.lastBounds.start} and end ${this.lastBounds.end}`
|
`🫙 Bounds for collection are start ${new Date(this.lastBounds.start).toISOString()} and end ${new Date(this.lastBounds.end).toISOString()}`
|
||||||
);
|
);
|
||||||
this._watchBounds();
|
this._watchBounds();
|
||||||
this._watchTimeSystem();
|
this._watchTimeSystem();
|
||||||
@ -144,6 +144,9 @@ export default class TelemetryCollection extends EventEmitter {
|
|||||||
* @private
|
* @private
|
||||||
*/
|
*/
|
||||||
async _requestHistoricalTelemetry() {
|
async _requestHistoricalTelemetry() {
|
||||||
|
console.debug(
|
||||||
|
`🫙 Requesting historical telemetry with start ${new Date(this.lastBounds.start).toISOString()} and end ${new Date(this.lastBounds.end).toISOString()}}`
|
||||||
|
);
|
||||||
let options = this.openmct.telemetry.standardizeRequestOptions({ ...this.options });
|
let options = this.openmct.telemetry.standardizeRequestOptions({ ...this.options });
|
||||||
const historicalProvider = this.openmct.telemetry.findRequestProvider(
|
const historicalProvider = this.openmct.telemetry.findRequestProvider(
|
||||||
this.domainObject,
|
this.domainObject,
|
||||||
@ -229,7 +232,6 @@ export default class TelemetryCollection extends EventEmitter {
|
|||||||
let hasDataBeforeStartBound = false;
|
let hasDataBeforeStartBound = false;
|
||||||
let size = this.options.size;
|
let size = this.options.size;
|
||||||
let enforceSize = size !== undefined && this.options.enforceSize;
|
let enforceSize = size !== undefined && this.options.enforceSize;
|
||||||
console.debug(`🫙 Bounds are telemetry are currently`, this.lastBounds);
|
|
||||||
|
|
||||||
// loop through, sort and dedupe
|
// loop through, sort and dedupe
|
||||||
for (let datum of data) {
|
for (let datum of data) {
|
||||||
@ -237,6 +239,13 @@ export default class TelemetryCollection extends EventEmitter {
|
|||||||
beforeStartOfBounds = parsedValue < this.lastBounds.start;
|
beforeStartOfBounds = parsedValue < this.lastBounds.start;
|
||||||
afterEndOfBounds = parsedValue > this.lastBounds.end;
|
afterEndOfBounds = parsedValue > this.lastBounds.end;
|
||||||
|
|
||||||
|
if (beforeStartOfBounds) {
|
||||||
|
console.debug(
|
||||||
|
`🫙 Datum is before start of bounds: ${new Date(parsedValue).toISOString()} < ${new Date(this.lastBounds.start).toISOString()}`,
|
||||||
|
this.options
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
if (
|
if (
|
||||||
!afterEndOfBounds &&
|
!afterEndOfBounds &&
|
||||||
(!beforeStartOfBounds || (this.isStrategyLatest && this.openmct.telemetry.greedyLAD()))
|
(!beforeStartOfBounds || (this.isStrategyLatest && this.openmct.telemetry.greedyLAD()))
|
||||||
@ -348,8 +357,12 @@ export default class TelemetryCollection extends EventEmitter {
|
|||||||
this.lastBounds = bounds;
|
this.lastBounds = bounds;
|
||||||
|
|
||||||
// delete start/end if they are defined in options as we've got new bounds
|
// delete start/end if they are defined in options as we've got new bounds
|
||||||
delete this.options.start;
|
if (!isTick && startChanged) {
|
||||||
delete this.options.end;
|
delete this.options.start;
|
||||||
|
}
|
||||||
|
if (!isTick && endChanged) {
|
||||||
|
delete this.options.end;
|
||||||
|
}
|
||||||
|
|
||||||
if (isTick) {
|
if (isTick) {
|
||||||
if (this.timeKey === undefined) {
|
if (this.timeKey === undefined) {
|
||||||
|
@ -110,7 +110,7 @@ export default class CompsManager extends EventEmitter {
|
|||||||
async load(telemetryOptions) {
|
async load(telemetryOptions) {
|
||||||
if (!_.isEqual(telemetryOptions, this.#telemetryOptions) && this.#loaded) {
|
if (!_.isEqual(telemetryOptions, this.#telemetryOptions) && this.#loaded) {
|
||||||
console.debug(
|
console.debug(
|
||||||
`😩 Reloading comps manager ${this.#domainObject.name} due to telemetry options change`,
|
`😩 Reloading comps manager ${this.#domainObject.name} due to telemetry options change. New bounds are: ${new Date(telemetryOptions.start).toISOString()} to ${new Date(telemetryOptions.end).toISOString()}`,
|
||||||
telemetryOptions
|
telemetryOptions
|
||||||
);
|
);
|
||||||
this.#destroy();
|
this.#destroy();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user