manifold-workflow-engine/lib.js

// Simulated LLM Service
/**
 * Simulates a Large Language Model (LLM) service for intent detection.
 */
export class DummyLlmService {
  /**
   * Queries the simulated LLM with a prompt.
   * @param {string} prompt - The input prompt to query the LLM.
   * @returns {Promise<{confidence: number, action: string}>} - The detected intent with confidence and action.
   */
  async query(prompt) {
    const intents = {
      analyze: { confidence: 0.9, action: 'analysis' },
      process: { confidence: 0.8, action: 'processing' },
      transform: { confidence: 0.7, action: 'transformation' },
    };

    const matchedIntent = Object.entries(intents).find(([key]) =>
      prompt.toLowerCase().includes(key),
    );

    return matchedIntent ? matchedIntent[1] : { confidence: 0.1, action: 'unknown' };
  }
}

// Interface for workflow operators
/**
 * Represents a workflow operator responsible for performing a specific operation.
 */
export class WorkflowOperator {
  /**
   * Creates an instance of WorkflowOperator.
   * @param {string} name - The name of the operator.
   * @param {function(object): Promise<object>} operation - The operation function executed by the operator.
   */
  constructor(name, operation) {
    this.name = name;
    this.operation = operation;
  }

  /**
   * Executes the operator's operation with the given state.
   * @param {object} state - The current state to be processed.
   * @returns {Promise<object>} - The updated state after the operation.
   */
  async execute(state) {
    return await this.operation(state);
  }
}

// Interface for manifold regions
/**
 * Represents a region within the manifold, containing workflow operators.
 */
export class ManifoldRegion {
  /**
   * Creates an instance of ManifoldRegion.
   * @param {string} name - The name of the region.
   * @param {WorkflowOperator[]} [operators=[]] - The operators available in this region.
   */
  constructor(name, operators = []) {
    this.name = name;
    this.operators = operators;
    this.adjacentRegions = new Set();
  }

  /**
   * Adds an operator to the region.
   * @param {WorkflowOperator} operator - The operator to be added.
   */
  addOperator(operator) {
    this.operators.push(operator);
  }

  /**
   * Establishes a connection to another region.
   * @param {ManifoldRegion} region - The region to connect to.
   */
  connectTo(region) {
    this.adjacentRegions.add(region);
    region.adjacentRegions.add(this);
  }

  /**
   * Retrieves valid operators for the given state.
   * @param {object} _state - The current state.
   * @returns {Promise<WorkflowOperator[]>} - The list of valid operators.
   */
  async getValidOperators(_state) {
    return this.operators;
  }
}

// Main manifold implementation
/**
 * Represents the workflow function manifold managing regions and state transitions.
 */
export class WorkflowFunctionManifold {
  /**
   * Creates an instance of WorkflowFunctionManifold.
   * @param {DummyLlmService} llmService - The LLM service used for intent detection.
   */
  constructor(llmService) {
    this.llmService = llmService;
    this.regions = new Map();
    this.currentRegion = null;
    this.state = {};
  }

  /**
   * Adds a region to the manifold.
   * @param {ManifoldRegion} region - The region to be added.
   */
  addRegion(region) {
    this.regions.set(region.name, region);
    if (!this.currentRegion) {
      this.currentRegion = region;
    }
  }

  /**
   * Navigates to the next region based on the provided prompt.
   * @param {string} prompt - The input prompt for intent matching.
   * @returns {Promise<boolean>} - Whether navigation was successful.
   */
  async navigate(prompt) {
    try {
      const intent = await this.llmService.query(prompt);

      const nextRegion = Array.from(this.currentRegion.adjacentRegions).find(region =>
        region.name.toLowerCase().includes(intent.action),
      );

      if (nextRegion && intent.confidence > 0.5) {
        this.currentRegion = nextRegion;
        return true;
      }
      console.warn(`No valid region found for prompt: "${prompt}"`);
      return false;
    } catch (error) {
      console.error(`Error during navigation for prompt "${prompt}":`, error);
      return false;
    }
  }

  /**
   * Executes the workflow based on the current region and provided prompt.
   * @param {string} prompt - The input prompt for intent matching.
   * @returns {Promise<boolean>} - Whether the workflow execution was successful.
   */
  async executeWorkflow(prompt) {
    try {
      const operators = await this.currentRegion.getValidOperators(this.state);
      const intent = await this.llmService.query(prompt);

      const matchedOperator = operators.find(op => op.name.toLowerCase().includes(intent.action));

      if (matchedOperator) {
        this.state = await matchedOperator.execute(this.state);
        return true;
      }
      console.warn(`No matching operator found for intent: ${intent.action}`);
      return false;
    } catch (error) {
      console.error(`Error during workflow execution for prompt "${prompt}":`, error);
      return false;
    }
  }
}