# docker-compose.yml
version: '3.8'

services:
  n8n:
    image: n8nio/n8n:latest
    container_name: n8n
    restart: always
    ports:
      - "5678:5678"
    environment:
      - N8N_HOST=${N8N_HOST}
      - N8N_PORT=5678
      - N8N_PROTOCOL=https
      - NODE_ENV=production
      - WEBHOOK_URL=${WEBHOOK_URL}
      - GENERIC_TIMEZONE=America/Sao_Paulo
      # Database
      - DB_TYPE=postgresdb
      - DB_POSTGRESDB_HOST=postgres
      - DB_POSTGRESDB_PORT=5432
      - DB_POSTGRESDB_DATABASE=n8n
      - DB_POSTGRESDB_USER=${POSTGRES_USER}
      - DB_POSTGRESDB_PASSWORD=${POSTGRES_PASSWORD}
      # Encryption
      - N8N_ENCRYPTION_KEY=${N8N_ENCRYPTION_KEY}
    volumes:
      - n8n_data:/home/node/.n8n
    depends_on:
      - postgres

  postgres:
    image: postgres:15-alpine
    container_name: n8n_postgres
    restart: always
    environment:
      - POSTGRES_USER=${POSTGRES_USER}
      - POSTGRES_PASSWORD=${POSTGRES_PASSWORD}
      - POSTGRES_DB=n8n
    volumes:
      - postgres_data:/var/lib/postgresql/data

volumes:
  n8n_data:
  postgres_data:

# .env
N8N_HOST=n8n.seudominio.com
WEBHOOK_URL=https://n8n.seudominio.com/
POSTGRES_USER=n8n_user
POSTGRES_PASSWORD=sua_senha_segura_aqui
N8N_ENCRYPTION_KEY=chave_de_32_caracteres_aqui123

// Configuração do Email Trigger
{
  "resource": "imap",
  "operation": "getNewEmails",
  "mailbox": "INBOX",
  "options": {
    "customMailbox": false,
    "markAsRead": true
  }
}

// Function node para preparar o prompt
const email = $input.first().json;

const prompt = `
Analise o seguinte email e extraia:
1. Assunto principal
2. Sentimento (positivo, negativo, neutro)
3. Ação requerida (se houver)
4. Prioridade (alta, média, baixa)

Email:
De: ${email.from}
Assunto: ${email.subject}
Corpo: ${email.text}

Responda em JSON.
`;

return {
  json: {
    prompt,
    originalEmail: email
  }
};

// Code node para processamento avançado
const items = $input.all();

const processedItems = items.map(item => {
  const analysis = JSON.parse(item.json.aiResponse);
  const email = item.json.originalEmail;

  // Determinar canal de notificação baseado na prioridade
  let notificationChannel = 'email';
  if (analysis.prioridade === 'alta') {
    notificationChannel = 'slack';
  }

  // Formatar mensagem
  const message = `
📧 Novo email processado
━━━━━━━━━━━━━━━━━━━━
📌 Assunto: ${analysis.assunto}
😊 Sentimento: ${analysis.sentimento}
⚡ Prioridade: ${analysis.prioridade}
📋 Ação: ${analysis.acao || 'Nenhuma ação necessária'}
━━━━━━━━━━━━━━━━━━━━
  `.trim();

  return {
    json: {
      ...item.json,
      analysis,
      notificationChannel,
      formattedMessage: message
    }
  };
});

return processedItems;

// Exemplo de configuração TypeScript para o node OpenAI
interface OpenAIConfig {
  model: 'gpt-4' | 'gpt-3.5-turbo' | 'gpt-4-turbo-preview';
  temperature: number;
  maxTokens: number;
  systemPrompt: string;
}

const config: OpenAIConfig = {
  model: 'gpt-4-turbo-preview',
  temperature: 0.3, // Mais determinístico para classificação
  maxTokens: 1000,
  systemPrompt: `Você é um assistente especializado em análise de emails.
    Sempre responda em JSON válido com a estrutura especificada.
    Seja objetivo e conciso nas análises.`
};

// Error Workflow - executado quando há falha
const errorData = $input.first().json;

const errorReport = {
  workflow: errorData.workflow.name,
  node: errorData.execution.lastNodeExecuted,
  error: errorData.execution.error.message,
  timestamp: new Date().toISOString(),
  executionId: errorData.execution.id
};

// Enviar alerta para o Slack
return {
  json: {
    channel: '#alerts',
    text: `🚨 Erro no workflow: ${errorReport.workflow}`,
    blocks: [
      {
        type: 'section',
        text: {
          type: 'mrkdwn',
          text: `*Erro no Workflow*\n${errorReport.error}`
        }
      }
    ]
  }
};

# /etc/nginx/sites-available/n8n
server {
    listen 80;
    server_name n8n.seudominio.com;
    return 301 https://$server_name$request_uri;
}

server {
    listen 443 ssl http2;
    server_name n8n.seudominio.com;

    ssl_certificate /etc/letsencrypt/live/n8n.seudominio.com/fullchain.pem;
    ssl_certificate_key /etc/letsencrypt/live/n8n.seudominio.com/privkey.pem;

    location / {
        proxy_pass http://localhost:5678;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection 'upgrade';
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
        proxy_cache_bypass $http_upgrade;

        # WebSocket support
        proxy_read_timeout 86400;
    }
}

#!/bin/bash
# backup-n8n.sh

DATE=$(date +%Y%m%d_%H%M%S)
BACKUP_DIR="/backups/n8n"

# Backup do PostgreSQL
docker exec n8n_postgres pg_dump -U n8n_user n8n > "$BACKUP_DIR/db_$DATE.sql"

# Backup dos workflows (via API)
curl -X GET "https://n8n.seudominio.com/api/v1/workflows" \
  -H "X-N8N-API-KEY: $N8N_API_KEY" \
  > "$BACKUP_DIR/workflows_$DATE.json"

# Comprimir e limpar backups antigos
gzip "$BACKUP_DIR/db_$DATE.sql"
find $BACKUP_DIR -mtime +30 -delete

echo "Backup concluído: $DATE"

{
  "dashboard": {
    "title": "n8n Monitoring",
    "panels": [
      {
        "title": "Execuções por Hora",
        "type": "graph",
        "targets": [
          {
            "expr": "sum(rate(n8n_workflow_executions_total[1h]))",
            "legendFormat": "Execuções"
          }
        ]
      },
      {
        "title": "Taxa de Erros",
        "type": "gauge",
        "targets": [
          {
            "expr": "sum(rate(n8n_workflow_errors_total[5m])) / sum(rate(n8n_workflow_executions_total[5m])) * 100"
          }
        ]
      }
    ]
  }
}