|
|
|
@ -34,6 +34,7 @@ import { |
|
|
|
import { |
|
|
|
AlarmFilter, |
|
|
|
ComparisonTsValue, |
|
|
|
ComplexOperation, |
|
|
|
EntityData, |
|
|
|
EntityDataPageLink, |
|
|
|
EntityFilter, |
|
|
|
@ -112,6 +113,7 @@ export interface EntityDataSubscriptionOptions { |
|
|
|
pageLink?: EntityDataPageLink; |
|
|
|
keyFilters?: Array<KeyFilter>; |
|
|
|
additionalKeyFilters?: Array<KeyFilter>; |
|
|
|
keyFiltersOperation?: ComplexOperation; |
|
|
|
subscriptionTimewindow?: SubscriptionTimewindow; |
|
|
|
latestTsOffset?: number; |
|
|
|
} |
|
|
|
@ -370,6 +372,7 @@ export class EntityDataSubscription { |
|
|
|
entityFilter: this.entityDataSubscriptionOptions.entityFilter, |
|
|
|
pageLink: this.entityDataSubscriptionOptions.pageLink, |
|
|
|
keyFilters, |
|
|
|
keyFiltersOperation: this.entityDataSubscriptionOptions.keyFiltersOperation, |
|
|
|
entityFields, |
|
|
|
latestValues: this.latestValues |
|
|
|
}; |
|
|
|
@ -494,7 +497,8 @@ export class EntityDataSubscription { |
|
|
|
} |
|
|
|
this.countCommand.query = { |
|
|
|
entityFilter: this.entityDataSubscriptionOptions.entityFilter, |
|
|
|
keyFilters |
|
|
|
keyFilters, |
|
|
|
keyFiltersOperation: this.entityDataSubscriptionOptions.keyFiltersOperation |
|
|
|
}; |
|
|
|
this.subscriber.subscriptionCommands.push(this.countCommand); |
|
|
|
|
|
|
|
@ -569,7 +573,8 @@ export class EntityDataSubscription { |
|
|
|
} |
|
|
|
this.alarmCountCommand.query = { |
|
|
|
entityFilter: this.entityDataSubscriptionOptions.entityFilter, |
|
|
|
keyFilters |
|
|
|
keyFilters, |
|
|
|
keyFiltersOperation: this.entityDataSubscriptionOptions.keyFiltersOperation |
|
|
|
}; |
|
|
|
if (this.entityDataSubscriptionOptions.alarmFilter) { |
|
|
|
this.alarmCountCommand.query = {...this.alarmCountCommand.query, ...this.entityDataSubscriptionOptions.alarmFilter}; |
|
|
|
|