Nodes

​

O que é um Node?

• Recebe dados do contexto de execução
• Executa uma ação específica
• Pode modificar o contexto
• Pode pausar a execução (nodes pausáveis)
• Retorna um resultado que é adicionado ao contexto

​

Estrutura de um Node

{
  "id": "node-1",
  "type": "transform",
  "config": {
    "transformType": "expression",
    "expression": "input.value * 2"
  },
  "position": {
    "x": 100,
    "y": 200
  }
}

​

Propriedades

• id: Identificador único do node no workflow
• type: Tipo do node (ex: transform, condition, input)
• config: Configuração específica do tipo de node
• position: Posição no editor visual (opcional)

​

Nodes Built-in

​

Input Node

{
  "type": "input",
  "config": {
    "prompt": "Digite seu nome:",
    "inputType": "text",
    "required": true,
    "timeoutMs": 300000
  }
}

• ⏸️ Pausável: Para a execução até receber entrada
• 🔄 Retomável: Execução pode ser retomada com dados
• ⏱️ Timeout: Configurável em milissegundos

• text: Texto livre
• number: Número
• email: Email válido
• url: URL válida
• boolean: Sim/Não

​

Wait Node

{
  "type": "wait",
  "config": {
    "delayMs": 5000
  }
}

• ⏸️ Pausável: Para a execução pelo tempo especificado
• ⏱️ Delay: Tempo em milissegundos

​

Condition Node

{
  "type": "condition",
  "config": {
    "condition": "input.amount > 100",
    "trueBranch": "node-process",
    "falseBranch": "node-reject"
  }
}

• 🔀 Roteamento: Direciona o fluxo baseado em condições
• 📊 Expressões: Suporta expressões JavaScript
• ✅ Múltiplas condições: Pode ter várias branches

​

Transform Node

{
  "type": "transform",
  "config": {
    "transformType": "expression",
    "expression": "input.toUpperCase()"
  }
}

• expression: Expressão JavaScript
• map: Mapeamento de campos
• filter: Filtrar arrays
• reduce: Reduzir arrays

​

Trigger Nodes

​

Webhook Trigger

{
  "type": "trigger_webhook",
  "config": {
    "_triggerId": "trigger_123",
    "path": "/meu-webhook"
  }
}

​

Schedule Trigger

{
  "type": "trigger_schedule",
  "config": {
    "_triggerId": "trigger_456",
    "cron": "0 0 * * *"
  }
}

​

Custom Nodes

​

Como Funciona

1. Registro: Node é registrado no Triglit
2. Configuração: Define endpoint e parâmetros
3. Execução: Triglit chama seu endpoint via webhook
4. Resposta: Seu servidor retorna o resultado

​

Exemplo de Custom Node

{
  "type": "custom",
  "config": {
    "nodeId": "custom-node-123",
    "endpoint": "https://api.seudominio.com/triglit/custom-nodes",
    "method": "POST",
    "params": {
      "action": "process-payment"
    }
  }
}

​

Node Registry

• Descobrir quais nodes estão disponíveis
• Obter schemas para validação e renderização de formulários
• Construir editores de workflows dinâmicos
• Validar configurações de nodes antes de salvar

​

Contexto de Execução

{
  "data": {
    "input": { "name": "João", "age": 30 },
    "node-1": { "result": "JOÃO" },
    "node-2": { "processed": true }
  },
  "metadata": {
    "runId": "run_123",
    "entityId": "entity_456",
    "executedNodes": ["node-1", "node-2"]
  }
}

​

Acessando Dados

// No node "node-2", acesse dados de "node-1"
context.data["node-1"].result

// Ou use o alias "input" para o último resultado
context.data.input

​

Ordem de Execução

node-1 → node-2 → node-3
         ↓
       node-4

1. node-1 executa primeiro
2. node-2 e node-4 executam em paralelo (após node-1)
3. node-3 executa após node-2

​

Nodes Pausáveis

• input: Aguarda entrada externa
• wait: Aguarda tempo determinado
• waitForEvent: Aguarda evento externo

​

Retomando Execução

{
  "runId": "run_123",
  "status": "paused",
  "resumeToken": "resume_abc123",
  "pausedAtNode": "node-input-1"
}

POST /v1/gateway/runs/{runId}/resume
{
  "resumeToken": "resume_abc123",
  "resumeData": {
    "input": "dados do usuário"
  }
}

​

Tratamento de Erros

• Retry automático: Configurável por node
• Error handling: Nodes de tratamento de erro
• DLQ: Dead Letter Queue para falhas persistentes

​

Exemplo de Error Handling

{
  "type": "try-catch",
  "config": {
    "tryBranch": "node-process",
    "catchBranch": "node-error-handler"
  }
}

​

Boas Práticas

​

Limitações

• Tamanho de dados: 1MB por node no contexto
• Timeout: 5 minutos por node (configurável)
• Retries: Máximo de 3 tentativas por padrão