Function graphOperator

agent-flow/src/data/GraphOperator.js:18–233

(graphString)

 * @return {{}} 画布操纵器对象.
 */
const graphOperator = (graphString) => {
  const self = {};
  const graph = JSON.parse(graphString);
  const shapes = graph.pages[0].shapes;

  /**
   * 获取配置信息.
   *
   * @param keys 键值数组.
   * @return {{}|*|null} 配置信息.
   */
  self.getConfig = (keys) => {
    const config = getConfigByKeys(keys);
    return config ? configToStruct(config) : null;
  };

  const getInputParams = (shape) => {
    if (shape.type === 'startNodeStart') {
      return shape.flowMeta.inputParams;
    } else if (shape.type === 'endNodeEnd') {
      return shape.flowMeta.callback.converter.entity.inputParams;
    } else {
      return shape.flowMeta.jober.converter.entity.inputParams;
    }
  };

  const getConfigByKeys = (keys) => {
    if (!Array.isArray(keys)) {
      throw new Error('Expected keys to be an array');
    }

    if (keys.length === 0) {
      return null;
    }

    const tmpKeys = [...keys];
    const shapeId = tmpKeys.shift();
    const shape = getShapeById(shapeId);
    const inputParams = getInputParams(shape);
    if (!inputParams) {
      throw new Error('Expected inputParams exists');
    }
    let config = {type: DATA_TYPES.OBJECT, value: inputParams};
    while (tmpKeys.length > 0 && config && config.value) {
      const key = tmpKeys.shift();
      config = config.value.find(v => v.name === key);
    }
    return config;
  };

  const getShapeById = (shapeId) => {
    return shapes.find((shape) => shape.id === shapeId);
  };

  /**
   * 修改配置.
   *
   * @param keys 键值数组.