webapp/packages/plugin-data-viewer/src/ResultSet/ResultSetTableFooterMenuService.ts - devel - vshmidt/cloudbeaver

webapp/packages/plugin-data-viewer/src/ResultSet/ResultSetTableFooterMenuService.ts
189 строк7 KB
Alexey Potsetsuev
dbeaver/pro#7080 refactor: grid API (#3799)
13 окт 2025, 14:30
13 окт 2025, 14:30682a387
/*
 * CloudBeaver - Cloud Database Manager
 * Copyright (C) 2020-2025 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 type { IDataContextProvider } from '@cloudbeaver/core-data-context';
import { injectable } from '@cloudbeaver/core-di';
import { NotificationService } from '@cloudbeaver/core-events';
import { ActionService, MenuService } from '@cloudbeaver/core-view';

import { DATA_CONTEXT_DV_DDM } from '../DatabaseDataModel/DataContext/DATA_CONTEXT_DV_DDM.js';
import { DATA_CONTEXT_DV_DDM_RESULT_INDEX } from '../DatabaseDataModel/DataContext/DATA_CONTEXT_DV_DDM_RESULT_INDEX.js';
import { type IDatabaseDataModel } from '../DatabaseDataModel/IDatabaseDataModel.js';
import { type IDatabaseDataOptions } from '../DatabaseDataModel/IDatabaseDataOptions.js';
import { DATA_VIEWER_DATA_MODEL_ACTIONS_MENU } from '../TableViewer/TableFooter/TableFooterMenu/DATA_VIEWER_DATA_MODEL_ACTIONS_MENU.js';
import { ACTION_COUNT_TOTAL_ELEMENTS } from './ACTION_COUNT_TOTAL_ELEMENTS.js';
import { isResultSetDataModel } from './isResultSetDataModel.js';
import { ResultSetDataSource } from './ResultSetDataSource.js';
import { IDatabaseDataMetadataAction } from '../DatabaseDataModel/Actions/IDatabaseDataMetadataAction.js';
import { IDatabaseDataConstraintAction } from '../DatabaseDataModel/Actions/IDatabaseDataConstraintAction.js';

interface IResultSetActionsMetadata {
  totalCount: {
    loading: boolean;
  };
}

@injectable(() => [ActionService, MenuService, NotificationService])
export class ResultSetTableFooterMenuService {
  constructor(
    private readonly actionService: ActionService,
    private readonly menuService: MenuService,
    private readonly notificationService: NotificationService,
  ) {}

  register() {
    this.menuService.addCreator({
      menus: [DATA_VIEWER_DATA_MODEL_ACTIONS_MENU],
      contexts: [DATA_CONTEXT_DV_DDM, DATA_CONTEXT_DV_DDM_RESULT_INDEX],
      isApplicable(context) {
        const model = context.get(DATA_CONTEXT_DV_DDM)!;
        const resultIndex = context.get(DATA_CONTEXT_DV_DDM_RESULT_INDEX)!;
        const result = model.source.getResult(resultIndex);

        return !!result;
      },
      getItems(context, items) {
        return [ACTION_COUNT_TOTAL_ELEMENTS, ...items];
      },
    });
    this.actionService.addHandler({
      id: 'result-set-data-base-handler',
      menus: [DATA_VIEWER_DATA_MODEL_ACTIONS_MENU],
      actions: [ACTION_COUNT_TOTAL_ELEMENTS],
      contexts: [DATA_CONTEXT_DV_DDM, DATA_CONTEXT_DV_DDM_RESULT_INDEX],
      isActionApplicable(context, action) {
        const model = context.get(DATA_CONTEXT_DV_DDM)! as any;

        if (!isResultSetDataModel<IDatabaseDataOptions>(model)) {
          return false;
        }

        const resultIndex = context.get(DATA_CONTEXT_DV_DDM_RESULT_INDEX)!;
        const result = model.source.getResult(resultIndex);

        if (!result) {
          return false;
        }
        const constraint = model.source.tryGetAction(resultIndex, IDatabaseDataConstraintAction);

        switch (action) {
          case ACTION_COUNT_TOTAL_ELEMENTS: {
            return !!constraint?.supported && !model.isDisabled(resultIndex);
          }
        }
        return true;
      },
      isDisabled: (context, action) => {
        const model = context.get(DATA_CONTEXT_DV_DDM)! as unknown as IDatabaseDataModel<ResultSetDataSource>;
        const resultIndex = context.get(DATA_CONTEXT_DV_DDM_RESULT_INDEX)!;

        if (model.isLoading() || model.isDisabled(resultIndex) || !model.source.getResult(resultIndex)) {
          return true;
        }

        switch (action) {
          case ACTION_COUNT_TOTAL_ELEMENTS: {
            const metadata = this.getState(context);

            return metadata.totalCount.loading && Boolean(model.source.totalCountRequestTask?.cancelled);
          }
        }

        return false;
      },
      isLoading: (context, action) => {
        const metadata = this.getState(context);

        switch (action) {
          case ACTION_COUNT_TOTAL_ELEMENTS: {
            return metadata.totalCount.loading;
          }
        }

        return false;
      },
      getActionInfo: (context, action) => {
        const model = context.get(DATA_CONTEXT_DV_DDM)! as unknown as IDatabaseDataModel<ResultSetDataSource>;
        const resultIndex = context.get(DATA_CONTEXT_DV_DDM_RESULT_INDEX)!;
        const metadata = this.getState(context);

        switch (action) {
          case ACTION_COUNT_TOTAL_ELEMENTS: {
            const result = model.source.getResult(resultIndex);
            if (!result) {
              return action.info;
            }

            let label = action.info.label;
            let icon = action.info.icon;

            if (metadata.totalCount.loading) {
              const cancelling = Boolean(model.source.totalCountRequestTask?.cancelled);
              label = cancelling ? 'ui_processing_canceling' : 'ui_processing_cancel';
              icon = 'cross';
            } else {
              const currentCount = result.loadedFully ? result.count : `${result.count}+`;
              label = String(result.totalCount ?? currentCount);
            }

            return { ...action.info, label, icon };
          }
        }

        return action.info;
      },
      handler: async (context, action) => {
        const model = context.get(DATA_CONTEXT_DV_DDM)! as unknown as IDatabaseDataModel<ResultSetDataSource>;
        const resultIndex = context.get(DATA_CONTEXT_DV_DDM_RESULT_INDEX)!;
        const metadata = this.getState(context);

        switch (action) {
          case ACTION_COUNT_TOTAL_ELEMENTS: {
            if (metadata.totalCount.loading) {
              if (model.source.totalCountRequestTask?.cancelled) {
                // Cancel request
                return;
              }

              try {
                await model.source.cancelLoadTotalCount();
              } catch (e: any) {
                if (!model.source.totalCountRequestTask?.cancelled) {
                  this.notificationService.logException(e);
                }
              }
            } else {
              try {
                metadata.totalCount.loading = true;
                await model.source.loadTotalCount(resultIndex);
              } catch (exception: any) {
                if (model.source.totalCountRequestTask?.cancelled) {
                  this.notificationService.logInfo({
                    title: 'data_viewer_total_count_canceled_title',
                    message: 'data_viewer_total_count_canceled_message',
                  });
                } else {
                  this.notificationService.logException(exception, 'data_viewer_total_count_failed');
                }
              } finally {
                metadata.totalCount.loading = false;
              }
            }
            break;
          }
        }
      },
    });
  }

  private getState(context: IDataContextProvider) {
    const model = context.get(DATA_CONTEXT_DV_DDM)!;
    const resultIndex = context.get(DATA_CONTEXT_DV_DDM_RESULT_INDEX)!;
    const metadataAction = model.source.getAction(resultIndex, IDatabaseDataMetadataAction);
    return metadataAction.get<IResultSetActionsMetadata>('result-set-database-metadata', () => ({ totalCount: { loading: false } }));
  }
}