#Referencia de la API

#Lado del servidor

Las APIs disponibles en la estructura del paquete del lado del servidor se muestran en el siguiente código:

import PluginWorkflowServer, {
  Trigger,
  Instruction,
  EXECUTION_STATUS,
  JOB_STATUS,
} from '@nocobase/plugin-workflow';

#PluginWorkflowServer

Clase del plugin de flujo de trabajo.

Normalmente, durante la ejecución de la aplicación, puede obtener la instancia del plugin de flujo de trabajo (referida como plugin a continuación) llamando a app.pm.get<PluginWorkflowServer>(PluginWorkflowServer) desde cualquier lugar donde pueda acceder a la instancia de la aplicación app.

#registerTrigger()

Permite extender y registrar un nuevo tipo de disparador.

Firma

registerTrigger(type: string, trigger: typeof Trigger | Trigger })

Parámetros

Ejemplo

import PluginWorkflowServer, { Trigger } from '@nocobase/plugin-workflow';

function handler(this: MyTrigger, workflow: WorkflowModel, message: string) {
  // trigger workflow
  this.workflow.trigger(workflow, { data: message.data });
}

class MyTrigger extends Trigger {
  messageHandlers: Map<number, WorkflowModel> = new Map();
  on(workflow: WorkflowModel) {
    const messageHandler = handler.bind(this, workflow);
    // listen some event to trigger workflow
    process.on(
      'message',
      this.messageHandlers.set(workflow.id, messageHandler),
    );
  }

  off(workflow: WorkflowModel) {
    const messageHandler = this.messageHandlers.get(workflow.id);
    // remove listener
    process.off('message', messageHandler);
  }
}

export default class MyPlugin extends Plugin {
  load() {
    // get workflow plugin instance
    const workflowPlugin =
      this.app.pm.get<PluginWorkflowServer>(PluginWorkflowServer);

    // register trigger
    workflowPlugin.registerTrigger('myTrigger', MyTrigger);
  }
}

#registerInstruction()

Permite extender y registrar un nuevo tipo de nodo.

Firma

registerInstruction(type: string, instruction: typeof Instruction | Instruction })

Parámetros

Ejemplo

import PluginWorkflowServer, { Instruction, JOB_STATUS } from '@nocobase/plugin-workflow';

class LogInstruction extends Instruction {
  run(node, input, processor) {
    console.log('my instruction runs!');
    return {
      status: JOB_STATUS.RESOVLED,
    };
  },
};

export default class MyPlugin extends Plugin {
  load() {
    // get workflow plugin instance
    const workflowPlugin = this.app.pm.get<PluginWorkflowServer>(PluginWorkflowServer);

    // register instruction
    workflowPlugin.registerInstruction('log', LogInstruction);
  }
}

#trigger()

Dispara un flujo de trabajo específico. Se utiliza principalmente en disparadores personalizados para activar el flujo de trabajo correspondiente cuando se detecta un evento personalizado específico.

Firma

trigger(workflow: Workflow, context: any)

Parámetros

Ejemplo

import { Trigger } from '@nocobase/plugin-workflow';

class MyTrigger extends Trigger {
  timer: NodeJS.Timeout;

  on(workflow) {
    // register event
    this.timer = setInterval(() => {
      // trigger workflow
      this.plugin.trigger(workflow, { date: new Date() });
    }, workflow.config.interval ?? 60000);
  }
}

#resume()

Reanuda la ejecución de un flujo de trabajo en espera con una tarea de nodo específica.

• Solo los flujos de trabajo en estado de espera (EXECUTION_STATUS.STARTED) pueden reanudarse.
• Solo las tareas de nodo en estado pendiente (JOB_STATUS.PENDING) pueden reanudarse.

Firma

resume(job: JobModel)

Parámetros

Ejemplo

Consulte el código fuente para más detalles.

#Trigger

Clase base para disparadores, utilizada para extender tipos de disparadores personalizados.

on/off se utilizan para registrar/desregistrar oyentes de eventos cuando un flujo de trabajo se habilita/deshabilita. El parámetro pasado es la instancia del flujo de trabajo correspondiente al disparador, que puede procesarse según la configuración. Algunos tipos de disparadores que ya tienen eventos escuchados globalmente pueden no necesitar implementar estos dos métodos. Por ejemplo, en un disparador programado, puede registrar un temporizador en on y desregistrarlo en off.

#Instruction

Clase base para tipos de instrucción, utilizada para extender tipos de instrucción personalizados.

Tipos relacionados

export type Job =
  | {
      status: JOB_STATUS[keyof JOB_STATUS];
      result?: unknown;
      [key: string]: unknown;
    }
  | JobModel
  | null;

export type InstructionResult = Job | Promise<Job>;

export type Runner = (
  node: FlowNodeModel,
  input: JobModel,
  processor: Processor,
) => InstructionResult;

export class Instruction {
  run: Runner;
  resume?: Runner;
}

Para getScope, puede consultar la implementación del nodo de bucle, que se utiliza para proporcionar contenido de variables locales para las ramas.

#EXECUTION_STATUS

Tabla de constantes para los estados del plan de ejecución del flujo de trabajo, utilizada para identificar el estado actual del plan de ejecución correspondiente.

Excepto por los tres primeros, todos los demás representan un estado de fallo, pero pueden usarse para describir diferentes motivos de fallo.

#JOB_STATUS

Tabla de constantes para los estados de las tareas de los nodos del flujo de trabajo, utilizada para identificar el estado actual de la tarea del nodo correspondiente. El estado generado por el nodo también afecta el estado de todo el plan de ejecución.

#Lado del cliente

Las APIs disponibles en la estructura del paquete del lado del cliente se muestran en el siguiente código:

import PluginWorkflowClient, {
  Trigger,
  Instruction,
} from '@nocobase/plugin-workflow/client';

#PluginWorkflowClient

#registerTrigger()

Registra el panel de configuración correspondiente al tipo de disparador.

Firma

registerTrigger(type: string, trigger: typeof Trigger | Trigger): void

Parámetros

#registerInstruction()

Registra el panel de configuración correspondiente al tipo de nodo.

Firma

registerInstruction(type: string, instruction: typeof Instruction | Instruction): void

Parámetros

#registerInstructionGroup()

Registra un grupo de tipos de nodo. NocoBase proporciona 4 grupos de tipos de nodo por defecto:

• 'control': Clases de control
• 'collection': Operaciones de colección
• 'manual': Procesamiento manual
• 'extended': Otras extensiones

Si necesita extender otros grupos, puede utilizar este método para registrarlos.

Firma

registerInstructionGroup(type: string, group: { label: string }): void

Parámetros

Ejemplo

export default class YourPluginClient extends Plugin {
  load() {
    const pluginWorkflow = this.app.pm.get(PluginWorkflowClient);

    pluginWorkflow.registerInstructionGroup('ai', { label: `{{t("AI", { ns: "${NAMESPACE}" })}}` });
  }
}

#Trigger

Clase base para disparadores, utilizada para extender tipos de disparadores personalizados.

• Si useVariables no está configurado, significa que este tipo de disparador no proporciona una función de recuperación de valores, y los datos de contexto del disparador no se pueden seleccionar en los nodos del flujo.

#Instruction

Clase base para instrucciones, utilizada para extender tipos de nodos personalizados.

Tipos relacionados

export type NodeAvailableContext = {
  workflow: object;
  upstream: object;
  branchIndex: number;
};

• Si useVariables no está configurado, significa que este tipo de nodo no proporciona una función de recuperación de valores, y los datos de resultado de este tipo de nodo no se pueden seleccionar en los nodos del flujo. Si el valor resultante es único (no seleccionable), puede devolver un contenido estático que exprese la información correspondiente (consulte: código fuente del nodo de cálculo). Si necesita que sea seleccionable (por ejemplo, una propiedad de un objeto), puede personalizar la salida del componente de selección correspondiente (consulte: código fuente del nodo de creación de datos).
• Component es un componente de renderizado personalizado para el nodo. Cuando el renderizado predeterminado del nodo no es suficiente, puede anularlo y usarlo completamente para un renderizado de vista de nodo personalizado. Por ejemplo, si necesita proporcionar más botones de acción u otras interacciones para el nodo de inicio de un tipo de rama, deberá usar este método (consulte: código fuente de la rama paralela).
• useInitializers se utiliza para proporcionar un método para inicializar bloques. Por ejemplo, en un nodo manual, puede inicializar bloques de usuario relacionados basándose en los nodos anteriores. Si se proporciona este método, estará disponible al inicializar bloques en la configuración de la interfaz del nodo manual (consulte: código fuente del nodo de creación de datos).
• isAvailable se utiliza principalmente para determinar si un nodo puede usarse (añadirse) en el entorno actual. El entorno actual incluye el flujo de trabajo actual, los nodos anteriores y el índice de la rama actual.