Conecta Rivalwin
con n8n

Configura el disparador del flujo

Abre n8n y crea un nuevo workflow. Elige el nodo de trigger según tu caso de uso.

Para testear usa Manual Trigger. Para producción, Schedule Trigger te permite ejecutarlo automáticamente, por ejemplo todos los lunes a las 9:00.

ampliar

Crea el informe con el nodo HTTP Request

Añade un nodo HTTP Request y configúralo para llamar al endpoint /new_report.

Body JSON del request:

{
  "rival_ref": "rvl_4a7e9f12",
  "date_from": "{{ $now.minus(30, 'days').toFormat('yyyy-MM-dd') }}",
  "date_to": "{{ $now.minus(2, 'days').toFormat('yyyy-MM-dd') }}",
  "country": "ES"
}

ampliar

Respuesta exitosa — guarda el campo hash para el siguiente paso:

{
  "hash": "abc123def456...",
  "status": "PENDING",
  "created_at": "2026-04-20 09:00:00"
}

Espera con un nodo Wait y consulta el estado

Añade un nodo Wait de 30 segundos antes de consultar el estado. Luego un segundo HTTP Request llama a /report_status.

Body del segundo HTTP Request, referenciando el hash del nodo anterior:

{
  "hash": "{{ $('HTTP Request').item.json.hash }}"
}

ampliar

Verifica el estado con un nodo IF

Añade un nodo IF que evalúe el campo status de la respuesta.

Configuración del nodo IF:

• Condición: {{ $json.status }} equals DONE
• True → procesa el informe
• False → si es ERROR termina con Stop and Error; si es PENDING o PROCESSING vuelve al Wait

ampliar

Extrae los datos del informe con un nodo Code

Cuando el estado es DONE, el campo report contiene toda la información. Usa un nodo Code para extraer lo que necesitas.

const report = $input.item.json.report;

// Datos generales
const rival = report.rival.name;
const totalAds = report.kpis.ads_total;
const impressionsMax = report.kpis.impressions_upper;
const pdfUrl = report.pdf_url;
const aiAnalysis = report.insights.gpt_analysis;

// Top 3 anuncios con más alcance
const topAds = report.ads
  .filter(ad => ad.reach != null)
  .sort((a, b) => b.reach - a.reach)
  .slice(0, 3)
  .map(ad => ({
    id: ad.ad_id,
    copy: ad.content ? ad.content.slice(0, 120) + '...' : '(sin texto)',
    reach: ad.reach,
    format: ad.display_format,
    image: ad.image_url || null
  }));

return [{
  json: { rival, totalAds, impressionsMax, pdfUrl, aiAnalysis, topAds }
}];

ampliar

Envía los datos donde los necesitas

Con los datos procesados, conecta cualquier nodo destino. Algunos ejemplos:

Ejemplo de mensaje de Slack con el resumen del informe:

🔍 Nuevo informe de competencia listo

*Competidor:* {{ $json.rival }}
*Anuncios activos:* {{ $json.totalAds }}
*Impresiones estimadas:* {{ $json.impressionsMax }}

*Top anuncio:* {{ $json.topAds[0].copy }}

📄 Ver PDF completo: {{ $json.pdfUrl }}