Fix pagination on timewindow updated

@@ -67,7 +67,7 @@ import {
   KeyFilter,
   KeyFilter,
   updateDatasourceFromEntityInfo
   updateDatasourceFromEntityInfo
 } from '@shared/models/query/query.models';
 } from '@shared/models/query/query.models';
-import { filter, map, switchMap, takeUntil } from 'rxjs/operators';
+import { distinct, filter, map, switchMap, takeUntil } from 'rxjs/operators';
 import { AlarmDataListener } from '@core/api/alarm-data.service';
 import { AlarmDataListener } from '@core/api/alarm-data.service';
 import { RpcStatus } from '@shared/models/rpc.models';
 import { RpcStatus } from '@shared/models/rpc.models';
 
 
@@ -139,6 +139,11 @@ export class WidgetSubscription implements IWidgetSubscription {
   executingSubjects: Array<Subject<any>>;
   executingSubjects: Array<Subject<any>>;
 
 
   subscribed = false;
   subscribed = false;
+  widgetTimewindowChangedSubject: Subject<WidgetTimewindow> = new ReplaySubject<WidgetTimewindow>();
+
+  widgetTimewindowChanged = this.widgetTimewindowChangedSubject.asObservable().pipe(
+    distinct()
+  );
 
 
   constructor(subscriptionContext: WidgetSubscriptionContext, public options: WidgetSubscriptionOptions) {
   constructor(subscriptionContext: WidgetSubscriptionContext, public options: WidgetSubscriptionOptions) {
     const subscriptionSubject = new ReplaySubject<IWidgetSubscription>();
     const subscriptionSubject = new ReplaySubject<IWidgetSubscription>();
@@ -805,6 +810,7 @@ export class WidgetSubscription implements IWidgetSubscription {
 
 
   update(isTimewindowTypeChanged = false) {
   update(isTimewindowTypeChanged = false) {
     if (this.type !== widgetType.rpc) {
     if (this.type !== widgetType.rpc) {
+      this.widgetTimewindowChangedSubject.next(this.timeWindowConfig);
       if (this.type === widgetType.alarm) {
       if (this.type === widgetType.alarm) {
         this.updateAlarmDataSubscription();
         this.updateAlarmDataSubscription();
       } else {
       } else {

@@ -139,6 +139,7 @@ export class TimeseriesTableWidgetComponent extends PageComponent implements OnI
   private rowStylesInfo: RowStyleInfo;
   private rowStylesInfo: RowStyleInfo;
 
 
   private subscriptions: Subscription[] = [];
   private subscriptions: Subscription[] = [];
+  private widgetTimewindowChangedSubscription: Subscription;
 
 
   private searchAction: WidgetAction = {
   private searchAction: WidgetAction = {
     name: 'action.search',
     name: 'action.search',
@@ -169,6 +170,23 @@ export class TimeseriesTableWidgetComponent extends PageComponent implements OnI
     this.datasources = this.ctx.datasources;
     this.datasources = this.ctx.datasources;
     this.initialize();
     this.initialize();
     this.ctx.updateWidgetParams();
     this.ctx.updateWidgetParams();
+
+    this.widgetTimewindowChangedSubscription = this.ctx.defaultSubscription.widgetTimewindowChanged.subscribe(
+      () => {
+        this.sources.forEach((source) => {
+          if (this.displayPagination) {
+            source.pageLink.page = 0;
+          }
+        });
+      }
+    );
+  }
+
+  ngOnDestroy(): void {
+    if (this.widgetTimewindowChangedSubscription) {
+      this.widgetTimewindowChangedSubscription.unsubscribe();
+      this.widgetTimewindowChangedSubscription = null;
+    }
   }
   }
 
 
   ngAfterViewInit(): void {
   ngAfterViewInit(): void {