webapp/packages/core-executor/src/ExecutorHandlersCollection.ts - devel - vshmidt/cloudbeaver

webapp/packages/core-executor/src/ExecutorHandlersCollection.ts
137 строк5 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 { makeObservable, observable } from 'mobx';

import type { IAsyncContextLoader, IContextLoader, ISyncContextLoader } from './IExecutionContext.js';
import type { IExecutorHandler } from './IExecutorHandler.js';
import type { ExecutorDataFilter, ExecutorDataMap, IChainLink, IExecutorHandlersCollection } from './IExecutorHandlersCollection.js';

export class ExecutorHandlersCollection<T = void, TResult = any | Promise<any>> implements IExecutorHandlersCollection<T, TResult> {
  handlers: Array<IExecutorHandler<T, TResult>>;
  postHandlers: Array<IExecutorHandler<T, TResult>>;
  chain: Array<IChainLink<T, TResult>>;

  get isEmpty(): boolean {
    return this.handlers.length === 0 && this.postHandlers.length === 0 && this.chain.length === 0;
  }

  readonly contextCreators: Map<IContextLoader<any, T>, IContextLoader<any, T>>;
  readonly collections: Array<IExecutorHandlersCollection<T, TResult>>;
  protected initialDataGetter: (() => T) | null;
  private readonly links: Map<IExecutorHandlersCollection<any, TResult>, IExecutorHandlersCollection<T, TResult>>;

  constructor() {
    this.links = new Map();
    this.contextCreators = new Map();
    this.collections = [];
    this.initialDataGetter = null;
    this.handlers = [];
    this.postHandlers = [];
    this.chain = [];

    makeObservable<this, 'links'>(this, {
      handlers: observable.shallow,
      postHandlers: observable.shallow,
      chain: observable.shallow,
      collections: observable.shallow,
      links: observable.shallow,
    });
  }

  addContextCreator<TContext>(context: ISyncContextLoader<TContext, T>, creator: ISyncContextLoader<TContext, T>): this;
  addContextCreator<TContext>(context: IAsyncContextLoader<TContext, T>, creator: IAsyncContextLoader<TContext, T>): this;
  addContextCreator<TContext>(context: IContextLoader<TContext, T>, creator: IContextLoader<TContext, T>): this {
    this.contextCreators.set(context, creator);
    return this;
  }

  setInitialDataGetter(getter: (() => T) | null): this {
    this.initialDataGetter = getter;
    return this;
  }

  addCollection(collection: IExecutorHandlersCollection<T, TResult>): this {
    this.collections.push(collection);
    return this;
  }

  for(link: IExecutorHandlersCollection<any, TResult>): IExecutorHandlersCollection<T, TResult> {
    if (!this.links.has(link)) {
      this.links.set(link, new ExecutorHandlersCollection());
    }

    return this.links.get(link)!;
  }

  getLinkHandlers(link: IExecutorHandlersCollection<any, TResult>): IExecutorHandlersCollection<T, TResult> | undefined {
    return this.links.get(link);
  }

  before<TNext>(executor: IExecutorHandlersCollection<TNext, TResult>, map?: ExecutorDataMap<T, TNext>, filter?: ExecutorDataFilter<T>): this {
    this.chain.push({
      executor,
      map,
      filter,
      type: 'before',
    });
    return this;
  }

  removeBefore(executor: IExecutorHandlersCollection<any, TResult>): void {
    this.chain = this.chain.filter(link => link.executor !== executor || link.type !== 'before');
  }

  next<TNext>(executor: IExecutorHandlersCollection<TNext, TResult>, map?: ExecutorDataMap<T, TNext>, filter?: ExecutorDataFilter<T>): this {
    this.chain.push({
      executor,
      map,
      filter,
      type: 'next',
    });
    return this;
  }

  removeNext(executor: IExecutorHandlersCollection<any, TResult>): void {
    this.chain = this.chain.filter(link => link.executor !== executor || link.type !== 'next');
  }

  hasHandler(handler: IExecutorHandler<T, TResult>): boolean {
    return this.handlers.includes(handler);
  }

  addHandler(handler: IExecutorHandler<T, TResult>): this {
    if (this.hasHandler(handler)) {
      return this;
    }
    this.handlers.push(handler);
    this.executeHandlerWithInitialData(handler);
    return this;
  }

  removeHandler(handler: IExecutorHandler<T, TResult>): void {
    this.handlers = this.handlers.filter(h => h !== handler);
  }

  addPostHandler(handler: IExecutorHandler<T, TResult>): this {
    if (this.postHandlers.includes(handler)) {
      return this;
    }
    this.postHandlers.push(handler);
    return this;
  }

  removePostHandler(handler: IExecutorHandler<T, TResult>): void {
    this.postHandlers = this.postHandlers.filter(h => h !== handler);
  }

  protected executeHandlerWithInitialData(handler: IExecutorHandler<T, TResult>) {
    if (!this.initialDataGetter) {
      return;
    }
  }
}