import { of, Subject } from 'rxjs';
import { mergeMap } from 'rxjs/operators';

export class PageSubscriber {
  private static _pageUpdated = new Subject<{
    pageId: string;
    value: boolean | any;
  }>();
  private static _pageUpdatedTrigger = () =>
    PageSubscriber._pageUpdated.asObservable();

  static refresh(options: any) {
    return PageSubscriber._pageUpdated.next(options);
  }
  static onRefresh() {
    return PageSubscriber._pageUpdatedTrigger().pipe(
      mergeMap((value) => {
        return of(value);
      })
    );
  }

  private static _clearEditorBar = new Subject<any>();
  private static _clearEditorBarTrigger = () =>
    PageSubscriber._clearEditorBar.asObservable();

  static clearEditorBar() {
    return PageSubscriber._clearEditorBar.next(undefined);
  }

  static onClearEditorBar() {
    return PageSubscriber._clearEditorBarTrigger();
  }
}