webapp/packages/plugin-object-viewer/src/ObjectPage/DBObjectPageService.ts - devel - vshmidt/cloudbeaver

webapp/packages/plugin-object-viewer/src/ObjectPage/DBObjectPageService.ts
120 строк3 KB
Alexey
refactor: migrate to pure esm CB-5684 (#2929)
21 сен 2024, 07:06
21 сен 2024, 07:066ad1488
/*
 * CloudBeaver - Cloud Database Manager
 * Copyright (C) 2020-2024 DBeaver Corp and others
 *
 * Licensed under the Apache License, Version 2.0.
 * you may not use this file except in compliance with the License.
 */
import { action, computed, makeObservable, observable } from 'mobx';

import { injectable } from '@cloudbeaver/core-di';
import type { ITab } from '@cloudbeaver/plugin-navigation-tabs';

import type { IObjectViewerTabState } from '../IObjectViewerTabState.js';
import { ObjectPage, type ObjectPageCallback, type ObjectPageOptions } from './ObjectPage.js';

@injectable()
export class DBObjectPageService {
  pages = new Map<string, ObjectPage<any>>();

  constructor() {
    makeObservable(this, {
      pages: observable,
      orderedPages: computed,
      register: action,
      selectPage: action.bound,
    });
  }

  get orderedPages(): Array<ObjectPage<any>> {
    return Array.from(this.pages.values()).sort(this.comparePages.bind(this));
  }

  register<T>(options: ObjectPageOptions<T>): ObjectPage<T> {
    const objectPage = new ObjectPage(options);
    this.pages.set(options.key, objectPage);
    return objectPage;
  }

  getPage<T>(pageId: string): ObjectPage<T> | undefined {
    return this.pages.get(pageId);
  }

  getPageState<T>(tab: ITab<IObjectViewerTabState>, page: ObjectPage<T> | string): T | undefined {
    const pageKey = typeof page === 'string' ? page : page.key;

    return tab.handlerState.pagesState[pageKey];
  }

  canSwitchPage(currentPage: ObjectPage<any>, page: ObjectPage<any>): boolean {
    if ((currentPage.priority || 0) < page.priority) {
      return true;
    }
    return false;
  }

  trySwitchPage<T>(tab: ITab<IObjectViewerTabState>, page: ObjectPage<T>, state?: T): boolean {
    const currentPage = this.getPage(tab.handlerState.pageId);

    const canSwitch = !currentPage || this.canSwitchPage(currentPage, page);

    if (canSwitch) {
      this.selectPage(tab, page, state);
      return true;
    }
    return false;
  }

  selectPage<T>(tab: ITab<IObjectViewerTabState>, page: ObjectPage<T>, state?: T): void {
    tab.handlerState.pageId = page.key;

    if (state !== undefined) {
      tab.handlerState.pagesState[page.key] = state;
    }

    this.callHandlerCallback(tab, page => page.onSelect);
  }

  async restorePages(tab: ITab<IObjectViewerTabState>): Promise<boolean> {
    for (const page of this.pages.values()) {
      if (page.onRestore && !(await page.onRestore(tab, this.getPageState(tab, page)))) {
        return false;
      }
    }
    return true;
  }

  async canClosePages(tab: ITab<IObjectViewerTabState>): Promise<boolean> {
    for (const page of this.pages.values()) {
      const state = await page.canClose?.(tab, this.getPageState(tab, page));

      if (state === false) {
        return false;
      }
    }

    return true;
  }

  async closePages(tab: ITab<IObjectViewerTabState>) {
    await this.callHandlerCallback(tab, page => page.onClose);
  }

  private async callHandlerCallback<T>(tab: ITab<IObjectViewerTabState>, selector: (page: ObjectPage<T>) => ObjectPageCallback<T> | undefined) {
    for (const page of this.pages.values()) {
      const callback = selector(page);
      if (callback) {
        callback.call(page, tab, this.getPageState(tab, page));
      }
    }
  }

  private comparePages(pageA: ObjectPage, pageB: ObjectPage) {
    return this.getPageOrder(pageA) - this.getPageOrder(pageB);
  }

  private getPageOrder(page: ObjectPage) {
    // TODO: can be configurable later
    return page.order || Number.MAX_SAFE_INTEGER;
  }
}