#Referência da API

#Lado do servidor

As APIs disponíveis na estrutura do pacote do lado do servidor são mostradas no código a seguir:

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

#PluginWorkflowServer

Classe do plugin de fluxo de trabalho.

Geralmente, durante a execução do aplicativo, você pode chamar app.pm.get<PluginWorkflowServer>(PluginWorkflowServer) em qualquer lugar onde possa obter a instância do aplicativo app para acessar a instância do plugin de fluxo de trabalho (referida como plugin abaixo).

#registerTrigger()

Estende e registra um novo tipo de gatilho.

Assinatura

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

Parâmetros

Exemplo

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

function handler(this: MyTrigger, workflow: WorkflowModel, message: string) {
  // aciona o fluxo de trabalho
  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);
    // escuta algum evento para acionar o fluxo de trabalho
    process.on(
      'message',
      this.messageHandlers.set(workflow.id, messageHandler),
    );
  }

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

export default class MyPlugin extends Plugin {
  load() {
    // obtém a instância do plugin de fluxo de trabalho
    const workflowPlugin =
      this.app.pm.get<PluginWorkflowServer>(PluginWorkflowServer);

    // registra o gatilho
    workflowPlugin.registerTrigger('myTrigger', MyTrigger);
  }
}

#registerInstruction()

Estende e registra um novo tipo de nó.

Assinatura

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

Parâmetros

Exemplo

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() {
    // obtém a instância do plugin de fluxo de trabalho
    const workflowPlugin = this.app.pm.get<PluginWorkflowServer>(PluginWorkflowServer);

    // registra a instrução
    workflowPlugin.registerInstruction('log', LogInstruction);
  }
}

#trigger()

Aciona um fluxo de trabalho específico. Usado principalmente em gatilhos personalizados para acionar o fluxo de trabalho correspondente quando um evento personalizado específico é detectado.

Assinatura

trigger(workflow: Workflow, context: any)

Parâmetros

Exemplo

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

class MyTrigger extends Trigger {
  timer: NodeJS.Timeout;

  on(workflow) {
    // registra o evento
    this.timer = setInterval(() => {
      // aciona o fluxo de trabalho
      this.plugin.trigger(workflow, { date: new Date() });
    }, workflow.config.interval ?? 60000);
  }
}

#resume()

Retoma a execução de um fluxo de trabalho em espera com uma tarefa de nó específica.

• Apenas fluxos de trabalho no estado de espera (EXECUTION_STATUS.STARTED) podem ser retomados.
• Apenas tarefas de nó no estado pendente (JOB_STATUS.PENDING) podem ser retomadas.

Assinatura

resume(job: JobModel)

Parâmetros

Exemplo

Veja os detalhes no código-fonte.

#Trigger

A classe base para gatilhos, usada para estender tipos de gatilhos personalizados.

on/off são usados para registrar/desregistrar listeners de eventos quando um fluxo de trabalho é ativado/desativado. O parâmetro passado é a instância do fluxo de trabalho correspondente ao gatilho, que pode ser processado de acordo com a configuração. Alguns tipos de gatilho que já possuem eventos escutados globalmente podem não precisar implementar esses dois métodos. Por exemplo, em um gatilho agendado, você pode registrar um temporizador em on e desregistrá-lo em off.

#Instruction

A classe base para tipos de instrução, usada para estender tipos de instrução 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, você pode consultar a implementação do nó de loop, que é usada para fornecer o conteúdo da variável local para as ramificações.

#EXECUTION_STATUS

Uma tabela de constantes para os status do plano de execução do fluxo de trabalho, usada para identificar o status atual do plano de execução correspondente.

Exceto pelos três primeiros, todos os outros representam um estado de falha, mas podem ser usados para descrever diferentes motivos de falha.

#JOB_STATUS

Uma tabela de constantes para os status das tarefas de nó do fluxo de trabalho, usada para identificar o status atual da tarefa de nó correspondente. O status gerado pelo nó também afeta o status de todo o plano de execução.

#Lado do cliente

As APIs disponíveis na estrutura do pacote do lado do cliente são mostradas no código a seguir:

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

#PluginWorkflowClient

#registerTrigger()

Registra o painel de configuração para o tipo de gatilho.

Assinatura

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

Parâmetros

#registerInstruction()

Registra o painel de configuração para o tipo de nó.

Assinatura

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

Parâmetros

#registerInstructionGroup()

Registra um grupo de tipos de nó. O NocoBase oferece 4 grupos de tipos de nó padrão:

• 'control': Controle
• 'collection': Operações de coleção
• 'manual': Processamento manual
• 'extended': Outras extensões

Se você precisar estender outros grupos, pode usar este método para registrá-los.

Assinatura

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

Parâmetros

Exemplo

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

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

#Trigger

A classe base para gatilhos, usada para estender tipos de gatilhos personalizados.

• Se useVariables não for definido, significa que este tipo de gatilho não oferece uma função de recuperação de valor, e os dados de contexto do gatilho não podem ser selecionados nos nós do fluxo de trabalho.

#Instruction

A classe base para instruções, usada para estender tipos de nós personalizados.

Tipos Relacionados

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

• Se useVariables não for definido, significa que este tipo de nó não oferece uma função de recuperação de valor, e os dados de resultado deste tipo de nó não podem ser selecionados nos nós do fluxo de trabalho. Se o valor do resultado for singular (não selecionável), você pode retornar um conteúdo estático que expresse a informação correspondente (consulte: código-fonte do nó de cálculo). Se for necessário que seja selecionável (por exemplo, uma propriedade de um Objeto), você pode personalizar a saída do componente de seleção correspondente (consulte: código-fonte do nó de criação de dados).
• Component é um componente de renderização personalizado para o nó. Quando a renderização padrão do nó não é suficiente, ele pode ser completamente substituído para uma renderização de visualização de nó personalizada. Por exemplo, se você precisar fornecer mais botões de ação ou outras interações para o nó inicial de um tipo de ramificação, você usaria este método (consulte: código-fonte da ramificação paralela).
• useInitializers é usado para fornecer um método para inicializar blocos. Por exemplo, em um nó manual, você pode inicializar blocos de usuário relacionados com base nos nós upstream. Se este método for fornecido, ele estará disponível ao inicializar blocos na configuração da interface do nó manual (consulte: código-fonte do nó de criação de dados).
• isAvailable é usado principalmente para determinar se um nó pode ser usado (adicionado) no ambiente atual. O ambiente atual inclui o fluxo de trabalho atual, nós upstream e o índice da ramificação atual.